Skip to content

Commit 0b8775c

Browse files
author
ci.datadog-api-spec
committed
Regenerate client from commit ce2ae7a of spec repo
1 parent 53c23e2 commit 0b8775c

7 files changed

Lines changed: 706 additions & 6 deletions

‎.generated-info‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
11
{
2-
"spec_repo_commit": "d93d991",
3-
"generated": "2025-07-15 09:33:00.867"
2+
"spec_repo_commit": "ce2ae7a",
3+
"generated": "2025-07-15 22:54:46.109"
44
}

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

Lines changed: 77 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25164,6 +25164,7 @@ components:
2516425164
- $ref: '#/components/schemas/ObservabilityPipelineEnrichmentTableProcessor'
2516525165
- $ref: '#/components/schemas/ObservabilityPipelineReduceProcessor'
2516625166
- $ref: '#/components/schemas/ObservabilityPipelineThrottleProcessor'
25167+
- $ref: '#/components/schemas/ObservabilityPipelineDatadogTagsProcessor'
2516725168
ObservabilityPipelineConfigSourceItem:
2516825169
description: A data source for the pipeline.
2516925170
oneOf:
@@ -25273,6 +25274,82 @@ components:
2527325274
type: string
2527425275
x-enum-varnames:
2527525276
- DATADOG_LOGS
25277+
ObservabilityPipelineDatadogTagsProcessor:
25278+
description: The `datadog_tags` processor filters logs based on Datadog tags.
25279+
It can include or exclude logs that have specific tag keys.
25280+
properties:
25281+
action:
25282+
$ref: '#/components/schemas/ObservabilityPipelineDatadogTagsProcessorAction'
25283+
id:
25284+
description: The unique identifier for this component. Used to reference
25285+
this component in other parts of the pipeline (for example, as the `input`
25286+
to downstream components).
25287+
example: datadog-tags-processor
25288+
type: string
25289+
include:
25290+
description: A Datadog search query used to determine which logs this processor
25291+
targets.
25292+
example: service:my-service
25293+
type: string
25294+
inputs:
25295+
description: A list of component IDs whose output is used as the `input`
25296+
for this component.
25297+
example:
25298+
- datadog-agent-source
25299+
items:
25300+
type: string
25301+
type: array
25302+
keys:
25303+
description: A list of tag keys to filter on. Tag keys must start with a
25304+
letter and contain only letters, numbers, underscores, hyphens, periods,
25305+
or slashes. Maximum 100 keys allowed.
25306+
example:
25307+
- env
25308+
- service
25309+
- version
25310+
items:
25311+
type: string
25312+
type: array
25313+
mode:
25314+
$ref: '#/components/schemas/ObservabilityPipelineDatadogTagsProcessorMode'
25315+
type:
25316+
$ref: '#/components/schemas/ObservabilityPipelineDatadogTagsProcessorType'
25317+
required:
25318+
- id
25319+
- type
25320+
- include
25321+
- mode
25322+
- action
25323+
- keys
25324+
- inputs
25325+
type: object
25326+
ObservabilityPipelineDatadogTagsProcessorAction:
25327+
description: The action to take on logs that match the specified tag keys.
25328+
enum:
25329+
- include
25330+
- exclude
25331+
example: include
25332+
type: string
25333+
x-enum-varnames:
25334+
- INCLUDE
25335+
- EXCLUDE
25336+
ObservabilityPipelineDatadogTagsProcessorMode:
25337+
description: The filtering mode. Currently only `filter` is supported.
25338+
enum:
25339+
- filter
25340+
example: filter
25341+
type: string
25342+
x-enum-varnames:
25343+
- FILTER
25344+
ObservabilityPipelineDatadogTagsProcessorType:
25345+
default: datadog_tags
25346+
description: The processor type. The value should always be `datadog_tags`.
25347+
enum:
25348+
- datadog_tags
25349+
example: datadog_tags
25350+
type: string
25351+
x-enum-varnames:
25352+
- DATADOG_TAGS
2527625353
ObservabilityPipelineDecoding:
2527725354
description: The decoding format used to interpret incoming logs.
2527825355
enum:

‎src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineConfigProcessorItem.java‎

Lines changed: 82 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -902,6 +902,57 @@ public ObservabilityPipelineConfigProcessorItem deserialize(
902902
e);
903903
}
904904

