8000 feat: enable "rest" transport in Python for services supporting numer… · googleapis/python-datastream@c96a9ad · GitHub
[go: up one dir, main page]
Skip to content
This repository was archived by the owner on Sep 5, 2023. It is now read-only.

Commit c96a9ad

Browse files
gcf-owl-bot[bot]gcf-owl-bot[bot]
authored
feat: enable "rest" transport in Python for services supporting numeric enums (#158)
* feat: enable "rest" transport in Python for services supporting numeric enums PiperOrigin-RevId: 508143576 Source-Link: googleapis/googleapis@7a702a9 Source-Link: https://github.com/googleapis/googleapis-gen/commit/6ad1279c0e7aa787ac6b66c9fd4a210692edffcd Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiNmFkMTI3OWMwZTdhYTc4N2FjNmI2NmM5ZmQ0YTIxMDY5MmVkZmZjZCJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md --------- Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
1 parent fcee625 commit c96a9ad

File tree

10 files changed

+22951
-173
lines changed

10 files changed

+22951
-173
lines changed

‎google/cloud/datastream_v1/gapic_metadata.json

Lines changed: 130 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -266,6 +266,136 @@
266266
]
267267
}
268268
}
269+
},
270+
"rest": {
271+
"libraryClient": "DatastreamClient",
272+
"rpcs": {
273+
"CreateConnectionProfile": {
274+
"methods": [
275+
"create_connection_profile"
276+
]
277+
},
278+
"CreatePrivateConnection": {
279+
"methods": [
280+
"create_private_connection"
281+
]
282+
},
283+
"CreateRoute": {
284+
"methods": [
285+
"create_route"
286+
]
287+
},
288+
"CreateStream": {
289+
"methods": [
290+
"create_stream"
291+
]
292+
},
293+
"DeleteConnectionProfile": {
294+
"methods": [
295+
"delete_connection_profile"
296+
]
297+
},
298+
"DeletePrivateConnection": {
299+
"methods": [
300+
"delete_private_connection"
301+
]
302+
},
303+
"DeleteRoute": {
304+
"methods": [
305+
"delete_route"
306+
]
307+
},
308+
"DeleteStream": {
309+
"methods": [
310+
"delete_stream"
311+
]
312+
},
313+
"DiscoverConnectionProfile": {
314+
"methods": [
315+
"discover_connection_profile"
316+
]
317+
},
318+
"FetchStaticIps": {
319+
"methods": [
320+
"fetch_static_ips"
321+
]
322+
},
323+
"GetConnectionProfile": {
324+
"methods": [
325+
"get_connection_profile"
326+
]
327+
},
328+
"GetPrivateConnection": {
329+
"methods": [
330+
"get_private_connection"
331+
]
332+
},
333+
"GetRoute": {
334+
"methods": [
335+
"get_route"
336+
]
337+
},
338+
"GetStream": {
339+
"methods": [
340+
"get_stream"
341+
]
342+
},
343+
"GetStreamObject": {
344+
"methods": [
345+
"get_stream_object"
346+
]
347+
},
348+
"ListConnectionProfiles": {
349+
"methods": [
350+
"list_connection_profiles"
351+
]
352+
},
353+
"ListPrivateConnections": {
354+
"methods": [
355+
"list_private_connections"
356+
]
357+
},
358+
"ListRoutes": {
359+
"methods": [
360+
"list_routes"
361+
]
362+
},
363+
"ListStreamObjects": {
364+
"methods": [
365+
"list_stream_objects"
366+
]
367+
},
368+
"ListStreams": {
369+
"methods": [
370+
"list_streams"
371+
]
372+
},
373+
"LookupStreamObject": {
374+
"methods": [
375+
"lookup_stream_object"
376+
]
377+
},
378+
"StartBackfillJob": {
379+
"methods": [
380+
"start_backfill_job"
381+
]
382+
},
383+
"StopBackfillJob": {
384+
"methods": [
385+
"stop_backfill_job"
386+
]
387+
},
388+
"UpdateConnectionProfile": {
389+
"methods": [
390+
"update_connection_profile"
391+
]
392+
},
393+
"UpdateStream": {
394+
"methods": [
395+
"update_stream"
396+
]
397+
}
398+
}
269399
}
270400
}
271401
}

‎google/cloud/datastream_v1/services/datastream/client.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -62,6 +62,7 @@
6262
from .transports.base import DEFAULT_CLIENT_INFO, DatastreamTransport
6363
from .transports.grpc import DatastreamGrpcTransport
6464
from .transports.grpc_asyncio import DatastreamGrpcAsyncIOTransport
65+
from .transports.rest import DatastreamRestTransport
6566

6667

6768
class DatastreamClientMeta(type):
@@ -75,6 +76,7 @@ class DatastreamClientMeta(type):
7576
_transport_registry = OrderedDict() # type: Dict[str, Type[DatastreamTransport]]
7677
_transport_registry["grpc"] = DatastreamGrpcTransport
7778
_transport_registry["grpc_asyncio"] = DatastreamGrpcAsyncIOTransport
79+
_transport_registry["rest"] = DatastreamRestTransport
7880

7981
def get_transport_class(
8082
cls,

‎google/cloud/datastream_v1/services/datastream/transports/__init__.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,14 +19,18 @@
1919
from .base import DatastreamTransport
2020
from .grpc import DatastreamGrpcTransport
2121
from .grpc_asyncio import DatastreamGrpcAsyncIOTransport
22+
from .rest import DatastreamRestInterceptor, DatastreamRestTransport
2223

2324
# Compile a registry of transports.
2425
_transport_registry = OrderedDict() # type: Dict[str, Type[DatastreamTransport]]
2526
_transport_registry["grpc"] = DatastreamGrpcTransport
2627
_transport_registry["grpc_asyncio"] = DatastreamGrpcAsyncIOTransport
28+
_transport_registry["rest"] = DatastreamRestTransport
2729

2830
__all__ = (
2931
"DatastreamTransport",
3032
"DatastreamGrpcTransport",
3133
"DatastreamGrpcAsyncIOTransport",
34+
"DatastreamRestTransport",
35+
"DatastreamRestInterceptor",
3236
)

0 commit comments

Comments
 (0)
0