SrSSKJr SSKJr SSKJr SSKrSSKJr SSKJr SSK J r SS K J r SS K J r SS K Jr SS KJr S rSzSjrSrSrSrSrSrSrSrSrSrSrSrSrSrSr Sr!Sr"Sr#S r$S{S!jr%S"r&S|S#jr'S}S$jr(S%r)S|S&jr*S'r+S|S(jr,S)r-S|S*jr.S|S+jr/S|S,jr0S-r1S.r2S|S/jr3S|S0jr4S1r5S2r6S|S3jr7S|S4jr8S5r9S6r:S7r;S|S8jrS}S;jr?S<r@S=rAS>rBS?rCS|S@jrDS|SAjrES}SBjrFS}SCjrGS}SDjrHS}SEjrIS}SFjrJS|SGjrKS|SHjrLS}SIjrMS}SJjrNS}SKjrOSLrPSMrQS|SNjrRS|SOjrSS|SPjrTS|SQjrUS|SRjrVS|SSjrWS|STjrXS|SUjrYS|SVjrZS|SWjr[S|SXjr\S|SYjr]S|SZjr^S[r_S\r`S]raS^rbS|S_jrcS|S`jrdSareS~SbjrfS}ScjrgS|SdjrhSeriSSfjrjS|SgjrkShrlSirmSjrnS|SkjroS|SljrpS|SmjrqSnrrS|SojrsS|SpjrtS|SqjruS|SrjrvS|SsjrwS|StjrxS|SujryS|SvjrzSwr{Sxr|Syr}g)zFlags for Eventarc commands.)absolute_import)division)unicode_literalsN) arg_parsers)base)concepts)deps)concept_parsers)presentation_specs) propertiesv1cZ[R"[R"S55/nSnU(aUS- nUS- nU(aRUR [R "[ RRRRS55 [R"SX#S9$)z4Builds an AttributeConfig for the location resource.zeventarc/locationz:The location for the Eventarc {resource}, which should be zeither ``global'' or zRone of the supported regions. Alternatively, set the [eventarc/location] property.z@use '-' location to aggregate results for all Eventarc locationslocation)name fallthroughs help_text) r PropertyFallthroughr FromStringappend Fallthroughgooglecloudsdk command_libeventarcflags SetLocationr ResourceParameterAttributeConfig)allow_aggregation allow_globalfallthroughs_listrs 0lib/googlecloudsdk/command_lib/eventarc/flags.pyLocationAttributeConfigr!!s z445HIJK) ((I )    & & / / 5 5 A A N   2 2 $5 cg)N-r%r"r rr;s r"c*[R"SS9$)z3Builds an AttributeConfig for the trigger resource.triggerrrrr%r"r TriggerAttributeConfigr*?  2 2 BBr"c*[R"SS9$)z3Builds an AttributeConfig for the channel resource.channelr(r)r%r"r ChannelAttributeConfigr.Dr+r"c*[R"SS9$)z>Builds an AttributeConfig for the channel connection resource.zchannel-connectionr(r)r%r"r ChannelConnectionAttributeConfigr0Is  2 28L MMr"c*[R"SS9$)z4Builds an AttributeConfig for the provider resource.providerr(r)r%r"r ProviderAttributeConfigr3N  2 2 CCr"c*[R"SS9$)z;Builds an AttributeConfig for the transport topic resource.ztransport-topicr(r)r%r"r TransportTopicAttributeConfigr6Ss  2 28I JJr"c*[R"SS9$)z7Builds an AttributeConfig for the message bus resource.z message-busr(r)r%r"r MessageBusAttributeConfigr8Xs  2 2 FFr"c*[R"SS9$)z=Builds an AttributeConfig for the Google API source resource.zgoogle-api-sourcer(r)r%r"r GoogleApiSourceAttributeConfigr:]s  2 28K LLr"c*[R"SS9$)z6Builds an AttributeConfig for the enrollment resource. enrollmentr(r)r%r"r EnrollmentAttributeConfigr=bs  2 2 EEr"c*[R"SS9$)z4Builds an AttributeConfig for the pipeline resource.pipeliner(r)r%r"r PipelineAttributeConfigr@gr4r"c*[R"SS9$)z8Builds an AttributeConfig for the Kafka source resource.z kafka-sourcer(r)r%r"r KafkaSourceAttributeConfigrBls  2 2 GGr"cn[R"SS[5[5[RS9$)z+Builds a ResourceSpec for trigger resource.z$eventarc.projects.locations.triggersr') resource_name triggersId locationsId projectsId)r ResourceSpecr*r! DEFAULT_PROJECT_ATTRIBUTE_CONFIGr%r"r TriggerResourceSpecrJq0   ,'))+::  r"cn[R"SS[5[5[RS9$)z+Builds a ResourceSpec for channel resource.z$eventarc.projects.locations.channelsr-)rD channelsIdrFrG)rrHr.r!rIr%r"r ChannelResourceSpecrN|rKr"cn[R"SS[5[5[RS9$)z6Builds a ResourceSpec for channel connection resource.z.eventarc.projects.locations.channelConnectionszchannel connection)rDchannelConnectionsIdrFrG)rrHr0r!rIr%r"r ChannelConnectionResourceSpecrQs0   6(;=)+::  r"cn[R"SS[5[5[RS9$)z)Builds a ResourceSpec for event provider.z%eventarc.projects.locations.providersr2)rD providersIdrFrG)rrHr3r!rIr%r"r ProviderResourceSpecrTs0   -)+)+::  r"c l[R"SS[5[SS9[RS9$)z&Builds a ResourceSpec for message bus.z(eventarc.projects.locations.messageBusesz message busFr)rDmessageBusesIdrFrG)rrHr8r!rIr%r"r MessageBusResourceSpecrXs2   0!.0)u=::  r"c l[R"SS[5[SS9[RS9$)z,Builds a ResourceSpec for Google API source.z,eventarc.projects.locations.googleApiSourceszGoogle API sourceFrV)rDgoogleApiSourcesIdrFrG)rrHr:r!rIr%r"r GoogleApiSourceResourceSpecr[s2   4'79)u=::  r"c l[R"SS[5[SS9[RS9$)z%Builds a ResourceSpec for enrollment.z'eventarc.projects.locations.enrollmentsr<FrV)rD enrollmentsIdrFrG)rrHr=r!rIr%r"r EnrollmentResourceSpecr^s2   / -/)u=::  r"c l[R"SU[5[SS9[RS9$)&Builds a ResourceSpec for destination.z%eventarc.projects.locations.pipelinesFrV)rD pipelinesIdrFrG)rrHr@r!rIrDs r PipelineResourceSpecrcs2   -!)+)u=::  r"c l[R"SS[5[SS9[RS9$)r`z(eventarc.projects.locations.kafkaSourcesz kafka sourceFrV)rDkafkaSourcesIdrFrG)rrHrBr!rIr%r"r KafkaSourceResourceSpecrfs2   0"/1)u=::  r"c[R"SS[5[RS9n[R R SUSUS9nURU5 g)zAAdds a resource argument for a customer-provided transport topic.zpubsub.projects.topicsz Pub/Sub topic)rDtopicsIdrGz--transport-topica*The Cloud Pub/Sub topic to use for the trigger's transport intermediary. This feature is currently only available for triggers of event type ``google.cloud.pubsub.topic.v1.messagePublished''. The topic must be in the same project as the trigger. If not specified, a transport topic will be created.requiredN)rrHr6rIr ConceptParser ForResource AddToParser)parserrj resource_specconcept_parsers r AddTransportTopicResourceArgrqsd''#,.:: - #00<<= = .V$r"c[R"SS[US9[RS9n[R R SXAUS9nURU5 g)z2Adds a resource argument for an Eventarc location.zeventarc.projects.locationsr)r)rDrFrGz --locationriN)rrHr!rIr rkrlrm)rngroup_help_textrjrrorps r AddLocationResourceArgrts`''#)  r"c&URSUSS9 g)z3Adds an argument for the trigger's service account.z--service-accountz:The IAM service account email associated with the trigger.rNrrnrjs r AddServiceAccountArgr@s Gr"c U[RR:XaSnSnOSnSnURU[R [R "5UUSS9 g)z1Adds an argument for the trigger's event filters.z--event-filtersa@The trigger's list of filters that apply to CloudEvents attributes. This flag can be repeated to add more filters to the list. Only events that match all these filters will be sent to the destination. The filters must include the ``type'' attribute, as well as any other attributes that are expected for the chosen type.z--matching-criteriaaThe criteria by which events are filtered for the trigger, specified as a comma-separated list of CloudEvents attribute names and values. This flag can also be repeated to add more criteria to the list. Only events that match with this criteria will be sent to the destination. The criteria must include the ``type'' attribute, as well as any other attributes that are expected for the chosen type.r)rrrjrrNrrrrrrr)rnrrjflagrs r AddEventFiltersArgrIsmd''*** D < !D B   % %      r"c U[RR:Xa7URS[R [R "5UUSSS9 gg)zHAdds an argument for the trigger's event filters in path pattern format.z--event-filters-path-patternaJThe trigger's list of filters in path pattern format that apply to CloudEvent attributes. This flag can be repeated to add more filters to the list. Only events that match all these filters will be sent to the destination. Currently, path pattern format is only available for the resourceName attribute for Cloud Audit Log events.zATTRIBUTE=PATH_PATTERN)rrrrjrrNrrnrrjrs r AddEventFiltersPathPatternArgrhsXd''*** &''  " )+r"cfU[RR:XaURSUUSS9 gg)z;Adds an argument for the trigger's event data content type.z--event-data-content-typeaDepending on the event provider, you can specify the encoding of the event data payload that will be delivered to your destination, to either be encoded in ``application/json'' or ``application/protobuf''. The default encoding is ``application/json''. Note that for custom sources or third-party providers, or for direct events from Cloud Pub/Sub, this formatting option is not supported.)rrjrN)rrrrrs r AddEventDataContentTypeArgrs>d''*** #  +r"cnU[RR:Xa UR$UR$)z*Gets the event filters from the arguments.)rrr event_filtersmatching_criteriaargsrs r GetEventFiltersArgrs.d''***     ! !!r"cXU[RR:Xa UR$g)zd''*** ,%j1%j>)*5 +r"cURUSS9nURSS9n[U5 U[RR :Xa [ U5 [U5 [U5 g)zgAdds arguments related to trigger's Cloud Run fully-managed resource destination for create operations.zDFlags for specifying a Cloud Run fully-managed resource destination.rTriN) rrAddDestinationRunServiceArgrrrAddDestinationRunJobArgAddDestinationRunPathArgAddDestinationRunRegionArg)rnrrj run_groupresource_groups r rrsh P) 9949H.n-d''***N+9%Y'r"cURUUSS9n[USS9 [U5 [U5 [ USS9 [ U5 g)zRAdds arguments related to trigger's GKE service destination for create operations.z/Flags for specifying a GKE service destination.rjrrTriN)r_AddDestinationGKEClusterArg_AddDestinationGKELocationArg_AddDestinationGKENamespaceArg_AddDestinationGKEServiceArg_AddDestinationGKEPathArg)rnrjr gke_groups r rrsN  <) y48 * +y48I&r"cPURUUSS9n[USS9 [U5 g)zPAdds arguments related to trigger's Workflows destination for create operations.z3Flags for specifying a Cloud Workflows destination.rTriNr_AddDestinationWorkflowArg"_AddDestinationWorkflowLocationArgrnrjrworkflow_groups r rrs4##  @$. ^d;$^4r"cPURUUSS9n[USS9 [U5 g)zTAdds arguments related to trigger's HTTP Endpoint destination for create operations.z1Flags for specifying a HTTP Endpoint destination.rTriN)r!_AddDestinationHTTPEndpointUriArg&_AddCreateNetworkConfigDestinationArgs)rnrjrhttp_endpoint_groups r rrs7((  >) $$7$G()<=r"c:URUUSS9n[USS9 g)zUAdds arguments related to trigger's Network Config destination for create operations.z:Flags for specifying a Network Config for the destination.rTriN)r_AddNetworkAttachmentArg)rnrjrnetwork_config_groups r r r s0 ))  G* /$?r"cPURUUSS9n[USS9 [U5 g)zNAdds arguments related to trigger's Function destination for create operation.z,Flags for specifying a Function destination.rTriNr_AddDestinationFunctionArg"_AddDestinationFunctionLocationArgrnrjrfunction_groups r rrs4##  9$. ^d;$^4r"cURUSS9n[X15 U[RR:Xa![ U5 [ U5 [USS9 gg)zFAdds arguments related to trigger's destination for update operations.zBFlags for updating the destination to which events should be sent.rTrN)r!_AddUpdateCloudRunDestinationArgsrrr_AddUpdateGKEDestinationArgs!_AddUpdateWorkflowDestinationArgs!_AddUpdateFunctionDestinationArgsrs r AddUpdateDestinationArgsrsZ22 O3*$J>d''*** ,%j1%j>+r"cURUSS9nUR5n[U5 U[RR :Xa [ U5 [U5 UR5n[U5 [U5 g)zgAdds arguments related to trigger's Cloud Run fully-managed resource destination for update operations.zBFlags for updating a Cloud Run fully-managed resource destination.rN) rrrrrrrrrAddClearDestinationRunPathArg)rnrrjrrdestination_run_path_groups r rrs| O)99;.n-d''***N+Y'(EEG56 :;r"cURUUSS9n[U5 [U5 UR5n[ U5 [ U5 g)zRAdds arguments related to trigger's GKE service destination for update operations.z-Flags for updating a GKE service destination.rN)rrrrr_AddClearDestinationGKEPathArg)rnrjrrdestination_gke_path_groups r rr.sS  :) !+y)(EEG67 !;$. ^,$^4r"cRURUUSS9n[U5 [U5 g)zOAdds arguments related to trigger's Function destination for update operations.z*Flags for updating a Function destination.rNrrs r rrGs2##  7$. ^,$^4r"c$URSSS9 g)zAAdds an argument for the trigger's destination Cloud Run service.z--destination-run-servicezName of the Cloud Run fully-managed service that receives the events for the trigger. The service must be in the same project as the trigger.rNrrs r rrRs! r"c&URSSSS9 g)z=Adds an argument for the trigger's destination Cloud Run job.z--destination-run-jobTzName of the Cloud Run fully-managed job that receives the events for the trigger. The job must be in the same project as the trigger.)rrNrrs r rr^s    r"c&URSUSS9 g)zMAdds an argument for the trigger's destination path on the Cloud Run service.z--destination-run-pathzRelative path on the destination Cloud Run service to which the events for the trigger should be sent. Examples: ``/route'', ``route'', ``route/subroute''.rNrrs r rrk  + r"c&URSUSS9 g)zJAdds an argument for the trigger's destination Cloud Run service's region.z--destination-run-regionzRegion in which the destination Cloud Run service can be found. If not specified, it is assumed that the service is in the same region as the trigger.rNrrs r rrxs    r"c&URSUSS9 g)zEAdds an argument for the trigger's destination GKE service's cluster.z--destination-gke-clusterzName of the GKE cluster that the destination GKE service is running in. The cluster must be in the same project as the trigger.rNrrs r rrs!! Q r"c&URSUSS9 g)zFAdds an argument for the trigger's destination GKE service's location.z--destination-gke-locationzLocation of the GKE cluster that the destination GKE service is running in. If not specified, it is assumed that the cluster is a regional cluster and is in the same region as the trigger.rNrrs r rrs!" H r"c&URSUSS9 g)zGAdds an argument for the trigger's destination GKE service's namespace.z--destination-gke-namespaceznNamespace that the destination GKE service is running in. If not specified, the ``default'' namespace is used.rNrrs r rrs # > r"c&URSUSS9 g)BAdds an argument for the trigger's destination GKE service's name.z--destination-gke-servicezMName of the destination GKE service that receives the events for the trigger.rNrrs r rrs !  r"c&URSUSS9 g)r.z--destination-gke-pathzRelative path on the destination GKE service to which the events for the trigger should be sent. Examples: ``/route'', ``route'', ``route/subroute''.rNrrs r rrr(r"c&URSUSS9 g)z8Adds an argument for the trigger's destination Workflow.z--destination-workflowzuID of the workflow that receives the events for the trigger. The workflow must be in the same project as the trigger.rNrrs r rr! E r"c&URSUSS9 g)zAAdds an argument for the trigger's destination Workflow location.z--destination-workflow-locationzLocation that the destination workflow is running in. If not specified, it is assumed that the workflow is in the same location as the trigger.rNrrs r rr ' % r"c&URSUSS9 g)z8Adds an argument for the trigger's destination Function.z--destination-functionzuID of the Function that receives the events for the trigger. The Function must be in the same project as the trigger.rNrrs r rrr1r"c&URSUSS9 g)zAAdds an argument for the trigger's destination Function location.z--destination-function-locationzLocation that the destination Function is running in. If not specified, it is assumed that the Function is in the same location as the trigger.rNrrs r rrr3r"c&URSUSS9 g)zAAdds an argument for the trigger's HTTP endpoint destination URI.z--destination-http-endpoint-uriz8URI that the destination HTTP Endpoint is connecting to.rNrrs r r r s' Er"c&URSUSS9 g)z?Adds an argument for the trigger's destination service account.--network-attachmentz]The network attachment associated with the trigger that allows access to the destination VPC.rNrrs r rrs  , r"c&URSSSS9 g)Nz--clear-service-account store_truez:Clear the IAM service account associated with the trigger.rrrrs r AddClearServiceAccountArgr< s  Gr"c&URSSSS9 g)zGAdds an argument for clearing the trigger's Cloud Run destination path.z--clear-destination-run-pathr:zpClear the relative path on the destination Cloud Run service to which the events for the trigger should be sent.r;Nrrs r rrs $  = r"c&URSSSS9 g)zAAdds an argument for clearing the trigger's GKE destination path.z--clear-destination-gke-pathr:zjClear the relative path on the destination GKE service to which the events for the trigger should be sent.r;Nrrs r r!r!s $  7 r"c$URSUS9 g)z.Adds a positional argument for the event type.rrNrrnrs r AddTypePositionalArgrA*sf9-r"c&URSUSS9 g)z$Adds an argument for the event type.z--typezThe event type.rNrrs r AddTypeArgrC/sh8IJr"c&URSUSS9 g)zHAdds an argument for the value of the serviceName CloudEvents attribute.z--service-namez3The value of the serviceName CloudEvents attribute.rNrrs r AddServiceNameArgrE4s @r"c [R"[R"S[ 5SSS9[R"S[ 5SSS0S 9/S S /0S 9R U5 g) Nr-zChannel to create.Triz --providerz Provider to use for the channel.rr}r~z--provider.locationzchannel.locationr)r rkr rrNrTrmrs r AddCreateChannelArgrG=sp  5 5!#"   5 5"$0#-r"2    #8:L9M!N#$Kr"cpUnU(aURUS9n[XAU5 URSUUSS9 g)2Adds an argument for the crypto key used for CMEK.rz --crypto-keyzFully qualified name of the crypto key to use for customer-managed encryption. If this is unspecified, Google-managed keys will be used for encryption.rN)rAddClearCryptoNameArgr)rnrjr with_clear policy_groups r AddCryptoKeyArgrMSsH,66f6EL,&9  .  r"c ,URSUUSSSS9 g)rIz--clear-crypto-keyFr:zqRemove the previously configured crypto key. The channel will continue to be encrypted using Google-managed keys.)rjrdefaultrrNr)rnrjrs r rJrJes*   A r"c&URSUSS9 g)z.Adds an argument for the cel match expression.z --cel-matchz,The cel match expression for the enrollment.rNrrs r AddCelMatchArgrQts 9r"c,URS/SQSUS9 g)z8Adds an argument for the logging config of the resource.z--logging-config) NONEDEBUGINFONOTICEWARNINGERRORCRITICALALERT EMERGENCYF)choicesrjrNrr@s r AddLoggingConfigArgr]}s%  r"cURSS9nURS[R"S[S9SSSS9 URS [R SS S 9 U(aURS S SSS 9 gg)zAAdds an argument for the wide scope subscription of the resource.Friz--project-subscriptions min_length element_typeGAS_PROJECT_SUBSCRIPTIONz+The project subscriptions for the resource.)rrrjrz--organization-subscriptionz/The organization subscription for the resource.)rrjrz--clear-project-subscriptionsr:z1Clear the project subscriptions for the resource.N)rrrArgListstrStoreTrueFalseAction)rnrKrs r AddWideScopeSubscriptionArgrgs  - -u - =%   !# >( 8 #  - - <  ' @ r"c,SnURS[R"[R"[[[[[[[[[[[[S[[S.SSS9SSS 9[R UUS S 9 g) z>Adds an argument for the pipeline's HTTP endpoint destination.a/ The pipeline's destinations. This flag can be repeated to add more destinations to the list. Currently, only one destination is supported per pipeline. A destination is specified in a dict format. For more information, see [Create an enrollment to receive events](https://cloud.google.com/eventarc/advanced/docs/receive-events/create-enrollment). Note: Exactly one of the `http_endpoint_uri`, `workflow`, `message_bus`, or `pubsub_topic` keys must be set. Valid keys are: *http_endpoint_uri*::: The URI of the HTTP endpoint. The value must be a RFC2396 URI string. Only HTTPS protocol is supported. The host can be either a static IP addressable from the VPC specified by the network config, or an internal DNS hostname of the service resolvable via Cloud DNS. For example: $ gcloud eventarc pipelines create example-pipeline --destinations=http_endpoint_uri='https://example.com' *http_endpoint_message_binding_template*::: The CEL expression used to construct a new HTTP request to be sent to the final destination. It can be optionally specified alongside with `http_endpoint_uri`. It represents a configuration used to bind a message to the final HTTP request that will be sent to the destination. If a binding is not specified, by default the message is treated as a CloudEvent and is mapped to the HTTP request according to the CloudEvent HTTP Protocol Binding Binary Content Mode. The pipeline converts the data field of the message to the format provided in `output_payload_format` and maps it to the body field of the result. It also sets the corresponding Content-Type header to the `output_payload_format` type. If the `output_payload_format` is unspecified, then the pipeline will treat the data field of the message as opaque binary data and attach it to the request body as bytes. In this case, the Content-Type header will be set to the value of the datacontenttype attribute set on the incoming CloudEvent message if present, or the `application/octet-stream` MIME type otherwise. The pipeline expects that the content of the message will adhere to the standard CloudEvent format. If not then the outgoing message request may fail with a persistent error. Note: When `http_endpoint_uri` is not set, `http_endpoint_message_binding_template` can't be set. The result of the CEL expression must be a map of key-value pairs such that: 1. If a map named `headers` exists on the result of the expression, then its key-value pairs are directly mapped to the HTTP request headers. The headers values are constructed from the corresponding value type's canonical representation. If the `headers` field does not exist, then the resulting HTTP request will not contain headers. 2. If a field named `body` exists on the result of the expression, then its value is directly mapped to the body of the request. If the value of the `body` field is of type bytes or string, then it is used as the HTTP request body as-is withouth any conversion. If the `body` field is of any other type, then it is converted to a JSON string. If the `body` field does not exist, then the resulting HTTP request will not contain a body. 3. Any other fields in the resulting expression will be ignored. The CEL expression may access the incoming CloudEvent message in its definition, as follows: 1. The `data` field of the incoming CloudEvent message can be accessed using the `message.data` value. 2. Each attribute of the incoming CloudEvent message can be accessed using the `message.` value, where is the name of the attribute. Headers added to the request by previous filters in the chain can be accessed in the CEL expression using the `headers` variable. The `headers` variable defines a map of key-value pairs corresponding to the HTTP headers added by previous mediation steps and not the headers present on the original incoming request. For example, the following CEL expression can be used to construct a headers-only HTTP request by adding an additional header to the headers added by previous mediations in the pipeline: ``` {"headers": headers.merge({"new-header-key": "new-header-value"})} ``` Additionally, the following CEL extension functions can be used in this CEL expression: * `toBase64Url`: map.toBase64Url() -> string - Converts a CelValue to a base64url encoded string. * `toJsonString`: map.toJsonString() -> string - Converts a CelValue to a JSON string. * `merge`: map1.merge(map2) -> map3 - Merges the passed CEL map with the existing CEL map the function is applied to. If the same key exists in both maps, or if the key's value is type map, then both maps are merged; Otherwise, the value from the passed map is used. * `toMap`: list(map).toMap() -> map - Converts a CEL list of CEL maps to a single CEL map. * `toDestinationPayloadFormat`: message.data.toDestinationPayloadFormat() -> string or bytes - Converts the message data to the destination payload format specified in `output_payload_format`. This function is meant to be applied to the message.data field. If the destination payload format is not set, the function will return the message data unchanged. * `toCloudEventJsonWithPayloadFormat`: message.toCloudEventJsonWithPayloadFormat() -> map - Converts a message to the corresponding structure of JSON format for CloudEvents. This function applies toDestinationPayloadFormat() to the message data. It also sets the corresponding datacontenttype of the CloudEvent, as indicated by the `output_payload_format` field. If `output_payload_format` is not set, it will use the existing datacontenttype on the CloudEvent if present; Otherwise, it leaves the datacontenttype unset. This function expects that the content of the message will adhere to the standard CloudEvent format. If it doesn't then this function will fail. The result is a CEL map that corresponds to the JSON representation of the CloudEvent. To convert that data to a JSON string it can be chained with the toJsonString() function. For example: $ gcloud eventarc pipelines create example-pipeline --destinations=http_endpoint_uri='https://example.com',http_endpoint_message_binding_template='{"headers": headers.merge({"new-header-key": "new-header-value"}),"body": "new-body"}' *workflow*::: The destination Workflow ID. For example: $ gcloud eventarc pipelines create example-pipeline --destinations=workflow=my-workflow *message_bus*::: The destination Message Bus ID. For example: $ gcloud eventarc pipelines create example-pipeline --destinations=message_bus=my-message-bus *pubsub_topic*::: The destination Pub/Sub topic ID. For example: $ gcloud eventarc pipelines create example-pipeline --destinations=pubsub_topic=my-topic *project*::: The project ID of the destination resource. If `project` is not set, then the project ID of the pipeline is used. For example: $ gcloud eventarc pipelines create example-pipeline --destinations=project=example-project,workflow=my-workflow Note: When `http_endpoint_uri` is set, `project` can't be set. *location*::: The location of the destination resource. If `location` is not set, then the location of the pipeline is used. For example: $ gcloud eventarc pipelines create example-pipeline --destinations=location=us-east1,workflow=my-workflow Note: When `http_endpoint_uri` is set, `location` can't be set. *network_attachment*::: The ID of the network attachment that allows access to the consumer VPC. For example: $ gcloud eventarc pipelines create example-pipeline --destinations=network_attachment=my-network-attachment,http_endpoint_uri='https://example.com' Note: `network_attachment` can only be set when `http_endpoint_uri` is set as well. *google_oidc_authentication_service_account*::: The service account email used to generate the OIDC token. The token can be used to invoke Cloud Run and Cloud Run functions destinations or HTTP endpoints that support Google OIDC. Note that the principal who calls this API must have `iam.serviceAccounts.actAs` permission on the service account. For more information, see [Service accounts overview](https://cloud.google.com/iam/docs/understanding-service-accounts). For example: $ gcloud eventarc pipelines create example-pipeline --destinations=http_endpoint_uri='https://example.com',google_oidc_authentication_service_account=example-service-account@example-project.gserviceaccount.iam.com *google_oidc_authentication_audience*::: The audience claim which identifies the recipient that the JWT is intended for. If unspecified, the destination URI will be used. For example: $ gcloud eventarc pipelines create example-pipeline --destinations=http_endpoint_uri='https://example.com',google_oidc_authentication_service_account=example-service-account@example-project.gserviceaccount.iam.com,google_oidc_authentication_audience='https://example.com' Note: `google_oidc_authentication_audience` can only be set if `google_oidc_authentication_service_account` is set. *oauth_token_authentication_service_account*::: The service account email used to generate the OAuth token. OAuth authorization should generally only be used when calling Google APIs hosted on *.googleapis.com. Note that the principal who calls this API must have iam.serviceAccounts.actAs permission in the service account. For more information, see [Service accounts overview](https://cloud.google.com/iam/docs/understanding-service-accounts). For example: $ gcloud eventarc pipelines create example-pipeline --destinations=http_endpoint_uri='https://example.com',oauth_token_authentication_service_account=example-service-account@example-project.gserviceaccount.iam.com *oauth_token_authentication_scope*::: The scope used to generate the OAuth token. If unspecified, "https://www.googleapis.com/auth/cloud-platform" will be used. For example: $ gcloud eventarc pipelines create example-pipeline --destinations=http_endpoint_uri='https://example.com',oauth_token_authentication_service_account=example-service-account@example-project.gserviceaccount.iam.com,oauth_token_authentication_scope=https://www.googleapis.com/auth/cloud-platform Note: At most one of `google_oidc_authentication_service_account` or `oauth_token_authentication_service_account` can be set; and `oauth_token_authentication_scope` can only be set if `oauth_token_authentication_service_account` is set. *output_payload_format_json*::: Indicates that the output payload format is JSON. For example: $ gcloud eventarc pipelines create example-pipeline --destinations=http_endpoint_uri='https://example.com',output_payload_format_json= --input-payload-format-json= Note: JSON schemas are not supported. Any value specified by this key is ignored. *output_payload_format_avro_schema_definition*::: The schema definition of the Avro output payload format. For example: $ gcloud eventarc pipelines create example-pipeline --destinations=http_endpoint_uri='https://example.com',output_payload_format_avro_schema_definition='{"type": "record", "name": "my_record", "fields": [{"name": "field1", "type": "string"}]}' --input-payload-format-avro-schema-definition='{"type": "record", "name": "my_record", "fields": [{"name": "field1", "type": "string"}]}' *output_payload_format_protobuf_schema_definition*::: The schema definition of the Protobuf output payload format. For example: $ gcloud eventarc pipelines create example-pipeline --destinations=http_endpoint_uri='https://example.com',output_payload_format_protobuf_schema_definition='syntax = "proto3"; message Location { string home_address = 1; }' --input-payload-format-protobuf-schema-definition='syntax = "proto3"; message Location { string home_address = 1; }' Note: If none of the `input_payload_format_json`, `input_payload_format_avro_schema_definition`, or `input_payload_format_protobuf_schema_definition` is set, then the message data is treated as an opaque binary and no output format can be set on the pipeline through the `output_payload_format_json`, `output_payload_format_avro_schema_definition`, or `output_payload_format_protobuf_schema_definition` field. Any mediations on the pipeline that involve access to the data field will fail as persistent errors. z--destinationsN)http_endpoint_uri&http_endpoint_message_binding_templateworkflowr pubsub_topicrvrnetwork_attachment*google_oidc_authentication_service_account#google_oidc_authentication_audience*oauth_token_authentication_service_account oauth_token_authentication_scopeoutput_payload_format_json,output_payload_format_avro_schema_definition0output_payload_format_protobuf_schema_definitionT)specallow_key_only includes_jsonr_#)rbracustom_delim_chara5[http_endpoint_uri=URI],[http_endpoint_message_binding_template=HTTP_ENDPOINT_MESSAGE_BINDING_TEMPLATE],[workflow=WORKFLOW],[message_bus=MESSAGE_BUS],[pubsub_topic=PUBSUB_TOPIC],[project=PROJECT],[location=LOCATION],[network_attachment=NETWORK_ATTACHMENT],[google_oidc_authentication_service_account=GOOGLE_OIDC_AUTHENTICATION_SERVICE_ACCOUNT],[google_oidc_authentication_audience=GOOGLE_OIDC_AUTHENTICATION_AUDIENCE],[oauth_token_authentication_service_account=OAUTH_TOKEN_AUTHENTICATION_SERVICE_ACCOUNT],[oauth_token_authentication_scope=OAUTH_TOKEN_AUTHENTICATION_SCOPE],[output_payload_format_json=OUTPUT_PAYLOAD_FORMAT_JSON],[output_payload_format_avro_schema_definition=OUTPUT_PAYLOAD_FORMAT_AVRO_SCHEMA_DEFINITION],[output_payload_format_protobuf_schema_definition=OUTPUT_PAYLOAD_FORMAT_PROTOBUF_SCHEMA_DEFINITION])rrrjrr)rrrdrrerrnrjrs r AddPipelineDestinationsArgr{sY)t    "**'*Adds an argument for the Kafka Source's bootstrap server URIs.a> The Kafka bootstrap server URIs, in the format : This flag can be repeated to add more URIs to the list, or comma-separated. At least one URI must be specified. Examples: $ gcloud eventarc kafka-sources create example-kafka-source --bootstrap-servers='broker-1.private:9092,broker-2.private:9092' z--bootstrap-serversBOOTSTRAP_SERVERr_r`rrrjrNrrrdrerzs r !AddKafkaSourceBootstrapServersArgr s:)    !# >  r"c \SnURSS[R"S[S9UUS9 g)z.Adds an argument for the Kafka Source's topic.z The Kafka topic(s) to subscribe to. At least one topic must be specified. Examples: $ gcloud eventarc kafka-sources create example-kafka-source --topics='topic1,topic2' z--topics KAFKA_TOPICr_r`rNrrzs r AddKafkaSourceTopicArgrs:)     !# >  r"c4SnURS[UUS9 g)z:Adds an argument for the Kafka Source's Consumer Group ID.a= The Kafka consumer group ID. If not specified, a random UUID will be generated. This consumer group ID is used by the Kafka cluster to record the current read offsets of any topics subscribed. Examples: $ gcloud eventarc kafka-sources create example-kafka-source --consumer-group-id='my-consumer-group' z--consumer-group-idrrjrNrrerzs r AddKafkaSourceConsumerGroupIDArgr.s*)    r"c Sn[R"[R"S[ 5SSS9[R"S[ 5USSSS .S 9/S S /0S 9R U5 g)zAdds an argument for the Kafka Source's mutual TLS Client Key.a The mutual TLS Client Key to use for authentication with the Kafka broker. This option is required if --tls-client-certificate is set. Examples: $ gcloud eventarc kafka-sources create example-kafka-source --tls-client-key='projects/123/secrets/my-key/versions/1' z--tls-client-keyrNrrzs r rrs*)     r"c&URSUSS9 g)zDAdds an argument for the Kafka sources's ingress network attachment.r8z^The network attachment associated with the Kafka source that allows access to the ingress VPC.rNrrs r "AddKafkaSourceNetworkAttachmentArgrs  ( r"cNURSU[R"5SS9 g)z%Adds arguments for resources' labels.z--labelsz KEY=VALUE)rrrN)rrrr@s r AddLabelsArgrs*      r"c [R"[R"S[ 5SSS9[R"S[ 5SSSSS S .S 9/S S /0S9R U5 g)z:Adds resource arguments for creating an Eventarc Pipeline.r?zThe pipeline to create.Tri--error-message-busz&The error message bus of the pipeline.F--error-message-bus-location--error-message-bus-projectrr--error-message-bus.locationpipeline.locationrN)r rkr rrcrXrmrs r AddCreatePipelineResourceArgsrs{  5 5"$'   5 5#$&6<:# ( )+>*?").Kr"cURSSS9n[R"[R"S[ 5SSS9[R"S[ 5SSSUS S S .S 9/S S/0S9RU5 URSSSSSS9 g)z:Adds resource arguments for updating an Eventarc Pipeline.FT)rjrr?zThe pipeline to update.rirz0The error message bus of the pipeline to update.rrr)rjrrrrrrz--clear-error-message-busr:z,Clear the error message bus of the pipeline.)rrrjrN) rr rkr rrcrXrmr)rnerror_message_bus_groups r AddUpdatePipelineResourceArgsrs"??T@  5 5"$'   5 5#$&@+<:# * )+>*?"+0K&&!  9  'r")FT)r?)F)FF)FFT)T)~__doc__ __future__rrrrgooglecloudsdk.callioperr googlecloudsdk.calliope.conceptsrr (googlecloudsdk.command_lib.util.conceptsr r googlecloudsdk.corer _IAM_API_VERSIONr!rr*r.r0r3r6r8r:r=r@rBrJrNrQrTrXr[r^rcrfrqrtrwrzrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr rrrrrrrrrrrrrrrrrrrr rr<rr!rArCrErGrMrJrQr]rgr{r~rrrrrrrrrrrrrrrrrr%r"r rs#&'/(51DG*4 C C N D K G M F D H %,@E % % K6?D8#L6 &R#L@38038," 6 ($ '5>$) @5 ?<$ =55                . K ,$ (8{|B:@("$ F  ;8"     8$r"