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

Commit 65e58ee

Browse filesBrowse files
yoshi-automationbusunkim96
yoshi-automation
authored and
busunkim96
committed
Add routing header to method metadata (via synth). (#7598)
1 parent 108694a commit 65e58ee
Copy full SHA for 65e58ee

File tree

Expand file treeCollapse file tree

4 files changed

+230
-6
lines changed
Filter options
Expand file treeCollapse file tree

4 files changed

+230
-6
lines changed

‎logging/google/cloud/logging_v2/gapic/config_service_v2_client.py

Copy file name to clipboardExpand all lines: logging/google/cloud/logging_v2/gapic/config_service_v2_client.py
+131Lines changed: 131 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@
2323
import google.api_core.gapic_v1.client_info
2424
import google.api_core.gapic_v1.config
2525
import google.api_core.gapic_v1.method
26+
import google.api_core.gapic_v1.routing_header
2627
import google.api_core.grpc_helpers
2728
import google.api_core.page_iterator
2829
import google.api_core.path_template
@@ -280,6 +281,19 @@ def list_sinks(
280281
request = logging_config_pb2.ListSinksRequest(
281282
parent=parent, page_size=page_size
282283
)
284+
if metadata is None:
285+
metadata = []
286+
metadata = list(metadata)
287+
try:
288+
routing_header = [("parent", parent)]
289+
except AttributeError:
290+
pass
291+
else:
292+
routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
293+
routing_header
294+
)
295+
metadata.append(routing_metadata)
296+
283297
iterator = google.api_core.page_iterator.GRPCIterator(
284298
client=None,
285299
method=functools.partial(
@@ -356,6 +370,19 @@ def get_sink(
356370
)
357371

358372
request = logging_config_pb2.GetSinkRequest(sink_name=sink_name)
373+
if metadata is None:
374+
metadata = []
375+
metadata = list(metadata)
376+
try:
377+
routing_header = [("sink_name", sink_name)]
378+
except AttributeError:
379+
pass
380+
else:
381+
routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
382+
routing_header
383+
)
384+
metadata.append(routing_metadata)
385+
359386
return self._inner_api_calls["get_sink"](
360387
request, retry=retry, timeout=timeout, metadata=metadata
361388
)
@@ -448,6 +475,19 @@ def create_sink(
448475
request = logging_config_pb2.CreateSinkRequest(
449476
parent=parent, sink=sink, unique_writer_identity=unique_writer_identity
450477
)
478+
if metadata is None:
479+
metadata = []
480+
metadata = list(metadata)
481+
try:
482+
routing_header = [("parent", parent)]
483+
except AttributeError:
484+
pass
485+
else:
486+
routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
487+
routing_header
488+
)
489+
metadata.append(routing_metadata)
490+
451491
return self._inner_api_calls["create_sink"](
452492
request, retry=retry, timeout=timeout, metadata=metadata
453493
)
@@ -561,6 +601,19 @@ def update_sink(
561601
unique_writer_identity=unique_writer_identity,
562602
update_mask=update_mask,
563603
)
604+
if metadata is None:
605+
metadata = []
606+
metadata = list(metadata)
607+
try:
608+
routing_header = [("sink_name", sink_name)]
609+
except AttributeError:
610+
pass
611+
else:
612+
routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
613+
routing_header
614+
)
615+
metadata.append(routing_metadata)
616+
564617
return self._inner_api_calls["update_sink"](
565618
request, retry=retry, timeout=timeout, metadata=metadata
566619
)
@@ -625,6 +678,19 @@ def delete_sink(
625678
)
626679

627680
request = logging_config_pb2.DeleteSinkRequest(sink_name=sink_name)
681+
if metadata is None:
682+
metadata = []
683+
metadata = list(metadata)
684+
try:
685+
routing_header = [("sink_name", sink_name)]
686+
except AttributeError:
687+
pass
688+
else:
689+
routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
690+
routing_header
691+
)
692+
metadata.append(routing_metadata)
693+
628694
self._inner_api_calls["delete_sink"](
629695
request, retry=retry, timeout=timeout, metadata=metadata
630696
)
@@ -711,6 +777,19 @@ def list_exclusions(
711777
request = logging_config_pb2.ListExclusionsRequest(
712778
parent=parent, page_size=page_size
713779
)
780+
if metadata is None:
781+
metadata = []
782+
metadata = list(metadata)
783+
try:
784+
routing_header = [("parent", parent)]
785+
except AttributeError:
786+
pass
787+
else:
788+
routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
789+
routing_header
790+
)
791+
metadata.append(routing_metadata)
792+
714793
iterator = google.api_core.page_iterator.GRPCIterator(
715794
client=None,
716795
method=functools.partial(
@@ -787,6 +866,19 @@ def get_exclusion(
787866
)
788867

789868
request = logging_config_pb2.GetExclusionRequest(name=name)
869+
if metadata is None:
870+
metadata = []
871+
metadata = list(metadata)
872+
try:
873+
routing_header = [("name", name)]
874+
except AttributeError:
875+
pass
876+
else:
877+
routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
878+
routing_header
879+
)
880+
metadata.append(routing_metadata)
881+
790882
return self._inner_api_calls["get_exclusion"](
791883
request, retry=retry, timeout=timeout, metadata=metadata
792884
)
@@ -866,6 +958,19 @@ def create_exclusion(
866958
request = logging_config_pb2.CreateExclusionRequest(
867959
parent=parent, exclusion=exclusion
868960
)
961+
if metadata is None:
962+
metadata = []
963+
metadata = list(metadata)
964+
try:
965+
routing_header = [("parent", parent)]
966+
except AttributeError:
967+
pass
968+
else:
969+
routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
970+
routing_header
971+
)
972+
metadata.append(routing_metadata)
973+
869974
return self._inner_api_calls["create_exclusion"](
870975
request, retry=retry, timeout=timeout, metadata=metadata
871976
)
@@ -956,6 +1061,19 @@ def update_exclusion(
9561061
request = logging_config_pb2.UpdateExclusionRequest(
9571062
name=name, exclusion=exclusion, update_mask=update_mask
9581063
)
1064+
if metadata is None:
1065+
metadata = []
1066+
metadata = list(metadata)
1067+
try:
1068+
routing_header = [("name", name)]
1069+
except AttributeError:
1070+
pass
1071+
else:
1072+
routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
1073+
routing_header
1074+
)
1075+
metadata.append(routing_metadata)
1076+
9591077
return self._inner_api_calls["update_exclusion"](
9601078
request, retry=retry, timeout=timeout, metadata=metadata
9611079
)
@@ -1018,6 +1136,19 @@ def delete_exclusion(
10181136
)
10191137

10201138
request = logging_config_pb2.DeleteExclusionRequest(name=name)
1139+
if metadata is None:
1140+
metadata = []
1141+
metadata = list(metadata)
1142+
try:
1143+
routing_header = [("name", name)]
1144+
except AttributeError:
1145+
pass
1146+
else:
1147+
routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
1148+
routing_header
1149+
)
1150+
metadata.append(routing_metadata)
1151+
10211152
self._inner_api_calls["delete_exclusion"](
10221153
request, retry=retry, timeout=timeout, metadata=metadata
10231154
)

