@@ -959,6 +959,11 @@ class ExpirationPolicy(proto.Message):
959
959
class PushConfig (proto .Message ):
960
960
r"""Configuration for a push delivery endpoint.
961
961
962
+ This message has `oneof`_ fields (mutually exclusive fields).
963
+ For each oneof, at most one member field can be set at the same time.
964
+ Setting any member of the oneof automatically clears all other
965
+ members.
966
+
962
967
.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields
963
968
964
969
Attributes:
@@ -998,6 +1003,18 @@ class PushConfig(proto.Message):
998
1003
every pushed message.
999
1004
1000
1005
This field is a member of `oneof`_ ``authentication_method``.
1006
+ pubsub_wrapper (google.pubsub_v1.types.PushConfig.PubsubWrapper):
1007
+ When set, the payload to the push endpoint is
1008
+ in the form of the JSON representation of a
1009
+ PubsubMessage
1010
+ (https://cloud.google.com/pubsub/docs/reference/rpc/google.pubsub.v1#pubsubmessage).
1011
+
1012
+ This field is a member of `oneof`_ ``wrapper``.
1013
+ no_wrapper (google.pubsub_v1.types.PushConfig.NoWrapper):
1014
+ When set, the payload to the push endpoint is
1015
+ not wrapped.
1016
+
1017
+ This field is a member of `oneof`_ ``wrapper``.
1001
1018
"""
1002
1019
1003
1020
class OidcToken (proto .Message ):
@@ -1033,6 +1050,29 @@ class OidcToken(proto.Message):
1033
1050
number = 2 ,
1034
1051
)
1035
1052
1053
+ class PubsubWrapper (proto .Message ):
1054
+ r"""The payload to the push endpoint is in the form of the JSON
1055
+ representation of a PubsubMessage
1056
+ (https://cloud.google.com/pubsub/docs/reference/rpc/google.pubsub.v1#pubsubmessage).
1057
+
1058
+ """
1059
+
1060
+ class NoWrapper (proto .Message ):
1061
+ r"""Sets the ``data`` field as the HTTP body for delivery.
1062
+
1063
+ Attributes:
1064
+ write_metadata (bool):
1065
+ When true, writes the Pub/Sub message metadata to
1066
+ ``x-goog-pubsub-<KEY>:<VAL>`` headers of the HTTP request.
1067
+ Writes the Pub/Sub message attributes to ``<KEY>:<VAL>``
1068
+ headers of the HTTP request.
1069
+ """
1070
+
1071
+ write_metadata : bool = proto .Field (
1072
+ proto .BOOL ,
1073
+ number = 1 ,
1074
+ )
1075
+
1036
1076
push_endpoint : str = proto .Field (
1037
1077
proto .STRING ,
1038
1078
number = 1 ,
@@ -1048,6 +1088,18 @@ class OidcToken(proto.Message):
1048
1088
oneof = "authentication_method" ,
1049
1089
message = OidcToken ,
1050
1090
)
1091
+ pubsub_wrapper : PubsubWrapper = proto .Field (
1092
+ proto .MESSAGE ,
1093
+ number = 4 ,
1094
+ oneof = "wrapper" ,
1095
+ message = PubsubWrapper ,
1096
+ )
1097
+ no_wrapper : NoWrapper = proto .Field (
1098
+ proto .MESSAGE ,
1099
+ number = 5 ,
1100
+ oneof = "wrapper" ,
1101
+ message = NoWrapper ,
1102
+ )
1051
1103
1052
1104
1053
1105
class BigQueryConfig (proto .Message ):
0 commit comments