N>SrSSKJr SSKJr SSKJr SSKJr SSKJr SSK J r SSK J r SS K Jr SS KJr SS KJr SS KJr SS KJr Sr"SS\R,5rSrSr"SS\ 5r"SS\5rg)z$Utilities for Eventarc Triggers API.)absolute_import)division)unicode_literals) list_pager)common)EventarcClientBase)apis)types) exceptions) resources) iso_duration)timesc\rSrSrSrSrg)NoFieldsSpecifiedError"z: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.pyrr"sBrrcr[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) r IsAuditLogTyper ParseDateTimer DurationMAX_ACTIVE_DELAY_MINUTESGetDateTimePlusDurationNowFormatDateTimeLOCAL) event_type update_time update_dtdelay active_dts rTriggerActiveTimer6,ss   j ) ) !!+.)   (@ A%++I=) YY[I    iZ LLrcJ^\rSrSrSrU4SjrSrSrSrSr Sr S r U=r $) _BaseTriggersClientAzBase Triggers Client.c>[[U] [RSS5 [ R "[RS5nURUlURUl URUl g)Nv1r#) superr8__init__rAPI_NAMEr GetClientInstanceMESSAGES_MODULE _messagesprojects_locations_triggers_serviceprojects_locations_operations_operation_service)selfclient __class__s rr=_BaseTriggersClient.__init__DsY 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)rA.EventarcProjectsLocationsTriggersCreateRequestParent RelativeNameNamerCCreate)rF trigger_reftrigger_message create_reqs rrQ_BaseTriggersClient.CreateKsYNN!!#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 )rA.EventarcProjectsLocationsTriggersDeleteRequestrOrCDelete)rFrR delete_reqs rrY_BaseTriggersClient.Delete\s?NN  % % 'O)J ==   ++rcURRUR5S9nURR U5$)zeGets a Trigger. Args: trigger_ref: Resource, the Trigger to get. Returns: The Trigger message. rW)rA+EventarcProjectsLocationsTriggersGetRequestrOrCGet)rFrRget_reqs rr^_BaseTriggersClient.Getis?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. )rKpageSizetriggersrb)field batch_sizelimitbatch_size_attribute)rA,EventarcProjectsLocationsTriggersListRequestrOr YieldFromListrC)rF location_refrf page_sizelist_reqs rList_BaseTriggersClient.ListvsV~~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. )r r# updateMask)rA-EventarcProjectsLocationsTriggersPatchRequestrOrCPatch)rFrRrS update_mask patch_reqs rrr_BaseTriggersClient.PatchsGLL  % % 'M I ==  y ))r)rArErC) rrrrrr=rQrYr^rmrrr __classcell__)rHs@rr8r8As*C," , &),**rr8cN\rSrSrSrSrSrSrSrSr Sr S r S r S r S rg )TriggersClientV1z3Client for Triggers service in the Eventarc GA API.c >Uc/O;UR5V V s/sHupURRXS9PM sn n n UbBUR5H.upU RURRXSS95 M0 U(aUR 5OSn URR U S9nURR US9nU(aUR 5OSnURRUR 5U UUUUUU S9$s sn n f)aBuilds 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 labels: dict or None, the Trigger's labels. Returns: A Trigger message with a destination service. N) attributevaluezmatch-path-pattern)r{r|operator)topic)pubsub)r eventFilterseventDataContentTypeserviceAccount destination transportchannellabels)itemsrA EventFilterappendrOPubsub TransportTrigger)rFrR event_filtersevent_filters_path_patternevent_data_content_typeservice_accountdestination_messagetransport_topic_ref channel_refrkeyr|filter_messagestransport_topic_namerrrs rBuildTriggerMessage$TriggersClientV1.BuildTriggerMessages2>*1b'--/8/JC ""S">/8O"-288:*# NN & &5I ' K L; /;;"&^^ " ")= " >F(((7I,7k&&(TG >> ! !  % % '$4&' "  !8s%DclURRUUUUS9nURRUS9$)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)rACloudRun Destination)rFdestination_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)rAGKEr)rFdestination_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/{})workflowformatrAr)rF project_iddestination_workflowdestination_workflow_locationworkflow_messages rBuildWorkflowDestinationMessage0TriggersClientV1.BuildWorkflowDestinationMessages5?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)rFrdestination_functiondestination_function_locationfunction_messages rBuildFunctionDestinationMessage0TriggersClientV1.BuildFunctionDestinationMessage#s5?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)rA HttpEndpoint NetworkConfigr)rFdestination_http_endpoint_urinetwork_attachmenthttp_endpoint_messagenetwork_config_messages r#BuildHTTPEndpointDestinationMessage4TriggersClientV1.BuildHTTPEndpointDestinationMessage5sd!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(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. 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.cloudFunctionrrrrz*Must specify at least one field to update.,)rrjoin)rFrrrrrrrrrrrrrrrrrss rBuildUpdateMask TriggersClientV1.BuildUpdateMaskOsnK45677834 4523/0</0<452()*/0 "  "#O PP 88K  rcB[R"UR5$)zGets the Trigger's event type.)r EventFiltersMessageToTyper)rFrSs r GetEventTypeTriggersClientV1.GetEventTypes  * *?+G+G HHrcBURRR$)zReturns the labels value class.)rAr LabelsValue)rFs rLabelsValueClass!TriggersClientV1.LabelsValueClasss >> ! ! - --rrN)rrrrrrrrrrrrrrrrrrrxrxs8;8t<278A$F$4T!lI.rrxN)r __future__rrrapitools.base.pyrgooglecloudsdk.api_lib.eventarcr$googlecloudsdk.api_lib.eventarc.basergooglecloudsdk.api_lib.utilr #googlecloudsdk.command_lib.eventarcr googlecloudsdk.corer r googlecloudsdk.core.utilr rr,Errorrr$r6r8rxrrrrsr+&''2C,5*)1*CZ--C M*[*,[*|L.*L.r