‎logging/google/cloud/logging_v2/gapic/logging_service_v2_client.py

Copy file name to clipboardExpand all lines: logging/google/cloud/logging_v2/gapic/logging_service_v2_client.py
+27Lines changed: 27 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@
2323
import google.api_core.gapic_v1.client_info
2424
import google.api_core.gapic_v1.config
2525
import google.api_core.gapic_v1.method
26+
import google.api_core.gapic_v1.routing_header
2627
import google.api_core.grpc_helpers
2728
import google.api_core.page_iterator
2829
import google.api_core.path_template
@@ -247,6 +248,19 @@ def delete_log(
247248
)
248249

249250
request = logging_pb2.DeleteLogRequest(log_name=log_name)
251+
if metadata is None:
252+
metadata = []
253+
metadata = list(metadata)
254+
try:
255+
routing_header = [("log_name", log_name)]
256+
except AttributeError:
257+
pass
258+
else:
259+
routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
260+
routing_header
261+
)
262+
metadata.append(routing_metadata)
263+
250264
self._inner_api_calls["delete_log"](
251265
request, retry=retry, timeout=timeout, metadata=metadata
252266
)
@@ -700,6 +714,19 @@ def list_logs(
700714
)
701715

702716
request = logging_pb2.ListLogsRequest(parent=parent, page_size=page_size)
717+
if metadata is None:
718+
metadata = []
719+
metadata = list(metadata)
720+
try:
721+
routing_header = [("parent", parent)]
722+
except AttributeError:
723+
pass
724+
else:
725+
routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
726+
routing_header
727+
)
728+
metadata.append(routing_metadata)
729+
703730
iterator = google.api_core.page_iterator.GRPCIterator(
704731
client=None,
705732
method=functools.partial(

‎logging/google/cloud/logging_v2/gapic/metrics_service_v2_client.py

Copy file name to clipboardExpand all lines: logging/google/cloud/logging_v2/gapic/metrics_service_v2_client.py
+66Lines changed: 66 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@
2323
import google.api_core.gapic_v1.client_info
2424
import google.api_core.gapic_v1.config
2525
import google.api_core.gapic_v1.method
26+
import google.api_core.gapic_v1.routing_header
2627
import google.api_core.grpc_helpers
2728
import google.api_core.page_iterator
2829
import google.api_core.path_template
@@ -267,6 +268,19 @@ def list_log_metrics(
267268
request = logging_metrics_pb2.ListLogMetricsRequest(
268269
parent=parent, page_size=page_size
269270
)
271+
if metadata is None:
272+
metadata = []
273+
metadata = list(metadata)
274+
try:
275+
routing_header = [("parent", parent)]
276+
except AttributeError:
277+
pass
278+
else:
279+
routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
280+
routing_header
281+
)
282+
metadata.append(routing_metadata)
283+
270284
iterator = google.api_core.page_iterator.GRPCIterator(
271285
client=None,
272286
method=functools.partial(
@@ -338,6 +352,19 @@ def get_log_metric(
338352
)
339353

340354
request = logging_metrics_pb2.GetLogMetricRequest(metric_name=metric_name)
355+
if metadata is None:
356+
metadata = []
357+
metadata = list(metadata)
358+
try:
359+
routing_header = [("metric_name", metric_name)]
360+
except AttributeError:
361+
pass
362+
else:
363+
routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
364+
routing_header
365+
)
366+
metadata.append(routing_metadata)
367+
341368
return self._inner_api_calls["get_log_metric"](
342369
request, retry=retry, timeout=timeout, metadata=metadata
343370
)
@@ -411,6 +438,19 @@ def create_log_metric(
411438
request = logging_metrics_pb2.CreateLogMetricRequest(
412439
parent=parent, metric=metric
413440
)
441+
if metadata is None:
442+
metadata = []
443+
metadata = list(metadata)
444+
try:
445+
routing_header = [("parent", parent)]
446+
except AttributeError:
447+
pass
448+
else:
449+
routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
450+
routing_header
451+
)
452+
metadata.append(routing_metadata)
453+
414454
return self._inner_api_calls["create_log_metric"](
415455
request, retry=retry, timeout=timeout, metadata=metadata
416456
)
@@ -485,6 +525,19 @@ def update_log_metric(
485525
request = logging_metrics_pb2.UpdateLogMetricRequest(
486526
metric_name=metric_name, metric=metric
487527
)
528+
if metadata is None:
529+
metadata = []
530+
metadata = list(metadata)
531+
try:
532+
routing_header = [("metric_name", metric_name)]
533+
except AttributeError:
534+
pass
535+
else:
536+
routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
537+
routing_header
538+
)
539+
metadata.append(routing_metadata)
540+
488541
return self._inner_api_calls["update_log_metric"](
489542
request, retry=retry, timeout=timeout, metadata=metadata
490543
)
@@ -542,6 +595,19 @@ def delete_log_metric(
542595
)
543596

544597
request = logging_metrics_pb2.DeleteLogMetricRequest(metric_name=metric_name)
598+
if metadata is None:
599+
metadata = []
600+
metadata = list(metadata)
601+
try:
602+
routing_header = [("metric_name", metric_name)]
603+
except AttributeError:
604+
pass
605+
else:
606+
routing_metadata = google.api_core.gapic_v1.routing_header.to_grpc_metadata(
607+
routing_header
608+
)
609+
metadata.append(routing_metadata)
610+
545611
self._inner_api_calls["delete_log_metric"](
546612
request, retry=retry, timeout=timeout, metadata=metadata
547613
)

‎logging/synth.metadata

Copy file name to clipboardExpand all lines: logging/synth.metadata
+6-6Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1,26 +1,26 @@
11
{
2-
"updateTime": "2019-02-26T13:20:43.903128Z",
2+
"updateTime": "2019-03-28T12:19:01.156618Z",
33
"sources": [
44
{
55
"generator": {
66
"name": "artman",
7-
"version": "0.16.14",
8-
"dockerImage": "googleapis/artman@sha256:f3d61ae45abaeefb6be5f228cda22732c2f1b00fb687c79c4bd4f2c42bb1e1a7"
7+
"version": "0.16.20",
8+
"dockerImage": "googleapis/artman@sha256:e3c054a2fb85a12481c722af616c7fb6f1d02d862248385eecbec3e4240ebd1e"
99
}
1010
},
1111
{
1212
"git": {
1313
"name": "googleapis",
1414
"remote": "https://github.com/googleapis/googleapis.git",
15-
"sha": "29f098cb03a9983cc9cb15993de5da64419046f2",
16-
"internalRef": "235621085"
15+
"sha": "6a84b3267b0a95e922608b9891219075047eee29",
16+
"internalRef": "240640999"
1717
}
1818
},
1919
{
2020
"template": {
2121
"name": "python_library",
2222
"origin": "synthtool.gcp",
23-
"version": "2019.1.16"
23+
"version": "2019.2.26"
2424
}
2525
}
2626
],

0 commit comments

Comments
0 (0)
Morty Proxy This is a proxified and sanitized view of the page, visit original site.