Skip to content

Commit ee79c97

Browse files
author
ci.datadog-api-spec
committed
Regenerate client from commit 30e9724 of spec repo
1 parent 3d5fb96 commit ee79c97

19 files changed

+1588
-10
lines changed

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

Lines changed: 63 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -43989,6 +43989,40 @@ components:
4398943989
type: string
4399043990
x-enum-varnames:
4399143991
- ELASTICSEARCH
43992+
ObservabilityPipelineEnrichmentTableFieldEventLookup:
43993+
description: Looks up a value from a field path in the log event.
43994+
properties:
43995+
event:
43996+
description: The path to the field in the log event to use as the lookup key.
43997+
example: log.user.id
43998+
type: string
43999+
required:
44000+
- event
44001+
type: object
44002+
ObservabilityPipelineEnrichmentTableFieldSecretLookup:
44003+
description: Looks up a value stored as a pipeline secret.
44004+
properties:
44005+
secret:
44006+
description: The name of the secret containing the lookup key value.
44007+
example: MY_LOOKUP_SECRET
44008+
type: string
44009+
required:
44010+
- secret
44011+
type: object
44012+
ObservabilityPipelineEnrichmentTableFieldStringPath:
44013+
description: A plain field path in the log event, used as the lookup key.
44014+
example: log.user.id
44015+
type: string
44016+
ObservabilityPipelineEnrichmentTableFieldVrlLookup:
44017+
description: Evaluates a VRL expression to produce the lookup key.
44018+
properties:
44019+
vrl:
44020+
description: A VRL expression that returns the value to use as the lookup key.
44021+
example: .log.user.id
44022+
type: string
44023+
required:
44024+
- vrl
44025+
type: object
4399244026
ObservabilityPipelineEnrichmentTableFile:
4399344027
description: Defines a static enrichment table loaded from a CSV file.
4399444028
properties:
@@ -44039,6 +44073,16 @@ components:
4403944073
type: string
4404044074
x-enum-varnames:
4404144075
- CSV
44076+
ObservabilityPipelineEnrichmentTableFileKeyItemField:
44077+
description: |-
44078+
Specifies the source of the key value used for enrichment table lookups.
44079+
Can be a plain field path string or an object specifying `event`, `vrl`, or `secret`.
44080+
example: log.user.id
44081+
oneOf:
44082+
- $ref: "#/components/schemas/ObservabilityPipelineEnrichmentTableFieldStringPath"
44083+
- $ref: "#/components/schemas/ObservabilityPipelineEnrichmentTableFieldEventLookup"
44084+
- $ref: "#/components/schemas/ObservabilityPipelineEnrichmentTableFieldVrlLookup"
44085+
- $ref: "#/components/schemas/ObservabilityPipelineEnrichmentTableFieldSecretLookup"
4404244086
ObservabilityPipelineEnrichmentTableFileKeyItems:
4404344087
description: Defines how to map log fields to enrichment table columns during lookups.
4404444088
properties:
@@ -44049,9 +44093,7 @@ components:
4404944093
comparison:
4405044094
$ref: "#/components/schemas/ObservabilityPipelineEnrichmentTableFileKeyItemsComparison"
4405144095
field:
44052-
description: The `items` `field`.
44053-
example: log.user.id
44054-
type: string
44096+
$ref: "#/components/schemas/ObservabilityPipelineEnrichmentTableFileKeyItemField"
4405544097
required:
4405644098
- column
4405744099
- comparison
@@ -47072,6 +47114,8 @@ components:
4707247114
description: Name of the environment variable or secret that holds the Splunk HEC token.
4707347115
example: SPLUNK_HEC_TOKEN
4707447116
type: string
47117+
token_strategy:
47118+
$ref: "#/components/schemas/ObservabilityPipelineSplunkHecDestinationTokenStrategy"
4707547119
type:
4707647120
$ref: "#/components/schemas/ObservabilityPipelineSplunkHecDestinationType"
4707747121
required:
@@ -47090,6 +47134,16 @@ components:
4709047134
x-enum-varnames:
4709147135
- JSON
4709247136
- RAW_MESSAGE
47137+
ObservabilityPipelineSplunkHecDestinationTokenStrategy:
47138+
description: Controls how the Splunk HEC token is supplied. Use `custom` to provide a token with `token_key`, or `from_source` to forward the token received from an upstream Splunk HEC source.
47139+
enum:
47140+
- custom
47141+
- from_source
47142+
example: custom
47143+
type: string
47144+
x-enum-varnames:
47145+
- CUSTOM
47146+
- FROM_SOURCE
4709347147
ObservabilityPipelineSplunkHecDestinationType:
4709447148
default: splunk_hec
4709547149
description: The destination type. Always `splunk_hec`.
@@ -47113,6 +47167,12 @@ components:
4711347167
description: The unique identifier for this component. Used in other parts of the pipeline to reference this component (for example, as the `input` to downstream components).
4711447168
example: splunk-hec-source
4711547169
type: string
47170+
store_hec_token:
47171+
description: |-
47172+
When `true`, the Splunk HEC token from the incoming request is stored in the event metadata.
47173+
This allows downstream components to forward the token to other Splunk HEC destinations.
47174+
example: true
47175+
type: boolean
4711647176
tls:
4711747177
$ref: "#/components/schemas/ObservabilityPipelineTls"
4711847178
type:

