o Mf @s$dZddlmZGdddeZdS)zDefine Cloud Logging API Sinks.)NotFoundc@seZdZdZdddddddZeddZedd Zed d Zed d Z eddZ ddZ e ddddZ ddZdddddZddddZddddZdddd d!Zddd"d#ZdS)$SinkzSinks represent filtered exports for log entries. See https://cloud.google.com/logging/docs/reference/v2/rest/v2/projects.sinks N)filter_parent destinationclientcCs(||_||_||_||_||_d|_dS)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)selfrrrrrr ^/var/www/html/analyze/labelStudio/lib/python3.10/site-packages/google/cloud/logging_v2/sink.py__init__s  z Sink.__init__cC|jS)zClient bound to the sink.r r r r rr9z Sink.clientcCs |jdur d|jj|_|jS)zOParent resource of the sink (project, organization, billingAccount, or folder).Nz projects/)r rprojectrr r rr>s z Sink.parentcCs|jd|jS)z&Fully-qualified name used in sink APIsz/sinks/)rrrr r r full_nameEszSink.full_namecCs d|jS)zURL path for the sink's APIs/)rrr r rpathJs z Sink.pathcCr)z&Identity used for exports via the sink)r rr r rwriter_identityOrzSink.writer_identitycCs&|d|_|d|_|d|_dS)z0Helper for API methods returning sink resources.rfilterwriterIdentityN)rgetrr )r resourcer r r_update_from_api_reprTs  zSink._update_from_api_repr)rcCs$|d}||||d}|||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)rr)r)clsrrr sink_nameinstancer r r from_api_reprZs zSink.from_api_reprcCs|dur|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. Nrr rr r r_require_clientzs zSink._require_clientF)runique_writer_identitycCs6||}|jj|j|j|j|j|d}||dS)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_createrrrrrr rr$rr r rcreates z Sink.create)rcCs4||}z |j|jWdStyYdSw)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. FT)r#r&sink_getrrr"r r rexistss  z Sink.existscCs&||}|j|j}||dS)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#r&r*rr)r rrr r rreloads z Sink.reloadcCs2||}|jj|j|j|j|d}||dS)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#r& sink_updaterrrrr(r r rupdates z Sink.updatecCs||}|j|jdS)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#r& sink_deleterr"r r rdeletes z Sink.delete)__name__ __module__ __qualname____doc__rpropertyrrrrrr classmethodr!r#r)r+r,r.r0r r r rrs.      rN)r4google.cloud.exceptionsrobjectrr r r rs