Skip to content

Commit c149816

Browse files
author
ci.datadog-api-spec
committed
Regenerate client from commit bd15e41 of spec repo
1 parent b6726fc commit c149816

File tree

4 files changed

+307
-0
lines changed

4 files changed

+307
-0
lines changed

‎.generator/schemas/v2/openapi.yaml‎

Lines changed: 28 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29300,6 +29300,7 @@ components:
2930029300
- $ref: '#/components/schemas/ObservabilityPipelineGooglePubSubSource'
2930129301
- $ref: '#/components/schemas/ObservabilityPipelineHttpClientSource'
2930229302
- $ref: '#/components/schemas/ObservabilityPipelineLogstashSource'
29303+
- $ref: '#/components/schemas/ObservabilityPipelineOpentelemetrySource'
2930329304
- $ref: '#/components/schemas/ObservabilityPipelineSocketSource'
2930429305
ObservabilityPipelineCrowdStrikeNextGenSiemDestination:
2930529306
description: The `crowdstrike_next_gen_siem` destination forwards logs to CrowdStrike
@@ -30749,6 +30750,33 @@ components:
3074930750
type: string
3075030751
x-enum-varnames:
3075130752
- OPENSEARCH
30753+
ObservabilityPipelineOpentelemetrySource:
30754+
description: The `opentelemetry` source receives OpenTelemetry data through
30755+
gRPC or HTTP.
30756+
properties:
30757+
id:
30758+
description: The unique identifier for this component. Used to reference
30759+
this component in other parts of the pipeline (e.g., as input to downstream
30760+
components).
30761+
example: opentelemetry-source
30762+
type: string
30763+
tls:
30764+
$ref: '#/components/schemas/ObservabilityPipelineTls'
30765+
type:
30766+
$ref: '#/components/schemas/ObservabilityPipelineOpentelemetrySourceType'
30767+
required:
30768+
- id
30769+
- type
30770+
type: object
30771+
ObservabilityPipelineOpentelemetrySourceType:
30772+
default: opentelemetry
30773+
description: The source type. The value should always be `opentelemetry`.
30774+
enum:
30775+
- opentelemetry
30776+
example: opentelemetry
30777+
type: string
30778+
x-enum-varnames:
30779+
- OPENTELEMETRY
3075230780
ObservabilityPipelineParseGrokProcessor:
3075330781
description: The `parse_grok` processor extracts structured fields from unstructured
3075430782
log messages using Grok patterns.

‎api/datadogV2/model_observability_pipeline_config_source_item.go‎

