Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 0 additions & 4 deletions .generator/schemas/v2/openapi.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -34514,7 +34514,6 @@ components:
- id
- type
- inputs
- auth
- customer_id
type: object
ObservabilityPipelineGoogleChronicleDestinationEncoding:
Expand Down Expand Up @@ -34580,9 +34579,7 @@ components:
- type
- inputs
- bucket
- auth
- storage_class
- acl
type: object
ObservabilityPipelineGoogleCloudStorageDestinationAcl:
description: Access control list setting for objects written to the bucket.
Expand Down Expand Up @@ -34713,7 +34710,6 @@ components:
required:
- id
- type
- auth
- decoding
- project
- subscription
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@ def __init__(self, **kwargs):
:type tls: ObservabilityPipelineTls, optional
:param acl: Access control list setting for objects written to the bucket.
:type acl: ObservabilityPipelineGoogleCloudStorageDestinationAcl
:type acl: ObservabilityPipelineGoogleCloudStorageDestinationAcl, optional
:param metadata: Custom metadata to attach to each object uploaded to the GCS bucket.
:type metadata: [ObservabilityPipelineMetadataEntry], optional
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -56,11 +56,11 @@ def openapi_types(_):

def __init__(
self_,
auth: ObservabilityPipelineGcpAuth,
customer_id: str,
id: str,
inputs: List[str],
type: ObservabilityPipelineGoogleChronicleDestinationType,
auth: Union[ObservabilityPipelineGcpAuth, UnsetType] = unset,
encoding: Union[ObservabilityPipelineGoogleChronicleDestinationEncoding, UnsetType] = unset,
log_type: Union[str, UnsetType] = unset,
**kwargs,
Expand All @@ -69,7 +69,7 @@ def __init__(
The ``google_chronicle`` destination sends logs to Google Chronicle.

:param auth: GCP credentials used to authenticate with Google Cloud Storage.
:type auth: ObservabilityPipelineGcpAuth
:type auth: ObservabilityPipelineGcpAuth, optional

:param customer_id: The Google Chronicle customer ID.
:type customer_id: str
Expand All @@ -89,13 +89,14 @@ def __init__(
:param type: The destination type. The value should always be ``google_chronicle``.
:type type: ObservabilityPipelineGoogleChronicleDestinationType
"""
if auth is not unset:
kwargs["auth"] = auth
if encoding is not unset:
kwargs["encoding"] = encoding
if log_type is not unset:
kwargs["log_type"] = log_type
super().__init__(kwargs)

self_.auth = auth
self_.customer_id = customer_id
self_.id = id
self_.inputs = inputs
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -68,13 +68,13 @@ def openapi_types(_):

def __init__(
self_,
acl: ObservabilityPipelineGoogleCloudStorageDestinationAcl,
auth: ObservabilityPipelineGcpAuth,
bucket: str,
id: str,
inputs: List[str],
storage_class: ObservabilityPipelineGoogleCloudStorageDestinationStorageClass,
type: ObservabilityPipelineGoogleCloudStorageDestinationType,
acl: Union[ObservabilityPipelineGoogleCloudStorageDestinationAcl, UnsetType] = unset,
auth: Union[ObservabilityPipelineGcpAuth, UnsetType] = unset,
key_prefix: Union[str, UnsetType] = unset,
metadata: Union[List[ObservabilityPipelineMetadataEntry], UnsetType] = unset,
**kwargs,
Expand All @@ -84,10 +84,10 @@ def __init__(
It requires a bucket name, GCP authentication, and metadata fields.

:param acl: Access control list setting for objects written to the bucket.
:type acl: ObservabilityPipelineGoogleCloudStorageDestinationAcl
:type acl: ObservabilityPipelineGoogleCloudStorageDestinationAcl, optional

:param auth: GCP credentials used to authenticate with Google Cloud Storage.
:type auth: ObservabilityPipelineGcpAuth
:type auth: ObservabilityPipelineGcpAuth, optional

:param bucket: Name of the GCS bucket.
:type bucket: str
Expand All @@ -110,14 +110,16 @@ def __init__(
:param type: The destination type. Always ``google_cloud_storage``.
:type type: ObservabilityPipelineGoogleCloudStorageDestinationType
"""
if acl is not unset:
kwargs["acl"] = acl
if auth is not unset:
kwargs["auth"] = auth
if key_prefix is not unset:
kwargs["key_prefix"] = key_prefix
if metadata is not unset:
kwargs["metadata"] = metadata
super().__init__(kwargs)

self_.acl = acl
self_.auth = auth
self_.bucket = bucket
self_.id = id
self_.inputs = inputs
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -54,20 +54,20 @@ def openapi_types(_):

def __init__(
self_,
auth: ObservabilityPipelineGcpAuth,
decoding: ObservabilityPipelineDecoding,
id: str,
project: str,
subscription: str,
type: ObservabilityPipelineGooglePubSubSourceType,
auth: Union[ObservabilityPipelineGcpAuth, UnsetType] = unset,
tls: Union[ObservabilityPipelineTls, UnsetType] = unset,
**kwargs,
):
"""
The ``google_pubsub`` source ingests logs from a Google Cloud Pub/Sub subscription.

:param auth: GCP credentials used to authenticate with Google Cloud Storage.
:type auth: ObservabilityPipelineGcpAuth
:type auth: ObservabilityPipelineGcpAuth, optional

:param decoding: The decoding format used to interpret incoming logs.
:type decoding: ObservabilityPipelineDecoding
Expand All @@ -87,11 +87,12 @@ def __init__(
:param type: The source type. The value should always be ``google_pubsub``.
:type type: ObservabilityPipelineGooglePubSubSourceType
"""
if auth is not unset:
kwargs["auth"] = auth
if tls is not unset:
kwargs["tls"] = tls
super().__init__(kwargs)

self_.auth = auth
self_.decoding = decoding
self_.id = id
self_.project = project
Expand Down