Regenerate client from commit e03163b of spec repo

Author: ci.datadog-api-spec

.generator/schemas/v2/openapi.yaml

@@ -29261,6 +29261,7 @@ components:
       - $ref: '#/components/schemas/ObservabilityPipelineSocketDestination'
       - $ref: '#/components/schemas/ObservabilityPipelineAmazonSecurityLakeDestination'
       - $ref: '#/components/schemas/ObservabilityPipelineCrowdStrikeNextGenSiemDestination'
+      - $ref: '#/components/schemas/ObservabilityPipelineGooglePubSubDestination'
     ObservabilityPipelineConfigProcessorItem:
       description: A processor for the pipeline.
       oneOf:
@@ -29300,6 +29301,7 @@ components:
       - $ref: '#/components/schemas/ObservabilityPipelineGooglePubSubSource'
       - $ref: '#/components/schemas/ObservabilityPipelineHttpClientSource'
       - $ref: '#/components/schemas/ObservabilityPipelineLogstashSource'
+      - $ref: '#/components/schemas/ObservabilityPipelineOpentelemetrySource'
       - $ref: '#/components/schemas/ObservabilityPipelineSocketSource'
     ObservabilityPipelineCrowdStrikeNextGenSiemDestination:
       description: The `crowdstrike_next_gen_siem` destination forwards logs to CrowdStrike
@@ -30322,6 +30324,65 @@ components:
       type: string
       x-enum-varnames:
       - GOOGLE_CLOUD_STORAGE
+    ObservabilityPipelineGooglePubSubDestination:
+      description: The `google_pubsub` destination publishes logs to a Google Cloud
+        Pub/Sub topic.
+      properties:
+        auth:
+          $ref: '#/components/schemas/ObservabilityPipelineGcpAuth'
+        encoding:
+          $ref: '#/components/schemas/ObservabilityPipelineGooglePubSubDestinationEncoding'
+        id:
+          description: The unique identifier for this component.
+          example: google-pubsub-destination
+          type: string
+        inputs:
+          description: A list of component IDs whose output is used as the `input`
+            for this component.
+          example:
+          - filter-processor
+          items:
+            type: string
+          type: array
+        project:
+          description: The GCP project ID that owns the Pub/Sub topic.
+          example: my-gcp-project
+          type: string
+        tls:
+          $ref: '#/components/schemas/ObservabilityPipelineTls'
+        topic:
+          description: The Pub/Sub topic name to publish logs to.
+          example: logs-subscription
+          type: string
+        type:
+          $ref: '#/components/schemas/ObservabilityPipelineGooglePubSubDestinationType'
+      required:
+      - id
+      - type
+      - inputs
+      - encoding
+      - project
+      - topic
+      type: object
+    ObservabilityPipelineGooglePubSubDestinationEncoding:
+      description: Encoding format for log events.
+      enum:
+      - json
+      - raw_message
+      example: json
+      type: string
+      x-enum-varnames:
+      - JSON
+      - RAW_MESSAGE
+    ObservabilityPipelineGooglePubSubDestinationType:
+      default: google_pubsub
+      description: The destination type. The value should always be `google_pubsub`.
+      enum:
+      - google_pubsub
+      example: google_pubsub
+      type: string
+      x-enum-varnames:
+      - GOOGLE_PUBSUB
     ObservabilityPipelineGooglePubSubSource:
       description: The `google_pubsub` source ingests logs from a Google Cloud Pub/Sub
         subscription.
@@ -30749,6 +30810,33 @@ components:
       type: string
       x-enum-varnames:
       - OPENSEARCH
+    ObservabilityPipelineOpentelemetrySource:
+      description: The `opentelemetry` source receives OpenTelemetry data through
+        gRPC or HTTP.
+      properties:
+        id:
+          description: The unique identifier for this component. Used to reference
+            this component in other parts of the pipeline (e.g., as input to downstream
+            components).
+          example: opentelemetry-source
+          type: string
+        tls:
+          $ref: '#/components/schemas/ObservabilityPipelineTls'
+        type:
+          $ref: '#/components/schemas/ObservabilityPipelineOpentelemetrySourceType'
+      required:
+      - id
+      - type
+      type: object
+    ObservabilityPipelineOpentelemetrySourceType:
+      default: opentelemetry
+      description: The source type. The value should always be `opentelemetry`.
+      enum:
+      - opentelemetry
+      example: opentelemetry
+      type: string
+      x-enum-varnames:
+      - OPENTELEMETRY
     ObservabilityPipelineParseGrokProcessor:
       description: The `parse_grok` processor extracts structured fields from unstructured
         log messages using Grok patterns.

api/datadogV2/model_observability_pipeline_config_destination_item.go

