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.