SrSSKJr SSKJr SSKJr SSKJr SSKJr Sr Sr S r S r SS jr SS jr"SS\5rg )z(Utilities for Cloud Pub/Sub Schemas API.)absolute_import)division)unicode_literals)apisInvalidArgumentErrorc[S5$)NzRThe schema name must include a revision-id of the format: SCHEMA_NAME@REVISION_ID.r,lib/googlecloudsdk/api_lib/pubsub/schemas.pyNoRevisionIdSpecifiedr s " r c@URS5n[U5S:$)N@)splitlen) schema_reffind_ids r CheckRevisionIdInSchemaPathr s!   S !' W r c[S5$)Nz7The schema type must be either AVRO or PROTOCOL-BUFFER.rr r r InvalidSchemaTyper%s ? r cUR5nUS:XdUS:Xa URRR$US:Xa URRR$[ 5e)Nzprotocol-bufferprotocol_bufferavro)lowerSchemaTypeValueValuesEnumPROTOCOL_BUFFERAVROr)messages schema_typetype_strs r ParseSchemaTyper#+s^    ( ""h2C&C ?? . . > >>6 ?? . . 3 33r c.[R"SSUS9$)Npubsubv1no_http)rGetClientInstancer's r r)r)4s  $ @@r Nc@U=(d [5nUR$N)r)MESSAGES_MODULE)clients r GetMessagesModuler.8s  (&(&   r c4\rSrSrSrS SjrSrSrSrSr g) SchemasClient=z4Client for schemas service in the Cloud Pub/Sub API.NcU=(d [5UlU=(d [U5UlURRUlgr+)r)r-r.r projects_schemas_service)selfr-r s r __init__SchemasClient.__init__@s5/-/DK9 1& 9DMKK00DMr cURRU[URU5US9nURRURR US9US9nUR R U5$)zCommits a revision for a Schema. Args: schema_ref: The full schema_path. schema_definition: The new schema definition to commit. schema_type: The type of the schema (avro or protocol-buffer). Returns: Schema: the committed Schema revision )nametype definition)schema)commitSchemaRequestr9)r rr#"PubsubProjectsSchemasCommitRequestCommitSchemaRequestr4Commit)r5rschema_definitionr!r< commit_reqs r r@SchemasClient.CommitEs|]] ! !  T]]K 8$"F AA MM==V=L BJ ==   ++r cURRURRUS9US9nURR U5$)aRolls back to a previous schema revision. Args: schema_ref: The path of the schema to rollback. revision_id: The revision_id to rollback to. Returns: Schema: the new schema revision you have rolled back to. Raises: InvalidArgumentError: If no revision_id is provided. ) revisionId)rollbackSchemaRequestr9)r $PubsubProjectsSchemasRollbackRequestRollbackSchemaRequestr4Rollback)r5r revision_id rollback_reqs r rISchemasClient.Rollback[sU==EE"mmAA"B  FL == ! !, //r c[U5(d [5eURRUS9nURR U5$)zDeletes a schema revision. Args: schema_ref: The path of the schema, with the revision_id. Returns: Schema: the deleted schema revision. )r9)rr r *PubsubProjectsSchemasDeleteRevisionRequestr4DeleteRevision)r5rdelete_revision_reqs r rOSchemasClient.DeleteRevisionpsR 'z 2 2 ! ## @@ A  == ' '(; <r\sF/&',G  A D=FD=r