a !f/@s:dZddlZzLddlmZddlmZddlm Z ddl m Z ddl mZddl mZWn.eyd ZdZZ dZ ZdZZYn0d Zdd lmZdd lmZddlm ZddlmZddlmZdd lmZddlmZddlmZddlm Z ddl!m"Z"ddl#m$Z$eo$ej%&dduZ'GdddeZ(dS)z?Client for interacting with the Google Stackdriver Logging API.N)ConfigServiceV2Api)LoggingServiceV2Api)MetricsServiceV2Api) _LoggingAPI) _MetricsAPI) _SinksAPIFT) JSONClient) Connection) ProtobufEntry) StructEntry) TextEntryLoggerMetricSinkZGCLOUD_ENABLE_GAXc@seZdZdZeZdZZZe ddZ e ddZ e ddZ d d Z d d Zdd dZdddZdddZdddZdddZdS)ClientaClient to bundle configuration needed for API requests. :type project: str :param project: the project which the client acts on behalf of. If not passed, falls back to the default inferred from the environment. :type credentials: :class:`oauth2client.client.OAuth2Credentials` or :class:`NoneType` :param credentials: The OAuth2 Credentials to use for the connection owned by this client. If not passed (and if no ``http`` object is passed), falls back to the default inferred from the environment. :type http: :class:`httplib2.Http` or class that defines ``request()``. :param http: An optional HTTP object to make requests. If not passed, an ``http`` object is created that is bound to the ``credentials`` for the current object. NcCs2|jdur,tr t}t||_n t|j|_|jS)zHelper for logging-related API calls. See: https://cloud.google.com/logging/docs/api/ref_v2beta1/rest/v2beta1/entries https://cloud.google.com/logging/docs/api/ref_v2beta1/rest/v2beta1/projects.logs N) _logging_api_USE_GAXGeneratedLoggingAPI GAXLoggingAPIJSONLoggingAPI connectionself generatedrV/var/www/html/python-backend/venv/lib/python3.9/site-packages/gcloud/logging/client.py logging_apiMs    zClient.logging_apicCs2|jdur,tr t}t||_n t|j|_|jS)zHelper for log sink-related API calls. See: https://cloud.google.com/logging/docs/api/ref_v2beta1/rest/v2beta1/projects.sinks N) _sinks_apirGeneratedSinksAPI GAXSinksAPI JSONSinksAPIrrrrr sinks_api]s    zClient.sinks_apicCs2|jdur,tr t}t||_n t|j|_|jS)zHelper for log metric-related API calls. See: https://cloud.google.com/logging/docs/api/ref_v2beta1/rest/v2beta1/projects.metrics N) _metrics_apirGeneratedMetricsAPI GAXMetricsAPIJSONMetricsAPIrrrrr metrics_apils    zClient.metrics_apicCs t||dS)zCreates a logger bound to the current client. :type name: str :param name: the name of the logger to be constructed. :rtype: :class:`gcloud.logging.logger.Logger` :returns: Logger created with the current client. clientr )rnamerrrlogger{s z Client.loggercCsNd|vrt|||Sd|vr,t|||Sd|vrBt|||StddS)ajDetect correct entry type from resource and instantiate. :type resource: dict :param resource: one entry resource from API response :type loggers: dict or None :param loggers: A mapping of logger fullnames -> loggers. If not passed, the entry will have a newly-created logger. :rtype: One of: :class:`gcloud.logging.entries.TextEntry`, :class:`gcloud.logging.entries.StructEntry`, :class:`gcloud.logging.entries.ProtobufEntry` :returns: the entry instance, constructed via the resource Z textPayloadZ jsonPayloadZ protoPayloadzCannot parse log entry resourceN)r from_api_reprr r ValueError)rresourceloggersrrr_entry_from_resourceszClient._entry_from_resourcec sJ|durjg}jj|||||d\}}ifdd|D}||fS)a3Return a page of log entries. See: https://cloud.google.com/logging/docs/api/ref_v2beta1/rest/v2beta1/entries/list :type projects: list of strings :param projects: project IDs to include. If not passed, defaults to the project bound to the client. :type filter_: str :param filter_: a filter expression. See: https://cloud.google.com/logging/docs/view/advanced_filters :type order_by: str :param order_by: One of :data:`gcloud.logging.ASCENDING` or :data:`gcloud.logging.DESCENDING`. :type page_size: int :param page_size: maximum number of entries to return, If not passed, defaults to a value set by the API. :type page_token: str :param page_token: opaque marker for the next "page" of entries. If not passed, the API will return the first page of entries. :rtype: tuple, (list, str) :returns: list of :class:`gcloud.logging.entry.TextEntry`, plus a "next page token" string: if not None, indicates that more entries can be retrieved with another call (pass that value as ``page_token``). N)projectsfilter_order_by page_size page_tokencsg|]}|qSr)r2.0r0r1rrr sz'Client.list_entries..)projectr list_entries) rr3r4r5r6r7 resourcestokenentriesrr:rr=s"  zClient.list_entriescCst||||dS)aICreates a sink bound to the current client. :type name: str :param name: the name of the sink to be constructed. :type filter_: str :param filter_: (optional) the advanced logs filter expression defining the entries exported by the sink. If not passed, the instance should already exist, to be refreshed via :meth:`Sink.reload`. :type destination: str :param destination: destination URI for the entries exported by the sink. If not passed, the instance should already exist, to be refreshed via :meth:`Sink.reload`. :rtype: :class:`gcloud.logging.sink.Sink` :returns: Sink created with the current client. r*r)rr,r4 destinationrrrsinksz Client.sinkcs0jj||\}}fdd|D}||fS)aUList sinks for the project associated with this client. See: https://cloud.google.com/logging/docs/api/ref_v2beta1/rest/v2beta1/projects.sinks/list :type page_size: int :param page_size: maximum number of sinks to return, If not passed, defaults to a value set by the API. :type page_token: str :param page_token: opaque marker for the next "page" of sinks. If not passed, the API will return the first page of sinks. :rtype: tuple, (list, str) :returns: list of :class:`gcloud.logging.sink.Sink`, plus a "next page token" string: if not None, indicates that more sinks can be retrieved with another call (pass that value as ``page_token``). csg|]}t|qSr)rr.r8rrrr;sz%Client.list_sinks..)r$ list_sinksr<)rr6r7r>r?ZsinksrrCrrDs zClient.list_sinkscCst||||dS)a+Creates a metric bound to the current client. :type name: str :param name: the name of the metric to be constructed. :type filter_: str :param filter_: the advanced logs filter expression defining the entries tracked by the metric. If not passed, the instance should already exist, to be refreshed via :meth:`Metric.reload`. :type description: str :param description: the description of the metric to be constructed. If not passed, the instance should already exist, to be refreshed via :meth:`Metric.reload`. :rtype: :class:`gcloud.logging.metric.Metric` :returns: Metric created with the current client. )r+ descriptionr)rr,r4rFrrrmetricsz Client.metriccs0jj||\}}fdd|D}||fS)aeList metrics for the project associated with this client. See: https://cloud.google.com/logging/docs/api/ref_v2beta1/rest/v2beta1/projects.metrics/list :type page_size: int :param page_size: maximum number of metrics to return, If not passed, defaults to a value set by the API. :type page_token: str :param page_token: opaque marker for the next "page" of metrics. If not passed, the API will return the first page of metrics. :rtype: tuple, (list, str) :returns: list of :class:`gcloud.logging.metric.Metric`, plus a "next page token" string: if not None, indicates that more metrics can be retrieved with another call (pass that value as ``page_token``). csg|]}t|qSr)rr.r8rCrrr;*sz'Client.list_metrics..)r) list_metricsr<)rr6r7r>r?ZmetricsrrCrrHs zClient.list_metrics)NNNNN)NN)NN)NrE)NN)__name__ __module__ __qualname____doc__r Z_connection_classrr r%propertyrr$r)r-r2r=rBrDrGrHrrrrr5s$      -   r))rLosZ-google.cloud.logging.v2.config_service_v2_apirr!Z.google.cloud.logging.v2.logging_service_v2_apirrZ.google.cloud.logging.v2.metrics_service_v2_apirr&Zgcloud.logging._gaxrrrr'rr" ImportErrorZ _HAVE_GAXZ gcloud.clientrZgcloud.logging.connectionr rr(r#Zgcloud.logging.entriesr r r Zgcloud.logging.loggerrZgcloud.logging.metricrZgcloud.logging.sinkrenvirongetrrrrrrs6