Skip to content

Commit a7ebef3

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

File tree

4 files changed

+385
-4
lines changed

4 files changed

+385
-4
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.

src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineConfigSourceItem.java

Lines changed: 81 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -823,6 +823,57 @@ public ObservabilityPipelineConfigSourceItem deserialize(
823823
e);
824824
}
825825

826+
// deserialize ObservabilityPipelineOpentelemetrySource
827+
try {
828+
boolean attemptParsing = true;
829+
// ensure that we respect type coercion as set on the client ObjectMapper
830+
if (ObservabilityPipelineOpentelemetrySource.class.equals(Integer.class)
831+
|| ObservabilityPipelineOpentelemetrySource.class.equals(Long.class)
832+
|| ObservabilityPipelineOpentelemetrySource.class.equals(Float.class)
833+
|| ObservabilityPipelineOpentelemetrySource.class.equals(Double.class)
834+
|| ObservabilityPipelineOpentelemetrySource.class.equals(Boolean.class)
835+
|| ObservabilityPipelineOpentelemetrySource.class.equals(String.class)) {
836+
attemptParsing = typeCoercion;
837+
if (!attemptParsing) {
838+
attemptParsing |=
839+
((ObservabilityPipelineOpentelemetrySource.class.equals(Integer.class)
840+
|| ObservabilityPipelineOpentelemetrySource.class.equals(Long.class))
841+
&& token == JsonToken.VALUE_NUMBER_INT);
842+
attemptParsing |=
843+
((ObservabilityPipelineOpentelemetrySource.class.equals(Float.class)
844+
|| ObservabilityPipelineOpentelemetrySource.class.equals(Double.class))
845+
&& (token == JsonToken.VALUE_NUMBER_FLOAT
846+
|| token == JsonToken.VALUE_NUMBER_INT));
847+
attemptParsing |=
848+
(ObservabilityPipelineOpentelemetrySource.class.equals(Boolean.class)
849+
&& (token == JsonToken.VALUE_FALSE || token == JsonToken.VALUE_TRUE));
850+
attemptParsing |=
851+
(ObservabilityPipelineOpentelemetrySource.class.equals(String.class)
852+
&& token == JsonToken.VALUE_STRING);
853+
}
854+
}
855+
if (attemptParsing) {
856+
tmp =
857+
tree.traverse(jp.getCodec())
858+
.readValueAs(ObservabilityPipelineOpentelemetrySource.class);
859+
// TODO: there is no validation against JSON schema constraints
860+
// (min, max, enum, pattern...), this does not perform a strict JSON
861+
// validation, which means the 'match' count may be higher than it should be.
862+
if (!((ObservabilityPipelineOpentelemetrySource) tmp).unparsed) {
863+
deserialized = tmp;
864+
match++;
865+
}
866+
log.log(
867+
Level.FINER, "Input data matches schema 'ObservabilityPipelineOpentelemetrySource'");
868+
}
869+
} catch (Exception e) {
870+
// deserialization failed, continue
871+
log.log(
872+
Level.FINER,
873+
"Input data does not match schema 'ObservabilityPipelineOpentelemetrySource'",
874+
e);
875+
}
876+
826877
// deserialize ObservabilityPipelineSocketSource
827878
try {
828879
boolean attemptParsing = true;
@@ -974,6 +1025,11 @@ public ObservabilityPipelineConfigSourceItem(ObservabilityPipelineLogstashSource
9741025
setActualInstance(o);
9751026
}
9761027

1028+
public ObservabilityPipelineConfigSourceItem(ObservabilityPipelineOpentelemetrySource o) {
1029+
super("oneOf", Boolean.FALSE);
1030+
setActualInstance(o);
1031+
}
1032+
9771033
public ObservabilityPipelineConfigSourceItem(ObservabilityPipelineSocketSource o) {
9781034
super("oneOf", Boolean.FALSE);
9791035
setActualInstance(o);
@@ -1024,6 +1080,9 @@ public ObservabilityPipelineConfigSourceItem(ObservabilityPipelineSocketSource o
10241080
schemas.put(
10251081
"ObservabilityPipelineLogstashSource",
10261082
new GenericType<ObservabilityPipelineLogstashSource>() {});
1083+
schemas.put(
1084+
"ObservabilityPipelineOpentelemetrySource",
1085+
new GenericType<ObservabilityPipelineOpentelemetrySource>() {});
10271086
schemas.put(
10281087
"ObservabilityPipelineSocketSource",
10291088
new GenericType<ObservabilityPipelineSocketSource>() {});
@@ -1046,7 +1105,7 @@ public Map<String, GenericType> getSchemas() {
10461105
* ObservabilityPipelineRsyslogSource, ObservabilityPipelineSyslogNgSource,
10471106
* ObservabilityPipelineAmazonDataFirehoseSource, ObservabilityPipelineGooglePubSubSource,
10481107
* ObservabilityPipelineHttpClientSource, ObservabilityPipelineLogstashSource,
1049-
* ObservabilityPipelineSocketSource
1108+
* ObservabilityPipelineOpentelemetrySource, ObservabilityPipelineSocketSource
10501109
*
10511110
* <p>It could be an instance of the 'oneOf' schemas. The oneOf child schemas may themselves be a
10521111
* composed schema (allOf, anyOf, oneOf).
@@ -1128,6 +1187,11 @@ public void setActualInstance(Object instance) {
11281187
super.setActualInstance(instance);
11291188
return;
11301189
}
1190+
if (JSON.isInstanceOf(
1191+
ObservabilityPipelineOpentelemetrySource.class, instance, new HashSet<Class<?>>())) {
1192+
super.setActualInstance(instance);
1193+
return;
1194+
}
11311195
if (JSON.isInstanceOf(
11321196
ObservabilityPipelineSocketSource.class, instance, new HashSet<Class<?>>())) {
11331197
super.setActualInstance(instance);
@@ -1147,7 +1211,8 @@ public void setActualInstance(Object instance) {
11471211
+ " ObservabilityPipelineRsyslogSource, ObservabilityPipelineSyslogNgSource,"
11481212
+ " ObservabilityPipelineAmazonDataFirehoseSource,"
11491213
+ " ObservabilityPipelineGooglePubSubSource, ObservabilityPipelineHttpClientSource,"
1150-
+ " ObservabilityPipelineLogstashSource, ObservabilityPipelineSocketSource");
1214+
+ " ObservabilityPipelineLogstashSource, ObservabilityPipelineOpentelemetrySource,"
1215+
+ " ObservabilityPipelineSocketSource");
11511216
}
11521217

11531218
/**
@@ -1159,7 +1224,7 @@ public void setActualInstance(Object instance) {
11591224
* ObservabilityPipelineRsyslogSource, ObservabilityPipelineSyslogNgSource,
11601225
* ObservabilityPipelineAmazonDataFirehoseSource, ObservabilityPipelineGooglePubSubSource,
11611226
* ObservabilityPipelineHttpClientSource, ObservabilityPipelineLogstashSource,
1162-
* ObservabilityPipelineSocketSource
1227+
* ObservabilityPipelineOpentelemetrySource, ObservabilityPipelineSocketSource
11631228
*
11641229
* @return The actual instance (ObservabilityPipelineKafkaSource,
11651230
* ObservabilityPipelineDatadogAgentSource, ObservabilityPipelineSplunkTcpSource,
@@ -1169,7 +1234,7 @@ public void setActualInstance(Object instance) {
11691234
* ObservabilityPipelineRsyslogSource, ObservabilityPipelineSyslogNgSource,
11701235
* ObservabilityPipelineAmazonDataFirehoseSource, ObservabilityPipelineGooglePubSubSource,
11711236
* ObservabilityPipelineHttpClientSource, ObservabilityPipelineLogstashSource,
1172-
* ObservabilityPipelineSocketSource)
1237+
* ObservabilityPipelineOpentelemetrySource, ObservabilityPipelineSocketSource)
11731238
*/
11741239
@Override
11751240
public Object getActualInstance() {
@@ -1358,6 +1423,18 @@ public ObservabilityPipelineLogstashSource getObservabilityPipelineLogstashSourc
13581423
return (ObservabilityPipelineLogstashSource) super.getActualInstance();
13591424
}
13601425

1426+
/**
1427+
* Get the actual instance of `ObservabilityPipelineOpentelemetrySource`. If the actual instance
1428+
* is not `ObservabilityPipelineOpentelemetrySource`, the ClassCastException will be thrown.
1429+
*
1430+
* @return The actual instance of `ObservabilityPipelineOpentelemetrySource`
1431+
* @throws ClassCastException if the instance is not `ObservabilityPipelineOpentelemetrySource`
1432+
*/
1433+
public ObservabilityPipelineOpentelemetrySource getObservabilityPipelineOpentelemetrySource()
1434+
throws ClassCastException {
1435+
return (ObservabilityPipelineOpentelemetrySource) super.getActualInstance();
1436+
}
1437+
13611438
/**
13621439
* Get the actual instance of `ObservabilityPipelineSocketSource`. If the actual instance is not
13631440
* `ObservabilityPipelineSocketSource`, the ClassCastException will be thrown.

0 commit comments

Comments
 (0)