Lines changed: 32 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@ type ObservabilityPipelineConfigSourceItem struct {
2525
ObservabilityPipelineGooglePubSubSource *ObservabilityPipelineGooglePubSubSource
2626
ObservabilityPipelineHttpClientSource *ObservabilityPipelineHttpClientSource
2727
ObservabilityPipelineLogstashSource *ObservabilityPipelineLogstashSource
28+
ObservabilityPipelineOpentelemetrySource *ObservabilityPipelineOpentelemetrySource
2829
ObservabilityPipelineSocketSource *ObservabilityPipelineSocketSource
2930

3031
// UnparsedObject contains the raw value of the object if there was an error when deserializing into the struct
@@ -106,6 +107,11 @@ func ObservabilityPipelineLogstashSourceAsObservabilityPipelineConfigSourceItem(
106107
return ObservabilityPipelineConfigSourceItem{ObservabilityPipelineLogstashSource: v}
107108
}
108109

110+
// ObservabilityPipelineOpentelemetrySourceAsObservabilityPipelineConfigSourceItem is a convenience function that returns ObservabilityPipelineOpentelemetrySource wrapped in ObservabilityPipelineConfigSourceItem.
111+
func ObservabilityPipelineOpentelemetrySourceAsObservabilityPipelineConfigSourceItem(v *ObservabilityPipelineOpentelemetrySource) ObservabilityPipelineConfigSourceItem {
112+
return ObservabilityPipelineConfigSourceItem{ObservabilityPipelineOpentelemetrySource: v}
113+
}
114+
109115
// ObservabilityPipelineSocketSourceAsObservabilityPipelineConfigSourceItem is a convenience function that returns ObservabilityPipelineSocketSource wrapped in ObservabilityPipelineConfigSourceItem.
110116
func ObservabilityPipelineSocketSourceAsObservabilityPipelineConfigSourceItem(v *ObservabilityPipelineSocketSource) ObservabilityPipelineConfigSourceItem {
111117
return ObservabilityPipelineConfigSourceItem{ObservabilityPipelineSocketSource: v}
@@ -370,6 +376,23 @@ func (obj *ObservabilityPipelineConfigSourceItem) UnmarshalJSON(data []byte) err
370376
obj.ObservabilityPipelineLogstashSource = nil
371377
}
372378

379+
// try to unmarshal data into ObservabilityPipelineOpentelemetrySource
380+
err = datadog.Unmarshal(data, &obj.ObservabilityPipelineOpentelemetrySource)
381+
if err == nil {
382+
if obj.ObservabilityPipelineOpentelemetrySource != nil && obj.ObservabilityPipelineOpentelemetrySource.UnparsedObject == nil {
383+
jsonObservabilityPipelineOpentelemetrySource, _ := datadog.Marshal(obj.ObservabilityPipelineOpentelemetrySource)
384+
if string(jsonObservabilityPipelineOpentelemetrySource) == "{}" { // empty struct
385+
obj.ObservabilityPipelineOpentelemetrySource = nil
386+
} else {
387+
match++
388+
}
389+
} else {
390+
obj.ObservabilityPipelineOpentelemetrySource = nil
391+
}
392+
} else {
393+
obj.ObservabilityPipelineOpentelemetrySource = nil
394+
}
395+
373396
// try to unmarshal data into ObservabilityPipelineSocketSource
374397
err = datadog.Unmarshal(data, &obj.ObservabilityPipelineSocketSource)
375398
if err == nil {
@@ -404,6 +427,7 @@ func (obj *ObservabilityPipelineConfigSourceItem) UnmarshalJSON(data []byte) err
404427
obj.ObservabilityPipelineGooglePubSubSource = nil
405428
obj.ObservabilityPipelineHttpClientSource = nil
406429
obj.ObservabilityPipelineLogstashSource = nil
430+
obj.ObservabilityPipelineOpentelemetrySource = nil
407431
obj.ObservabilityPipelineSocketSource = nil
408432
return datadog.Unmarshal(data, &obj.UnparsedObject)
409433
}
@@ -472,6 +496,10 @@ func (obj ObservabilityPipelineConfigSourceItem) MarshalJSON() ([]byte, error) {
472496
return datadog.Marshal(&obj.ObservabilityPipelineLogstashSource)
473497
}
474498

499+
if obj.ObservabilityPipelineOpentelemetrySource != nil {
500+
return datadog.Marshal(&obj.ObservabilityPipelineOpentelemetrySource)
501+
}
502+
475503
if obj.ObservabilityPipelineSocketSource != nil {
476504
return datadog.Marshal(&obj.ObservabilityPipelineSocketSource)
477505
}
@@ -544,6 +572,10 @@ func (obj *ObservabilityPipelineConfigSourceItem) GetActualInstance() interface{
544572
return obj.ObservabilityPipelineLogstashSource
545573
}
546574

575+
if obj.ObservabilityPipelineOpentelemetrySource != nil {
576+
return obj.ObservabilityPipelineOpentelemetrySource
577+
}
578+
547579
if obj.ObservabilityPipelineSocketSource != nil {
548580
return obj.ObservabilityPipelineSocketSource
549581
}

‎api/datadogV2/model_observability_pipeline_opentelemetry_source.go‎

Lines changed: 183 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,183 @@
1+
// Unless explicitly stated otherwise all files in this repository are licensed under the Apache-2.0 License.
2+
// This product includes software developed at Datadog (https://www.datadoghq.com/).
3+
// Copyright 2019-Present Datadog, Inc.
4+
5+
package datadogV2
6+
7+
import (
8+
"fmt"
9+
10+
"github.com/DataDog/datadog-api-client-go/v2/api/datadog"
11+
)
12+
13+
// ObservabilityPipelineOpentelemetrySource The `opentelemetry` source receives OpenTelemetry data through gRPC or HTTP.
14+
type ObservabilityPipelineOpentelemetrySource struct {
15+
// The unique identifier for this component. Used to reference this component in other parts of the pipeline (e.g., as input to downstream components).
16+
Id string `json:"id"`
17+
// Configuration for enabling TLS encryption between the pipeline component and external services.
18+
Tls *ObservabilityPipelineTls `json:"tls,omitempty"`
19+
// The source type. The value should always be `opentelemetry`.
20+
Type ObservabilityPipelineOpentelemetrySourceType `json:"type"`
21+
// UnparsedObject contains the raw value of the object if there was an error when deserializing into the struct
22+
UnparsedObject map[string]interface{} `json:"-"`
23+
AdditionalProperties map[string]interface{} `json:"-"`
24+
}
25+
26+
// NewObservabilityPipelineOpentelemetrySource instantiates a new ObservabilityPipelineOpentelemetrySource object.
27+
// This constructor will assign default values to properties that have it defined,
28+
// and makes sure properties required by API are set, but the set of arguments
29+
// will change when the set of required properties is changed.
30+
func NewObservabilityPipelineOpentelemetrySource(id string, typeVar ObservabilityPipelineOpentelemetrySourceType) *ObservabilityPipelineOpentelemetrySource {
31+
this := ObservabilityPipelineOpentelemetrySource{}
32+
this.Id = id
33+
this.Type = typeVar
34+
return &this
35+
}
36+
37+
// NewObservabilityPipelineOpentelemetrySourceWithDefaults instantiates a new ObservabilityPipelineOpentelemetrySource object.
38+
// This constructor will only assign default values to properties that have it defined,
39+
// but it doesn't guarantee that properties required by API are set.
40+
func NewObservabilityPipelineOpentelemetrySourceWithDefaults() *ObservabilityPipelineOpentelemetrySource {
41+
this := ObservabilityPipelineOpentelemetrySource{}
42+
var typeVar ObservabilityPipelineOpentelemetrySourceType = OBSERVABILITYPIPELINEOPENTELEMETRYSOURCETYPE_OPENTELEMETRY
43+
this.Type = typeVar
44+
return &this
45+
}
46+
47+
// GetId returns the Id field value.
48+
func (o *ObservabilityPipelineOpentelemetrySource) GetId() string {
49+
if o == nil {
50+
var ret string
51+
return ret
52+
}
53+
return o.Id
54+
}
55+
56+
// GetIdOk returns a tuple with the Id field value
57+
// and a boolean to check if the value has been set.
58+
func (o *ObservabilityPipelineOpentelemetrySource) GetIdOk() (*string, bool) {
59+
if o == nil {
60+
return nil, false
61+
}
62+
return &o.Id, true
63+
}
64+
65+
// SetId sets field value.
66+
func (o *ObservabilityPipelineOpentelemetrySource) SetId(v string) {
67+
o.Id = v
68+
}
69+
70+
// GetTls returns the Tls field value if set, zero value otherwise.
71+
func (o *ObservabilityPipelineOpentelemetrySource) GetTls() ObservabilityPipelineTls {
72+
if o == nil || o.Tls == nil {
73+
var ret ObservabilityPipelineTls
74+
return ret
75+
}
76+
return *o.Tls
77+
}
78+
79+
// GetTlsOk returns a tuple with the Tls field value if set, nil otherwise
80+
// and a boolean to check if the value has been set.
81+
func (o *ObservabilityPipelineOpentelemetrySource) GetTlsOk() (*ObservabilityPipelineTls, bool) {
82+
if o == nil || o.Tls == nil {
83+
return nil, false
84+
}
85+
return o.Tls, true
86+
}
87+
88+
// HasTls returns a boolean if a field has been set.
89+
func (o *ObservabilityPipelineOpentelemetrySource) HasTls() bool {
90+
return o != nil && o.Tls != nil
91+
}
92+
93+
// SetTls gets a reference to the given ObservabilityPipelineTls and assigns it to the Tls field.
94+
func (o *ObservabilityPipelineOpentelemetrySource) SetTls(v ObservabilityPipelineTls) {
95+
o.Tls = &v
96+
}
97+
98+
// GetType returns the Type field value.
99+
func (o *ObservabilityPipelineOpentelemetrySource) GetType() ObservabilityPipelineOpentelemetrySourceType {
100+
if o == nil {
101+
var ret ObservabilityPipelineOpentelemetrySourceType
102+
return ret
103+
}
104+
return o.Type
105+
}
106+
107+
// GetTypeOk returns a tuple with the Type field value
108+
// and a boolean to check if the value has been set.
109+
func (o *ObservabilityPipelineOpentelemetrySource) GetTypeOk() (*ObservabilityPipelineOpentelemetrySourceType, bool) {
110+
if o == nil {
111+
return nil, false
112+
}
113+
return &o.Type, true
114+
}
115+
116+
// SetType sets field value.
117+
func (o *ObservabilityPipelineOpentelemetrySource) SetType(v ObservabilityPipelineOpentelemetrySourceType) {
118+
o.Type = v
119+
}
120+
121+
// MarshalJSON serializes the struct using spec logic.
122+
func (o ObservabilityPipelineOpentelemetrySource) MarshalJSON() ([]byte, error) {
123+
toSerialize := map[string]interface{}{}
124+
if o.UnparsedObject != nil {
125+
return datadog.Marshal(o.UnparsedObject)
126+
}
127+
toSerialize["id"] = o.Id
128+
if o.Tls != nil {
129+
toSerialize["tls"] = o.Tls
130+
}
131+
toSerialize["type"] = o.Type
132+
133+
for key, value := range o.AdditionalProperties {
134+
toSerialize[key] = value
135+
}
136+
return datadog.Marshal(toSerialize)
137+
}
138+
139+
// UnmarshalJSON deserializes the given payload.
140+
func (o *ObservabilityPipelineOpentelemetrySource) UnmarshalJSON(bytes []byte) (err error) {
141+
all := struct {
142+
Id *string `json:"id"`
143+
Tls *ObservabilityPipelineTls `json:"tls,omitempty"`
144+
Type *ObservabilityPipelineOpentelemetrySourceType `json:"type"`
145+
}{}
146+
if err = datadog.Unmarshal(bytes, &all); err != nil {
147+
return datadog.Unmarshal(bytes, &o.UnparsedObject)
148+
}
149+
if all.Id == nil {
150+
return fmt.Errorf("required field id missing")
151+
}
152+
if all.Type == nil {
153+
return fmt.Errorf("required field type missing")
154+
}
155+
additionalProperties := make(map[string]interface{})
156+
if err = datadog.Unmarshal(bytes, &additionalProperties); err == nil {
157+
datadog.DeleteKeys(additionalProperties, &[]string{"id", "tls", "type"})
158+
} else {
159+
return err
160+
}
161+
162+
hasInvalidField := false
163+
o.Id = *all.Id
164+
if all.Tls != nil && all.Tls.UnparsedObject != nil && o.UnparsedObject == nil {
165+
hasInvalidField = true
166+
}
167+
o.Tls = all.Tls
168+
if !all.Type.IsValid() {
169+
hasInvalidField = true
170+
} else {
171+
o.Type = *all.Type
172+
}
173+
174+
if len(additionalProperties) > 0 {
175+
o.AdditionalProperties = additionalProperties
176+
}
177+
178+
if hasInvalidField {
179+
return datadog.Unmarshal(bytes, &o.UnparsedObject)
180+
}
181+
182+
return nil
183+
}

‎api/datadogV2/model_observability_pipeline_opentelemetry_source_type.go‎

Lines changed: 64 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,64 @@
1+
// Unless explicitly stated otherwise all files in this repository are licensed under the Apache-2.0 License.
2+
// This product includes software developed at Datadog (https://www.datadoghq.com/).
3+
// Copyright 2019-Present Datadog, Inc.
4+
5+
package datadogV2
6+
7+
import (
8+
"fmt"
9+
10+
"github.com/DataDog/datadog-api-client-go/v2/api/datadog"
11+
)
12+
13+
// ObservabilityPipelineOpentelemetrySourceType The source type. The value should always be `opentelemetry`.
14+
type ObservabilityPipelineOpentelemetrySourceType string
15+
16+
// List of ObservabilityPipelineOpentelemetrySourceType.
17+
const (
18+
OBSERVABILITYPIPELINEOPENTELEMETRYSOURCETYPE_OPENTELEMETRY ObservabilityPipelineOpentelemetrySourceType = "opentelemetry"
19+
)
20+
21+
var allowedObservabilityPipelineOpentelemetrySourceTypeEnumValues = []ObservabilityPipelineOpentelemetrySourceType{
22+
OBSERVABILITYPIPELINEOPENTELEMETRYSOURCETYPE_OPENTELEMETRY,
23+
}
24+
25+
// GetAllowedValues reeturns the list of possible values.
26+
func (v *ObservabilityPipelineOpentelemetrySourceType) GetAllowedValues() []ObservabilityPipelineOpentelemetrySourceType {
27+
return allowedObservabilityPipelineOpentelemetrySourceTypeEnumValues
28+
}
29+
30+
// UnmarshalJSON deserializes the given payload.
31+
func (v *ObservabilityPipelineOpentelemetrySourceType) UnmarshalJSON(src []byte) error {
32+
var value string
33+
err := datadog.Unmarshal(src, &value)
34+
if err != nil {
35+
return err
36+
}
37+
*v = ObservabilityPipelineOpentelemetrySourceType(value)
38+
return nil
39+
}
40+
41+
// NewObservabilityPipelineOpentelemetrySourceTypeFromValue returns a pointer to a valid ObservabilityPipelineOpentelemetrySourceType
42+
// for the value passed as argument, or an error if the value passed is not allowed by the enum.
43+
func NewObservabilityPipelineOpentelemetrySourceTypeFromValue(v string) (*ObservabilityPipelineOpentelemetrySourceType, error) {
44+
ev := ObservabilityPipelineOpentelemetrySourceType(v)
45+
if ev.IsValid() {
46+
return &ev, nil
47+
}
48+
return nil, fmt.Errorf("invalid value '%v' for ObservabilityPipelineOpentelemetrySourceType: valid values are %v", v, allowedObservabilityPipelineOpentelemetrySourceTypeEnumValues)
49+
}
50+
51+
// IsValid return true if the value is valid for the enum, false otherwise.
52+
func (v ObservabilityPipelineOpentelemetrySourceType) IsValid() bool {
53+
for _, existing := range allowedObservabilityPipelineOpentelemetrySourceTypeEnumValues {
54+
if existing == v {
55+
return true
56+
}
57+
}
58+
return false
59+
}
60+
61+
// Ptr returns reference to ObservabilityPipelineOpentelemetrySourceType value.
62+
func (v ObservabilityPipelineOpentelemetrySourceType) Ptr() *ObservabilityPipelineOpentelemetrySourceType {
63+
return &v
64+
}

0 commit comments

Comments
 (0)