‎examples/v2/observability-pipelines/ValidatePipeline_1267410221.java‎

Lines changed: 94 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,94 @@
1+
// Validate an observability pipeline with Splunk HEC destination token_strategy returns "OK"
2+
// response
3+
4+
import com.datadog.api.client.ApiClient;
5+
import com.datadog.api.client.ApiException;
6+
import com.datadog.api.client.v2.api.ObservabilityPipelinesApi;
7+
import com.datadog.api.client.v2.model.ObservabilityPipelineConfig;
8+
import com.datadog.api.client.v2.model.ObservabilityPipelineConfigDestinationItem;
9+
import com.datadog.api.client.v2.model.ObservabilityPipelineConfigProcessorGroup;
10+
import com.datadog.api.client.v2.model.ObservabilityPipelineConfigProcessorItem;
11+
import com.datadog.api.client.v2.model.ObservabilityPipelineConfigSourceItem;
12+
import com.datadog.api.client.v2.model.ObservabilityPipelineDataAttributes;
13+
import com.datadog.api.client.v2.model.ObservabilityPipelineDatadogAgentSource;
14+
import com.datadog.api.client.v2.model.ObservabilityPipelineDatadogAgentSourceType;
15+
import com.datadog.api.client.v2.model.ObservabilityPipelineFilterProcessor;
16+
import com.datadog.api.client.v2.model.ObservabilityPipelineFilterProcessorType;
17+
import com.datadog.api.client.v2.model.ObservabilityPipelineSpec;
18+
import com.datadog.api.client.v2.model.ObservabilityPipelineSpecData;
19+
import com.datadog.api.client.v2.model.ObservabilityPipelineSplunkHecDestination;
20+
import com.datadog.api.client.v2.model.ObservabilityPipelineSplunkHecDestinationTokenStrategy;
21+
import com.datadog.api.client.v2.model.ObservabilityPipelineSplunkHecDestinationType;
22+
import com.datadog.api.client.v2.model.ValidationResponse;
23+
import java.util.Collections;
24+
25+
public class Example {
26+
public static void main(String[] args) {
27+
ApiClient defaultClient = ApiClient.getDefaultApiClient();
28+
ObservabilityPipelinesApi apiInstance = new ObservabilityPipelinesApi(defaultClient);
29+
30+
ObservabilityPipelineSpec body =
31+
new ObservabilityPipelineSpec()
32+
.data(
33+
new ObservabilityPipelineSpecData()
34+
.attributes(
35+
new ObservabilityPipelineDataAttributes()
36+
.config(
37+
new ObservabilityPipelineConfig()
38+
.destinations(
39+
Collections.singletonList(
40+
new ObservabilityPipelineConfigDestinationItem(
41+
new ObservabilityPipelineSplunkHecDestination()
42+
.id("splunk-hec-destination")
43+
.inputs(
44+
Collections.singletonList(
45+
"my-processor-group"))
46+
.type(
47+
ObservabilityPipelineSplunkHecDestinationType
48+
.SPLUNK_HEC)
49+
.tokenKey("SPLUNK_HEC_TOKEN")
50+
.tokenStrategy(
51+
ObservabilityPipelineSplunkHecDestinationTokenStrategy
52+
.CUSTOM))))
53+
.processorGroups(
54+
Collections.singletonList(
55+
new ObservabilityPipelineConfigProcessorGroup()
56+
.enabled(true)
57+
.id("my-processor-group")
58+
.include("service:my-service")
59+
.inputs(
60+
Collections.singletonList(
61+
"datadog-agent-source"))
62+
.processors(
63+
Collections.singletonList(
64+
new ObservabilityPipelineConfigProcessorItem(
65+
new ObservabilityPipelineFilterProcessor()
66+
.enabled(true)
67+
.id("filter-processor")
68+
.include("status:error")
69+
.type(
70+
ObservabilityPipelineFilterProcessorType
71+
.FILTER))))))
72+
.sources(
73+
Collections.singletonList(
74+
new ObservabilityPipelineConfigSourceItem(
75+
new ObservabilityPipelineDatadogAgentSource()
76+
.id("datadog-agent-source")
77+
.type(
78+
ObservabilityPipelineDatadogAgentSourceType
79+
.DATADOG_AGENT)))))
80+
.name("Pipeline with Splunk HEC token_strategy"))
81+
.type("pipelines"));
82+
83+
try {
84+
ValidationResponse result = apiInstance.validatePipeline(body);
85+
System.out.println(result);
86+
} catch (ApiException e) {
87+
System.err.println("Exception when calling ObservabilityPipelinesApi#validatePipeline");
88+
System.err.println("Status code: " + e.getCode());
89+
System.err.println("Reason: " + e.getResponseBody());
90+
System.err.println("Response headers: " + e.getResponseHeaders());
91+
e.printStackTrace();
92+
}
93+
}
94+
}

