Skip to content

Commit 437fcf7

Browse files
author
ci.datadog-api-spec
committed
Regenerate client from commit db66851 of spec repo
1 parent 3d5fb96 commit 437fcf7

19 files changed

+1587
-11
lines changed

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

Lines changed: 61 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -43989,6 +43989,36 @@ components:
4398943989
type: string
4399043990
x-enum-varnames:
4399143991
- ELASTICSEARCH
43992+
ObservabilityPipelineEnrichmentTableFieldEventLookup:
43993+
description: Specifies an event field path to use as the enrichment table lookup key.
43994+
properties:
43995+
event:
43996+
description: Path to the field in the log event.
43997+
example: log.user.id
43998+
type: string
43999+
required:
44000+
- event
44001+
type: object
44002+
ObservabilityPipelineEnrichmentTableFieldSecretLookup:
44003+
description: Specifies a secret reference to use as the enrichment table lookup key.
44004+
properties:
44005+
secret:
44006+
description: The name of the secret whose value is used as the lookup key.
44007+
example: LOOKUP_KEY_SECRET
44008+
type: string
44009+
required:
44010+
- secret
44011+
type: object
44012+
ObservabilityPipelineEnrichmentTableFieldVrlLookup:
44013+
description: Specifies a VRL expression to compute the enrichment table lookup key.
44014+
properties:
44015+
vrl:
44016+
description: A VRL expression that resolves to the lookup key value.
44017+
example: .user_id
44018+
type: string
44019+
required:
44020+
- vrl
44021+
type: object
4399244022
ObservabilityPipelineEnrichmentTableFile:
4399344023
description: Defines a static enrichment table loaded from a CSV file.
4399444024
properties:
@@ -44039,6 +44069,18 @@ components:
4403944069
type: string
4404044070
x-enum-varnames:
4404144071
- CSV
44072+
ObservabilityPipelineEnrichmentTableFileKeyItemField:
44073+
description: |-
44074+
Specifies the source of the key value used for enrichment table lookups.
44075+
Can be a plain field path string, or an object specifying the lookup type (`event`, `vrl`, or `secret`).
44076+
example: log.user.id
44077+
oneOf:
44078+
- description: A plain field path in the log event.
44079+
example: log.user.id
44080+
type: string
44081+
- $ref: "#/components/schemas/ObservabilityPipelineEnrichmentTableFieldEventLookup"
44082+
- $ref: "#/components/schemas/ObservabilityPipelineEnrichmentTableFieldVrlLookup"
44083+
- $ref: "#/components/schemas/ObservabilityPipelineEnrichmentTableFieldSecretLookup"
4404244084
ObservabilityPipelineEnrichmentTableFileKeyItems:
4404344085
description: Defines how to map log fields to enrichment table columns during lookups.
4404444086
properties:
@@ -44049,9 +44091,7 @@ components:
4404944091
comparison:
4405044092
$ref: "#/components/schemas/ObservabilityPipelineEnrichmentTableFileKeyItemsComparison"
4405144093
field:
44052-
description: The `items` `field`.
44053-
example: log.user.id
44054-
type: string
44094+
$ref: "#/components/schemas/ObservabilityPipelineEnrichmentTableFileKeyItemField"
4405544095
required:
4405644096
- column
4405744097
- comparison
@@ -47072,6 +47112,8 @@ components:
4707247112
description: Name of the environment variable or secret that holds the Splunk HEC token.
4707347113
example: SPLUNK_HEC_TOKEN
4707447114
type: string
47115+
token_strategy:
47116+
$ref: "#/components/schemas/ObservabilityPipelineSplunkHecDestinationTokenStrategy"
4707547117
type:
4707647118
$ref: "#/components/schemas/ObservabilityPipelineSplunkHecDestinationType"
4707747119
required:
@@ -47090,6 +47132,16 @@ components:
4709047132
x-enum-varnames:
4709147133
- JSON
4709247134
- RAW_MESSAGE
47135+
ObservabilityPipelineSplunkHecDestinationTokenStrategy:
47136+
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.
47137+
enum:
47138+
- custom
47139+
- from_source
47140+
example: custom
47141+
type: string
47142+
x-enum-varnames:
47143+
- CUSTOM
47144+
- FROM_SOURCE
4709347145
ObservabilityPipelineSplunkHecDestinationType:
4709447146
default: splunk_hec
4709547147
description: The destination type. Always `splunk_hec`.
@@ -47113,6 +47165,12 @@ components:
4711347165
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).
4711447166
example: splunk-hec-source
4711547167
type: string
47168+
store_hec_token:
47169+
description: |-
47170+
When `true`, the Splunk HEC token from the incoming request is stored in the event metadata.
47171+
This allows downstream components to forward the token to other Splunk HEC destinations.
47172+
example: true
47173+
type: boolean
4711647174
tls:
4711747175
$ref: "#/components/schemas/ObservabilityPipelineTls"
4711847176
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)