905+
// deserialize ObservabilityPipelineDatadogTagsProcessor
906+
try {
907+
boolean attemptParsing = true;
908+
// ensure that we respect type coercion as set on the client ObjectMapper
909+
if (ObservabilityPipelineDatadogTagsProcessor.class.equals(Integer.class)
910+
|| ObservabilityPipelineDatadogTagsProcessor.class.equals(Long.class)
911+
|| ObservabilityPipelineDatadogTagsProcessor.class.equals(Float.class)
912+
|| ObservabilityPipelineDatadogTagsProcessor.class.equals(Double.class)
913+
|| ObservabilityPipelineDatadogTagsProcessor.class.equals(Boolean.class)
914+
|| ObservabilityPipelineDatadogTagsProcessor.class.equals(String.class)) {
915+
attemptParsing = typeCoercion;
916+
if (!attemptParsing) {
917+
attemptParsing |=
918+
((ObservabilityPipelineDatadogTagsProcessor.class.equals(Integer.class)
919+
|| ObservabilityPipelineDatadogTagsProcessor.class.equals(Long.class))
920+
&& token == JsonToken.VALUE_NUMBER_INT);
921+
attemptParsing |=
922+
((ObservabilityPipelineDatadogTagsProcessor.class.equals(Float.class)
923+
|| ObservabilityPipelineDatadogTagsProcessor.class.equals(Double.class))
924+
&& (token == JsonToken.VALUE_NUMBER_FLOAT
925+
|| token == JsonToken.VALUE_NUMBER_INT));
926+
attemptParsing |=
927+
(ObservabilityPipelineDatadogTagsProcessor.class.equals(Boolean.class)
928+
&& (token == JsonToken.VALUE_FALSE || token == JsonToken.VALUE_TRUE));
929+
attemptParsing |=
930+
(ObservabilityPipelineDatadogTagsProcessor.class.equals(String.class)
931+
&& token == JsonToken.VALUE_STRING);
932+
}
933+
}
934+
if (attemptParsing) {
935+
tmp =
936+
tree.traverse(jp.getCodec())
937+
.readValueAs(ObservabilityPipelineDatadogTagsProcessor.class);
938+
// TODO: there is no validation against JSON schema constraints
939+
// (min, max, enum, pattern...), this does not perform a strict JSON
940+
// validation, which means the 'match' count may be higher than it should be.
941+
if (!((ObservabilityPipelineDatadogTagsProcessor) tmp).unparsed) {
942+
deserialized = tmp;
943+
match++;
944+
}
945+
log.log(
946+
Level.FINER, "Input data matches schema 'ObservabilityPipelineDatadogTagsProcessor'");
947+
}
948+
} catch (Exception e) {
949+
// deserialization failed, continue
950+
log.log(
951+
Level.FINER,
952+
"Input data does not match schema 'ObservabilityPipelineDatadogTagsProcessor'",
953+
e);
954+
}
955+
905956
ObservabilityPipelineConfigProcessorItem ret = new ObservabilityPipelineConfigProcessorItem();
906957
if (match == 1) {
907958
ret.setActualInstance(deserialized);
@@ -1013,6 +1064,11 @@ public ObservabilityPipelineConfigProcessorItem(ObservabilityPipelineThrottlePro
10131064
setActualInstance(o);
10141065
}
10151066

1067+
public ObservabilityPipelineConfigProcessorItem(ObservabilityPipelineDatadogTagsProcessor o) {
1068+
super("oneOf", Boolean.FALSE);
1069+
setActualInstance(o);
1070+
}
1071+
10161072
static {
10171073
schemas.put(
10181074
"ObservabilityPipelineFilterProcessor",
@@ -1062,6 +1118,9 @@ public ObservabilityPipelineConfigProcessorItem(ObservabilityPipelineThrottlePro
10621118
schemas.put(
10631119
"ObservabilityPipelineThrottleProcessor",
10641120
new GenericType<ObservabilityPipelineThrottleProcessor>() {});
1121+
schemas.put(
1122+
"ObservabilityPipelineDatadogTagsProcessor",
1123+
new GenericType<ObservabilityPipelineDatadogTagsProcessor>() {});
10651124
JSON.registerDescendants(
10661125
ObservabilityPipelineConfigProcessorItem.class, Collections.unmodifiableMap(schemas));
10671126
}
@@ -1081,7 +1140,7 @@ public Map<String, GenericType> getSchemas() {
10811140
* ObservabilityPipelineSensitiveDataScannerProcessor, ObservabilityPipelineOcsfMapperProcessor,
10821141
* ObservabilityPipelineAddEnvVarsProcessor, ObservabilityPipelineDedupeProcessor,
10831142
* ObservabilityPipelineEnrichmentTableProcessor, ObservabilityPipelineReduceProcessor,
1084-
* ObservabilityPipelineThrottleProcessor
1143+
* ObservabilityPipelineThrottleProcessor, ObservabilityPipelineDatadogTagsProcessor
10851144
*
10861145
* <p>It could be an instance of the 'oneOf' schemas. The oneOf child schemas may themselves be a
10871146
* composed schema (allOf, anyOf, oneOf).
@@ -1170,6 +1229,11 @@ public void setActualInstance(Object instance) {
11701229
super.setActualInstance(instance);
11711230
return;
11721231
}
1232+
if (JSON.isInstanceOf(
1233+
ObservabilityPipelineDatadogTagsProcessor.class, instance, new HashSet<Class<?>>())) {
1234+
super.setActualInstance(instance);
1235+
return;
1236+
}
11731237

11741238
if (JSON.isInstanceOf(UnparsedObject.class, instance, new HashSet<Class<?>>())) {
11751239
super.setActualInstance(instance);
@@ -1187,7 +1251,8 @@ public void setActualInstance(Object instance) {
11871251
+ " ObservabilityPipelineOcsfMapperProcessor, ObservabilityPipelineAddEnvVarsProcessor,"
11881252
+ " ObservabilityPipelineDedupeProcessor,"
11891253
+ " ObservabilityPipelineEnrichmentTableProcessor,"
1190-
+ " ObservabilityPipelineReduceProcessor, ObservabilityPipelineThrottleProcessor");
1254+
+ " ObservabilityPipelineReduceProcessor, ObservabilityPipelineThrottleProcessor,"
1255+
+ " ObservabilityPipelineDatadogTagsProcessor");
11911256
}
11921257

11931258
/**
@@ -1199,7 +1264,7 @@ public void setActualInstance(Object instance) {
11991264
* ObservabilityPipelineSensitiveDataScannerProcessor, ObservabilityPipelineOcsfMapperProcessor,
12001265
* ObservabilityPipelineAddEnvVarsProcessor, ObservabilityPipelineDedupeProcessor,
12011266
* ObservabilityPipelineEnrichmentTableProcessor, ObservabilityPipelineReduceProcessor,
1202-
* ObservabilityPipelineThrottleProcessor
1267+
* ObservabilityPipelineThrottleProcessor, ObservabilityPipelineDatadogTagsProcessor
12031268
*
12041269
* @return The actual instance (ObservabilityPipelineFilterProcessor,
12051270
* ObservabilityPipelineParseJSONProcessor, ObservabilityPipelineQuotaProcessor,
@@ -1209,7 +1274,8 @@ public void setActualInstance(Object instance) {
12091274
* ObservabilityPipelineSensitiveDataScannerProcessor,
12101275
* ObservabilityPipelineOcsfMapperProcessor, ObservabilityPipelineAddEnvVarsProcessor,
12111276
* ObservabilityPipelineDedupeProcessor, ObservabilityPipelineEnrichmentTableProcessor,
1212-
* ObservabilityPipelineReduceProcessor, ObservabilityPipelineThrottleProcessor)
1277+
* ObservabilityPipelineReduceProcessor, ObservabilityPipelineThrottleProcessor,
1278+
* ObservabilityPipelineDatadogTagsProcessor)
12131279
*/
12141280
@Override
12151281
public Object getActualInstance() {
@@ -1413,4 +1479,16 @@ public ObservabilityPipelineThrottleProcessor getObservabilityPipelineThrottlePr
14131479
throws ClassCastException {
14141480
return (ObservabilityPipelineThrottleProcessor) super.getActualInstance();
14151481
}
1482+
1483+
/**
1484+
* Get the actual instance of `ObservabilityPipelineDatadogTagsProcessor`. If the actual instance
1485+
* is not `ObservabilityPipelineDatadogTagsProcessor`, the ClassCastException will be thrown.
1486+
*
1487+
* @return The actual instance of `ObservabilityPipelineDatadogTagsProcessor`
1488+
* @throws ClassCastException if the instance is not `ObservabilityPipelineDatadogTagsProcessor`
1489+
*/
1490+
public ObservabilityPipelineDatadogTagsProcessor getObservabilityPipelineDatadogTagsProcessor()
1491+
throws ClassCastException {
1492+
return (ObservabilityPipelineDatadogTagsProcessor) super.getActualInstance();
1493+
}
14161494
}

0 commit comments

Comments
 (0)