Skip to content

Commit 773c391

Browse files
author
ci.datadog-api-spec
committed
Regenerate client from commit 2651fb1 of spec repo
1 parent 79d895f commit 773c391

19 files changed

+1586
-11
lines changed

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

Lines changed: 61 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -43973,6 +43973,36 @@ components:
4397343973
type: string
4397443974
x-enum-varnames:
4397543975
- ELASTICSEARCH
43976+
ObservabilityPipelineEnrichmentTableFieldEventLookup:
43977+
description: Specifies an event field path to use as the enrichment table lookup key.
43978+
properties:
43979+
event:
43980+
description: Path to the field in the log event.
43981+
example: log.user.id
43982+
type: string
43983+
required:
43984+
- event
43985+
type: object
43986+
ObservabilityPipelineEnrichmentTableFieldSecretLookup:
43987+
description: Specifies a secret reference to use as the enrichment table lookup key.
43988+
properties:
43989+
secret:
43990+
description: The name of the secret whose value is used as the lookup key.
43991+
example: LOOKUP_KEY_SECRET
43992+
type: string
43993+
required:
43994+
- secret
43995+
type: object
43996+
ObservabilityPipelineEnrichmentTableFieldVrlLookup:
43997+
description: Specifies a VRL expression to compute the enrichment table lookup key.
43998+
properties:
43999+
vrl:
44000+
description: A VRL expression that resolves to the lookup key value.
44001+
example: .user_id
44002+
type: string
44003+
required:
44004+
- vrl
44005+
type: object
4397644006
ObservabilityPipelineEnrichmentTableFile:
4397744007
description: Defines a static enrichment table loaded from a CSV file.
4397844008
properties:
@@ -44023,6 +44053,18 @@ components:
4402344053
type: string
4402444054
x-enum-varnames:
4402544055
- CSV
44056+
ObservabilityPipelineEnrichmentTableFileKeyItemField:
44057+
description: |-
44058+
Specifies the source of the key value used for enrichment table lookups.
44059+
Can be a plain field path string, or an object specifying the lookup type (`event`, `vrl`, or `secret`).
44060+
example: log.user.id
44061+
oneOf:
44062+
- description: A plain field path in the log event.
44063+
example: log.user.id
44064+
type: string
44065+
- $ref: "#/components/schemas/ObservabilityPipelineEnrichmentTableFieldEventLookup"
44066+
- $ref: "#/components/schemas/ObservabilityPipelineEnrichmentTableFieldVrlLookup"
44067+
- $ref: "#/components/schemas/ObservabilityPipelineEnrichmentTableFieldSecretLookup"
4402644068
ObservabilityPipelineEnrichmentTableFileKeyItems:
4402744069
description: Defines how to map log fields to enrichment table columns during lookups.
4402844070
properties:
@@ -44033,9 +44075,7 @@ components:
4403344075
comparison:
4403444076
$ref: "#/components/schemas/ObservabilityPipelineEnrichmentTableFileKeyItemsComparison"
4403544077
field:
44036-
description: The `items` `field`.
44037-
example: log.user.id
44038-
type: string
44078+
$ref: "#/components/schemas/ObservabilityPipelineEnrichmentTableFileKeyItemField"
4403944079
required:
4404044080
- column
4404144081
- comparison
@@ -47056,6 +47096,8 @@ components:
4705647096
description: Name of the environment variable or secret that holds the Splunk HEC token.
4705747097
example: SPLUNK_HEC_TOKEN
4705847098
type: string
47099+
token_strategy:
47100+
$ref: "#/components/schemas/ObservabilityPipelineSplunkHecDestinationTokenStrategy"
4705947101
type:
4706047102
$ref: "#/components/schemas/ObservabilityPipelineSplunkHecDestinationType"
4706147103
required:
@@ -47074,6 +47116,16 @@ components:
4707447116
x-enum-varnames:
4707547117
- JSON
4707647118
- RAW_MESSAGE
47119+
ObservabilityPipelineSplunkHecDestinationTokenStrategy:
47120+
description: Controls how the Splunk HEC token is supplied. Use `custom` to provide a token via `token_key`, or `from_source` to forward the token received from an upstream Splunk HEC source.
47121+
enum:
47122+
- custom
47123+
- from_source
47124+
example: custom
47125+
type: string
47126+
x-enum-varnames:
47127+
- CUSTOM
47128+
- FROM_SOURCE
4707747129
ObservabilityPipelineSplunkHecDestinationType:
4707847130
default: splunk_hec
4707947131
description: The destination type. Always `splunk_hec`.
@@ -47097,6 +47149,12 @@ components:
4709747149
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).
4709847150
example: splunk-hec-source
4709947151
type: string
47152+
store_hec_token:
47153+
description: |-
47154+
When `true`, the Splunk HEC token from the incoming request is stored in the event.
47155+
This allows downstream components to forward the token to other Splunk HEC destinations.
47156+
example: true
47157+
type: boolean
4710047158
tls:
4710147159
$ref: "#/components/schemas/ObservabilityPipelineTls"
4710247160
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)