+bSrSSKJr SSKJr SrSrSrSrS Sjr SS jr "S S \ 5r g )z(Utilities for Cloud Pub/Sub Schemas API.)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 " rc@URS5n[U5S:$)N@)splitlen) schema_reffind_ids r CheckRevisionIdInSchemaPathrs!   S !' W rc[S5$)Nz7The schema type must be either AVRO or PROTOCOL-BUFFER.rrrr InvalidSchemaTyper"s ? rcUR5nUS:XdUS:Xa URRR$US:Xa URRR$[ 5e)Nzprotocol-bufferprotocol_bufferavro)lowerSchemaTypeValueValuesEnumPROTOCOL_BUFFERAVROr)messages schema_typetype_strs r ParseSchemaTyper (s^    ( ""h2C&C ?? . . > >>6 ?? . . 3 33rc.[R"SSUS9$)Npubsubv1no_http)rGetClientInstancer$s r r&r&1s  $ @@rNc@U=(d [5nUR$N)r&MESSAGES_MODULE)clients r GetMessagesModuler+5s  (&(&   rc4\rSrSrSrS SjrSrSrSrSr g) SchemasClient:z4Client for schemas service in the Cloud Pub/Sub API.NcU=(d [5UlU=(d [U5UlURRUlgr()r&r*r+rprojects_schemas_service)selfr*rs r __init__SchemasClient.__init__=s5/-/DK9 1& 9DMKK00DMrcURRU[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)commitSchemaRequestr6)rrr "PubsubProjectsSchemasCommitRequestCommitSchemaRequestr1Commit)r2rschema_definitionrr9 commit_reqs r r=SchemasClient.CommitBs|]] ! !  T]]K 8$"F AA MM==V=L BJ ==   ++rcURRURRUS9US9nURR 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)rollbackSchemaRequestr6)r$PubsubProjectsSchemasRollbackRequestRollbackSchemaRequestr1Rollback)r2r revision_id rollback_reqs r rFSchemasClient.RollbackXsU==EE"mmAA"B  FL == ! !, //rc[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. )r6)rr r*PubsubProjectsSchemasDeleteRevisionRequestr1DeleteRevision)r2rdelete_revision_reqs r rLSchemasClient.DeleteRevisionmsR 'z 2 2 ! ## @@ A  == ' '(; <rXs?/-G  A D=FD=r