@@ -95,7 +95,7 @@ message Pipeline {
9595
9696 // Represents a HTTP endpoint destination.
9797 message HttpEndpoint {
98- // Required. The URI of the HTTP enpdoint .
98+ // Required. The URI of the HTTP endpoint .
9999 //
100100 // The value must be a RFC2396 URI string.
101101 // Examples: `https://svc.us-central1.p.local:8080/route`.
@@ -107,10 +107,11 @@ message Pipeline {
107107 //
108108 // If a binding expression is not specified here, the message
109109 // is treated as a CloudEvent and is mapped to the HTTP request according
110- // to the CloudEvent HTTP Protocol Binding Binary Content Mode. In this
111- // representation, all fields except the `data` and `datacontenttype`
112- // field on the message are mapped to HTTP request headers with a prefix
113- // of `ce-`.
110+ // to the CloudEvent HTTP Protocol Binding Binary Content Mode
111+ // (https://github.com/cloudevents/spec/blob/main/cloudevents/bindings/http-protocol-binding.md#31-binary-content-mode).
112+ // In this representation, all fields except the `data` and
113+ // `datacontenttype` field on the message are mapped to HTTP request
114+ // headers with a prefix of `ce-`.
114115 //
115116 // To construct the HTTP request payload and the value of the content-type
116117 // HTTP header, the payload format is defined as follows:
@@ -140,7 +141,7 @@ message Pipeline {
140141 // - If a map named `headers` exists on the result of the expression,
141142 // then its key/value pairs are directly mapped to the HTTP request
142143 // headers. The headers values are constructed from the corresponding
143- // value type’ s canonical representation. If the `headers` field doesn’ t
144+ // value type' s canonical representation. If the `headers` field doesn' t
144145 // exist then the resulting HTTP request will be the headers of the
145146 // CloudEvent HTTP Binding Binary Content Mode representation of the final
146147 // message. Note: If the specified binding expression, has updated the
@@ -182,6 +183,11 @@ message Pipeline {
182183 // "body": "new-body"
183184 // }
184185 // ```
186+ // - The default binding for the message payload can be accessed using the
187+ // `body` variable. It conatins a string representation of the message
188+ // payload in the format specified by the `output_payload_format` field.
189+ // If the `input_payload_format` field is not set, the `body`
190+ // variable contains the same message payload bytes that were published.
185191 //
186192 // Additionally, the following CEL extension functions are provided for
187193 // use in this CEL expression:
@@ -239,33 +245,28 @@ message Pipeline {
239245 // - toMap:
240246 // [map1, map2, ...].toMap() -> map
241247 // - Converts a CEL list of CEL maps to a single CEL map
242- // - toDestinationPayloadFormat():
243- // message.data.toDestinationPayloadFormat() -> string or bytes
244- // - Converts the message data to the destination payload format
245- // specified in Pipeline.Destination.output_payload_format
246- // - This function is meant to be applied to the message.data field.
247- // - If the destination payload format is not set, the function will
248- // return the message data unchanged.
249248 // - toCloudEventJsonWithPayloadFormat:
250249 // message.toCloudEventJsonWithPayloadFormat() -> map
251250 // - Converts a message to the corresponding structure of JSON
252- // format for CloudEvents
253- // - This function applies toDestinationPayloadFormat() to the
254- // message data. It also sets the corresponding datacontenttype of
251+ // format for CloudEvents.
252+ // - It converts `data` to destination payload format
253+ // specified in `output_payload_format`. If `output_payload_format` is
254+ // not set, the data will remain unchanged.
255+ // - It also sets the corresponding datacontenttype of
255256 // the CloudEvent, as indicated by
256- // Pipeline.Destination. output_payload_format. If no
257- // output_payload_format is set it will use the existing
258- // datacontenttype on the CloudEvent if present, else leave
259- // datacontenttype absent .
257+ // ` output_payload_format` . If no
258+ // ` output_payload_format` is set it will use the value of the
259+ // " datacontenttype" attribute on the CloudEvent if present, else
260+ // remove " datacontenttype" attribute .
260261 // - This function expects that the content of the message will
261- // adhere to the standard CloudEvent format. If it doesn’ t then this
262+ // adhere to the standard CloudEvent format. If it doesn' t then this
262263 // function will fail.
263264 // - The result is a CEL map that corresponds to the JSON
264265 // representation of the CloudEvent. To convert that data to a JSON
265266 // string it can be chained with the toJsonString function.
266267 //
267268 // The Pipeline expects that the message it receives adheres to the
268- // standard CloudEvent format. If it doesn’ t then the outgoing message
269+ // standard CloudEvent format. If it doesn' t then the outgoing message
269270 // request may fail with a persistent error.
270271 string message_binding_template = 3
271272 [(google.api.field_behavior ) = OPTIONAL ];
@@ -274,14 +275,14 @@ message Pipeline {
274275 // Represents a config used to authenticate message requests.
275276 message AuthenticationConfig {
276277 // Represents a config used to authenticate with a Google OIDC token using
277- // a GCP service account. Use this authentication method to invoke your
278- // Cloud Run and Cloud Functions destinations or HTTP endpoints that
279- // support Google OIDC.
278+ // a Google Cloud service account. Use this authentication method to
279+ // invoke your Cloud Run and Cloud Functions destinations or HTTP
280+ // endpoints that support Google OIDC.
280281 message OidcToken {
281282 // Required. Service account email used to generate the OIDC Token.
282283 // The principal who calls this API must have
283284 // iam.serviceAccounts.actAs permission in the service account. See
284- // https://cloud.google.com/iam/docs/understanding-service-accounts?hl=en#sa_common
285+ // https://cloud.google.com/iam/docs/understanding-service-accounts
285286 // for more information. Eventarc service agents must have
286287 // roles/roles/iam.serviceAccountTokenCreator role to allow the
287288 // Pipeline to create OpenID tokens for authenticated requests.
@@ -307,7 +308,7 @@ message Pipeline {
307308 // token](https://developers.google.com/identity/protocols/OAuth2).
308309 // The principal who calls this API must have
309310 // iam.serviceAccounts.actAs permission in the service account. See
310- // https://cloud.google.com/iam/docs/understanding-service-accounts?hl=en#sa_common
311+ // https://cloud.google.com/iam/docs/understanding-service-accounts
311312 // for more information. Eventarc service agents must have
312313 // roles/roles/iam.serviceAccountTokenCreator role to allow Pipeline
313314 // to create OAuth2 tokens for authenticated requests.
@@ -327,7 +328,7 @@ message Pipeline {
327328 // The type of authentication method.
328329 oneof authentication_method_descriptor {
329330 // Optional. This authenticate method will apply Google OIDC tokens
330- // signed by a GCP service account to the requests.
331+ // signed by a Google Cloud service account to the requests.
331332 OidcToken google_oidc = 1 [(google.api.field_behavior ) = OPTIONAL ];
332333
333334 // Optional. If specified, an [OAuth
@@ -389,9 +390,9 @@ message Pipeline {
389390
390391 // Optional. An authentication config used to authenticate message requests,
391392 // such that destinations can verify the source. For example, this can be
392- // used with private GCP destinations that require GCP credentials to access
393- // like Cloud Run. This field is optional and should be set only by users
394- // interested in authenticated push
393+ // used with private Google Cloud destinations that require Google Cloud
394+ // credentials for access like Cloud Run. This field is optional and should
395+ // be set only by users interested in authenticated push.
395396 AuthenticationConfig authentication_config = 5
396397 [(google.api.field_behavior ) = OPTIONAL ];
397398
@@ -478,7 +479,7 @@ message Pipeline {
478479 // datacontenttype on the CloudEvent if present, else leave
479480 // datacontenttype absent.
480481 // - This function expects that the content of the message will
481- // adhere to the standard CloudEvent format. If it doesn’ t then this
482+ // adhere to the standard CloudEvent format. If it doesn' t then this
482483 // function will fail.
483484 // - The result is a CEL map that corresponds to the JSON
484485 // representation of the CloudEvent. To convert that data to a JSON
@@ -600,5 +601,9 @@ message Pipeline {
600601 // Output only. This checksum is computed by the server based on the value of
601602 // other fields, and might be sent only on create requests to ensure that the
602603 // client has an up-to-date value before proceeding.
603- string etag = 99 ;
604+ string etag = 99 [(google.api.field_behavior ) = OUTPUT_ONLY ];
605+
606+ // Output only. Whether or not this Pipeline satisfies the requirements of
607+ // physical zone separation
608+ bool satisfies_pzs = 14 [(google.api.field_behavior ) = OUTPUT_ONLY ];
604609}
0 commit comments