@SrSSKJr SSKJr SSKJr SSKJr SSKJ r SSK J r SSK J r SS K Jr SS K Jr S r"S S \ R"5rSrSr"SS\R*5r"SS\5rg)z$Utilities for Eventarc Triggers API.) list_pager)base)common)apis)types) exceptions) resources) iso_duration)timesc\rSrSrSrSrg)NoFieldsSpecifiedErrorz:Error when no fields were specified for a Patch operation.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r/lib/googlecloudsdk/api_lib/eventarc/triggers.pyrrsBrrcr[RRURSS9nUR 5$)Nz$eventarc.projects.locations.triggers) collection)r REGISTRYParseRelativeNamenameSelfLink)resourcetriggers r GetTriggerURIr!#s7    0 0mm F 1 H'    rc>[R"U5(dg[R"U5n[R "[ S9n[R"X#5n[R"5U:ag[R"US[RS9$)aComputes the time by which the trigger will become active. Args: event_type: str, the trigger's event type. update_time: str, the time when the trigger was last modified. Returns: The active time as a string, or None if the trigger is already active. N)minutesz%H:%M:%S)fmttzinfo) rIsAuditLogTyper ParseDateTimer DurationMAX_ACTIVE_DELAY_MINUTESGetDateTimePlusDurationNowFormatDateTimeLOCAL) event_type update_time update_dtdelay active_dts rTriggerActiveTimer3)ss   j ) ) !!+.)   (@ A%++I=) YY[I    iZ LLrcJ^\rSrSrSrU4SjrSrSrSrSr Sr S r U=r $) _BaseTriggersClient>zBase Triggers Client.c>[[U] [RSS5 [ R "[RS5nURUlURUl URUl g)Nv1r ) superr5__init__rAPI_NAMErGetClientInstanceMESSAGES_MODULE _messagesprojects_locations_triggers_serviceprojects_locations_operations_operation_service)selfclient __class__s rr:_BaseTriggersClient.__init__AsY t-footYO  # #FOOT :F++DN66DM$BBDrcURRUR5R5UUR 5S9nUR R U5$)aCreates a new Trigger. Args: trigger_ref: Resource, the Trigger to create. trigger_message: Trigger, the trigger message that holds trigger's event_filters, service account, destination, transport, etc. Returns: A long-running operation for create. )parentr triggerId)r>.EventarcProjectsLocationsTriggersCreateRequestParent RelativeNameNamer@Create)rC trigger_reftrigger_message create_reqs rrN_BaseTriggersClient.CreateHsYNN!!#002""$O&J ==   ++rcURRUR5S9nURR U5$)z{Deletes a Trigger. Args: trigger_ref: Resource, the Trigger to delete. Returns: A long-running operation for delete. r)r>.EventarcProjectsLocationsTriggersDeleteRequestrLr@Delete)rCrO delete_reqs rrV_BaseTriggersClient.DeleteYs?NN  % % 'O)J ==   ++rcURRUR5S9nURR U5$)zeGets a Trigger. Args: trigger_ref: Resource, the Trigger to get. Returns: The Trigger message. rT)r>+EventarcProjectsLocationsTriggersGetRequestrLr@Get)rCrOget_reqs rr[_BaseTriggersClient.Getfs?nnHH  % % 'I)G ==  W %%rc URRUR5US9n[R"UR USUUSS9$)aILists Triggers in a given location. Args: location_ref: Resource, the location to list Triggers in. limit: int or None, the total number of results to return. page_size: int, the number of entries in each batch (affects requests made, but not the yielded results). Returns: A generator of Triggers in the location. )rHpageSizetriggersr_)field batch_sizelimitbatch_size_attribute)r>,EventarcProjectsLocationsTriggersListRequestrLr YieldFromListr@)rC location_refrc page_sizelist_reqs rList_BaseTriggersClient.ListssV~~JJ((*YK@H  # # '  ))rcURRUR5UUS9nURR U5$)aIUpdates a Trigger. Args: trigger_ref: Resource, the Trigger to update. trigger_message: Trigger, the trigger message that holds trigger's event_filters, service account, destination, transport, etc. update_mask: str, a comma-separated list of Trigger fields to update. Returns: A long-running operation for update. )rr updateMask)r>-EventarcProjectsLocationsTriggersPatchRequestrLr@Patch)rCrOrP update_mask patch_reqs rro_BaseTriggersClient.PatchsGLL  % % 'M I ==  y ))r)r>rBr@) rrrrrr:rNrVr[rjror __classcell__)rEs@rr5r5>s*C," , &),**rr5cT\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rg)TriggersClientV1z3Client for Triggers service in the Eventarc GA API.c \/n Ub;UR5V V s/sHupURRXS9PM n n n UbBUR5H.upU RURRXSS95 M0 U(aUR 5OSnURR US9nURR US9nU(aUR 5OSnURRUR 5U UUUUUURU 5U S9 $s sn n f)a%Builds a Trigger message with the given data. Args: trigger_ref: Resource, the Trigger to create. event_filters: dict or None, the Trigger's event filters. event_filters_path_pattern: dict or None, the Trigger's event filters in path pattern format. event_data_content_type: str or None, the data content type of the Trigger's event. service_account: str or None, the Trigger's service account. destination_message: Destination message or None, the Trigger's destination. transport_topic_ref: Resource or None, the user-provided transport topic. channel_ref: Resource or None, the channel for 3p events max_retry_attempts: int or None, the Trigger's max retry attempts. labels: dict or None, the Trigger's labels. Returns: A Trigger message with a destination service. N) attributevaluezmatch-path-pattern)rxryoperator)topic)pubsub) r eventFilterseventDataContentTypeserviceAccount destination transportchannel retryPolicylabels) itemsr> EventFilterappendrLPubsub TransportTrigger_BuildRetryPolicy)rCrO event_filtersevent_filters_path_patternevent_data_content_typeservice_accountdestination_messagetransport_topic_ref channel_refmax_retry_attemptsrfilter_messageskeyrytransport_topic_namer|rrs rBuildTriggerMessage$TriggersClientV1.BuildTriggerMessagesJBO *//11jc .. $ $s $ @1"-288:*# NN & &5I ' K L; /;;"&^^ " ")= " >F(((7I,7k&&(TG >> ! !  % % '$4&'**+=> "  !s%D(c<UcgURRUS9$)zBuilds a RetryPolicy message with the given data. Args: max_retry_attempts: int or None, the Trigger's max retry attempts. Returns: A RetryPolicy message with the given data. N) maxAttempts)r> RetryPolicy)rCrs rr"TriggersClientV1._BuildRetryPolicys&!  >> % %2D % EErclURRUUUUS9nURRUS9$)aBuilds a Destination message for a destination Cloud Run service. Args: destination_run_service: str or None, the destination Cloud Run service. destination_run_job: str or None, the destination Cloud Run job. destination_run_path: str or None, the path on the destination Cloud Run service. destination_run_region: str or None, the destination Cloud Run service's region. Returns: A Destination message for a destination Cloud Run service. )servicejobpathregion)cloudRun)r>CloudRun Destination)rCdestination_run_servicedestination_run_jobdestination_run_pathdestination_run_region run_messages rBuildCloudRunDestinationMessage0TriggersClientV1.BuildCloudRunDestinationMessagesC$..))'  !% *'K >> % %{ % ;;rcnURRUUUUUS9nURRUS9$)a)Builds a Destination message for a destination GKE service. Args: destination_gke_cluster: str or None, the destination GKE service's cluster. destination_gke_location: str or None, the location of the destination GKE service's cluster. destination_gke_namespace: str or None, the destination GKE service's namespace. destination_gke_service: str or None, the destination GKE service. destination_gke_path: str or None, the path on the destination GKE service. Returns: A Destination message for a destination GKE service. )clusterlocation namespacerr)gke)r>GKEr)rCdestination_gke_clusterdestination_gke_locationdestination_gke_namespacedestination_gke_servicedestination_gke_path gke_messages rBuildGKEDestinationMessage+TriggersClientV1.BuildGKEDestinationMessagesF(..$$')+' ! %#K >> % %+ % 66rcXSRXU5nURRUS9$)aBuilds a Workflow Destination message with the given data. Args: project_id: the ID of the project. destination_workflow: str or None, the Trigger's destination Workflow ID. destination_workflow_location: str or None, the location of the Trigger's destination Workflow. It defaults to the Trigger's location. Returns: A Destination message with a Workflow destination. z%projects/{}/locations/{}/workflows/{})workflowformatr>r)rC project_iddestination_workflowdestination_workflow_locationworkflow_messages rBuildWorkflowDestinationMessage0TriggersClientV1.BuildWorkflowDestinationMessage s5?EE3GI >> % %/? % @@rcXSRXU5nURRUS9$)aBuilds a Function Destination message with the given data. Args: project_id: the ID of the project. destination_function: str or None, the Trigger's destination Function ID. destination_function_location: str or None, the location of the Trigger's destination Function. It defaults to the Trigger's location. Returns: A Destination message with a Function destination. z%projects/{}/locations/{}/functions/{}) cloudFunctionr)rCrdestination_functiondestination_function_locationfunction_messages rBuildFunctionDestinationMessage0TriggersClientV1.BuildFunctionDestinationMessage2s5?EE3GI >> % %4D % EErcURRUS9nURRUS9nURRUUS9$)a-Builds a HTTP Endpoint Destination message with the given data. Args: destination_http_endpoint_uri: str or None, the Trigger's destination uri. network_attachment: str or None, the Trigger's destination network attachment. Returns: A Destination message with a HTTP Endpoint destination. )uri)networkAttachment) httpEndpoint networkConfig)r> HttpEndpoint NetworkConfigr)rCdestination_http_endpoint_urinetwork_attachmenthttp_endpoint_messagenetwork_config_messages r#BuildHTTPEndpointDestinationMessage4TriggersClientV1.BuildHTTPEndpointDestinationMessageDsd!NN77 )8"^^99,: >> % %*, & rc/nU(aURS5 U(aURS5 U(aURS5 U(aURS5 U (aURS5 U (aURS5 U (aURS5 U (dU (aURS5 U(dU(aURS 5 U(dU(aURS 5 U(aURS 5 U(aURS 5 U(aURS 5 U(aURS5 U(d [S5eSRU5$)aBuilds an update mask for updating a Cloud Run trigger. Args: event_filters: bool, whether to update the event filters. event_filters_path_pattern: bool, whether to update the event filters with path pattern syntax. event_data_content_type: bool, whether to update the event data content type. service_account: bool, whether to update the service account. destination_run_service: bool, whether to update the destination Cloud Run service. destination_run_job: bool, whether to update the desintation Cloud Run job. destination_run_path: bool, whether to update the destination Cloud Run path. destination_run_region: bool, whether to update the destination Cloud Run region. destination_gke_namespace: bool, whether to update the destination GKE service namespace. destination_gke_service: bool, whether to update the destination GKE service name. destination_gke_path: bool, whether to update the destination GKE path. destination_workflow: bool, whether to update the destination workflow. destination_workflow_location: bool, whether to update the destination workflow location. destination_function: bool, whether to update the destination function. destination_function_location: bool, whether to update the destination function location. max_retry_attempts: bool, whether to update the max retry attempts. labels: bool, whether to update the labels. Returns: The update mask as a string. Raises: NoFieldsSpecifiedError: No fields are being updated. zdestination.cloudRun.pathzdestination.cloudRun.regionzdestination.cloudRun.servicezdestination.cloudRun.jobzdestination.gke.namespacezdestination.gke.servicezdestination.gke.pathzdestination.workflowzdestination.cloudFunctionr}rr~rrz*Must specify at least one field to update.,)rrjoin)rCrrrrrrrrrrrrrrrrrrps rBuildUpdateMask TriggersClientV1.BuildUpdateMask^s*rK45677834 4523/0</0<452()*/0' "  "#O PP 88K  rcB[R"UR5$)zGets the Trigger's event type.)rEventFiltersMessageToTyper})rCrPs r GetEventTypeTriggersClientV1.GetEventTypes  * *?+G+G HHrcBURRR$)zReturns the labels value class.)r>r LabelsValue)rCs rLabelsValueClass!TriggersClientV1.LabelsValueClasss >> ! ! - --rrN)rrrrrrrrrrrrrrrrrrrrurus>;=~ F<278A$F$4X!tI.rruN)rapitools.base.pyrgooglecloudsdk.api_lib.eventarcrrgooglecloudsdk.api_lib.utilr#googlecloudsdk.command_lib.eventarcrgooglecloudsdk.corerr googlecloudsdk.core.utilr r r)Errorrr!r3EventarcClientBaser5rurrrrsp+(02,5*)1*CZ--C M*[*$11[*|b.*b.r