@@ -28,6 +28,7 @@ type ObservabilityPipelineConfigDestinationItem struct {
 	ObservabilityPipelineSocketDestination                 *ObservabilityPipelineSocketDestination
 	ObservabilityPipelineAmazonSecurityLakeDestination     *ObservabilityPipelineAmazonSecurityLakeDestination
 	ObservabilityPipelineCrowdStrikeNextGenSiemDestination *ObservabilityPipelineCrowdStrikeNextGenSiemDestination
+	ObservabilityPipelineGooglePubSubDestination           *ObservabilityPipelineGooglePubSubDestination
 
 	// UnparsedObject contains the raw value of the object if there was an error when deserializing into the struct
 	UnparsedObject interface{}
@@ -123,6 +124,11 @@ func ObservabilityPipelineCrowdStrikeNextGenSiemDestinationAsObservabilityPipeli
 	return ObservabilityPipelineConfigDestinationItem{ObservabilityPipelineCrowdStrikeNextGenSiemDestination: v}
 }
 
+// ObservabilityPipelineGooglePubSubDestinationAsObservabilityPipelineConfigDestinationItem is a convenience function that returns ObservabilityPipelineGooglePubSubDestination wrapped in ObservabilityPipelineConfigDestinationItem.
+func ObservabilityPipelineGooglePubSubDestinationAsObservabilityPipelineConfigDestinationItem(v *ObservabilityPipelineGooglePubSubDestination) ObservabilityPipelineConfigDestinationItem {
+	return ObservabilityPipelineConfigDestinationItem{ObservabilityPipelineGooglePubSubDestination: v}
+}
+
 // UnmarshalJSON turns data into one of the pointers in the struct.
 func (obj *ObservabilityPipelineConfigDestinationItem) UnmarshalJSON(data []byte) error {
 	var err error
@@ -433,6 +439,23 @@ func (obj *ObservabilityPipelineConfigDestinationItem) UnmarshalJSON(data []byte
 		obj.ObservabilityPipelineCrowdStrikeNextGenSiemDestination = nil
 	}
 
+	// try to unmarshal data into ObservabilityPipelineGooglePubSubDestination
+	err = datadog.Unmarshal(data, &obj.ObservabilityPipelineGooglePubSubDestination)
+	if err == nil {
+		if obj.ObservabilityPipelineGooglePubSubDestination != nil && obj.ObservabilityPipelineGooglePubSubDestination.UnparsedObject == nil {
+			jsonObservabilityPipelineGooglePubSubDestination, _ := datadog.Marshal(obj.ObservabilityPipelineGooglePubSubDestination)
+			if string(jsonObservabilityPipelineGooglePubSubDestination) == "{}" { // empty struct
+				obj.ObservabilityPipelineGooglePubSubDestination = nil
+			} else {
+				match++
+			}
+		} else {
+			obj.ObservabilityPipelineGooglePubSubDestination = nil
+		}
+	} else {
+		obj.ObservabilityPipelineGooglePubSubDestination = nil
+	}
+
 	if match != 1 { // more than 1 match
 		// reset to nil
 		obj.ObservabilityPipelineDatadogLogsDestination = nil
@@ -453,6 +476,7 @@ func (obj *ObservabilityPipelineConfigDestinationItem) UnmarshalJSON(data []byte
 		obj.ObservabilityPipelineSocketDestination = nil
 		obj.ObservabilityPipelineAmazonSecurityLakeDestination = nil
 		obj.ObservabilityPipelineCrowdStrikeNextGenSiemDestination = nil
+		obj.ObservabilityPipelineGooglePubSubDestination = nil
 		return datadog.Unmarshal(data, &obj.UnparsedObject)
 	}
 	return nil // exactly one match
@@ -532,6 +556,10 @@ func (obj ObservabilityPipelineConfigDestinationItem) MarshalJSON() ([]byte, err
 		return datadog.Marshal(&obj.ObservabilityPipelineCrowdStrikeNextGenSiemDestination)
 	}
 
+	if obj.ObservabilityPipelineGooglePubSubDestination != nil {
+		return datadog.Marshal(&obj.ObservabilityPipelineGooglePubSubDestination)
+	}
+
 	if obj.UnparsedObject != nil {
 		return datadog.Marshal(obj.UnparsedObject)
 	}
@@ -612,6 +640,10 @@ func (obj *ObservabilityPipelineConfigDestinationItem) GetActualInstance() inter
 		return obj.ObservabilityPipelineCrowdStrikeNextGenSiemDestination
 	}
 
+	if obj.ObservabilityPipelineGooglePubSubDestination != nil {
+		return obj.ObservabilityPipelineGooglePubSubDestination
+	}
+
 	// all schemas are nil
 	return nil
 }

api/datadogV2/model_observability_pipeline_config_source_item.go

