Skip to content

Commit 03972ae

Browse files
author
ci.datadog-api-spec
committed
Regenerate client from commit 231fe28 of spec repo
1 parent b4baa65 commit 03972ae

7 files changed

Lines changed: 289 additions & 1 deletion

File tree

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

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -77209,6 +77209,13 @@ components:
7720977209
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).
7721077210
example: splunk-tcp-source
7721177211
type: string
77212+
max_connection_duration_secs:
77213+
description: Maximum duration, in seconds, that a connection can remain open before it is closed. When unset, connections can remain open indefinitely.
77214+
example: 3600
77215+
format: int64
77216+
maximum: 9007199254740991
77217+
minimum: 1
77218+
type: integer
7721277219
tls:
7721377220
$ref: "#/components/schemas/ObservabilityPipelineMtlsServerTls"
7721477221
type:

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

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

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

Lines changed: 35 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@
2626
@JsonPropertyOrder({
2727
ObservabilityPipelineSplunkTcpSource.JSON_PROPERTY_ADDRESS_KEY,
2828
ObservabilityPipelineSplunkTcpSource.JSON_PROPERTY_ID,
29+
ObservabilityPipelineSplunkTcpSource.JSON_PROPERTY_MAX_CONNECTION_DURATION_SECS,
2930
ObservabilityPipelineSplunkTcpSource.JSON_PROPERTY_TLS,
3031
ObservabilityPipelineSplunkTcpSource.JSON_PROPERTY_TYPE
3132
})
@@ -39,6 +40,10 @@ public class ObservabilityPipelineSplunkTcpSource {
3940
public static final String JSON_PROPERTY_ID = "id";
4041
private String id;
4142

43+
public static final String JSON_PROPERTY_MAX_CONNECTION_DURATION_SECS =
44+
"max_connection_duration_secs";
45+
private Long maxConnectionDurationSecs;
46+
4247
public static final String JSON_PROPERTY_TLS = "tls";
4348
private ObservabilityPipelineMtlsServerTls tls;
4449

@@ -101,6 +106,29 @@ public void setId(String id) {
101106
this.id = id;
102107
}
103108

109+
public ObservabilityPipelineSplunkTcpSource maxConnectionDurationSecs(
110+
Long maxConnectionDurationSecs) {
111+
this.maxConnectionDurationSecs = maxConnectionDurationSecs;
112+
return this;
113+
}
114+
115+
/**
116+
* Maximum duration, in seconds, that a connection can remain open before it is closed. When
117+
* unset, connections can remain open indefinitely. minimum: 1 maximum: 9007199254740991
118+
*
119+
* @return maxConnectionDurationSecs
120+
*/
121+
@jakarta.annotation.Nullable
122+
@JsonProperty(JSON_PROPERTY_MAX_CONNECTION_DURATION_SECS)
123+
@JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
124+
public Long getMaxConnectionDurationSecs() {
125+
return maxConnectionDurationSecs;
126+
}
127+
128+
public void setMaxConnectionDurationSecs(Long maxConnectionDurationSecs) {
129+
this.maxConnectionDurationSecs = maxConnectionDurationSecs;
130+
}
131+
104132
public ObservabilityPipelineSplunkTcpSource tls(ObservabilityPipelineMtlsServerTls tls) {
105133
this.tls = tls;
106134
this.unparsed |= tls.unparsed;
@@ -210,6 +238,9 @@ public boolean equals(Object o) {
210238
(ObservabilityPipelineSplunkTcpSource) o;
211239
return Objects.equals(this.addressKey, observabilityPipelineSplunkTcpSource.addressKey)
212240
&& Objects.equals(this.id, observabilityPipelineSplunkTcpSource.id)
241+
&& Objects.equals(
242+
this.maxConnectionDurationSecs,
243+
observabilityPipelineSplunkTcpSource.maxConnectionDurationSecs)
213244
&& Objects.equals(this.tls, observabilityPipelineSplunkTcpSource.tls)
214245
&& Objects.equals(this.type, observabilityPipelineSplunkTcpSource.type)
215246
&& Objects.equals(
@@ -218,7 +249,7 @@ public boolean equals(Object o) {
218249

219250
@Override
220251
public int hashCode() {
221-
return Objects.hash(addressKey, id, tls, type, additionalProperties);
252+
return Objects.hash(addressKey, id, maxConnectionDurationSecs, tls, type, additionalProperties);
222253
}
223254

224255
@Override
@@ -227,6 +258,9 @@ public String toString() {
227258
sb.append("class ObservabilityPipelineSplunkTcpSource {\n");
228259
sb.append(" addressKey: ").append(toIndentedString(addressKey)).append("\n");
229260
sb.append(" id: ").append(toIndentedString(id)).append("\n");
261+
sb.append(" maxConnectionDurationSecs: ")
262+
.append(toIndentedString(maxConnectionDurationSecs))
263+
.append("\n");
230264
sb.append(" tls: ").append(toIndentedString(tls)).append("\n");
231265
sb.append(" type: ").append(toIndentedString(type)).append("\n");
232266
sb.append(" additionalProperties: ")

‎src/test/resources/com/datadog/api/client/v2/api/observability_pipelines.feature‎

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -271,6 +271,14 @@ Feature: Observability Pipelines
271271
Then the response status is 200 OK
272272
And the response "errors" has length 0
273273

274+
@team:DataDog/observability-pipelines
275+
Scenario: Validate an observability pipeline with Splunk TCP source max_connection_duration_secs returns "OK" response
276+
Given new "ValidatePipeline" request
277+
And body with value {"data": {"attributes": {"config": {"destinations": [{"id": "datadog-logs-destination", "inputs": ["my-processor-group"], "type": "datadog_logs"}], "processor_groups": [{"enabled": true, "id": "my-processor-group", "include": "service:my-service", "inputs": ["splunk-tcp-source"], "processors": [{"enabled": true, "id": "filter-processor", "include": "status:error", "type": "filter"}]}], "sources": [{"id": "splunk-tcp-source", "type": "splunk_tcp", "max_connection_duration_secs": 3600}]}, "name": "Pipeline with Splunk TCP max connection duration"}, "type": "pipelines"}}
278+
When the request is sent
279+
Then the response status is 200 OK
280+
And the response "errors" has length 0
281+
274282
@team:DataDog/observability-pipelines
275283
Scenario: Validate an observability pipeline with amazon S3 source compression returns "OK" response
276284
Given new "ValidatePipeline" request

‎src/test/resources/generated-test/test-runner-data/manifest.json‎

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7966,6 +7966,13 @@
79667966
"scenario": "Validate an observability pipeline with Splunk HEC source valid_tokens returns \"OK\" response",
79677967
"version": "v2"
79687968
},
7969+
{
7970+
"feature": "Observability Pipelines",
7971+
"feature_file": "../../com/datadog/api/client/v2/api/observability_pipelines.feature",
7972+
"file": "v2/observability-pipelines/validate-an-observability-pipeline-with-splunk-tcp-source-max-connection-duration-secs-returns-ok-response.json",
7973+
"scenario": "Validate an observability pipeline with Splunk TCP source max_connection_duration_secs returns \"OK\" response",
7974+
"version": "v2"
7975+
},
79697976
{
79707977
"feature": "Observability Pipelines",
79717978
"feature_file": "../../com/datadog/api/client/v2/api/observability_pipelines.feature",

‎src/test/resources/generated-test/test-runner-data/v2/observability-pipelines/validate-an-observability-pipeline-with-splunk-tcp-source-max-connection-duration-secs-returns-ok-response.json‎

Lines changed: 69 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,69 @@
1+
{
2+
"api": "ObservabilityPipelines",
3+
"expected_status": 200,
4+
"feature": "Observability Pipelines",
5+
"id": "v2/Observability Pipelines/Validate an observability pipeline with Splunk TCP source max_connection_duration_secs returns \"OK\" response",
6+
"operation_id": "ValidatePipeline",
7+
"request": {
8+
"body": {
9+
"schema": {
10+
"format": null,
11+
"ref": "ObservabilityPipelineSpec",
12+
"type": "object"
13+
},
14+
"source": "inline",
15+
"value": {
16+
"data": {
17+
"attributes": {
18+
"config": {
19+
"destinations": [
20+
{
21+
"id": "datadog-logs-destination",
22+
"inputs": [
23+
"my-processor-group"
24+
],
25+
"type": "datadog_logs"
26+
}
27+
],
28+
"processor_groups": [
29+
{
30+
"enabled": true,
31+
"id": "my-processor-group",
32+
"include": "service:my-service",
33+
"inputs": [
34+
"splunk-tcp-source"
35+
],
36+
"processors": [
37+
{
38+
"enabled": true,
39+
"id": "filter-processor",
40+
"include": "status:error",
41+
"type": "filter"
42+
}
43+
]
44+
}
45+
],
46+
"sources": [
47+
{
48+
"id": "splunk-tcp-source",
49+
"max_connection_duration_secs": 3600,
50+
"type": "splunk_tcp"
51+
}
52+
]
53+
},
54+
"name": "Pipeline with Splunk TCP max connection duration"
55+
},
56+
"type": "pipelines"
57+
}
58+
}
59+
},
60+
"content_type": "application/json",
61+
"method": "POST",
62+
"pagination": false,
63+
"parameters": [],
64+
"path": "/api/v2/obs-pipelines/pipelines/validate"
65+
},
66+
"scenario": "Validate an observability pipeline with Splunk TCP source max_connection_duration_secs returns \"OK\" response",
67+
"schema_version": 1,
68+
"version": "v2"
69+
}

‎src/test/resources/generated-test/test-server-data/v2/observability-pipelines.json‎

Lines changed: 74 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2476,6 +2476,80 @@
24762476
"scenario": "Validate an observability pipeline with Splunk HEC source valid_tokens returns \"OK\" response",
24772477
"version": "v2"
24782478
},
2479+
{
2480+
"feature": "Observability Pipelines",
2481+
"frozen_at": "2026-09-02T13:38:34.105Z",
2482+
"interactions": [
2483+
{
2484+
"request": {
2485+
"body": {
2486+
"type": "json",
2487+
"value": {
2488+
"data": {
2489+
"attributes": {
2490+
"config": {
2491+
"destinations": [
2492+
{
2493+
"id": "datadog-logs-destination",
2494+
"inputs": [
2495+
"my-processor-group"
2496+
],
2497+
"type": "datadog_logs"
2498+
}
2499+
],
2500+
"processor_groups": [
2501+
{
2502+
"enabled": true,
2503+
"id": "my-processor-group",
2504+
"include": "service:my-service",
2505+
"inputs": [
2506+
"splunk-tcp-source"
2507+
],
2508+
"processors": [
2509+
{
2510+
"enabled": true,
2511+
"id": "filter-processor",
2512+
"include": "status:error",
2513+
"type": "filter"
2514+
}
2515+
]
2516+
}
2517+
],
2518+
"sources": [
2519+
{
2520+
"id": "splunk-tcp-source",
2521+
"max_connection_duration_secs": 3600,
2522+
"type": "splunk_tcp"
2523+
}
2524+
]
2525+
},
2526+
"name": "Pipeline with Splunk TCP max connection duration"
2527+
},
2528+
"type": "pipelines"
2529+
}
2530+
}
2531+
},
2532+
"content_type": "application/json",
2533+
"method": "POST",
2534+
"path": "/api/v2/obs-pipelines/pipelines/validate",
2535+
"query": []
2536+
},
2537+
"response": {
2538+
"body": {
2539+
"encoding": "text",
2540+
"value": "{\"errors\":[]}\n"
2541+
},
2542+
"headers": {
2543+
"content-type": "application/vnd.api+json"
2544+
},
2545+
"reason": "OK",
2546+
"status": 200
2547+
}
2548+
}
2549+
],
2550+
"scenario": "Validate an observability pipeline with Splunk TCP source max_connection_duration_secs returns \"OK\" response",
2551+
"version": "v2"
2552+
},
24792553
{
24802554
"feature": "Observability Pipelines",
24812555
"frozen_at": "2026-04-08T12:44:25.060Z",

0 commit comments

Comments
 (0)