feat: add schema evolution methods and fields (#842)

* feat: Add support for python 3.11 chore: Update gapic-generator-python to v1.8.0 PiperOrigin-RevId: 500768693 Source-Link: googleapis/googleapis@190b612 Source-Link: googleapis/googleapis-gen@7bf29a4 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiN2JmMjlhNDE0YjllY2FjMzE3MGYwYjY1YmRjMmE5NTcwNWMwZWYxYSJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * feat: add schema evolution methods and fields PiperOrigin-RevId: 500819578 Source-Link: googleapis/googleapis@05a375f Source-Link: googleapis/googleapis-gen@303c959 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiMzAzYzk1OTJjNDk4ZGMwMjQzMmRhYTI5YWNiNDZkNjdkZWNmYjBjMiJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * require proto-plus 1.22.2 for python 3.11 Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com> Co-authored-by: Anthonios Partheniou <[email protected]> Co-authored-by: Kamal Aboul-Hosn <[email protected]>
googleapis · Jan 10, 2023 · 9479356 · 9479356
1 parent 41c4e9a
commit 9479356
Show file tree

Hide file tree

Showing 29 changed files with 4,025 additions and 130 deletions.
diff --git a/google/pubsub/__init__.py b/google/pubsub/__init__.py
@@ -72,11 +72,16 @@
 from google.pubsub_v1.types.pubsub import UpdateSnapshotRequest
 from google.pubsub_v1.types.pubsub import UpdateSubscriptionRequest
 from google.pubsub_v1.types.pubsub import UpdateTopicRequest
+from google.pubsub_v1.types.schema import CommitSchemaRequest
 from google.pubsub_v1.types.schema import CreateSchemaRequest
 from google.pubsub_v1.types.schema import DeleteSchemaRequest
+from google.pubsub_v1.types.schema import DeleteSchemaRevisionRequest
 from google.pubsub_v1.types.schema import GetSchemaRequest
+from google.pubsub_v1.types.schema import ListSchemaRevisionsRequest
+from google.pubsub_v1.types.schema import ListSchemaRevisionsResponse
 from google.pubsub_v1.types.schema import ListSchemasRequest
 from google.pubsub_v1.types.schema import ListSchemasResponse
+from google.pubsub_v1.types.schema import RollbackSchemaRequest
 from google.pubsub_v1.types.schema import Schema
 from google.pubsub_v1.types.schema import ValidateMessageRequest
 from google.pubsub_v1.types.schema import ValidateMessageResponse
@@ -137,11 +142,16 @@
  "UpdateSnapshotRequest",
  "UpdateSubscriptionRequest",
  "UpdateTopicRequest",
+ "CommitSchemaRequest",
  "CreateSchemaRequest",
  "DeleteSchemaRequest",
+ "DeleteSchemaRevisionRequest",
  "GetSchemaRequest",
+ "ListSchemaRevisionsRequest",
+ "ListSchemaRevisionsResponse",
  "ListSchemasRequest",
  "ListSchemasResponse",
+ "RollbackSchemaRequest",
  "Schema",
  "ValidateMessageRequest",
  "ValidateMessageResponse",

diff --git a/google/pubsub_v1/__init__.py b/google/pubsub_v1/__init__.py
@@ -70,11 +70,16 @@
 from .types.pubsub import UpdateSnapshotRequest
 from .types.pubsub import UpdateSubscriptionRequest
 from .types.pubsub import UpdateTopicRequest
+from .types.schema import CommitSchemaRequest
 from .types.schema import CreateSchemaRequest
 from .types.schema import DeleteSchemaRequest
+from .types.schema import DeleteSchemaRevisionRequest
 from .types.schema import GetSchemaRequest
+from .types.schema import ListSchemaRevisionsRequest
+from .types.schema import ListSchemaRevisionsResponse
 from .types.schema import ListSchemasRequest
 from .types.schema import ListSchemasResponse
+from .types.schema import RollbackSchemaRequest
 from .types.schema import Schema
 from .types.schema import ValidateMessageRequest
 from .types.schema import ValidateMessageResponse
@@ -89,10 +94,12 @@
  "SubscriberAsyncClient",
  "AcknowledgeRequest",
  "BigQueryConfig",
+ "CommitSchemaRequest",
  "CreateSchemaRequest",
  "CreateSnapshotRequest",
  "DeadLetterPolicy",
  "DeleteSchemaRequest",
+ "DeleteSchemaRevisionRequest",
  "DeleteSnapshotRequest",
  "DeleteSubscriptionRequest",
  "DeleteTopicRequest",
@@ -104,6 +111,8 @@
  "GetSnapshotRequest",
  "GetSubscriptionRequest",
  "GetTopicRequest",
+ "ListSchemaRevisionsRequest",
+ "ListSchemaRevisionsResponse",
  "ListSchemasRequest",
  "ListSchemasResponse",
  "ListSnapshotsRequest",
@@ -128,6 +137,7 @@
  "PushConfig",
  "ReceivedMessage",
  "RetryPolicy",
+ "RollbackSchemaRequest",
  "Schema",
  "SchemaServiceClient",
  "SchemaSettings",

diff --git a/google/pubsub_v1/gapic_metadata.json b/google/pubsub_v1/gapic_metadata.json
@@ -114,6 +114,11 @@
  "grpc": {
  "libraryClient": "SchemaServiceClient",
  "rpcs": {
+ "CommitSchema": {
+ "methods": [
+ "commit_schema"
+ ]
+ },
  "CreateSchema": {
  "methods": [
  "create_schema"
@@ -124,16 +129,31 @@
  "delete_schema"
  ]
  },
+ "DeleteSchemaRevision": {
+ "methods": [
+ "delete_schema_revision"
+ ]
+ },
  "GetSchema": {
  "methods": [
  "get_schema"
  ]
  },
+ "ListSchemaRevisions": {
+ "methods": [
+ "list_schema_revisions"
+ ]
+ },
  "ListSchemas": {
  "methods": [
  "list_schemas"
  ]
  },
+ "RollbackSchema": {
+ "methods": [
+ "rollback_schema"
+ ]
+ },
  "ValidateMessage": {
  "methods": [
  "validate_message"
@@ -149,6 +169,11 @@
  "grpc-async": {
  "libraryClient": "SchemaServiceAsyncClient",
  "rpcs": {
+ "CommitSchema": {
+ "methods": [
+ "commit_schema"
+ ]
+ },
  "CreateSchema": {
  "methods": [
  "create_schema"
@@ -159,16 +184,31 @@
  "delete_schema"
  ]
  },
+ "DeleteSchemaRevision": {
+ "methods": [
+ "delete_schema_revision"
+ ]
+ },
  "GetSchema": {
  "methods": [
  "get_schema"
  ]
  },
+ "ListSchemaRevisions": {
+ "methods": [
+ "list_schema_revisions"
+ ]
+ },
  "ListSchemas": {
  "methods": [
  "list_schemas"
  ]
  },
+ "RollbackSchema": {
+ "methods": [
+ "rollback_schema"
+ ]
+ },
  "ValidateMessage": {
  "methods": [
  "validate_message"

diff --git a/google/pubsub_v1/services/publisher/async_client.py b/google/pubsub_v1/services/publisher/async_client.py
@@ -138,7 +138,7 @@ def get_mtls_endpoint_and_cert_source(
  The API endpoint is determined in the following order:
  (1) if `client_options.api_endpoint` if provided, use the provided one.
  (2) if `GOOGLE_API_USE_CLIENT_CERTIFICATE` environment variable is "always", use the
- default mTLS endpoint; if the environment variabel is "never", use the default API
+ default mTLS endpoint; if the environment variable is "never", use the default API
  endpoint; otherwise if client cert source exists, use the default mTLS endpoint, otherwise
  use the default API endpoint.
 

diff --git a/google/pubsub_v1/services/publisher/client.py b/google/pubsub_v1/services/publisher/client.py
@@ -338,7 +338,7 @@ def get_mtls_endpoint_and_cert_source(
  The API endpoint is determined in the following order:
  (1) if `client_options.api_endpoint` if provided, use the provided one.
  (2) if `GOOGLE_API_USE_CLIENT_CERTIFICATE` environment variable is "always", use the
- default mTLS endpoint; if the environment variabel is "never", use the default API
+ default mTLS endpoint; if the environment variable is "never", use the default API
  endpoint; otherwise if client cert source exists, use the default mTLS endpoint, otherwise
  use the default API endpoint.