‎examples/v2/observability-pipelines/ValidatePipeline_2960728933.java‎

Lines changed: 88 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,88 @@
1+
// Validate an observability pipeline with Splunk HEC source store_hec_token returns "OK" response
2+
3+
import com.datadog.api.client.ApiClient;
4+
import com.datadog.api.client.ApiException;
5+
import com.datadog.api.client.v2.api.ObservabilityPipelinesApi;
6+
import com.datadog.api.client.v2.model.ObservabilityPipelineConfig;
7+
import com.datadog.api.client.v2.model.ObservabilityPipelineConfigDestinationItem;
8+
import com.datadog.api.client.v2.model.ObservabilityPipelineConfigProcessorGroup;
9+
import com.datadog.api.client.v2.model.ObservabilityPipelineConfigProcessorItem;
10+
import com.datadog.api.client.v2.model.ObservabilityPipelineConfigSourceItem;
11+
import com.datadog.api.client.v2.model.ObservabilityPipelineDataAttributes;
12+
import com.datadog.api.client.v2.model.ObservabilityPipelineDatadogLogsDestination;
13+
import com.datadog.api.client.v2.model.ObservabilityPipelineDatadogLogsDestinationType;
14+
import com.datadog.api.client.v2.model.ObservabilityPipelineFilterProcessor;
15+
import com.datadog.api.client.v2.model.ObservabilityPipelineFilterProcessorType;
16+
import com.datadog.api.client.v2.model.ObservabilityPipelineSpec;
17+
import com.datadog.api.client.v2.model.ObservabilityPipelineSpecData;
18+
import com.datadog.api.client.v2.model.ObservabilityPipelineSplunkHecSource;
19+
import com.datadog.api.client.v2.model.ObservabilityPipelineSplunkHecSourceType;
20+
import com.datadog.api.client.v2.model.ValidationResponse;
21+
import java.util.Collections;
22+
23+
public class Example {
24+
public static void main(String[] args) {
25+
ApiClient defaultClient = ApiClient.getDefaultApiClient();
26+
ObservabilityPipelinesApi apiInstance = new ObservabilityPipelinesApi(defaultClient);
27+
28+
ObservabilityPipelineSpec body =
29+
new ObservabilityPipelineSpec()
30+
.data(
31+
new ObservabilityPipelineSpecData()
32+
.attributes(
33+
new ObservabilityPipelineDataAttributes()
34+
.config(
35+
new ObservabilityPipelineConfig()
36+
.destinations(
37+
Collections.singletonList(
38+
new ObservabilityPipelineConfigDestinationItem(
39+
new ObservabilityPipelineDatadogLogsDestination()
40+
.id("datadog-logs-destination")
41+
.inputs(
42+
Collections.singletonList(
43+
"my-processor-group"))
44+
.type(
45+
ObservabilityPipelineDatadogLogsDestinationType
46+
.DATADOG_LOGS))))
47+
.processorGroups(
48+
Collections.singletonList(
49+
new ObservabilityPipelineConfigProcessorGroup()
50+
.enabled(true)
51+
.id("my-processor-group")
52+
.include("service:my-service")
53+
.inputs(
54+
Collections.singletonList("splunk-hec-source"))
55+
.processors(
56+
Collections.singletonList(
57+
new ObservabilityPipelineConfigProcessorItem(
58+
new ObservabilityPipelineFilterProcessor()
59+
.enabled(true)
60+
.id("filter-processor")
61+
.include("status:error")
62+
.type(
63+
ObservabilityPipelineFilterProcessorType
64+
.FILTER))))))
65+
.sources(
66+
Collections.singletonList(
67+
new ObservabilityPipelineConfigSourceItem(
68+
new ObservabilityPipelineSplunkHecSource()
69+
.id("splunk-hec-source")
70+
.type(
71+
ObservabilityPipelineSplunkHecSourceType
72+
.SPLUNK_HEC)
73+
.storeHecToken(true)))))
74+
.name("Pipeline with Splunk HEC store_hec_token"))
75+
.type("pipelines"));
76+
77+
try {
78+
ValidationResponse result = apiInstance.validatePipeline(body);
79+
System.out.println(result);
80+
} catch (ApiException e) {
81+
System.err.println("Exception when calling ObservabilityPipelinesApi#validatePipeline");
82+
System.err.println("Status code: " + e.getCode());
83+
System.err.println("Reason: " + e.getResponseBody());
84+
System.err.println("Response headers: " + e.getResponseHeaders());
85+
e.printStackTrace();
86+
}
87+
}
88+
}

0 commit comments

Comments
 (0)