@@ -25,6 +25,7 @@ type ObservabilityPipelineConfigSourceItem struct {
 	ObservabilityPipelineGooglePubSubSource       *ObservabilityPipelineGooglePubSubSource
 	ObservabilityPipelineHttpClientSource         *ObservabilityPipelineHttpClientSource
 	ObservabilityPipelineLogstashSource           *ObservabilityPipelineLogstashSource
+	ObservabilityPipelineOpentelemetrySource      *ObservabilityPipelineOpentelemetrySource
 	ObservabilityPipelineSocketSource             *ObservabilityPipelineSocketSource
 
 	// UnparsedObject contains the raw value of the object if there was an error when deserializing into the struct
@@ -106,6 +107,11 @@ func ObservabilityPipelineLogstashSourceAsObservabilityPipelineConfigSourceItem(
 	return ObservabilityPipelineConfigSourceItem{ObservabilityPipelineLogstashSource: v}
 }
 
+// ObservabilityPipelineOpentelemetrySourceAsObservabilityPipelineConfigSourceItem is a convenience function that returns ObservabilityPipelineOpentelemetrySource wrapped in ObservabilityPipelineConfigSourceItem.
+func ObservabilityPipelineOpentelemetrySourceAsObservabilityPipelineConfigSourceItem(v *ObservabilityPipelineOpentelemetrySource) ObservabilityPipelineConfigSourceItem {
+	return ObservabilityPipelineConfigSourceItem{ObservabilityPipelineOpentelemetrySource: v}
+}
+
 // ObservabilityPipelineSocketSourceAsObservabilityPipelineConfigSourceItem is a convenience function that returns ObservabilityPipelineSocketSource wrapped in ObservabilityPipelineConfigSourceItem.
 func ObservabilityPipelineSocketSourceAsObservabilityPipelineConfigSourceItem(v *ObservabilityPipelineSocketSource) ObservabilityPipelineConfigSourceItem {
 	return ObservabilityPipelineConfigSourceItem{ObservabilityPipelineSocketSource: v}
@@ -370,6 +376,23 @@ func (obj *ObservabilityPipelineConfigSourceItem) UnmarshalJSON(data []byte) err
 		obj.ObservabilityPipelineLogstashSource = nil
 	}
 
+	// try to unmarshal data into ObservabilityPipelineOpentelemetrySource
+	err = datadog.Unmarshal(data, &obj.ObservabilityPipelineOpentelemetrySource)
+	if err == nil {
+		if obj.ObservabilityPipelineOpentelemetrySource != nil && obj.ObservabilityPipelineOpentelemetrySource.UnparsedObject == nil {
+			jsonObservabilityPipelineOpentelemetrySource, _ := datadog.Marshal(obj.ObservabilityPipelineOpentelemetrySource)
+			if string(jsonObservabilityPipelineOpentelemetrySource) == "{}" { // empty struct
+				obj.ObservabilityPipelineOpentelemetrySource = nil
+			} else {
+				match++
+			}
+		} else {
+			obj.ObservabilityPipelineOpentelemetrySource = nil
+		}
+	} else {
+		obj.ObservabilityPipelineOpentelemetrySource = nil
+	}
+
 	// try to unmarshal data into ObservabilityPipelineSocketSource
 	err = datadog.Unmarshal(data, &obj.ObservabilityPipelineSocketSource)
 	if err == nil {
@@ -404,6 +427,7 @@ func (obj *ObservabilityPipelineConfigSourceItem) UnmarshalJSON(data []byte) err
 		obj.ObservabilityPipelineGooglePubSubSource = nil
 		obj.ObservabilityPipelineHttpClientSource = nil
 		obj.ObservabilityPipelineLogstashSource = nil
+		obj.ObservabilityPipelineOpentelemetrySource = nil
 		obj.ObservabilityPipelineSocketSource = nil
 		return datadog.Unmarshal(data, &obj.UnparsedObject)
 	}
@@ -472,6 +496,10 @@ func (obj ObservabilityPipelineConfigSourceItem) MarshalJSON() ([]byte, error) {
 		return datadog.Marshal(&obj.ObservabilityPipelineLogstashSource)
 	}
 
+	if obj.ObservabilityPipelineOpentelemetrySource != nil {
+		return datadog.Marshal(&obj.ObservabilityPipelineOpentelemetrySource)
+	}
+
 	if obj.ObservabilityPipelineSocketSource != nil {
 		return datadog.Marshal(&obj.ObservabilityPipelineSocketSource)
 	}
@@ -544,6 +572,10 @@ func (obj *ObservabilityPipelineConfigSourceItem) GetActualInstance() interface{
 		return obj.ObservabilityPipelineLogstashSource
 	}
 
+	if obj.ObservabilityPipelineOpentelemetrySource != nil {
+		return obj.ObservabilityPipelineOpentelemetrySource
+	}
+
 	if obj.ObservabilityPipelineSocketSource != nil {
 		return obj.ObservabilityPipelineSocketSource
 	}