Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly
Appearance settings
This repository was archived by the owner on Sep 5, 2023. It is now read-only.

Commit c96a9ad

Browse filesBrowse 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
Copy full SHA for c96a9ad

File tree

Expand file treeCollapse file tree

10 files changed

+22951
-173
lines changed
Filter options
Expand file treeCollapse file tree

10 files changed

+22951
-173
lines changed

‎google/cloud/datastream_v1/gapic_metadata.json

Copy file name to clipboardExpand all lines: google/cloud/datastream_v1/gapic_metadata.json
+130Lines 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

Copy file name to clipboardExpand all lines: google/cloud/datastream_v1/services/datastream/client.py
+2Lines 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

Copy file name to clipboardExpand all lines: google/cloud/datastream_v1/services/datastream/transports/__init__.py
+4Lines 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)
Morty Proxy This is a proxified and sanitized view of the page, visit original site.