Make google auth optional for Observability Pipelines (#3476)

Co-authored-by: ci.datadog-api-spec <[email protected]>

Author: api-clients-generation-pipeline[bot]

.generator/schemas/v2/openapi.yaml

@@ -34514,7 +34514,6 @@ components:
       - id
       - type
       - inputs
-      - auth
       - customer_id
       type: object
     ObservabilityPipelineGoogleChronicleDestinationEncoding:
@@ -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.
@@ -34713,7 +34710,6 @@ components:
       required:
       - id
       - type
-      - auth
       - decoding
       - project
       - subscription

api/datadogV2/model_observability_pipeline_google_chronicle_destination.go

@@ -13,7 +13,7 @@ import (
 // ObservabilityPipelineGoogleChronicleDestination The `google_chronicle` destination sends logs to Google Chronicle.
 type ObservabilityPipelineGoogleChronicleDestination struct {
 	// GCP credentials used to authenticate with Google Cloud Storage.
-	Auth ObservabilityPipelineGcpAuth `json:"auth"`
+	Auth *ObservabilityPipelineGcpAuth `json:"auth,omitempty"`
 	// The Google Chronicle customer ID.
 	CustomerId string `json:"customer_id"`
 	// The encoding format for the logs sent to Chronicle.
@@ -35,9 +35,8 @@ type ObservabilityPipelineGoogleChronicleDestination struct {
 // This constructor will assign default values to properties that have it defined,
 // and makes sure properties required by API are set, but the set of arguments
 // will change when the set of required properties is changed.
-func NewObservabilityPipelineGoogleChronicleDestination(auth ObservabilityPipelineGcpAuth, customerId string, id string, inputs []string, typeVar ObservabilityPipelineGoogleChronicleDestinationType) *ObservabilityPipelineGoogleChronicleDestination {
+func NewObservabilityPipelineGoogleChronicleDestination(customerId string, id string, inputs []string, typeVar ObservabilityPipelineGoogleChronicleDestinationType) *ObservabilityPipelineGoogleChronicleDestination {
 	this := ObservabilityPipelineGoogleChronicleDestination{}
-	this.Auth = auth
 	this.CustomerId = customerId
 	this.Id = id
 	this.Inputs = inputs
@@ -55,27 +54,32 @@ func NewObservabilityPipelineGoogleChronicleDestinationWithDefaults() *Observabi
 	return &this
 }
 
-// GetAuth returns the Auth field value.
+// GetAuth returns the Auth field value if set, zero value otherwise.
 func (o *ObservabilityPipelineGoogleChronicleDestination) GetAuth() ObservabilityPipelineGcpAuth {
-	if o == nil {
+	if o == nil || o.Auth == nil {
 		var ret ObservabilityPipelineGcpAuth
 		return ret
 	}
-	return o.Auth
+	return *o.Auth
 }
 
-// GetAuthOk returns a tuple with the Auth field value
+// GetAuthOk returns a tuple with the Auth field value if set, nil otherwise
 // and a boolean to check if the value has been set.
 func (o *ObservabilityPipelineGoogleChronicleDestination) GetAuthOk() (*ObservabilityPipelineGcpAuth, bool) {
-	if o == nil {
+	if o == nil || o.Auth == nil {
 		return nil, false
 	}
-	return &o.Auth, true
+	return o.Auth, true
+}
+
+// HasAuth returns a boolean if a field has been set.
+func (o *ObservabilityPipelineGoogleChronicleDestination) HasAuth() bool {
+	return o != nil && o.Auth != nil
 }
 
-// SetAuth sets field value.
+// SetAuth gets a reference to the given ObservabilityPipelineGcpAuth and assigns it to the Auth field.
 func (o *ObservabilityPipelineGoogleChronicleDestination) SetAuth(v ObservabilityPipelineGcpAuth) {
-	o.Auth = v
+	o.Auth = &v
 }
 
 // GetCustomerId returns the CustomerId field value.
@@ -232,7 +236,9 @@ func (o ObservabilityPipelineGoogleChronicleDestination) MarshalJSON() ([]byte,
 	if o.UnparsedObject != nil {
 		return datadog.Marshal(o.UnparsedObject)
 	}
-	toSerialize["auth"] = o.Auth
+	if o.Auth != nil {
+		toSerialize["auth"] = o.Auth
+	}
 	toSerialize["customer_id"] = o.CustomerId
 	if o.Encoding != nil {
 		toSerialize["encoding"] = o.Encoding
@@ -253,7 +259,7 @@ func (o ObservabilityPipelineGoogleChronicleDestination) MarshalJSON() ([]byte,
 // UnmarshalJSON deserializes the given payload.
 func (o *ObservabilityPipelineGoogleChronicleDestination) UnmarshalJSON(bytes []byte) (err error) {
 	all := struct {
-		Auth       *ObservabilityPipelineGcpAuth                            `json:"auth"`
+		Auth       *ObservabilityPipelineGcpAuth                            `json:"auth,omitempty"`
 		CustomerId *string                                                  `json:"customer_id"`
 		Encoding   *ObservabilityPipelineGoogleChronicleDestinationEncoding `json:"encoding,omitempty"`
 		Id         *string                                                  `json:"id"`
@@ -264,9 +270,6 @@ func (o *ObservabilityPipelineGoogleChronicleDestination) UnmarshalJSON(bytes []
 	if err = datadog.Unmarshal(bytes, &all); err != nil {
 		return datadog.Unmarshal(bytes, &o.UnparsedObject)
 	}
-	if all.Auth == nil {
-		return fmt.Errorf("required field auth missing")
-	}
 	if all.CustomerId == nil {
 		return fmt.Errorf("required field customer_id missing")
 	}
@@ -287,10 +290,10 @@ func (o *ObservabilityPipelineGoogleChronicleDestination) UnmarshalJSON(bytes []
 	}
 
 	hasInvalidField := false
-	if all.Auth.UnparsedObject != nil && o.UnparsedObject == nil {
+	if all.Auth != nil && all.Auth.UnparsedObject != nil && o.UnparsedObject == nil {
 		hasInvalidField = true
 	}
-	o.Auth = *all.Auth
+	o.Auth = all.Auth
 	o.CustomerId = *all.CustomerId
 	if all.Encoding != nil && !all.Encoding.IsValid() {
 		hasInvalidField = true

api/datadogV2/model_observability_pipeline_google_cloud_storage_destination.go

@@ -14,9 +14,9 @@ import (
 // It requires a bucket name, GCP authentication, and metadata fields.
 type ObservabilityPipelineGoogleCloudStorageDestination struct {
 	// Access control list setting for objects written to the bucket.
-	Acl ObservabilityPipelineGoogleCloudStorageDestinationAcl `json:"acl"`
+	Acl *ObservabilityPipelineGoogleCloudStorageDestinationAcl `json:"acl,omitempty"`
 	// GCP credentials used to authenticate with Google Cloud Storage.
-	Auth ObservabilityPipelineGcpAuth `json:"auth"`
+	Auth *ObservabilityPipelineGcpAuth `json:"auth,omitempty"`
 	// Name of the GCS bucket.
 	Bucket string `json:"bucket"`
 	// Unique identifier for the destination component.
@@ -40,10 +40,8 @@ type ObservabilityPipelineGoogleCloudStorageDestination struct {
 // This constructor will assign default values to properties that have it defined,
 // and makes sure properties required by API are set, but the set of arguments
 // will change when the set of required properties is changed.
-func NewObservabilityPipelineGoogleCloudStorageDestination(acl ObservabilityPipelineGoogleCloudStorageDestinationAcl, auth ObservabilityPipelineGcpAuth, bucket string, id string, inputs []string, storageClass ObservabilityPipelineGoogleCloudStorageDestinationStorageClass, typeVar ObservabilityPipelineGoogleCloudStorageDestinationType) *ObservabilityPipelineGoogleCloudStorageDestination {
+func NewObservabilityPipelineGoogleCloudStorageDestination(bucket string, id string, inputs []string, storageClass ObservabilityPipelineGoogleCloudStorageDestinationStorageClass, typeVar ObservabilityPipelineGoogleCloudStorageDestinationType) *ObservabilityPipelineGoogleCloudStorageDestination {
 	this := ObservabilityPipelineGoogleCloudStorageDestination{}
-	this.Acl = acl
-	this.Auth = auth
 	this.Bucket = bucket
 	this.Id = id
 	this.Inputs = inputs
@@ -62,50 +60,60 @@ func NewObservabilityPipelineGoogleCloudStorageDestinationWithDefaults() *Observ
 	return &this
 }
 
-// GetAcl returns the Acl field value.
+// GetAcl returns the Acl field value if set, zero value otherwise.
 func (o *ObservabilityPipelineGoogleCloudStorageDestination) GetAcl() ObservabilityPipelineGoogleCloudStorageDestinationAcl {
-	if o == nil {
+	if o == nil || o.Acl == nil {
 		var ret ObservabilityPipelineGoogleCloudStorageDestinationAcl
 		return ret
 	}
-	return o.Acl
+	return *o.Acl
 }
 
-// GetAclOk returns a tuple with the Acl field value
+// GetAclOk returns a tuple with the Acl field value if set, nil otherwise
 // and a boolean to check if the value has been set.
 func (o *ObservabilityPipelineGoogleCloudStorageDestination) GetAclOk() (*ObservabilityPipelineGoogleCloudStorageDestinationAcl, bool) {
-	if o == nil {
+	if o == nil || o.Acl == nil {
 		return nil, false
 	}
-	return &o.Acl, true
+	return o.Acl, true
+}
+
+// HasAcl returns a boolean if a field has been set.
+func (o *ObservabilityPipelineGoogleCloudStorageDestination) HasAcl() bool {
+	return o != nil && o.Acl != nil
 }
 
-// SetAcl sets field value.
+// SetAcl gets a reference to the given ObservabilityPipelineGoogleCloudStorageDestinationAcl and assigns it to the Acl field.
 func (o *ObservabilityPipelineGoogleCloudStorageDestination) SetAcl(v ObservabilityPipelineGoogleCloudStorageDestinationAcl) {
-	o.Acl = v
+	o.Acl = &v
 }
 
-// GetAuth returns the Auth field value.
+// GetAuth returns the Auth field value if set, zero value otherwise.
 func (o *ObservabilityPipelineGoogleCloudStorageDestination) GetAuth() ObservabilityPipelineGcpAuth {
-	if o == nil {
+	if o == nil || o.Auth == nil {
 		var ret ObservabilityPipelineGcpAuth
 		return ret
 	}
-	return o.Auth
+	return *o.Auth
 }
 
-// GetAuthOk returns a tuple with the Auth field value
+// GetAuthOk returns a tuple with the Auth field value if set, nil otherwise
 // and a boolean to check if the value has been set.
 func (o *ObservabilityPipelineGoogleCloudStorageDestination) GetAuthOk() (*ObservabilityPipelineGcpAuth, bool) {
-	if o == nil {
+	if o == nil || o.Auth == nil {
 		return nil, false
 	}
-	return &o.Auth, true
+	return o.Auth, true
 }
 
-// SetAuth sets field value.
+// HasAuth returns a boolean if a field has been set.
+func (o *ObservabilityPipelineGoogleCloudStorageDestination) HasAuth() bool {
+	return o != nil && o.Auth != nil
+}
+
+// SetAuth gets a reference to the given ObservabilityPipelineGcpAuth and assigns it to the Auth field.
 func (o *ObservabilityPipelineGoogleCloudStorageDestination) SetAuth(v ObservabilityPipelineGcpAuth) {
-	o.Auth = v
+	o.Auth = &v
 }
 
 // GetBucket returns the Bucket field value.
@@ -285,8 +293,12 @@ func (o ObservabilityPipelineGoogleCloudStorageDestination) MarshalJSON() ([]byt
 	if o.UnparsedObject != nil {
 		return datadog.Marshal(o.UnparsedObject)
 	}
-	toSerialize["acl"] = o.Acl
-	toSerialize["auth"] = o.Auth
+	if o.Acl != nil {
+		toSerialize["acl"] = o.Acl
+	}
+	if o.Auth != nil {
+		toSerialize["auth"] = o.Auth
+	}
 	toSerialize["bucket"] = o.Bucket
 	toSerialize["id"] = o.Id
 	toSerialize["inputs"] = o.Inputs
@@ -308,8 +320,8 @@ func (o ObservabilityPipelineGoogleCloudStorageDestination) MarshalJSON() ([]byt
 // UnmarshalJSON deserializes the given payload.
 func (o *ObservabilityPipelineGoogleCloudStorageDestination) UnmarshalJSON(bytes []byte) (err error) {
 	all := struct {
-		Acl          *ObservabilityPipelineGoogleCloudStorageDestinationAcl          `json:"acl"`
-		Auth         *ObservabilityPipelineGcpAuth                                   `json:"auth"`
+		Acl          *ObservabilityPipelineGoogleCloudStorageDestinationAcl          `json:"acl,omitempty"`
+		Auth         *ObservabilityPipelineGcpAuth                                   `json:"auth,omitempty"`
 		Bucket       *string                                                         `json:"bucket"`
 		Id           *string                                                         `json:"id"`
 		Inputs       *[]string                                                       `json:"inputs"`
@@ -321,12 +333,6 @@ func (o *ObservabilityPipelineGoogleCloudStorageDestination) UnmarshalJSON(bytes
 	if err = datadog.Unmarshal(bytes, &all); err != nil {
 		return datadog.Unmarshal(bytes, &o.UnparsedObject)
 	}
-	if all.Acl == nil {
-		return fmt.Errorf("required field acl missing")
-	}
-	if all.Auth == nil {
-		return fmt.Errorf("required field auth missing")
-	}
 	if all.Bucket == nil {
 		return fmt.Errorf("required field bucket missing")
 	}
@@ -350,15 +356,15 @@ func (o *ObservabilityPipelineGoogleCloudStorageDestination) UnmarshalJSON(bytes
 	}
 
 	hasInvalidField := false
-	if !all.Acl.IsValid() {
+	if all.Acl != nil && !all.Acl.IsValid() {
 		hasInvalidField = true
 	} else {
-		o.Acl = *all.Acl
+		o.Acl = all.Acl
 	}
-	if all.Auth.UnparsedObject != nil && o.UnparsedObject == nil {
+	if all.Auth != nil && all.Auth.UnparsedObject != nil && o.UnparsedObject == nil {
 		hasInvalidField = true
 	}
-	o.Auth = *all.Auth
+	o.Auth = all.Auth
 	o.Bucket = *all.Bucket
 	o.Id = *all.Id
 	o.Inputs = *all.Inputs

api/datadogV2/model_observability_pipeline_google_pub_sub_source.go

@@ -13,7 +13,7 @@ import (
 // ObservabilityPipelineGooglePubSubSource The `google_pubsub` source ingests logs from a Google Cloud Pub/Sub subscription.
 type ObservabilityPipelineGooglePubSubSource struct {
 	// GCP credentials used to authenticate with Google Cloud Storage.
-	Auth ObservabilityPipelineGcpAuth `json:"auth"`
+	Auth *ObservabilityPipelineGcpAuth `json:"auth,omitempty"`
 	// The decoding format used to interpret incoming logs.
 	Decoding ObservabilityPipelineDecoding `json:"decoding"`
 	// The unique identifier for this component. Used to reference this component in other parts of the pipeline (e.g., as input to downstream components).
@@ -35,9 +35,8 @@ type ObservabilityPipelineGooglePubSubSource struct {
 // This constructor will assign default values to properties that have it defined,
 // and makes sure properties required by API are set, but the set of arguments
 // will change when the set of required properties is changed.
-func NewObservabilityPipelineGooglePubSubSource(auth ObservabilityPipelineGcpAuth, decoding ObservabilityPipelineDecoding, id string, project string, subscription string, typeVar ObservabilityPipelineGooglePubSubSourceType) *ObservabilityPipelineGooglePubSubSource {
+func NewObservabilityPipelineGooglePubSubSource(decoding ObservabilityPipelineDecoding, id string, project string, subscription string, typeVar ObservabilityPipelineGooglePubSubSourceType) *ObservabilityPipelineGooglePubSubSource {
 	this := ObservabilityPipelineGooglePubSubSource{}
-	this.Auth = auth
 	this.Decoding = decoding
 	this.Id = id
 	this.Project = project
@@ -56,27 +55,32 @@ func NewObservabilityPipelineGooglePubSubSourceWithDefaults() *ObservabilityPipe
 	return &this
 }
 
-// GetAuth returns the Auth field value.
+// GetAuth returns the Auth field value if set, zero value otherwise.
 func (o *ObservabilityPipelineGooglePubSubSource) GetAuth() ObservabilityPipelineGcpAuth {
-	if o == nil {
+	if o == nil || o.Auth == nil {
 		var ret ObservabilityPipelineGcpAuth
 		return ret
 	}
-	return o.Auth
+	return *o.Auth
 }
 
-// GetAuthOk returns a tuple with the Auth field value
+// GetAuthOk returns a tuple with the Auth field value if set, nil otherwise
 // and a boolean to check if the value has been set.
 func (o *ObservabilityPipelineGooglePubSubSource) GetAuthOk() (*ObservabilityPipelineGcpAuth, bool) {
-	if o == nil {
+	if o == nil || o.Auth == nil {
 		return nil, false
 	}
-	return &o.Auth, true
+	return o.Auth, true
+}
+
+// HasAuth returns a boolean if a field has been set.
+func (o *ObservabilityPipelineGooglePubSubSource) HasAuth() bool {
+	return o != nil && o.Auth != nil
 }
 
-// SetAuth sets field value.
+// SetAuth gets a reference to the given ObservabilityPipelineGcpAuth and assigns it to the Auth field.
 func (o *ObservabilityPipelineGooglePubSubSource) SetAuth(v ObservabilityPipelineGcpAuth) {
-	o.Auth = v
+	o.Auth = &v
 }
 
 // GetDecoding returns the Decoding field value.
@@ -228,7 +232,9 @@ func (o ObservabilityPipelineGooglePubSubSource) MarshalJSON() ([]byte, error) {
 	if o.UnparsedObject != nil {
 		return datadog.Marshal(o.UnparsedObject)
 	}
-	toSerialize["auth"] = o.Auth
+	if o.Auth != nil {
+		toSerialize["auth"] = o.Auth
+	}
 	toSerialize["decoding"] = o.Decoding
 	toSerialize["id"] = o.Id
 	toSerialize["project"] = o.Project
@@ -247,7 +253,7 @@ func (o ObservabilityPipelineGooglePubSubSource) MarshalJSON() ([]byte, error) {
 // UnmarshalJSON deserializes the given payload.
 func (o *ObservabilityPipelineGooglePubSubSource) UnmarshalJSON(bytes []byte) (err error) {
 	all := struct {
-		Auth         *ObservabilityPipelineGcpAuth                `json:"auth"`
+		Auth         *ObservabilityPipelineGcpAuth                `json:"auth,omitempty"`
 		Decoding     *ObservabilityPipelineDecoding               `json:"decoding"`
 		Id           *string                                      `json:"id"`
 		Project      *string                                      `json:"project"`
@@ -258,9 +264,6 @@ func (o *ObservabilityPipelineGooglePubSubSource) UnmarshalJSON(bytes []byte) (e
 	if err = datadog.Unmarshal(bytes, &all); err != nil {
 		return datadog.Unmarshal(bytes, &o.UnparsedObject)
 	}
-	if all.Auth == nil {
-		return fmt.Errorf("required field auth missing")
-	}
 	if all.Decoding == nil {
 		return fmt.Errorf("required field decoding missing")
 	}
@@ -284,10 +287,10 @@ func (o *ObservabilityPipelineGooglePubSubSource) UnmarshalJSON(bytes []byte) (e
 	}
 
 	hasInvalidField := false
-	if all.Auth.UnparsedObject != nil && o.UnparsedObject == nil {
+	if all.Auth != nil && all.Auth.UnparsedObject != nil && o.UnparsedObject == nil {
 		hasInvalidField = true
 	}
-	o.Auth = *all.Auth
+	o.Auth = all.Auth
 	if !all.Decoding.IsValid() {
 		hasInvalidField = true
 	} else {