feat: enable "rest" transport in Python for services supporting numeric enums

google/pubsub_v1/gapic_metadata.json

@@ -106,6 +106,56 @@
               ]
             }
           }
+        },
+        "rest": {
+          "libraryClient": "PublisherClient",
+          "rpcs": {
+            "CreateTopic": {
+              "methods": [
+                "create_topic"
+              ]
+            },
+            "DeleteTopic": {
+              "methods": [
+                "delete_topic"
+              ]
+            },
+            "DetachSubscription": {
+              "methods": [
+                "detach_subscription"
+              ]
+            },
+            "GetTopic": {
+              "methods": [
+                "get_topic"
+              ]
+            },
+            "ListTopicSnapshots": {
+              "methods": [
+                "list_topic_snapshots"
+              ]
+            },
+            "ListTopicSubscriptions": {
+              "methods": [
+                "list_topic_subscriptions"
+              ]
+            },
+            "ListTopics": {
+              "methods": [
+                "list_topics"
+              ]
+            },
+            "Publish": {
+              "methods": [
+                "publish"
+              ]
+            },
+            "UpdateTopic": {
+              "methods": [
+                "update_topic"
+              ]
+            }
+          }
         }
       }
     },
@@ -220,6 +270,61 @@
               ]
             }
           }
+        },
+        "rest": {
+          "libraryClient": "SchemaServiceClient",
+          "rpcs": {
+            "CommitSchema": {
+              "methods": [
+                "commit_schema"
+              ]
+            },
+            "CreateSchema": {
+              "methods": [
+                "create_schema"
+              ]
+            },
+            "DeleteSchema": {
+              "methods": [
+                "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"
+              ]
+            },
+            "ValidateSchema": {
+              "methods": [
+                "validate_schema"
+              ]
+            }
+          }
         }
       }
     },
@@ -394,6 +499,91 @@
               ]
             }
           }
+        },
+        "rest": {
+          "libraryClient": "SubscriberClient",
+          "rpcs": {
+            "Acknowledge": {
+              "methods": [
+                "acknowledge"
+              ]
+            },
+            "CreateSnapshot": {
+              "methods": [
+                "create_snapshot"
+              ]
+            },
+            "CreateSubscription": {
+              "methods": [
+                "create_subscription"
+              ]
+            },
+            "DeleteSnapshot": {
+              "methods": [
+                "delete_snapshot"
+              ]
+            },
+            "DeleteSubscription": {
+              "methods": [
+                "delete_subscription"
+              ]
+            },
+            "GetSnapshot": {
+              "methods": [
+                "get_snapshot"
+              ]
+            },
+            "GetSubscription": {
+              "methods": [
+                "get_subscription"
+              ]
+            },
+            "ListSnapshots": {
+              "methods": [
+                "list_snapshots"
+              ]
+            },
+            "ListSubscriptions": {
+              "methods": [
+                "list_subscriptions"
+              ]
+            },
+            "ModifyAckDeadline": {
+              "methods": [
+                "modify_ack_deadline"
+              ]
+            },
+            "ModifyPushConfig": {
+              "methods": [
+                "modify_push_config"
+              ]
+            },
+            "Pull": {
+              "methods": [
+                "pull"
+              ]
+            },
+            "Seek": {
+              "methods": [
+                "seek"
+              ]
+            },
+            "StreamingPull": {
+              "methods": [
+                "streaming_pull"
+              ]
+            },
+            "UpdateSnapshot": {
+              "methods": [
+                "update_snapshot"
+              ]
+            },
+            "UpdateSubscription": {
+              "methods": [
+                "update_subscription"
+              ]
+            }
+          }
         }
       }
     }

google/pubsub_v1/services/publisher/client.py

@@ -60,6 +60,7 @@
 from .transports.base import PublisherTransport, DEFAULT_CLIENT_INFO
 from .transports.grpc import PublisherGrpcTransport
 from .transports.grpc_asyncio import PublisherGrpcAsyncIOTransport
+from .transports.rest import PublisherRestTransport
 
 
 class PublisherClientMeta(type):
@@ -73,6 +74,7 @@ class PublisherClientMeta(type):
     _transport_registry = OrderedDict()  # type: Dict[str, Type[PublisherTransport]]
     _transport_registry["grpc"] = PublisherGrpcTransport
     _transport_registry["grpc_asyncio"] = PublisherGrpcAsyncIOTransport
+    _transport_registry["rest"] = PublisherRestTransport
 
     def get_transport_class(
         cls,

google/pubsub_v1/services/publisher/transports/__init__.py

@@ -19,15 +19,20 @@
 from .base import PublisherTransport
 from .grpc import PublisherGrpcTransport
 from .grpc_asyncio import PublisherGrpcAsyncIOTransport
+from .rest import PublisherRestTransport
+from .rest import PublisherRestInterceptor
 
 
 # Compile a registry of transports.
 _transport_registry = OrderedDict()  # type: Dict[str, Type[PublisherTransport]]
 _transport_registry["grpc"] = PublisherGrpcTransport
 _transport_registry["grpc_asyncio"] = PublisherGrpcAsyncIOTransport
+_transport_registry["rest"] = PublisherRestTransport
 
 __all__ = (
     "PublisherTransport",
     "PublisherGrpcTransport",
     "PublisherGrpcAsyncIOTransport",
+    "PublisherRestTransport",
+    "PublisherRestInterceptor",
 )