]j *dZddlmZGddeZy)zDefine Cloud Logging API Sinks.)NotFoundceZdZdZddddddZedZedZedZedZ ed Z d Z e dd d Z d ZddddZdddZdddZddddZdddZy)SinkzSinks represent filtered exports for log entries. See https://cloud.google.com/logging/docs/reference/v2/rest/v2/projects.sinks N)filter_parent destinationclientcX||_||_||_||_||_d|_y)a Args: name (str): The name of the sink. parent(Optional[str]): The resource in which to create the sink: :: "projects/[PROJECT_ID]" "organizations/[ORGANIZATION_ID]" "billingAccounts/[BILLING_ACCOUNT_ID]" "folders/[FOLDER_ID]". Defaults to the project stored on the client. filter_ (Optional[str]): The advanced logs filter expression defining the entries exported by the sink. destination (Optional[str]): Destination URI for the entries exported by the sink. If not passed, the instance should already exist, to be refreshed via :meth:`reload`. client (Optional[~logging_v2.client.Client]): A client which holds credentials and project configuration for the sink (which requires a project). N)namerr_client_parent_writer_identity)selfr rrrr s F/root/env/lib/python3.12/site-packages/google/cloud/logging_v2/sink.py__init__z Sink.__init__s00  &  $c|jS)zClient bound to the sink.r rs rr z Sink.client9s||rcn|jd|jj|_|jS)zOParent resource of the sink (project, organization, billingAccount, or folder).z projects/)r r projectrs rrz Sink.parent>s1 << &t{{':':&;>"##rc|jS)z&Identity used for exports via the sink)rrs rwriter_identityzSink.writer_identityOs$$$rcp|d|_|jd|_|jd|_y)z0Helper for API methods returning sink resources.rfilterwriterIdentityN)rgetrr)rresources r_update_from_api_reprzSink._update_from_api_reprTs1#M2||H- ( -= >r)rcH|d}||||}|j||S)aConstruct a sink given its API representation Args: resource (dict): sink resource representation returned from the API client (~logging_v2.client.Client): Client which holds credentials and project configuration for the sink. parent(Optional[str]): The resource in which to create the sink: :: "projects/[PROJECT_ID]" "organizations/[ORGANIZATION_ID]" "billingAccounts/[BILLING_ACCOUNT_ID]" "folders/[FOLDER_ID]". Defaults to the project stored on the client. Returns: ~logging_v2.sink.Sink: Sink parsed from ``resource``. Raises: ValueError: if ``client`` is not ``None`` and the project from the resource does not agree with the project from the client. r )r r)r$)clsr#r r sink_nameinstances r from_api_reprzSink.from_api_reprZs/6V$ y?&&x0rc"| |j}|S)aCheck client or verify over-ride. Also sets ``parent``. Args: client (Union[None, ~logging_v2.client.Client]): The client to use. If not passed, falls back to the ``client`` stored on the current sink. Returns: ~logging_v2.client.Client: The client passed in or the currently bound client. rrr s r_require_clientzSink._require_clientzs >\\F rF)r unique_writer_identityc|j|}|jj|j|j|j |j |}|j|y)aCreate the sink via a PUT request See https://cloud.google.com/logging/docs/reference/v2/rest/v2/projects.sinks/create Args: client (Optional[~logging_v2.client.Client]): The client to use. If not passed, falls back to the ``client`` stored on the current sink. unique_writer_identity (Optional[bool]): Determines the kind of IAM identity returned as writer_identity in the new sink. r-N)r, sinks_api sink_createrr rrr$rr r-r#s rcreatez Sink.creates`%%f-##// KK II LL   #9 0  ""8,r)r c|j|} |jj|jy#t$rYywxYw)aTest for the existence of the sink via a GET request See https://cloud.google.com/logging/docs/reference/v2/rest/v2/projects.sinks/get Args: client (Optional[~logging_v2.client.Client]): The client to use. If not passed, falls back to the ``client`` stored on the current sink. Returns: bool: Boolean indicating existence of the sink. TF)r,r0sink_getrrr+s rexistsz Sink.existssJ%%f-     % %dnn 5  s%9 AAc|j|}|jj|j}|j |y)a`Sync local sink configuration via a GET request See https://cloud.google.com/logging/docs/reference/v2/rest/v2/projects.sinks/get Args: client (Optional[~logging_v2.client.Client]): The client to use. If not passed, falls back to the ``client`` stored on the current sink. N)r,r0r5rr$)rr r#s rreloadz Sink.reloads<%%f-##,,T^^< ""8,rc|j|}|jj|j|j|j |}|j |y)aUpdate sink configuration via a PUT request See https://cloud.google.com/logging/docs/reference/v2/rest/v2/projects.sinks/update Args: client (Optional[~logging_v2.client.Client]): The client to use. If not passed, falls back to the ``client`` stored on the current sink. unique_writer_identity (Optional[bool]): Determines the kind of IAM identity returned as writer_identity in the new sink. r/N)r,r0 sink_updaterrrr$r2s rupdatez Sink.updatesY%%f-##// NN LL   #9 0  ""8,rcp|j|}|jj|jy)aVDelete a sink via a DELETE request See https://cloud.google.com/logging/docs/reference/v2/rest/v2/projects.sinks/delete Args: client (Optional[~logging_v2.client.Client]): The client to use. If not passed, falls back to the ``client`` stored on the current sink. N)r,r0 sink_deleterr+s rdeletez Sink.deletes,%%f-$$T^^4r)__name__ __module__ __qualname____doc__rpropertyr rrrrr$ classmethodr)r,r3r6r8r;r>rrrrs $Dd4%> 22$$%%? 7;> $E-. $. $ - $E-, $ 5rrN)rBgoogle.cloud.exceptionsrobjectrrErrrHs&,U56U5r