getSchemas() {
* ObservabilityPipelineSyslogNgDestination, AzureStorageDestination,
* MicrosoftSentinelDestination, ObservabilityPipelineGoogleChronicleDestination,
* ObservabilityPipelineNewRelicDestination, ObservabilityPipelineSentinelOneDestination,
- * ObservabilityPipelineOpenSearchDestination, ObservabilityPipelineAmazonOpenSearchDestination
+ * ObservabilityPipelineOpenSearchDestination, ObservabilityPipelineAmazonOpenSearchDestination,
+ * ObservabilityPipelineSocketDestination, ObservabilityPipelineAmazonSecurityLakeDestination,
+ * ObservabilityPipelineCrowdStrikeNextGenSiemDestination
*
* It could be an instance of the 'oneOf' schemas. The oneOf child schemas may themselves be a
* composed schema (allOf, anyOf, oneOf).
@@ -1109,6 +1297,25 @@ public void setActualInstance(Object instance) {
super.setActualInstance(instance);
return;
}
+ if (JSON.isInstanceOf(
+ ObservabilityPipelineSocketDestination.class, instance, new HashSet>())) {
+ super.setActualInstance(instance);
+ return;
+ }
+ if (JSON.isInstanceOf(
+ ObservabilityPipelineAmazonSecurityLakeDestination.class,
+ instance,
+ new HashSet>())) {
+ super.setActualInstance(instance);
+ return;
+ }
+ if (JSON.isInstanceOf(
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestination.class,
+ instance,
+ new HashSet>())) {
+ super.setActualInstance(instance);
+ return;
+ }
if (JSON.isInstanceOf(UnparsedObject.class, instance, new HashSet>())) {
super.setActualInstance(instance);
@@ -1127,7 +1334,10 @@ public void setActualInstance(Object instance) {
+ " ObservabilityPipelineNewRelicDestination,"
+ " ObservabilityPipelineSentinelOneDestination,"
+ " ObservabilityPipelineOpenSearchDestination,"
- + " ObservabilityPipelineAmazonOpenSearchDestination");
+ + " ObservabilityPipelineAmazonOpenSearchDestination,"
+ + " ObservabilityPipelineSocketDestination,"
+ + " ObservabilityPipelineAmazonSecurityLakeDestination,"
+ + " ObservabilityPipelineCrowdStrikeNextGenSiemDestination");
}
/**
@@ -1139,7 +1349,9 @@ public void setActualInstance(Object instance) {
* AzureStorageDestination, MicrosoftSentinelDestination,
* ObservabilityPipelineGoogleChronicleDestination, ObservabilityPipelineNewRelicDestination,
* ObservabilityPipelineSentinelOneDestination, ObservabilityPipelineOpenSearchDestination,
- * ObservabilityPipelineAmazonOpenSearchDestination
+ * ObservabilityPipelineAmazonOpenSearchDestination, ObservabilityPipelineSocketDestination,
+ * ObservabilityPipelineAmazonSecurityLakeDestination,
+ * ObservabilityPipelineCrowdStrikeNextGenSiemDestination
*
* @return The actual instance (ObservabilityPipelineDatadogLogsDestination,
* ObservabilityPipelineAmazonS3Destination,
@@ -1150,7 +1362,9 @@ public void setActualInstance(Object instance) {
* MicrosoftSentinelDestination, ObservabilityPipelineGoogleChronicleDestination,
* ObservabilityPipelineNewRelicDestination, ObservabilityPipelineSentinelOneDestination,
* ObservabilityPipelineOpenSearchDestination,
- * ObservabilityPipelineAmazonOpenSearchDestination)
+ * ObservabilityPipelineAmazonOpenSearchDestination, ObservabilityPipelineSocketDestination,
+ * ObservabilityPipelineAmazonSecurityLakeDestination,
+ * ObservabilityPipelineCrowdStrikeNextGenSiemDestination)
*/
@Override
public Object getActualInstance() {
@@ -1344,4 +1558,44 @@ public ObservabilityPipelineOpenSearchDestination getObservabilityPipelineOpenSe
getObservabilityPipelineAmazonOpenSearchDestination() throws ClassCastException {
return (ObservabilityPipelineAmazonOpenSearchDestination) super.getActualInstance();
}
+
+ /**
+ * Get the actual instance of `ObservabilityPipelineSocketDestination`. If the actual instance is
+ * not `ObservabilityPipelineSocketDestination`, the ClassCastException will be thrown.
+ *
+ * @return The actual instance of `ObservabilityPipelineSocketDestination`
+ * @throws ClassCastException if the instance is not `ObservabilityPipelineSocketDestination`
+ */
+ public ObservabilityPipelineSocketDestination getObservabilityPipelineSocketDestination()
+ throws ClassCastException {
+ return (ObservabilityPipelineSocketDestination) super.getActualInstance();
+ }
+
+ /**
+ * Get the actual instance of `ObservabilityPipelineAmazonSecurityLakeDestination`. If the actual
+ * instance is not `ObservabilityPipelineAmazonSecurityLakeDestination`, the ClassCastException
+ * will be thrown.
+ *
+ * @return The actual instance of `ObservabilityPipelineAmazonSecurityLakeDestination`
+ * @throws ClassCastException if the instance is not
+ * `ObservabilityPipelineAmazonSecurityLakeDestination`
+ */
+ public ObservabilityPipelineAmazonSecurityLakeDestination
+ getObservabilityPipelineAmazonSecurityLakeDestination() throws ClassCastException {
+ return (ObservabilityPipelineAmazonSecurityLakeDestination) super.getActualInstance();
+ }
+
+ /**
+ * Get the actual instance of `ObservabilityPipelineCrowdStrikeNextGenSiemDestination`. If the
+ * actual instance is not `ObservabilityPipelineCrowdStrikeNextGenSiemDestination`, the
+ * ClassCastException will be thrown.
+ *
+ * @return The actual instance of `ObservabilityPipelineCrowdStrikeNextGenSiemDestination`
+ * @throws ClassCastException if the instance is not
+ * `ObservabilityPipelineCrowdStrikeNextGenSiemDestination`
+ */
+ public ObservabilityPipelineCrowdStrikeNextGenSiemDestination
+ getObservabilityPipelineCrowdStrikeNextGenSiemDestination() throws ClassCastException {
+ return (ObservabilityPipelineCrowdStrikeNextGenSiemDestination) super.getActualInstance();
+ }
}
diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineConfigProcessorItem.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineConfigProcessorItem.java
index 18000ccfacd..3ec77e02e20 100644
--- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineConfigProcessorItem.java
+++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineConfigProcessorItem.java
@@ -902,6 +902,106 @@ public ObservabilityPipelineConfigProcessorItem deserialize(
e);
}
+ // deserialize ObservabilityPipelineCustomProcessor
+ try {
+ boolean attemptParsing = true;
+ // ensure that we respect type coercion as set on the client ObjectMapper
+ if (ObservabilityPipelineCustomProcessor.class.equals(Integer.class)
+ || ObservabilityPipelineCustomProcessor.class.equals(Long.class)
+ || ObservabilityPipelineCustomProcessor.class.equals(Float.class)
+ || ObservabilityPipelineCustomProcessor.class.equals(Double.class)
+ || ObservabilityPipelineCustomProcessor.class.equals(Boolean.class)
+ || ObservabilityPipelineCustomProcessor.class.equals(String.class)) {
+ attemptParsing = typeCoercion;
+ if (!attemptParsing) {
+ attemptParsing |=
+ ((ObservabilityPipelineCustomProcessor.class.equals(Integer.class)
+ || ObservabilityPipelineCustomProcessor.class.equals(Long.class))
+ && token == JsonToken.VALUE_NUMBER_INT);
+ attemptParsing |=
+ ((ObservabilityPipelineCustomProcessor.class.equals(Float.class)
+ || ObservabilityPipelineCustomProcessor.class.equals(Double.class))
+ && (token == JsonToken.VALUE_NUMBER_FLOAT
+ || token == JsonToken.VALUE_NUMBER_INT));
+ attemptParsing |=
+ (ObservabilityPipelineCustomProcessor.class.equals(Boolean.class)
+ && (token == JsonToken.VALUE_FALSE || token == JsonToken.VALUE_TRUE));
+ attemptParsing |=
+ (ObservabilityPipelineCustomProcessor.class.equals(String.class)
+ && token == JsonToken.VALUE_STRING);
+ }
+ }
+ if (attemptParsing) {
+ tmp =
+ tree.traverse(jp.getCodec()).readValueAs(ObservabilityPipelineCustomProcessor.class);
+ // TODO: there is no validation against JSON schema constraints
+ // (min, max, enum, pattern...), this does not perform a strict JSON
+ // validation, which means the 'match' count may be higher than it should be.
+ if (!((ObservabilityPipelineCustomProcessor) tmp).unparsed) {
+ deserialized = tmp;
+ match++;
+ }
+ log.log(Level.FINER, "Input data matches schema 'ObservabilityPipelineCustomProcessor'");
+ }
+ } catch (Exception e) {
+ // deserialization failed, continue
+ log.log(
+ Level.FINER,
+ "Input data does not match schema 'ObservabilityPipelineCustomProcessor'",
+ e);
+ }
+
+ // deserialize ObservabilityPipelineDatadogTagsProcessor
+ try {
+ boolean attemptParsing = true;
+ // ensure that we respect type coercion as set on the client ObjectMapper
+ if (ObservabilityPipelineDatadogTagsProcessor.class.equals(Integer.class)
+ || ObservabilityPipelineDatadogTagsProcessor.class.equals(Long.class)
+ || ObservabilityPipelineDatadogTagsProcessor.class.equals(Float.class)
+ || ObservabilityPipelineDatadogTagsProcessor.class.equals(Double.class)
+ || ObservabilityPipelineDatadogTagsProcessor.class.equals(Boolean.class)
+ || ObservabilityPipelineDatadogTagsProcessor.class.equals(String.class)) {
+ attemptParsing = typeCoercion;
+ if (!attemptParsing) {
+ attemptParsing |=
+ ((ObservabilityPipelineDatadogTagsProcessor.class.equals(Integer.class)
+ || ObservabilityPipelineDatadogTagsProcessor.class.equals(Long.class))
+ && token == JsonToken.VALUE_NUMBER_INT);
+ attemptParsing |=
+ ((ObservabilityPipelineDatadogTagsProcessor.class.equals(Float.class)
+ || ObservabilityPipelineDatadogTagsProcessor.class.equals(Double.class))
+ && (token == JsonToken.VALUE_NUMBER_FLOAT
+ || token == JsonToken.VALUE_NUMBER_INT));
+ attemptParsing |=
+ (ObservabilityPipelineDatadogTagsProcessor.class.equals(Boolean.class)
+ && (token == JsonToken.VALUE_FALSE || token == JsonToken.VALUE_TRUE));
+ attemptParsing |=
+ (ObservabilityPipelineDatadogTagsProcessor.class.equals(String.class)
+ && token == JsonToken.VALUE_STRING);
+ }
+ }
+ if (attemptParsing) {
+ tmp =
+ tree.traverse(jp.getCodec())
+ .readValueAs(ObservabilityPipelineDatadogTagsProcessor.class);
+ // TODO: there is no validation against JSON schema constraints
+ // (min, max, enum, pattern...), this does not perform a strict JSON
+ // validation, which means the 'match' count may be higher than it should be.
+ if (!((ObservabilityPipelineDatadogTagsProcessor) tmp).unparsed) {
+ deserialized = tmp;
+ match++;
+ }
+ log.log(
+ Level.FINER, "Input data matches schema 'ObservabilityPipelineDatadogTagsProcessor'");
+ }
+ } catch (Exception e) {
+ // deserialization failed, continue
+ log.log(
+ Level.FINER,
+ "Input data does not match schema 'ObservabilityPipelineDatadogTagsProcessor'",
+ e);
+ }
+
ObservabilityPipelineConfigProcessorItem ret = new ObservabilityPipelineConfigProcessorItem();
if (match == 1) {
ret.setActualInstance(deserialized);
@@ -1013,6 +1113,16 @@ public ObservabilityPipelineConfigProcessorItem(ObservabilityPipelineThrottlePro
setActualInstance(o);
}
+ public ObservabilityPipelineConfigProcessorItem(ObservabilityPipelineCustomProcessor o) {
+ super("oneOf", Boolean.FALSE);
+ setActualInstance(o);
+ }
+
+ public ObservabilityPipelineConfigProcessorItem(ObservabilityPipelineDatadogTagsProcessor o) {
+ super("oneOf", Boolean.FALSE);
+ setActualInstance(o);
+ }
+
static {
schemas.put(
"ObservabilityPipelineFilterProcessor",
@@ -1062,6 +1172,12 @@ public ObservabilityPipelineConfigProcessorItem(ObservabilityPipelineThrottlePro
schemas.put(
"ObservabilityPipelineThrottleProcessor",
new GenericType() {});
+ schemas.put(
+ "ObservabilityPipelineCustomProcessor",
+ new GenericType() {});
+ schemas.put(
+ "ObservabilityPipelineDatadogTagsProcessor",
+ new GenericType() {});
JSON.registerDescendants(
ObservabilityPipelineConfigProcessorItem.class, Collections.unmodifiableMap(schemas));
}
@@ -1081,7 +1197,8 @@ public Map getSchemas() {
* ObservabilityPipelineSensitiveDataScannerProcessor, ObservabilityPipelineOcsfMapperProcessor,
* ObservabilityPipelineAddEnvVarsProcessor, ObservabilityPipelineDedupeProcessor,
* ObservabilityPipelineEnrichmentTableProcessor, ObservabilityPipelineReduceProcessor,
- * ObservabilityPipelineThrottleProcessor
+ * ObservabilityPipelineThrottleProcessor, ObservabilityPipelineCustomProcessor,
+ * ObservabilityPipelineDatadogTagsProcessor
*
* It could be an instance of the 'oneOf' schemas. The oneOf child schemas may themselves be a
* composed schema (allOf, anyOf, oneOf).
@@ -1170,6 +1287,16 @@ public void setActualInstance(Object instance) {
super.setActualInstance(instance);
return;
}
+ if (JSON.isInstanceOf(
+ ObservabilityPipelineCustomProcessor.class, instance, new HashSet>())) {
+ super.setActualInstance(instance);
+ return;
+ }
+ if (JSON.isInstanceOf(
+ ObservabilityPipelineDatadogTagsProcessor.class, instance, new HashSet>())) {
+ super.setActualInstance(instance);
+ return;
+ }
if (JSON.isInstanceOf(UnparsedObject.class, instance, new HashSet>())) {
super.setActualInstance(instance);
@@ -1187,7 +1314,8 @@ public void setActualInstance(Object instance) {
+ " ObservabilityPipelineOcsfMapperProcessor, ObservabilityPipelineAddEnvVarsProcessor,"
+ " ObservabilityPipelineDedupeProcessor,"
+ " ObservabilityPipelineEnrichmentTableProcessor,"
- + " ObservabilityPipelineReduceProcessor, ObservabilityPipelineThrottleProcessor");
+ + " ObservabilityPipelineReduceProcessor, ObservabilityPipelineThrottleProcessor,"
+ + " ObservabilityPipelineCustomProcessor, ObservabilityPipelineDatadogTagsProcessor");
}
/**
@@ -1199,7 +1327,8 @@ public void setActualInstance(Object instance) {
* ObservabilityPipelineSensitiveDataScannerProcessor, ObservabilityPipelineOcsfMapperProcessor,
* ObservabilityPipelineAddEnvVarsProcessor, ObservabilityPipelineDedupeProcessor,
* ObservabilityPipelineEnrichmentTableProcessor, ObservabilityPipelineReduceProcessor,
- * ObservabilityPipelineThrottleProcessor
+ * ObservabilityPipelineThrottleProcessor, ObservabilityPipelineCustomProcessor,
+ * ObservabilityPipelineDatadogTagsProcessor
*
* @return The actual instance (ObservabilityPipelineFilterProcessor,
* ObservabilityPipelineParseJSONProcessor, ObservabilityPipelineQuotaProcessor,
@@ -1209,7 +1338,8 @@ public void setActualInstance(Object instance) {
* ObservabilityPipelineSensitiveDataScannerProcessor,
* ObservabilityPipelineOcsfMapperProcessor, ObservabilityPipelineAddEnvVarsProcessor,
* ObservabilityPipelineDedupeProcessor, ObservabilityPipelineEnrichmentTableProcessor,
- * ObservabilityPipelineReduceProcessor, ObservabilityPipelineThrottleProcessor)
+ * ObservabilityPipelineReduceProcessor, ObservabilityPipelineThrottleProcessor,
+ * ObservabilityPipelineCustomProcessor, ObservabilityPipelineDatadogTagsProcessor)
*/
@Override
public Object getActualInstance() {
@@ -1413,4 +1543,28 @@ public ObservabilityPipelineThrottleProcessor getObservabilityPipelineThrottlePr
throws ClassCastException {
return (ObservabilityPipelineThrottleProcessor) super.getActualInstance();
}
+
+ /**
+ * Get the actual instance of `ObservabilityPipelineCustomProcessor`. If the actual instance is
+ * not `ObservabilityPipelineCustomProcessor`, the ClassCastException will be thrown.
+ *
+ * @return The actual instance of `ObservabilityPipelineCustomProcessor`
+ * @throws ClassCastException if the instance is not `ObservabilityPipelineCustomProcessor`
+ */
+ public ObservabilityPipelineCustomProcessor getObservabilityPipelineCustomProcessor()
+ throws ClassCastException {
+ return (ObservabilityPipelineCustomProcessor) super.getActualInstance();
+ }
+
+ /**
+ * Get the actual instance of `ObservabilityPipelineDatadogTagsProcessor`. If the actual instance
+ * is not `ObservabilityPipelineDatadogTagsProcessor`, the ClassCastException will be thrown.
+ *
+ * @return The actual instance of `ObservabilityPipelineDatadogTagsProcessor`
+ * @throws ClassCastException if the instance is not `ObservabilityPipelineDatadogTagsProcessor`
+ */
+ public ObservabilityPipelineDatadogTagsProcessor getObservabilityPipelineDatadogTagsProcessor()
+ throws ClassCastException {
+ return (ObservabilityPipelineDatadogTagsProcessor) super.getActualInstance();
+ }
}
diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineConfigSourceItem.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineConfigSourceItem.java
index 0ed0198745a..58c17babac0 100644
--- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineConfigSourceItem.java
+++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineConfigSourceItem.java
@@ -823,6 +823,52 @@ public ObservabilityPipelineConfigSourceItem deserialize(
e);
}
+ // deserialize ObservabilityPipelineSocketSource
+ try {
+ boolean attemptParsing = true;
+ // ensure that we respect type coercion as set on the client ObjectMapper
+ if (ObservabilityPipelineSocketSource.class.equals(Integer.class)
+ || ObservabilityPipelineSocketSource.class.equals(Long.class)
+ || ObservabilityPipelineSocketSource.class.equals(Float.class)
+ || ObservabilityPipelineSocketSource.class.equals(Double.class)
+ || ObservabilityPipelineSocketSource.class.equals(Boolean.class)
+ || ObservabilityPipelineSocketSource.class.equals(String.class)) {
+ attemptParsing = typeCoercion;
+ if (!attemptParsing) {
+ attemptParsing |=
+ ((ObservabilityPipelineSocketSource.class.equals(Integer.class)
+ || ObservabilityPipelineSocketSource.class.equals(Long.class))
+ && token == JsonToken.VALUE_NUMBER_INT);
+ attemptParsing |=
+ ((ObservabilityPipelineSocketSource.class.equals(Float.class)
+ || ObservabilityPipelineSocketSource.class.equals(Double.class))
+ && (token == JsonToken.VALUE_NUMBER_FLOAT
+ || token == JsonToken.VALUE_NUMBER_INT));
+ attemptParsing |=
+ (ObservabilityPipelineSocketSource.class.equals(Boolean.class)
+ && (token == JsonToken.VALUE_FALSE || token == JsonToken.VALUE_TRUE));
+ attemptParsing |=
+ (ObservabilityPipelineSocketSource.class.equals(String.class)
+ && token == JsonToken.VALUE_STRING);
+ }
+ }
+ if (attemptParsing) {
+ tmp = tree.traverse(jp.getCodec()).readValueAs(ObservabilityPipelineSocketSource.class);
+ // TODO: there is no validation against JSON schema constraints
+ // (min, max, enum, pattern...), this does not perform a strict JSON
+ // validation, which means the 'match' count may be higher than it should be.
+ if (!((ObservabilityPipelineSocketSource) tmp).unparsed) {
+ deserialized = tmp;
+ match++;
+ }
+ log.log(Level.FINER, "Input data matches schema 'ObservabilityPipelineSocketSource'");
+ }
+ } catch (Exception e) {
+ // deserialization failed, continue
+ log.log(
+ Level.FINER, "Input data does not match schema 'ObservabilityPipelineSocketSource'", e);
+ }
+
ObservabilityPipelineConfigSourceItem ret = new ObservabilityPipelineConfigSourceItem();
if (match == 1) {
ret.setActualInstance(deserialized);
@@ -928,6 +974,11 @@ public ObservabilityPipelineConfigSourceItem(ObservabilityPipelineLogstashSource
setActualInstance(o);
}
+ public ObservabilityPipelineConfigSourceItem(ObservabilityPipelineSocketSource o) {
+ super("oneOf", Boolean.FALSE);
+ setActualInstance(o);
+ }
+
static {
schemas.put(
"ObservabilityPipelineKafkaSource", new GenericType() {});
@@ -973,6 +1024,9 @@ public ObservabilityPipelineConfigSourceItem(ObservabilityPipelineLogstashSource
schemas.put(
"ObservabilityPipelineLogstashSource",
new GenericType() {});
+ schemas.put(
+ "ObservabilityPipelineSocketSource",
+ new GenericType() {});
JSON.registerDescendants(
ObservabilityPipelineConfigSourceItem.class, Collections.unmodifiableMap(schemas));
}
@@ -991,7 +1045,8 @@ public Map getSchemas() {
* ObservabilityPipelineHttpServerSource, ObservabilityPipelineSumoLogicSource,
* ObservabilityPipelineRsyslogSource, ObservabilityPipelineSyslogNgSource,
* ObservabilityPipelineAmazonDataFirehoseSource, ObservabilityPipelineGooglePubSubSource,
- * ObservabilityPipelineHttpClientSource, ObservabilityPipelineLogstashSource
+ * ObservabilityPipelineHttpClientSource, ObservabilityPipelineLogstashSource,
+ * ObservabilityPipelineSocketSource
*
* It could be an instance of the 'oneOf' schemas. The oneOf child schemas may themselves be a
* composed schema (allOf, anyOf, oneOf).
@@ -1073,6 +1128,11 @@ public void setActualInstance(Object instance) {
super.setActualInstance(instance);
return;
}
+ if (JSON.isInstanceOf(
+ ObservabilityPipelineSocketSource.class, instance, new HashSet>())) {
+ super.setActualInstance(instance);
+ return;
+ }
if (JSON.isInstanceOf(UnparsedObject.class, instance, new HashSet>())) {
super.setActualInstance(instance);
@@ -1087,7 +1147,7 @@ public void setActualInstance(Object instance) {
+ " ObservabilityPipelineRsyslogSource, ObservabilityPipelineSyslogNgSource,"
+ " ObservabilityPipelineAmazonDataFirehoseSource,"
+ " ObservabilityPipelineGooglePubSubSource, ObservabilityPipelineHttpClientSource,"
- + " ObservabilityPipelineLogstashSource");
+ + " ObservabilityPipelineLogstashSource, ObservabilityPipelineSocketSource");
}
/**
@@ -1098,7 +1158,8 @@ public void setActualInstance(Object instance) {
* ObservabilityPipelineHttpServerSource, ObservabilityPipelineSumoLogicSource,
* ObservabilityPipelineRsyslogSource, ObservabilityPipelineSyslogNgSource,
* ObservabilityPipelineAmazonDataFirehoseSource, ObservabilityPipelineGooglePubSubSource,
- * ObservabilityPipelineHttpClientSource, ObservabilityPipelineLogstashSource
+ * ObservabilityPipelineHttpClientSource, ObservabilityPipelineLogstashSource,
+ * ObservabilityPipelineSocketSource
*
* @return The actual instance (ObservabilityPipelineKafkaSource,
* ObservabilityPipelineDatadogAgentSource, ObservabilityPipelineSplunkTcpSource,
@@ -1107,7 +1168,8 @@ public void setActualInstance(Object instance) {
* ObservabilityPipelineHttpServerSource, ObservabilityPipelineSumoLogicSource,
* ObservabilityPipelineRsyslogSource, ObservabilityPipelineSyslogNgSource,
* ObservabilityPipelineAmazonDataFirehoseSource, ObservabilityPipelineGooglePubSubSource,
- * ObservabilityPipelineHttpClientSource, ObservabilityPipelineLogstashSource)
+ * ObservabilityPipelineHttpClientSource, ObservabilityPipelineLogstashSource,
+ * ObservabilityPipelineSocketSource)
*/
@Override
public Object getActualInstance() {
@@ -1295,4 +1357,16 @@ public ObservabilityPipelineLogstashSource getObservabilityPipelineLogstashSourc
throws ClassCastException {
return (ObservabilityPipelineLogstashSource) super.getActualInstance();
}
+
+ /**
+ * Get the actual instance of `ObservabilityPipelineSocketSource`. If the actual instance is not
+ * `ObservabilityPipelineSocketSource`, the ClassCastException will be thrown.
+ *
+ * @return The actual instance of `ObservabilityPipelineSocketSource`
+ * @throws ClassCastException if the instance is not `ObservabilityPipelineSocketSource`
+ */
+ public ObservabilityPipelineSocketSource getObservabilityPipelineSocketSource()
+ throws ClassCastException {
+ return (ObservabilityPipelineSocketSource) super.getActualInstance();
+ }
}
diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineCrowdStrikeNextGenSiemDestination.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineCrowdStrikeNextGenSiemDestination.java
new file mode 100644
index 00000000000..5709d5ab340
--- /dev/null
+++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineCrowdStrikeNextGenSiemDestination.java
@@ -0,0 +1,323 @@
+/*
+ * Unless explicitly stated otherwise all files in this repository are licensed under the Apache-2.0 License.
+ * This product includes software developed at Datadog (https://www.datadoghq.com/).
+ * Copyright 2019-Present Datadog, Inc.
+ */
+
+package com.datadog.api.client.v2.model;
+
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonPropertyOrder;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+
+/**
+ * The crowdstrike_next_gen_siem destination forwards logs to CrowdStrike Next Gen
+ * SIEM.
+ */
+@JsonPropertyOrder({
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestination.JSON_PROPERTY_COMPRESSION,
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestination.JSON_PROPERTY_ENCODING,
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestination.JSON_PROPERTY_ID,
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestination.JSON_PROPERTY_INPUTS,
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestination.JSON_PROPERTY_TLS,
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestination.JSON_PROPERTY_TYPE
+})
+@jakarta.annotation.Generated(
+ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator")
+public class ObservabilityPipelineCrowdStrikeNextGenSiemDestination {
+ @JsonIgnore public boolean unparsed = false;
+ public static final String JSON_PROPERTY_COMPRESSION = "compression";
+ private ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompression compression;
+
+ public static final String JSON_PROPERTY_ENCODING = "encoding";
+ private ObservabilityPipelineCrowdStrikeNextGenSiemDestinationEncoding encoding;
+
+ public static final String JSON_PROPERTY_ID = "id";
+ private String id;
+
+ public static final String JSON_PROPERTY_INPUTS = "inputs";
+ private List inputs = new ArrayList<>();
+
+ public static final String JSON_PROPERTY_TLS = "tls";
+ private ObservabilityPipelineTls tls;
+
+ public static final String JSON_PROPERTY_TYPE = "type";
+ private ObservabilityPipelineCrowdStrikeNextGenSiemDestinationType type =
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestinationType.CROWDSTRIKE_NEXT_GEN_SIEM;
+
+ public ObservabilityPipelineCrowdStrikeNextGenSiemDestination() {}
+
+ @JsonCreator
+ public ObservabilityPipelineCrowdStrikeNextGenSiemDestination(
+ @JsonProperty(required = true, value = JSON_PROPERTY_ENCODING)
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestinationEncoding encoding,
+ @JsonProperty(required = true, value = JSON_PROPERTY_ID) String id,
+ @JsonProperty(required = true, value = JSON_PROPERTY_INPUTS) List inputs,
+ @JsonProperty(required = true, value = JSON_PROPERTY_TYPE)
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestinationType type) {
+ this.encoding = encoding;
+ this.unparsed |= !encoding.isValid();
+ this.id = id;
+ this.inputs = inputs;
+ this.type = type;
+ this.unparsed |= !type.isValid();
+ }
+
+ public ObservabilityPipelineCrowdStrikeNextGenSiemDestination compression(
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompression compression) {
+ this.compression = compression;
+ this.unparsed |= compression.unparsed;
+ return this;
+ }
+
+ /**
+ * Compression configuration for log events.
+ *
+ * @return compression
+ */
+ @jakarta.annotation.Nullable
+ @JsonProperty(JSON_PROPERTY_COMPRESSION)
+ @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
+ public ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompression getCompression() {
+ return compression;
+ }
+
+ public void setCompression(
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompression compression) {
+ this.compression = compression;
+ }
+
+ public ObservabilityPipelineCrowdStrikeNextGenSiemDestination encoding(
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestinationEncoding encoding) {
+ this.encoding = encoding;
+ this.unparsed |= !encoding.isValid();
+ return this;
+ }
+
+ /**
+ * Encoding format for log events.
+ *
+ * @return encoding
+ */
+ @JsonProperty(JSON_PROPERTY_ENCODING)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public ObservabilityPipelineCrowdStrikeNextGenSiemDestinationEncoding getEncoding() {
+ return encoding;
+ }
+
+ public void setEncoding(ObservabilityPipelineCrowdStrikeNextGenSiemDestinationEncoding encoding) {
+ if (!encoding.isValid()) {
+ this.unparsed = true;
+ }
+ this.encoding = encoding;
+ }
+
+ public ObservabilityPipelineCrowdStrikeNextGenSiemDestination id(String id) {
+ this.id = id;
+ return this;
+ }
+
+ /**
+ * The unique identifier for this component.
+ *
+ * @return id
+ */
+ @JsonProperty(JSON_PROPERTY_ID)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public String getId() {
+ return id;
+ }
+
+ public void setId(String id) {
+ this.id = id;
+ }
+
+ public ObservabilityPipelineCrowdStrikeNextGenSiemDestination inputs(List inputs) {
+ this.inputs = inputs;
+ return this;
+ }
+
+ public ObservabilityPipelineCrowdStrikeNextGenSiemDestination addInputsItem(String inputsItem) {
+ this.inputs.add(inputsItem);
+ return this;
+ }
+
+ /**
+ * A list of component IDs whose output is used as the input for this component.
+ *
+ * @return inputs
+ */
+ @JsonProperty(JSON_PROPERTY_INPUTS)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public List getInputs() {
+ return inputs;
+ }
+
+ public void setInputs(List inputs) {
+ this.inputs = inputs;
+ }
+
+ public ObservabilityPipelineCrowdStrikeNextGenSiemDestination tls(ObservabilityPipelineTls tls) {
+ this.tls = tls;
+ this.unparsed |= tls.unparsed;
+ return this;
+ }
+
+ /**
+ * Configuration for enabling TLS encryption between the pipeline component and external services.
+ *
+ * @return tls
+ */
+ @jakarta.annotation.Nullable
+ @JsonProperty(JSON_PROPERTY_TLS)
+ @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
+ public ObservabilityPipelineTls getTls() {
+ return tls;
+ }
+
+ public void setTls(ObservabilityPipelineTls tls) {
+ this.tls = tls;
+ }
+
+ public ObservabilityPipelineCrowdStrikeNextGenSiemDestination type(
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestinationType type) {
+ this.type = type;
+ this.unparsed |= !type.isValid();
+ return this;
+ }
+
+ /**
+ * The destination type. The value should always be crowdstrike_next_gen_siem.
+ *
+ * @return type
+ */
+ @JsonProperty(JSON_PROPERTY_TYPE)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public ObservabilityPipelineCrowdStrikeNextGenSiemDestinationType getType() {
+ return type;
+ }
+
+ public void setType(ObservabilityPipelineCrowdStrikeNextGenSiemDestinationType type) {
+ if (!type.isValid()) {
+ this.unparsed = true;
+ }
+ this.type = type;
+ }
+
+ /**
+ * A container for additional, undeclared properties. This is a holder for any undeclared
+ * properties as specified with the 'additionalProperties' keyword in the OAS document.
+ */
+ private Map additionalProperties;
+
+ /**
+ * Set the additional (undeclared) property with the specified name and value. If the property
+ * does not already exist, create it otherwise replace it.
+ *
+ * @param key The arbitrary key to set
+ * @param value The associated value
+ * @return ObservabilityPipelineCrowdStrikeNextGenSiemDestination
+ */
+ @JsonAnySetter
+ public ObservabilityPipelineCrowdStrikeNextGenSiemDestination putAdditionalProperty(
+ String key, Object value) {
+ if (this.additionalProperties == null) {
+ this.additionalProperties = new HashMap();
+ }
+ this.additionalProperties.put(key, value);
+ return this;
+ }
+
+ /**
+ * Return the additional (undeclared) property.
+ *
+ * @return The additional properties
+ */
+ @JsonAnyGetter
+ public Map getAdditionalProperties() {
+ return additionalProperties;
+ }
+
+ /**
+ * Return the additional (undeclared) property with the specified name.
+ *
+ * @param key The arbitrary key to get
+ * @return The specific additional property for the given key
+ */
+ public Object getAdditionalProperty(String key) {
+ if (this.additionalProperties == null) {
+ return null;
+ }
+ return this.additionalProperties.get(key);
+ }
+
+ /**
+ * Return true if this ObservabilityPipelineCrowdStrikeNextGenSiemDestination object is equal to
+ * o.
+ */
+ @Override
+ public boolean equals(Object o) {
+ if (this == o) {
+ return true;
+ }
+ if (o == null || getClass() != o.getClass()) {
+ return false;
+ }
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestination
+ observabilityPipelineCrowdStrikeNextGenSiemDestination =
+ (ObservabilityPipelineCrowdStrikeNextGenSiemDestination) o;
+ return Objects.equals(
+ this.compression, observabilityPipelineCrowdStrikeNextGenSiemDestination.compression)
+ && Objects.equals(
+ this.encoding, observabilityPipelineCrowdStrikeNextGenSiemDestination.encoding)
+ && Objects.equals(this.id, observabilityPipelineCrowdStrikeNextGenSiemDestination.id)
+ && Objects.equals(
+ this.inputs, observabilityPipelineCrowdStrikeNextGenSiemDestination.inputs)
+ && Objects.equals(this.tls, observabilityPipelineCrowdStrikeNextGenSiemDestination.tls)
+ && Objects.equals(this.type, observabilityPipelineCrowdStrikeNextGenSiemDestination.type)
+ && Objects.equals(
+ this.additionalProperties,
+ observabilityPipelineCrowdStrikeNextGenSiemDestination.additionalProperties);
+ }
+
+ @Override
+ public int hashCode() {
+ return Objects.hash(compression, encoding, id, inputs, tls, type, additionalProperties);
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder();
+ sb.append("class ObservabilityPipelineCrowdStrikeNextGenSiemDestination {\n");
+ sb.append(" compression: ").append(toIndentedString(compression)).append("\n");
+ sb.append(" encoding: ").append(toIndentedString(encoding)).append("\n");
+ sb.append(" id: ").append(toIndentedString(id)).append("\n");
+ sb.append(" inputs: ").append(toIndentedString(inputs)).append("\n");
+ sb.append(" tls: ").append(toIndentedString(tls)).append("\n");
+ sb.append(" type: ").append(toIndentedString(type)).append("\n");
+ sb.append(" additionalProperties: ")
+ .append(toIndentedString(additionalProperties))
+ .append("\n");
+ sb.append('}');
+ return sb.toString();
+ }
+
+ /**
+ * Convert the given object to string with each line indented by 4 spaces (except the first line).
+ */
+ private String toIndentedString(Object o) {
+ if (o == null) {
+ return "null";
+ }
+ return o.toString().replace("\n", "\n ");
+ }
+}
diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompression.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompression.java
new file mode 100644
index 00000000000..de48e9f4a5b
--- /dev/null
+++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompression.java
@@ -0,0 +1,191 @@
+/*
+ * Unless explicitly stated otherwise all files in this repository are licensed under the Apache-2.0 License.
+ * This product includes software developed at Datadog (https://www.datadoghq.com/).
+ * Copyright 2019-Present Datadog, Inc.
+ */
+
+package com.datadog.api.client.v2.model;
+
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonPropertyOrder;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Objects;
+
+/** Compression configuration for log events. */
+@JsonPropertyOrder({
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompression.JSON_PROPERTY_ALGORITHM,
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompression.JSON_PROPERTY_LEVEL
+})
+@jakarta.annotation.Generated(
+ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator")
+public class ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompression {
+ @JsonIgnore public boolean unparsed = false;
+ public static final String JSON_PROPERTY_ALGORITHM = "algorithm";
+ private ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompressionAlgorithm algorithm;
+
+ public static final String JSON_PROPERTY_LEVEL = "level";
+ private Long level;
+
+ public ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompression() {}
+
+ @JsonCreator
+ public ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompression(
+ @JsonProperty(required = true, value = JSON_PROPERTY_ALGORITHM)
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompressionAlgorithm algorithm) {
+ this.algorithm = algorithm;
+ this.unparsed |= !algorithm.isValid();
+ }
+
+ public ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompression algorithm(
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompressionAlgorithm algorithm) {
+ this.algorithm = algorithm;
+ this.unparsed |= !algorithm.isValid();
+ return this;
+ }
+
+ /**
+ * Compression algorithm for log events.
+ *
+ * @return algorithm
+ */
+ @JsonProperty(JSON_PROPERTY_ALGORITHM)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompressionAlgorithm getAlgorithm() {
+ return algorithm;
+ }
+
+ public void setAlgorithm(
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompressionAlgorithm algorithm) {
+ if (!algorithm.isValid()) {
+ this.unparsed = true;
+ }
+ this.algorithm = algorithm;
+ }
+
+ public ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompression level(Long level) {
+ this.level = level;
+ return this;
+ }
+
+ /**
+ * Compression level.
+ *
+ * @return level
+ */
+ @jakarta.annotation.Nullable
+ @JsonProperty(JSON_PROPERTY_LEVEL)
+ @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
+ public Long getLevel() {
+ return level;
+ }
+
+ public void setLevel(Long level) {
+ this.level = level;
+ }
+
+ /**
+ * A container for additional, undeclared properties. This is a holder for any undeclared
+ * properties as specified with the 'additionalProperties' keyword in the OAS document.
+ */
+ private Map additionalProperties;
+
+ /**
+ * Set the additional (undeclared) property with the specified name and value. If the property
+ * does not already exist, create it otherwise replace it.
+ *
+ * @param key The arbitrary key to set
+ * @param value The associated value
+ * @return ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompression
+ */
+ @JsonAnySetter
+ public ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompression putAdditionalProperty(
+ String key, Object value) {
+ if (this.additionalProperties == null) {
+ this.additionalProperties = new HashMap();
+ }
+ this.additionalProperties.put(key, value);
+ return this;
+ }
+
+ /**
+ * Return the additional (undeclared) property.
+ *
+ * @return The additional properties
+ */
+ @JsonAnyGetter
+ public Map getAdditionalProperties() {
+ return additionalProperties;
+ }
+
+ /**
+ * Return the additional (undeclared) property with the specified name.
+ *
+ * @param key The arbitrary key to get
+ * @return The specific additional property for the given key
+ */
+ public Object getAdditionalProperty(String key) {
+ if (this.additionalProperties == null) {
+ return null;
+ }
+ return this.additionalProperties.get(key);
+ }
+
+ /**
+ * Return true if this ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompression object is
+ * equal to o.
+ */
+ @Override
+ public boolean equals(Object o) {
+ if (this == o) {
+ return true;
+ }
+ if (o == null || getClass() != o.getClass()) {
+ return false;
+ }
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompression
+ observabilityPipelineCrowdStrikeNextGenSiemDestinationCompression =
+ (ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompression) o;
+ return Objects.equals(
+ this.algorithm,
+ observabilityPipelineCrowdStrikeNextGenSiemDestinationCompression.algorithm)
+ && Objects.equals(
+ this.level, observabilityPipelineCrowdStrikeNextGenSiemDestinationCompression.level)
+ && Objects.equals(
+ this.additionalProperties,
+ observabilityPipelineCrowdStrikeNextGenSiemDestinationCompression.additionalProperties);
+ }
+
+ @Override
+ public int hashCode() {
+ return Objects.hash(algorithm, level, additionalProperties);
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder();
+ sb.append("class ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompression {\n");
+ sb.append(" algorithm: ").append(toIndentedString(algorithm)).append("\n");
+ sb.append(" level: ").append(toIndentedString(level)).append("\n");
+ sb.append(" additionalProperties: ")
+ .append(toIndentedString(additionalProperties))
+ .append("\n");
+ sb.append('}');
+ return sb.toString();
+ }
+
+ /**
+ * Convert the given object to string with each line indented by 4 spaces (except the first line).
+ */
+ private String toIndentedString(Object o) {
+ if (o == null) {
+ return "null";
+ }
+ return o.toString().replace("\n", "\n ");
+ }
+}
diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompressionAlgorithm.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompressionAlgorithm.java
new file mode 100644
index 00000000000..037d732cf81
--- /dev/null
+++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompressionAlgorithm.java
@@ -0,0 +1,70 @@
+/*
+ * Unless explicitly stated otherwise all files in this repository are licensed under the Apache-2.0 License.
+ * This product includes software developed at Datadog (https://www.datadoghq.com/).
+ * Copyright 2019-Present Datadog, Inc.
+ */
+
+package com.datadog.api.client.v2.model;
+
+import com.datadog.api.client.ModelEnum;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.core.JsonGenerator;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.SerializerProvider;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.fasterxml.jackson.databind.ser.std.StdSerializer;
+import java.io.IOException;
+import java.util.Arrays;
+import java.util.HashSet;
+import java.util.Set;
+
+/** Compression algorithm for log events. */
+@JsonSerialize(
+ using =
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompressionAlgorithm
+ .ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompressionAlgorithmSerializer
+ .class)
+public class ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompressionAlgorithm
+ extends ModelEnum {
+
+ private static final Set allowedValues =
+ new HashSet(Arrays.asList("gzip", "zlib"));
+
+ public static final ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompressionAlgorithm
+ GZIP = new ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompressionAlgorithm("gzip");
+ public static final ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompressionAlgorithm
+ ZLIB = new ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompressionAlgorithm("zlib");
+
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompressionAlgorithm(String value) {
+ super(value, allowedValues);
+ }
+
+ public static
+ class ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompressionAlgorithmSerializer
+ extends StdSerializer<
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompressionAlgorithm> {
+ public ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompressionAlgorithmSerializer(
+ Class t) {
+ super(t);
+ }
+
+ public ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompressionAlgorithmSerializer() {
+ this(null);
+ }
+
+ @Override
+ public void serialize(
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompressionAlgorithm value,
+ JsonGenerator jgen,
+ SerializerProvider provider)
+ throws IOException, JsonProcessingException {
+ jgen.writeObject(value.value);
+ }
+ }
+
+ @JsonCreator
+ public static ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompressionAlgorithm
+ fromValue(String value) {
+ return new ObservabilityPipelineCrowdStrikeNextGenSiemDestinationCompressionAlgorithm(value);
+ }
+}
diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineCrowdStrikeNextGenSiemDestinationEncoding.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineCrowdStrikeNextGenSiemDestinationEncoding.java
new file mode 100644
index 00000000000..426ccf5943d
--- /dev/null
+++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineCrowdStrikeNextGenSiemDestinationEncoding.java
@@ -0,0 +1,67 @@
+/*
+ * Unless explicitly stated otherwise all files in this repository are licensed under the Apache-2.0 License.
+ * This product includes software developed at Datadog (https://www.datadoghq.com/).
+ * Copyright 2019-Present Datadog, Inc.
+ */
+
+package com.datadog.api.client.v2.model;
+
+import com.datadog.api.client.ModelEnum;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.core.JsonGenerator;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.SerializerProvider;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.fasterxml.jackson.databind.ser.std.StdSerializer;
+import java.io.IOException;
+import java.util.Arrays;
+import java.util.HashSet;
+import java.util.Set;
+
+/** Encoding format for log events. */
+@JsonSerialize(
+ using =
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestinationEncoding
+ .ObservabilityPipelineCrowdStrikeNextGenSiemDestinationEncodingSerializer.class)
+public class ObservabilityPipelineCrowdStrikeNextGenSiemDestinationEncoding
+ extends ModelEnum {
+
+ private static final Set allowedValues =
+ new HashSet(Arrays.asList("json", "raw_message"));
+
+ public static final ObservabilityPipelineCrowdStrikeNextGenSiemDestinationEncoding JSON =
+ new ObservabilityPipelineCrowdStrikeNextGenSiemDestinationEncoding("json");
+ public static final ObservabilityPipelineCrowdStrikeNextGenSiemDestinationEncoding RAW_MESSAGE =
+ new ObservabilityPipelineCrowdStrikeNextGenSiemDestinationEncoding("raw_message");
+
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestinationEncoding(String value) {
+ super(value, allowedValues);
+ }
+
+ public static class ObservabilityPipelineCrowdStrikeNextGenSiemDestinationEncodingSerializer
+ extends StdSerializer {
+ public ObservabilityPipelineCrowdStrikeNextGenSiemDestinationEncodingSerializer(
+ Class t) {
+ super(t);
+ }
+
+ public ObservabilityPipelineCrowdStrikeNextGenSiemDestinationEncodingSerializer() {
+ this(null);
+ }
+
+ @Override
+ public void serialize(
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestinationEncoding value,
+ JsonGenerator jgen,
+ SerializerProvider provider)
+ throws IOException, JsonProcessingException {
+ jgen.writeObject(value.value);
+ }
+ }
+
+ @JsonCreator
+ public static ObservabilityPipelineCrowdStrikeNextGenSiemDestinationEncoding fromValue(
+ String value) {
+ return new ObservabilityPipelineCrowdStrikeNextGenSiemDestinationEncoding(value);
+ }
+}
diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineCrowdStrikeNextGenSiemDestinationType.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineCrowdStrikeNextGenSiemDestinationType.java
new file mode 100644
index 00000000000..34a861bb9b6
--- /dev/null
+++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineCrowdStrikeNextGenSiemDestinationType.java
@@ -0,0 +1,65 @@
+/*
+ * Unless explicitly stated otherwise all files in this repository are licensed under the Apache-2.0 License.
+ * This product includes software developed at Datadog (https://www.datadoghq.com/).
+ * Copyright 2019-Present Datadog, Inc.
+ */
+
+package com.datadog.api.client.v2.model;
+
+import com.datadog.api.client.ModelEnum;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.core.JsonGenerator;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.SerializerProvider;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.fasterxml.jackson.databind.ser.std.StdSerializer;
+import java.io.IOException;
+import java.util.Arrays;
+import java.util.HashSet;
+import java.util.Set;
+
+/** The destination type. The value should always be crowdstrike_next_gen_siem. */
+@JsonSerialize(
+ using =
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestinationType
+ .ObservabilityPipelineCrowdStrikeNextGenSiemDestinationTypeSerializer.class)
+public class ObservabilityPipelineCrowdStrikeNextGenSiemDestinationType extends ModelEnum {
+
+ private static final Set allowedValues =
+ new HashSet(Arrays.asList("crowdstrike_next_gen_siem"));
+
+ public static final ObservabilityPipelineCrowdStrikeNextGenSiemDestinationType
+ CROWDSTRIKE_NEXT_GEN_SIEM =
+ new ObservabilityPipelineCrowdStrikeNextGenSiemDestinationType(
+ "crowdstrike_next_gen_siem");
+
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestinationType(String value) {
+ super(value, allowedValues);
+ }
+
+ public static class ObservabilityPipelineCrowdStrikeNextGenSiemDestinationTypeSerializer
+ extends StdSerializer {
+ public ObservabilityPipelineCrowdStrikeNextGenSiemDestinationTypeSerializer(
+ Class t) {
+ super(t);
+ }
+
+ public ObservabilityPipelineCrowdStrikeNextGenSiemDestinationTypeSerializer() {
+ this(null);
+ }
+
+ @Override
+ public void serialize(
+ ObservabilityPipelineCrowdStrikeNextGenSiemDestinationType value,
+ JsonGenerator jgen,
+ SerializerProvider provider)
+ throws IOException, JsonProcessingException {
+ jgen.writeObject(value.value);
+ }
+ }
+
+ @JsonCreator
+ public static ObservabilityPipelineCrowdStrikeNextGenSiemDestinationType fromValue(String value) {
+ return new ObservabilityPipelineCrowdStrikeNextGenSiemDestinationType(value);
+ }
+}
diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineCustomProcessor.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineCustomProcessor.java
new file mode 100644
index 00000000000..00901ad1ebf
--- /dev/null
+++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineCustomProcessor.java
@@ -0,0 +1,290 @@
+/*
+ * Unless explicitly stated otherwise all files in this repository are licensed under the Apache-2.0 License.
+ * This product includes software developed at Datadog (https://www.datadoghq.com/).
+ * Copyright 2019-Present Datadog, Inc.
+ */
+
+package com.datadog.api.client.v2.model;
+
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonPropertyOrder;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+
+/**
+ * The custom_processor processor transforms events using Vector Remap Language (VRL) scripts with
+ * advanced filtering capabilities.
+ */
+@JsonPropertyOrder({
+ ObservabilityPipelineCustomProcessor.JSON_PROPERTY_ID,
+ ObservabilityPipelineCustomProcessor.JSON_PROPERTY_INCLUDE,
+ ObservabilityPipelineCustomProcessor.JSON_PROPERTY_INPUTS,
+ ObservabilityPipelineCustomProcessor.JSON_PROPERTY_REMAPS,
+ ObservabilityPipelineCustomProcessor.JSON_PROPERTY_TYPE
+})
+@jakarta.annotation.Generated(
+ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator")
+public class ObservabilityPipelineCustomProcessor {
+ @JsonIgnore public boolean unparsed = false;
+ public static final String JSON_PROPERTY_ID = "id";
+ private String id;
+
+ public static final String JSON_PROPERTY_INCLUDE = "include";
+ private String include = "*";
+
+ public static final String JSON_PROPERTY_INPUTS = "inputs";
+ private List inputs = new ArrayList<>();
+
+ public static final String JSON_PROPERTY_REMAPS = "remaps";
+ private List remaps = new ArrayList<>();
+
+ public static final String JSON_PROPERTY_TYPE = "type";
+ private ObservabilityPipelineCustomProcessorType type =
+ ObservabilityPipelineCustomProcessorType.CUSTOM_PROCESSOR;
+
+ public ObservabilityPipelineCustomProcessor() {}
+
+ @JsonCreator
+ public ObservabilityPipelineCustomProcessor(
+ @JsonProperty(required = true, value = JSON_PROPERTY_ID) String id,
+ @JsonProperty(required = true, value = JSON_PROPERTY_INCLUDE) String include,
+ @JsonProperty(required = true, value = JSON_PROPERTY_INPUTS) List inputs,
+ @JsonProperty(required = true, value = JSON_PROPERTY_REMAPS)
+ List remaps,
+ @JsonProperty(required = true, value = JSON_PROPERTY_TYPE)
+ ObservabilityPipelineCustomProcessorType type) {
+ this.id = id;
+ this.include = include;
+ this.inputs = inputs;
+ this.remaps = remaps;
+ this.type = type;
+ this.unparsed |= !type.isValid();
+ }
+
+ public ObservabilityPipelineCustomProcessor id(String id) {
+ this.id = id;
+ return this;
+ }
+
+ /**
+ * The unique identifier for this processor.
+ *
+ * @return id
+ */
+ @JsonProperty(JSON_PROPERTY_ID)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public String getId() {
+ return id;
+ }
+
+ public void setId(String id) {
+ this.id = id;
+ }
+
+ public ObservabilityPipelineCustomProcessor include(String include) {
+ this.include = include;
+ return this;
+ }
+
+ /**
+ * A Datadog search query used to determine which logs this processor targets. This field should
+ * always be set to * for the custom_processor processor.
+ *
+ * @return include
+ */
+ @JsonProperty(JSON_PROPERTY_INCLUDE)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public String getInclude() {
+ return include;
+ }
+
+ public void setInclude(String include) {
+ this.include = include;
+ }
+
+ public ObservabilityPipelineCustomProcessor inputs(List inputs) {
+ this.inputs = inputs;
+ return this;
+ }
+
+ public ObservabilityPipelineCustomProcessor addInputsItem(String inputsItem) {
+ this.inputs.add(inputsItem);
+ return this;
+ }
+
+ /**
+ * A list of component IDs whose output is used as the input for this processor.
+ *
+ * @return inputs
+ */
+ @JsonProperty(JSON_PROPERTY_INPUTS)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public List getInputs() {
+ return inputs;
+ }
+
+ public void setInputs(List inputs) {
+ this.inputs = inputs;
+ }
+
+ public ObservabilityPipelineCustomProcessor remaps(
+ List remaps) {
+ this.remaps = remaps;
+ for (ObservabilityPipelineCustomProcessorRemap item : remaps) {
+ this.unparsed |= item.unparsed;
+ }
+ return this;
+ }
+
+ public ObservabilityPipelineCustomProcessor addRemapsItem(
+ ObservabilityPipelineCustomProcessorRemap remapsItem) {
+ this.remaps.add(remapsItem);
+ this.unparsed |= remapsItem.unparsed;
+ return this;
+ }
+
+ /**
+ * Array of VRL remap rules.
+ *
+ * @return remaps
+ */
+ @JsonProperty(JSON_PROPERTY_REMAPS)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public List getRemaps() {
+ return remaps;
+ }
+
+ public void setRemaps(List remaps) {
+ this.remaps = remaps;
+ }
+
+ public ObservabilityPipelineCustomProcessor type(ObservabilityPipelineCustomProcessorType type) {
+ this.type = type;
+ this.unparsed |= !type.isValid();
+ return this;
+ }
+
+ /**
+ * The processor type. The value should always be custom_processor.
+ *
+ * @return type
+ */
+ @JsonProperty(JSON_PROPERTY_TYPE)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public ObservabilityPipelineCustomProcessorType getType() {
+ return type;
+ }
+
+ public void setType(ObservabilityPipelineCustomProcessorType type) {
+ if (!type.isValid()) {
+ this.unparsed = true;
+ }
+ this.type = type;
+ }
+
+ /**
+ * A container for additional, undeclared properties. This is a holder for any undeclared
+ * properties as specified with the 'additionalProperties' keyword in the OAS document.
+ */
+ private Map additionalProperties;
+
+ /**
+ * Set the additional (undeclared) property with the specified name and value. If the property
+ * does not already exist, create it otherwise replace it.
+ *
+ * @param key The arbitrary key to set
+ * @param value The associated value
+ * @return ObservabilityPipelineCustomProcessor
+ */
+ @JsonAnySetter
+ public ObservabilityPipelineCustomProcessor putAdditionalProperty(String key, Object value) {
+ if (this.additionalProperties == null) {
+ this.additionalProperties = new HashMap();
+ }
+ this.additionalProperties.put(key, value);
+ return this;
+ }
+
+ /**
+ * Return the additional (undeclared) property.
+ *
+ * @return The additional properties
+ */
+ @JsonAnyGetter
+ public Map getAdditionalProperties() {
+ return additionalProperties;
+ }
+
+ /**
+ * Return the additional (undeclared) property with the specified name.
+ *
+ * @param key The arbitrary key to get
+ * @return The specific additional property for the given key
+ */
+ public Object getAdditionalProperty(String key) {
+ if (this.additionalProperties == null) {
+ return null;
+ }
+ return this.additionalProperties.get(key);
+ }
+
+ /** Return true if this ObservabilityPipelineCustomProcessor object is equal to o. */
+ @Override
+ public boolean equals(Object o) {
+ if (this == o) {
+ return true;
+ }
+ if (o == null || getClass() != o.getClass()) {
+ return false;
+ }
+ ObservabilityPipelineCustomProcessor observabilityPipelineCustomProcessor =
+ (ObservabilityPipelineCustomProcessor) o;
+ return Objects.equals(this.id, observabilityPipelineCustomProcessor.id)
+ && Objects.equals(this.include, observabilityPipelineCustomProcessor.include)
+ && Objects.equals(this.inputs, observabilityPipelineCustomProcessor.inputs)
+ && Objects.equals(this.remaps, observabilityPipelineCustomProcessor.remaps)
+ && Objects.equals(this.type, observabilityPipelineCustomProcessor.type)
+ && Objects.equals(
+ this.additionalProperties, observabilityPipelineCustomProcessor.additionalProperties);
+ }
+
+ @Override
+ public int hashCode() {
+ return Objects.hash(id, include, inputs, remaps, type, additionalProperties);
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder();
+ sb.append("class ObservabilityPipelineCustomProcessor {\n");
+ sb.append(" id: ").append(toIndentedString(id)).append("\n");
+ sb.append(" include: ").append(toIndentedString(include)).append("\n");
+ sb.append(" inputs: ").append(toIndentedString(inputs)).append("\n");
+ sb.append(" remaps: ").append(toIndentedString(remaps)).append("\n");
+ sb.append(" type: ").append(toIndentedString(type)).append("\n");
+ sb.append(" additionalProperties: ")
+ .append(toIndentedString(additionalProperties))
+ .append("\n");
+ sb.append('}');
+ return sb.toString();
+ }
+
+ /**
+ * Convert the given object to string with each line indented by 4 spaces (except the first line).
+ */
+ private String toIndentedString(Object o) {
+ if (o == null) {
+ return "null";
+ }
+ return o.toString().replace("\n", "\n ");
+ }
+}
diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineCustomProcessorRemap.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineCustomProcessorRemap.java
new file mode 100644
index 00000000000..fc99f2aa61b
--- /dev/null
+++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineCustomProcessorRemap.java
@@ -0,0 +1,260 @@
+/*
+ * Unless explicitly stated otherwise all files in this repository are licensed under the Apache-2.0 License.
+ * This product includes software developed at Datadog (https://www.datadoghq.com/).
+ * Copyright 2019-Present Datadog, Inc.
+ */
+
+package com.datadog.api.client.v2.model;
+
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonPropertyOrder;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Objects;
+
+/** Defines a single VRL remap rule with its own filtering and transformation logic. */
+@JsonPropertyOrder({
+ ObservabilityPipelineCustomProcessorRemap.JSON_PROPERTY_DROP_ON_ERROR,
+ ObservabilityPipelineCustomProcessorRemap.JSON_PROPERTY_ENABLED,
+ ObservabilityPipelineCustomProcessorRemap.JSON_PROPERTY_INCLUDE,
+ ObservabilityPipelineCustomProcessorRemap.JSON_PROPERTY_NAME,
+ ObservabilityPipelineCustomProcessorRemap.JSON_PROPERTY_SOURCE
+})
+@jakarta.annotation.Generated(
+ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator")
+public class ObservabilityPipelineCustomProcessorRemap {
+ @JsonIgnore public boolean unparsed = false;
+ public static final String JSON_PROPERTY_DROP_ON_ERROR = "drop_on_error";
+ private Boolean dropOnError;
+
+ public static final String JSON_PROPERTY_ENABLED = "enabled";
+ private Boolean enabled;
+
+ public static final String JSON_PROPERTY_INCLUDE = "include";
+ private String include;
+
+ public static final String JSON_PROPERTY_NAME = "name";
+ private String name;
+
+ public static final String JSON_PROPERTY_SOURCE = "source";
+ private String source;
+
+ public ObservabilityPipelineCustomProcessorRemap() {}
+
+ @JsonCreator
+ public ObservabilityPipelineCustomProcessorRemap(
+ @JsonProperty(required = true, value = JSON_PROPERTY_DROP_ON_ERROR) Boolean dropOnError,
+ @JsonProperty(required = true, value = JSON_PROPERTY_ENABLED) Boolean enabled,
+ @JsonProperty(required = true, value = JSON_PROPERTY_INCLUDE) String include,
+ @JsonProperty(required = true, value = JSON_PROPERTY_NAME) String name,
+ @JsonProperty(required = true, value = JSON_PROPERTY_SOURCE) String source) {
+ this.dropOnError = dropOnError;
+ this.enabled = enabled;
+ this.include = include;
+ this.name = name;
+ this.source = source;
+ }
+
+ public ObservabilityPipelineCustomProcessorRemap dropOnError(Boolean dropOnError) {
+ this.dropOnError = dropOnError;
+ return this;
+ }
+
+ /**
+ * Whether to drop events that caused errors during processing.
+ *
+ * @return dropOnError
+ */
+ @JsonProperty(JSON_PROPERTY_DROP_ON_ERROR)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public Boolean getDropOnError() {
+ return dropOnError;
+ }
+
+ public void setDropOnError(Boolean dropOnError) {
+ this.dropOnError = dropOnError;
+ }
+
+ public ObservabilityPipelineCustomProcessorRemap enabled(Boolean enabled) {
+ this.enabled = enabled;
+ return this;
+ }
+
+ /**
+ * Whether this remap rule is enabled.
+ *
+ * @return enabled
+ */
+ @JsonProperty(JSON_PROPERTY_ENABLED)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public Boolean getEnabled() {
+ return enabled;
+ }
+
+ public void setEnabled(Boolean enabled) {
+ this.enabled = enabled;
+ }
+
+ public ObservabilityPipelineCustomProcessorRemap include(String include) {
+ this.include = include;
+ return this;
+ }
+
+ /**
+ * A Datadog search query used to filter events for this specific remap rule.
+ *
+ * @return include
+ */
+ @JsonProperty(JSON_PROPERTY_INCLUDE)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public String getInclude() {
+ return include;
+ }
+
+ public void setInclude(String include) {
+ this.include = include;
+ }
+
+ public ObservabilityPipelineCustomProcessorRemap name(String name) {
+ this.name = name;
+ return this;
+ }
+
+ /**
+ * A descriptive name for this remap rule.
+ *
+ * @return name
+ */
+ @JsonProperty(JSON_PROPERTY_NAME)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public String getName() {
+ return name;
+ }
+
+ public void setName(String name) {
+ this.name = name;
+ }
+
+ public ObservabilityPipelineCustomProcessorRemap source(String source) {
+ this.source = source;
+ return this;
+ }
+
+ /**
+ * The VRL script source code that defines the processing logic.
+ *
+ * @return source
+ */
+ @JsonProperty(JSON_PROPERTY_SOURCE)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public String getSource() {
+ return source;
+ }
+
+ public void setSource(String source) {
+ this.source = source;
+ }
+
+ /**
+ * A container for additional, undeclared properties. This is a holder for any undeclared
+ * properties as specified with the 'additionalProperties' keyword in the OAS document.
+ */
+ private Map additionalProperties;
+
+ /**
+ * Set the additional (undeclared) property with the specified name and value. If the property
+ * does not already exist, create it otherwise replace it.
+ *
+ * @param key The arbitrary key to set
+ * @param value The associated value
+ * @return ObservabilityPipelineCustomProcessorRemap
+ */
+ @JsonAnySetter
+ public ObservabilityPipelineCustomProcessorRemap putAdditionalProperty(String key, Object value) {
+ if (this.additionalProperties == null) {
+ this.additionalProperties = new HashMap();
+ }
+ this.additionalProperties.put(key, value);
+ return this;
+ }
+
+ /**
+ * Return the additional (undeclared) property.
+ *
+ * @return The additional properties
+ */
+ @JsonAnyGetter
+ public Map getAdditionalProperties() {
+ return additionalProperties;
+ }
+
+ /**
+ * Return the additional (undeclared) property with the specified name.
+ *
+ * @param key The arbitrary key to get
+ * @return The specific additional property for the given key
+ */
+ public Object getAdditionalProperty(String key) {
+ if (this.additionalProperties == null) {
+ return null;
+ }
+ return this.additionalProperties.get(key);
+ }
+
+ /** Return true if this ObservabilityPipelineCustomProcessorRemap object is equal to o. */
+ @Override
+ public boolean equals(Object o) {
+ if (this == o) {
+ return true;
+ }
+ if (o == null || getClass() != o.getClass()) {
+ return false;
+ }
+ ObservabilityPipelineCustomProcessorRemap observabilityPipelineCustomProcessorRemap =
+ (ObservabilityPipelineCustomProcessorRemap) o;
+ return Objects.equals(this.dropOnError, observabilityPipelineCustomProcessorRemap.dropOnError)
+ && Objects.equals(this.enabled, observabilityPipelineCustomProcessorRemap.enabled)
+ && Objects.equals(this.include, observabilityPipelineCustomProcessorRemap.include)
+ && Objects.equals(this.name, observabilityPipelineCustomProcessorRemap.name)
+ && Objects.equals(this.source, observabilityPipelineCustomProcessorRemap.source)
+ && Objects.equals(
+ this.additionalProperties,
+ observabilityPipelineCustomProcessorRemap.additionalProperties);
+ }
+
+ @Override
+ public int hashCode() {
+ return Objects.hash(dropOnError, enabled, include, name, source, additionalProperties);
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder();
+ sb.append("class ObservabilityPipelineCustomProcessorRemap {\n");
+ sb.append(" dropOnError: ").append(toIndentedString(dropOnError)).append("\n");
+ sb.append(" enabled: ").append(toIndentedString(enabled)).append("\n");
+ sb.append(" include: ").append(toIndentedString(include)).append("\n");
+ sb.append(" name: ").append(toIndentedString(name)).append("\n");
+ sb.append(" source: ").append(toIndentedString(source)).append("\n");
+ sb.append(" additionalProperties: ")
+ .append(toIndentedString(additionalProperties))
+ .append("\n");
+ sb.append('}');
+ return sb.toString();
+ }
+
+ /**
+ * Convert the given object to string with each line indented by 4 spaces (except the first line).
+ */
+ private String toIndentedString(Object o) {
+ if (o == null) {
+ return "null";
+ }
+ return o.toString().replace("\n", "\n ");
+ }
+}
diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineCustomProcessorType.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineCustomProcessorType.java
new file mode 100644
index 00000000000..3d61d33f7cd
--- /dev/null
+++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineCustomProcessorType.java
@@ -0,0 +1,63 @@
+/*
+ * Unless explicitly stated otherwise all files in this repository are licensed under the Apache-2.0 License.
+ * This product includes software developed at Datadog (https://www.datadoghq.com/).
+ * Copyright 2019-Present Datadog, Inc.
+ */
+
+package com.datadog.api.client.v2.model;
+
+import com.datadog.api.client.ModelEnum;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.core.JsonGenerator;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.SerializerProvider;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.fasterxml.jackson.databind.ser.std.StdSerializer;
+import java.io.IOException;
+import java.util.Arrays;
+import java.util.HashSet;
+import java.util.Set;
+
+/** The processor type. The value should always be custom_processor. */
+@JsonSerialize(
+ using =
+ ObservabilityPipelineCustomProcessorType.ObservabilityPipelineCustomProcessorTypeSerializer
+ .class)
+public class ObservabilityPipelineCustomProcessorType extends ModelEnum {
+
+ private static final Set allowedValues =
+ new HashSet(Arrays.asList("custom_processor"));
+
+ public static final ObservabilityPipelineCustomProcessorType CUSTOM_PROCESSOR =
+ new ObservabilityPipelineCustomProcessorType("custom_processor");
+
+ ObservabilityPipelineCustomProcessorType(String value) {
+ super(value, allowedValues);
+ }
+
+ public static class ObservabilityPipelineCustomProcessorTypeSerializer
+ extends StdSerializer {
+ public ObservabilityPipelineCustomProcessorTypeSerializer(
+ Class t) {
+ super(t);
+ }
+
+ public ObservabilityPipelineCustomProcessorTypeSerializer() {
+ this(null);
+ }
+
+ @Override
+ public void serialize(
+ ObservabilityPipelineCustomProcessorType value,
+ JsonGenerator jgen,
+ SerializerProvider provider)
+ throws IOException, JsonProcessingException {
+ jgen.writeObject(value.value);
+ }
+ }
+
+ @JsonCreator
+ public static ObservabilityPipelineCustomProcessorType fromValue(String value) {
+ return new ObservabilityPipelineCustomProcessorType(value);
+ }
+}
diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineDatadogTagsProcessor.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineDatadogTagsProcessor.java
new file mode 100644
index 00000000000..c38aacab4bf
--- /dev/null
+++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineDatadogTagsProcessor.java
@@ -0,0 +1,353 @@
+/*
+ * Unless explicitly stated otherwise all files in this repository are licensed under the Apache-2.0 License.
+ * This product includes software developed at Datadog (https://www.datadoghq.com/).
+ * Copyright 2019-Present Datadog, Inc.
+ */
+
+package com.datadog.api.client.v2.model;
+
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonPropertyOrder;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+
+/**
+ * The datadog_tags processor includes or excludes specific Datadog tags in your logs.
+ */
+@JsonPropertyOrder({
+ ObservabilityPipelineDatadogTagsProcessor.JSON_PROPERTY_ACTION,
+ ObservabilityPipelineDatadogTagsProcessor.JSON_PROPERTY_ID,
+ ObservabilityPipelineDatadogTagsProcessor.JSON_PROPERTY_INCLUDE,
+ ObservabilityPipelineDatadogTagsProcessor.JSON_PROPERTY_INPUTS,
+ ObservabilityPipelineDatadogTagsProcessor.JSON_PROPERTY_KEYS,
+ ObservabilityPipelineDatadogTagsProcessor.JSON_PROPERTY_MODE,
+ ObservabilityPipelineDatadogTagsProcessor.JSON_PROPERTY_TYPE
+})
+@jakarta.annotation.Generated(
+ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator")
+public class ObservabilityPipelineDatadogTagsProcessor {
+ @JsonIgnore public boolean unparsed = false;
+ public static final String JSON_PROPERTY_ACTION = "action";
+ private ObservabilityPipelineDatadogTagsProcessorAction action;
+
+ public static final String JSON_PROPERTY_ID = "id";
+ private String id;
+
+ public static final String JSON_PROPERTY_INCLUDE = "include";
+ private String include;
+
+ public static final String JSON_PROPERTY_INPUTS = "inputs";
+ private List inputs = new ArrayList<>();
+
+ public static final String JSON_PROPERTY_KEYS = "keys";
+ private List keys = new ArrayList<>();
+
+ public static final String JSON_PROPERTY_MODE = "mode";
+ private ObservabilityPipelineDatadogTagsProcessorMode mode;
+
+ public static final String JSON_PROPERTY_TYPE = "type";
+ private ObservabilityPipelineDatadogTagsProcessorType type =
+ ObservabilityPipelineDatadogTagsProcessorType.DATADOG_TAGS;
+
+ public ObservabilityPipelineDatadogTagsProcessor() {}
+
+ @JsonCreator
+ public ObservabilityPipelineDatadogTagsProcessor(
+ @JsonProperty(required = true, value = JSON_PROPERTY_ACTION)
+ ObservabilityPipelineDatadogTagsProcessorAction action,
+ @JsonProperty(required = true, value = JSON_PROPERTY_ID) String id,
+ @JsonProperty(required = true, value = JSON_PROPERTY_INCLUDE) String include,
+ @JsonProperty(required = true, value = JSON_PROPERTY_INPUTS) List inputs,
+ @JsonProperty(required = true, value = JSON_PROPERTY_KEYS) List keys,
+ @JsonProperty(required = true, value = JSON_PROPERTY_MODE)
+ ObservabilityPipelineDatadogTagsProcessorMode mode,
+ @JsonProperty(required = true, value = JSON_PROPERTY_TYPE)
+ ObservabilityPipelineDatadogTagsProcessorType type) {
+ this.action = action;
+ this.unparsed |= !action.isValid();
+ this.id = id;
+ this.include = include;
+ this.inputs = inputs;
+ this.keys = keys;
+ this.mode = mode;
+ this.unparsed |= !mode.isValid();
+ this.type = type;
+ this.unparsed |= !type.isValid();
+ }
+
+ public ObservabilityPipelineDatadogTagsProcessor action(
+ ObservabilityPipelineDatadogTagsProcessorAction action) {
+ this.action = action;
+ this.unparsed |= !action.isValid();
+ return this;
+ }
+
+ /**
+ * The action to take on tags with matching keys.
+ *
+ * @return action
+ */
+ @JsonProperty(JSON_PROPERTY_ACTION)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public ObservabilityPipelineDatadogTagsProcessorAction getAction() {
+ return action;
+ }
+
+ public void setAction(ObservabilityPipelineDatadogTagsProcessorAction action) {
+ if (!action.isValid()) {
+ this.unparsed = true;
+ }
+ this.action = action;
+ }
+
+ public ObservabilityPipelineDatadogTagsProcessor id(String id) {
+ this.id = id;
+ return this;
+ }
+
+ /**
+ * The unique identifier for this component. Used to reference this component in other parts of
+ * the pipeline (for example, as the input to downstream components).
+ *
+ * @return id
+ */
+ @JsonProperty(JSON_PROPERTY_ID)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public String getId() {
+ return id;
+ }
+
+ public void setId(String id) {
+ this.id = id;
+ }
+
+ public ObservabilityPipelineDatadogTagsProcessor include(String include) {
+ this.include = include;
+ return this;
+ }
+
+ /**
+ * A Datadog search query used to determine which logs this processor targets.
+ *
+ * @return include
+ */
+ @JsonProperty(JSON_PROPERTY_INCLUDE)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public String getInclude() {
+ return include;
+ }
+
+ public void setInclude(String include) {
+ this.include = include;
+ }
+
+ public ObservabilityPipelineDatadogTagsProcessor inputs(List inputs) {
+ this.inputs = inputs;
+ return this;
+ }
+
+ public ObservabilityPipelineDatadogTagsProcessor addInputsItem(String inputsItem) {
+ this.inputs.add(inputsItem);
+ return this;
+ }
+
+ /**
+ * A list of component IDs whose output is used as the input for this component.
+ *
+ * @return inputs
+ */
+ @JsonProperty(JSON_PROPERTY_INPUTS)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public List getInputs() {
+ return inputs;
+ }
+
+ public void setInputs(List inputs) {
+ this.inputs = inputs;
+ }
+
+ public ObservabilityPipelineDatadogTagsProcessor keys(List keys) {
+ this.keys = keys;
+ return this;
+ }
+
+ public ObservabilityPipelineDatadogTagsProcessor addKeysItem(String keysItem) {
+ this.keys.add(keysItem);
+ return this;
+ }
+
+ /**
+ * A list of tag keys.
+ *
+ * @return keys
+ */
+ @JsonProperty(JSON_PROPERTY_KEYS)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public List getKeys() {
+ return keys;
+ }
+
+ public void setKeys(List keys) {
+ this.keys = keys;
+ }
+
+ public ObservabilityPipelineDatadogTagsProcessor mode(
+ ObservabilityPipelineDatadogTagsProcessorMode mode) {
+ this.mode = mode;
+ this.unparsed |= !mode.isValid();
+ return this;
+ }
+
+ /**
+ * The processing mode.
+ *
+ * @return mode
+ */
+ @JsonProperty(JSON_PROPERTY_MODE)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public ObservabilityPipelineDatadogTagsProcessorMode getMode() {
+ return mode;
+ }
+
+ public void setMode(ObservabilityPipelineDatadogTagsProcessorMode mode) {
+ if (!mode.isValid()) {
+ this.unparsed = true;
+ }
+ this.mode = mode;
+ }
+
+ public ObservabilityPipelineDatadogTagsProcessor type(
+ ObservabilityPipelineDatadogTagsProcessorType type) {
+ this.type = type;
+ this.unparsed |= !type.isValid();
+ return this;
+ }
+
+ /**
+ * The processor type. The value should always be datadog_tags.
+ *
+ * @return type
+ */
+ @JsonProperty(JSON_PROPERTY_TYPE)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public ObservabilityPipelineDatadogTagsProcessorType getType() {
+ return type;
+ }
+
+ public void setType(ObservabilityPipelineDatadogTagsProcessorType type) {
+ if (!type.isValid()) {
+ this.unparsed = true;
+ }
+ this.type = type;
+ }
+
+ /**
+ * A container for additional, undeclared properties. This is a holder for any undeclared
+ * properties as specified with the 'additionalProperties' keyword in the OAS document.
+ */
+ private Map additionalProperties;
+
+ /**
+ * Set the additional (undeclared) property with the specified name and value. If the property
+ * does not already exist, create it otherwise replace it.
+ *
+ * @param key The arbitrary key to set
+ * @param value The associated value
+ * @return ObservabilityPipelineDatadogTagsProcessor
+ */
+ @JsonAnySetter
+ public ObservabilityPipelineDatadogTagsProcessor putAdditionalProperty(String key, Object value) {
+ if (this.additionalProperties == null) {
+ this.additionalProperties = new HashMap();
+ }
+ this.additionalProperties.put(key, value);
+ return this;
+ }
+
+ /**
+ * Return the additional (undeclared) property.
+ *
+ * @return The additional properties
+ */
+ @JsonAnyGetter
+ public Map getAdditionalProperties() {
+ return additionalProperties;
+ }
+
+ /**
+ * Return the additional (undeclared) property with the specified name.
+ *
+ * @param key The arbitrary key to get
+ * @return The specific additional property for the given key
+ */
+ public Object getAdditionalProperty(String key) {
+ if (this.additionalProperties == null) {
+ return null;
+ }
+ return this.additionalProperties.get(key);
+ }
+
+ /** Return true if this ObservabilityPipelineDatadogTagsProcessor object is equal to o. */
+ @Override
+ public boolean equals(Object o) {
+ if (this == o) {
+ return true;
+ }
+ if (o == null || getClass() != o.getClass()) {
+ return false;
+ }
+ ObservabilityPipelineDatadogTagsProcessor observabilityPipelineDatadogTagsProcessor =
+ (ObservabilityPipelineDatadogTagsProcessor) o;
+ return Objects.equals(this.action, observabilityPipelineDatadogTagsProcessor.action)
+ && Objects.equals(this.id, observabilityPipelineDatadogTagsProcessor.id)
+ && Objects.equals(this.include, observabilityPipelineDatadogTagsProcessor.include)
+ && Objects.equals(this.inputs, observabilityPipelineDatadogTagsProcessor.inputs)
+ && Objects.equals(this.keys, observabilityPipelineDatadogTagsProcessor.keys)
+ && Objects.equals(this.mode, observabilityPipelineDatadogTagsProcessor.mode)
+ && Objects.equals(this.type, observabilityPipelineDatadogTagsProcessor.type)
+ && Objects.equals(
+ this.additionalProperties,
+ observabilityPipelineDatadogTagsProcessor.additionalProperties);
+ }
+
+ @Override
+ public int hashCode() {
+ return Objects.hash(action, id, include, inputs, keys, mode, type, additionalProperties);
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder();
+ sb.append("class ObservabilityPipelineDatadogTagsProcessor {\n");
+ sb.append(" action: ").append(toIndentedString(action)).append("\n");
+ sb.append(" id: ").append(toIndentedString(id)).append("\n");
+ sb.append(" include: ").append(toIndentedString(include)).append("\n");
+ sb.append(" inputs: ").append(toIndentedString(inputs)).append("\n");
+ sb.append(" keys: ").append(toIndentedString(keys)).append("\n");
+ sb.append(" mode: ").append(toIndentedString(mode)).append("\n");
+ sb.append(" type: ").append(toIndentedString(type)).append("\n");
+ sb.append(" additionalProperties: ")
+ .append(toIndentedString(additionalProperties))
+ .append("\n");
+ sb.append('}');
+ return sb.toString();
+ }
+
+ /**
+ * Convert the given object to string with each line indented by 4 spaces (except the first line).
+ */
+ private String toIndentedString(Object o) {
+ if (o == null) {
+ return "null";
+ }
+ return o.toString().replace("\n", "\n ");
+ }
+}
diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineDatadogTagsProcessorAction.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineDatadogTagsProcessorAction.java
new file mode 100644
index 00000000000..8ef51d4614f
--- /dev/null
+++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineDatadogTagsProcessorAction.java
@@ -0,0 +1,65 @@
+/*
+ * Unless explicitly stated otherwise all files in this repository are licensed under the Apache-2.0 License.
+ * This product includes software developed at Datadog (https://www.datadoghq.com/).
+ * Copyright 2019-Present Datadog, Inc.
+ */
+
+package com.datadog.api.client.v2.model;
+
+import com.datadog.api.client.ModelEnum;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.core.JsonGenerator;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.SerializerProvider;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.fasterxml.jackson.databind.ser.std.StdSerializer;
+import java.io.IOException;
+import java.util.Arrays;
+import java.util.HashSet;
+import java.util.Set;
+
+/** The action to take on tags with matching keys. */
+@JsonSerialize(
+ using =
+ ObservabilityPipelineDatadogTagsProcessorAction
+ .ObservabilityPipelineDatadogTagsProcessorActionSerializer.class)
+public class ObservabilityPipelineDatadogTagsProcessorAction extends ModelEnum {
+
+ private static final Set allowedValues =
+ new HashSet(Arrays.asList("include", "exclude"));
+
+ public static final ObservabilityPipelineDatadogTagsProcessorAction INCLUDE =
+ new ObservabilityPipelineDatadogTagsProcessorAction("include");
+ public static final ObservabilityPipelineDatadogTagsProcessorAction EXCLUDE =
+ new ObservabilityPipelineDatadogTagsProcessorAction("exclude");
+
+ ObservabilityPipelineDatadogTagsProcessorAction(String value) {
+ super(value, allowedValues);
+ }
+
+ public static class ObservabilityPipelineDatadogTagsProcessorActionSerializer
+ extends StdSerializer {
+ public ObservabilityPipelineDatadogTagsProcessorActionSerializer(
+ Class t) {
+ super(t);
+ }
+
+ public ObservabilityPipelineDatadogTagsProcessorActionSerializer() {
+ this(null);
+ }
+
+ @Override
+ public void serialize(
+ ObservabilityPipelineDatadogTagsProcessorAction value,
+ JsonGenerator jgen,
+ SerializerProvider provider)
+ throws IOException, JsonProcessingException {
+ jgen.writeObject(value.value);
+ }
+ }
+
+ @JsonCreator
+ public static ObservabilityPipelineDatadogTagsProcessorAction fromValue(String value) {
+ return new ObservabilityPipelineDatadogTagsProcessorAction(value);
+ }
+}
diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineDatadogTagsProcessorMode.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineDatadogTagsProcessorMode.java
new file mode 100644
index 00000000000..f0f737536ef
--- /dev/null
+++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineDatadogTagsProcessorMode.java
@@ -0,0 +1,62 @@
+/*
+ * Unless explicitly stated otherwise all files in this repository are licensed under the Apache-2.0 License.
+ * This product includes software developed at Datadog (https://www.datadoghq.com/).
+ * Copyright 2019-Present Datadog, Inc.
+ */
+
+package com.datadog.api.client.v2.model;
+
+import com.datadog.api.client.ModelEnum;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.core.JsonGenerator;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.SerializerProvider;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.fasterxml.jackson.databind.ser.std.StdSerializer;
+import java.io.IOException;
+import java.util.Arrays;
+import java.util.HashSet;
+import java.util.Set;
+
+/** The processing mode. */
+@JsonSerialize(
+ using =
+ ObservabilityPipelineDatadogTagsProcessorMode
+ .ObservabilityPipelineDatadogTagsProcessorModeSerializer.class)
+public class ObservabilityPipelineDatadogTagsProcessorMode extends ModelEnum {
+
+ private static final Set allowedValues = new HashSet(Arrays.asList("filter"));
+
+ public static final ObservabilityPipelineDatadogTagsProcessorMode FILTER =
+ new ObservabilityPipelineDatadogTagsProcessorMode("filter");
+
+ ObservabilityPipelineDatadogTagsProcessorMode(String value) {
+ super(value, allowedValues);
+ }
+
+ public static class ObservabilityPipelineDatadogTagsProcessorModeSerializer
+ extends StdSerializer {
+ public ObservabilityPipelineDatadogTagsProcessorModeSerializer(
+ Class t) {
+ super(t);
+ }
+
+ public ObservabilityPipelineDatadogTagsProcessorModeSerializer() {
+ this(null);
+ }
+
+ @Override
+ public void serialize(
+ ObservabilityPipelineDatadogTagsProcessorMode value,
+ JsonGenerator jgen,
+ SerializerProvider provider)
+ throws IOException, JsonProcessingException {
+ jgen.writeObject(value.value);
+ }
+ }
+
+ @JsonCreator
+ public static ObservabilityPipelineDatadogTagsProcessorMode fromValue(String value) {
+ return new ObservabilityPipelineDatadogTagsProcessorMode(value);
+ }
+}
diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineDatadogTagsProcessorType.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineDatadogTagsProcessorType.java
new file mode 100644
index 00000000000..02a83a8e94b
--- /dev/null
+++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineDatadogTagsProcessorType.java
@@ -0,0 +1,63 @@
+/*
+ * Unless explicitly stated otherwise all files in this repository are licensed under the Apache-2.0 License.
+ * This product includes software developed at Datadog (https://www.datadoghq.com/).
+ * Copyright 2019-Present Datadog, Inc.
+ */
+
+package com.datadog.api.client.v2.model;
+
+import com.datadog.api.client.ModelEnum;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.core.JsonGenerator;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.SerializerProvider;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.fasterxml.jackson.databind.ser.std.StdSerializer;
+import java.io.IOException;
+import java.util.Arrays;
+import java.util.HashSet;
+import java.util.Set;
+
+/** The processor type. The value should always be datadog_tags. */
+@JsonSerialize(
+ using =
+ ObservabilityPipelineDatadogTagsProcessorType
+ .ObservabilityPipelineDatadogTagsProcessorTypeSerializer.class)
+public class ObservabilityPipelineDatadogTagsProcessorType extends ModelEnum {
+
+ private static final Set allowedValues =
+ new HashSet(Arrays.asList("datadog_tags"));
+
+ public static final ObservabilityPipelineDatadogTagsProcessorType DATADOG_TAGS =
+ new ObservabilityPipelineDatadogTagsProcessorType("datadog_tags");
+
+ ObservabilityPipelineDatadogTagsProcessorType(String value) {
+ super(value, allowedValues);
+ }
+
+ public static class ObservabilityPipelineDatadogTagsProcessorTypeSerializer
+ extends StdSerializer {
+ public ObservabilityPipelineDatadogTagsProcessorTypeSerializer(
+ Class t) {
+ super(t);
+ }
+
+ public ObservabilityPipelineDatadogTagsProcessorTypeSerializer() {
+ this(null);
+ }
+
+ @Override
+ public void serialize(
+ ObservabilityPipelineDatadogTagsProcessorType value,
+ JsonGenerator jgen,
+ SerializerProvider provider)
+ throws IOException, JsonProcessingException {
+ jgen.writeObject(value.value);
+ }
+ }
+
+ @JsonCreator
+ public static ObservabilityPipelineDatadogTagsProcessorType fromValue(String value) {
+ return new ObservabilityPipelineDatadogTagsProcessorType(value);
+ }
+}
diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSocketDestination.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSocketDestination.java
new file mode 100644
index 00000000000..775a97879fd
--- /dev/null
+++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSocketDestination.java
@@ -0,0 +1,348 @@
+/*
+ * Unless explicitly stated otherwise all files in this repository are licensed under the Apache-2.0 License.
+ * This product includes software developed at Datadog (https://www.datadoghq.com/).
+ * Copyright 2019-Present Datadog, Inc.
+ */
+
+package com.datadog.api.client.v2.model;
+
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonPropertyOrder;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+
+/** The socket destination sends logs over TCP or UDP to a remote server. */
+@JsonPropertyOrder({
+ ObservabilityPipelineSocketDestination.JSON_PROPERTY_ENCODING,
+ ObservabilityPipelineSocketDestination.JSON_PROPERTY_FRAMING,
+ ObservabilityPipelineSocketDestination.JSON_PROPERTY_ID,
+ ObservabilityPipelineSocketDestination.JSON_PROPERTY_INPUTS,
+ ObservabilityPipelineSocketDestination.JSON_PROPERTY_MODE,
+ ObservabilityPipelineSocketDestination.JSON_PROPERTY_TLS,
+ ObservabilityPipelineSocketDestination.JSON_PROPERTY_TYPE
+})
+@jakarta.annotation.Generated(
+ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator")
+public class ObservabilityPipelineSocketDestination {
+ @JsonIgnore public boolean unparsed = false;
+ public static final String JSON_PROPERTY_ENCODING = "encoding";
+ private ObservabilityPipelineSocketDestinationEncoding encoding;
+
+ public static final String JSON_PROPERTY_FRAMING = "framing";
+ private ObservabilityPipelineSocketDestinationFraming framing;
+
+ public static final String JSON_PROPERTY_ID = "id";
+ private String id;
+
+ public static final String JSON_PROPERTY_INPUTS = "inputs";
+ private List inputs = new ArrayList<>();
+
+ public static final String JSON_PROPERTY_MODE = "mode";
+ private ObservabilityPipelineSocketDestinationMode mode;
+
+ public static final String JSON_PROPERTY_TLS = "tls";
+ private ObservabilityPipelineTls tls;
+
+ public static final String JSON_PROPERTY_TYPE = "type";
+ private ObservabilityPipelineSocketDestinationType type =
+ ObservabilityPipelineSocketDestinationType.SOCKET;
+
+ public ObservabilityPipelineSocketDestination() {}
+
+ @JsonCreator
+ public ObservabilityPipelineSocketDestination(
+ @JsonProperty(required = true, value = JSON_PROPERTY_ENCODING)
+ ObservabilityPipelineSocketDestinationEncoding encoding,
+ @JsonProperty(required = true, value = JSON_PROPERTY_FRAMING)
+ ObservabilityPipelineSocketDestinationFraming framing,
+ @JsonProperty(required = true, value = JSON_PROPERTY_ID) String id,
+ @JsonProperty(required = true, value = JSON_PROPERTY_INPUTS) List inputs,
+ @JsonProperty(required = true, value = JSON_PROPERTY_MODE)
+ ObservabilityPipelineSocketDestinationMode mode,
+ @JsonProperty(required = true, value = JSON_PROPERTY_TYPE)
+ ObservabilityPipelineSocketDestinationType type) {
+ this.encoding = encoding;
+ this.unparsed |= !encoding.isValid();
+ this.framing = framing;
+ this.unparsed |= framing.unparsed;
+ this.id = id;
+ this.inputs = inputs;
+ this.mode = mode;
+ this.unparsed |= !mode.isValid();
+ this.type = type;
+ this.unparsed |= !type.isValid();
+ }
+
+ public ObservabilityPipelineSocketDestination encoding(
+ ObservabilityPipelineSocketDestinationEncoding encoding) {
+ this.encoding = encoding;
+ this.unparsed |= !encoding.isValid();
+ return this;
+ }
+
+ /**
+ * Encoding format for log events.
+ *
+ * @return encoding
+ */
+ @JsonProperty(JSON_PROPERTY_ENCODING)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public ObservabilityPipelineSocketDestinationEncoding getEncoding() {
+ return encoding;
+ }
+
+ public void setEncoding(ObservabilityPipelineSocketDestinationEncoding encoding) {
+ if (!encoding.isValid()) {
+ this.unparsed = true;
+ }
+ this.encoding = encoding;
+ }
+
+ public ObservabilityPipelineSocketDestination framing(
+ ObservabilityPipelineSocketDestinationFraming framing) {
+ this.framing = framing;
+ this.unparsed |= framing.unparsed;
+ return this;
+ }
+
+ /**
+ * Framing method configuration.
+ *
+ * @return framing
+ */
+ @JsonProperty(JSON_PROPERTY_FRAMING)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public ObservabilityPipelineSocketDestinationFraming getFraming() {
+ return framing;
+ }
+
+ public void setFraming(ObservabilityPipelineSocketDestinationFraming framing) {
+ this.framing = framing;
+ }
+
+ public ObservabilityPipelineSocketDestination id(String id) {
+ this.id = id;
+ return this;
+ }
+
+ /**
+ * The unique identifier for this component.
+ *
+ * @return id
+ */
+ @JsonProperty(JSON_PROPERTY_ID)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public String getId() {
+ return id;
+ }
+
+ public void setId(String id) {
+ this.id = id;
+ }
+
+ public ObservabilityPipelineSocketDestination inputs(List inputs) {
+ this.inputs = inputs;
+ return this;
+ }
+
+ public ObservabilityPipelineSocketDestination addInputsItem(String inputsItem) {
+ this.inputs.add(inputsItem);
+ return this;
+ }
+
+ /**
+ * A list of component IDs whose output is used as the input for this component.
+ *
+ * @return inputs
+ */
+ @JsonProperty(JSON_PROPERTY_INPUTS)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public List getInputs() {
+ return inputs;
+ }
+
+ public void setInputs(List inputs) {
+ this.inputs = inputs;
+ }
+
+ public ObservabilityPipelineSocketDestination mode(
+ ObservabilityPipelineSocketDestinationMode mode) {
+ this.mode = mode;
+ this.unparsed |= !mode.isValid();
+ return this;
+ }
+
+ /**
+ * Protocol used to send logs.
+ *
+ * @return mode
+ */
+ @JsonProperty(JSON_PROPERTY_MODE)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public ObservabilityPipelineSocketDestinationMode getMode() {
+ return mode;
+ }
+
+ public void setMode(ObservabilityPipelineSocketDestinationMode mode) {
+ if (!mode.isValid()) {
+ this.unparsed = true;
+ }
+ this.mode = mode;
+ }
+
+ public ObservabilityPipelineSocketDestination tls(ObservabilityPipelineTls tls) {
+ this.tls = tls;
+ this.unparsed |= tls.unparsed;
+ return this;
+ }
+
+ /**
+ * Configuration for enabling TLS encryption between the pipeline component and external services.
+ *
+ * @return tls
+ */
+ @jakarta.annotation.Nullable
+ @JsonProperty(JSON_PROPERTY_TLS)
+ @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
+ public ObservabilityPipelineTls getTls() {
+ return tls;
+ }
+
+ public void setTls(ObservabilityPipelineTls tls) {
+ this.tls = tls;
+ }
+
+ public ObservabilityPipelineSocketDestination type(
+ ObservabilityPipelineSocketDestinationType type) {
+ this.type = type;
+ this.unparsed |= !type.isValid();
+ return this;
+ }
+
+ /**
+ * The destination type. The value should always be socket.
+ *
+ * @return type
+ */
+ @JsonProperty(JSON_PROPERTY_TYPE)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public ObservabilityPipelineSocketDestinationType getType() {
+ return type;
+ }
+
+ public void setType(ObservabilityPipelineSocketDestinationType type) {
+ if (!type.isValid()) {
+ this.unparsed = true;
+ }
+ this.type = type;
+ }
+
+ /**
+ * A container for additional, undeclared properties. This is a holder for any undeclared
+ * properties as specified with the 'additionalProperties' keyword in the OAS document.
+ */
+ private Map additionalProperties;
+
+ /**
+ * Set the additional (undeclared) property with the specified name and value. If the property
+ * does not already exist, create it otherwise replace it.
+ *
+ * @param key The arbitrary key to set
+ * @param value The associated value
+ * @return ObservabilityPipelineSocketDestination
+ */
+ @JsonAnySetter
+ public ObservabilityPipelineSocketDestination putAdditionalProperty(String key, Object value) {
+ if (this.additionalProperties == null) {
+ this.additionalProperties = new HashMap();
+ }
+ this.additionalProperties.put(key, value);
+ return this;
+ }
+
+ /**
+ * Return the additional (undeclared) property.
+ *
+ * @return The additional properties
+ */
+ @JsonAnyGetter
+ public Map getAdditionalProperties() {
+ return additionalProperties;
+ }
+
+ /**
+ * Return the additional (undeclared) property with the specified name.
+ *
+ * @param key The arbitrary key to get
+ * @return The specific additional property for the given key
+ */
+ public Object getAdditionalProperty(String key) {
+ if (this.additionalProperties == null) {
+ return null;
+ }
+ return this.additionalProperties.get(key);
+ }
+
+ /** Return true if this ObservabilityPipelineSocketDestination object is equal to o. */
+ @Override
+ public boolean equals(Object o) {
+ if (this == o) {
+ return true;
+ }
+ if (o == null || getClass() != o.getClass()) {
+ return false;
+ }
+ ObservabilityPipelineSocketDestination observabilityPipelineSocketDestination =
+ (ObservabilityPipelineSocketDestination) o;
+ return Objects.equals(this.encoding, observabilityPipelineSocketDestination.encoding)
+ && Objects.equals(this.framing, observabilityPipelineSocketDestination.framing)
+ && Objects.equals(this.id, observabilityPipelineSocketDestination.id)
+ && Objects.equals(this.inputs, observabilityPipelineSocketDestination.inputs)
+ && Objects.equals(this.mode, observabilityPipelineSocketDestination.mode)
+ && Objects.equals(this.tls, observabilityPipelineSocketDestination.tls)
+ && Objects.equals(this.type, observabilityPipelineSocketDestination.type)
+ && Objects.equals(
+ this.additionalProperties, observabilityPipelineSocketDestination.additionalProperties);
+ }
+
+ @Override
+ public int hashCode() {
+ return Objects.hash(encoding, framing, id, inputs, mode, tls, type, additionalProperties);
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder();
+ sb.append("class ObservabilityPipelineSocketDestination {\n");
+ sb.append(" encoding: ").append(toIndentedString(encoding)).append("\n");
+ sb.append(" framing: ").append(toIndentedString(framing)).append("\n");
+ sb.append(" id: ").append(toIndentedString(id)).append("\n");
+ sb.append(" inputs: ").append(toIndentedString(inputs)).append("\n");
+ sb.append(" mode: ").append(toIndentedString(mode)).append("\n");
+ sb.append(" tls: ").append(toIndentedString(tls)).append("\n");
+ sb.append(" type: ").append(toIndentedString(type)).append("\n");
+ sb.append(" additionalProperties: ")
+ .append(toIndentedString(additionalProperties))
+ .append("\n");
+ sb.append('}');
+ return sb.toString();
+ }
+
+ /**
+ * Convert the given object to string with each line indented by 4 spaces (except the first line).
+ */
+ private String toIndentedString(Object o) {
+ if (o == null) {
+ return "null";
+ }
+ return o.toString().replace("\n", "\n ");
+ }
+}
diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSocketDestinationEncoding.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSocketDestinationEncoding.java
new file mode 100644
index 00000000000..82458e9a34e
--- /dev/null
+++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSocketDestinationEncoding.java
@@ -0,0 +1,65 @@
+/*
+ * Unless explicitly stated otherwise all files in this repository are licensed under the Apache-2.0 License.
+ * This product includes software developed at Datadog (https://www.datadoghq.com/).
+ * Copyright 2019-Present Datadog, Inc.
+ */
+
+package com.datadog.api.client.v2.model;
+
+import com.datadog.api.client.ModelEnum;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.core.JsonGenerator;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.SerializerProvider;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.fasterxml.jackson.databind.ser.std.StdSerializer;
+import java.io.IOException;
+import java.util.Arrays;
+import java.util.HashSet;
+import java.util.Set;
+
+/** Encoding format for log events. */
+@JsonSerialize(
+ using =
+ ObservabilityPipelineSocketDestinationEncoding
+ .ObservabilityPipelineSocketDestinationEncodingSerializer.class)
+public class ObservabilityPipelineSocketDestinationEncoding extends ModelEnum {
+
+ private static final Set allowedValues =
+ new HashSet(Arrays.asList("json", "raw_message"));
+
+ public static final ObservabilityPipelineSocketDestinationEncoding JSON =
+ new ObservabilityPipelineSocketDestinationEncoding("json");
+ public static final ObservabilityPipelineSocketDestinationEncoding RAW_MESSAGE =
+ new ObservabilityPipelineSocketDestinationEncoding("raw_message");
+
+ ObservabilityPipelineSocketDestinationEncoding(String value) {
+ super(value, allowedValues);
+ }
+
+ public static class ObservabilityPipelineSocketDestinationEncodingSerializer
+ extends StdSerializer {
+ public ObservabilityPipelineSocketDestinationEncodingSerializer(
+ Class t) {
+ super(t);
+ }
+
+ public ObservabilityPipelineSocketDestinationEncodingSerializer() {
+ this(null);
+ }
+
+ @Override
+ public void serialize(
+ ObservabilityPipelineSocketDestinationEncoding value,
+ JsonGenerator jgen,
+ SerializerProvider provider)
+ throws IOException, JsonProcessingException {
+ jgen.writeObject(value.value);
+ }
+ }
+
+ @JsonCreator
+ public static ObservabilityPipelineSocketDestinationEncoding fromValue(String value) {
+ return new ObservabilityPipelineSocketDestinationEncoding(value);
+ }
+}
diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSocketDestinationFraming.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSocketDestinationFraming.java
new file mode 100644
index 00000000000..c627b278584
--- /dev/null
+++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSocketDestinationFraming.java
@@ -0,0 +1,453 @@
+/*
+ * Unless explicitly stated otherwise all files in this repository are licensed under the Apache-2.0 License.
+ * This product includes software developed at Datadog (https://www.datadoghq.com/).
+ * Copyright 2019-Present Datadog, Inc.
+ */
+
+package com.datadog.api.client.v2.model;
+
+import com.datadog.api.client.AbstractOpenApiSchema;
+import com.datadog.api.client.JSON;
+import com.datadog.api.client.UnparsedObject;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.core.JsonGenerator;
+import com.fasterxml.jackson.core.JsonParser;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.core.JsonToken;
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.fasterxml.jackson.databind.DeserializationContext;
+import com.fasterxml.jackson.databind.JsonMappingException;
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.MapperFeature;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.SerializerProvider;
+import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.fasterxml.jackson.databind.deser.std.StdDeserializer;
+import com.fasterxml.jackson.databind.ser.std.StdSerializer;
+import jakarta.ws.rs.core.GenericType;
+import java.io.IOException;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.Map;
+import java.util.logging.Level;
+import java.util.logging.Logger;
+
+@jakarta.annotation.Generated(
+ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator")
+@JsonDeserialize(
+ using =
+ ObservabilityPipelineSocketDestinationFraming
+ .ObservabilityPipelineSocketDestinationFramingDeserializer.class)
+@JsonSerialize(
+ using =
+ ObservabilityPipelineSocketDestinationFraming
+ .ObservabilityPipelineSocketDestinationFramingSerializer.class)
+public class ObservabilityPipelineSocketDestinationFraming extends AbstractOpenApiSchema {
+ private static final Logger log =
+ Logger.getLogger(ObservabilityPipelineSocketDestinationFraming.class.getName());
+
+ @JsonIgnore public boolean unparsed = false;
+
+ public static class ObservabilityPipelineSocketDestinationFramingSerializer
+ extends StdSerializer {
+ public ObservabilityPipelineSocketDestinationFramingSerializer(
+ Class t) {
+ super(t);
+ }
+
+ public ObservabilityPipelineSocketDestinationFramingSerializer() {
+ this(null);
+ }
+
+ @Override
+ public void serialize(
+ ObservabilityPipelineSocketDestinationFraming value,
+ JsonGenerator jgen,
+ SerializerProvider provider)
+ throws IOException, JsonProcessingException {
+ jgen.writeObject(value.getActualInstance());
+ }
+ }
+
+ public static class ObservabilityPipelineSocketDestinationFramingDeserializer
+ extends StdDeserializer {
+ public ObservabilityPipelineSocketDestinationFramingDeserializer() {
+ this(ObservabilityPipelineSocketDestinationFraming.class);
+ }
+
+ public ObservabilityPipelineSocketDestinationFramingDeserializer(Class> vc) {
+ super(vc);
+ }
+
+ @Override
+ public ObservabilityPipelineSocketDestinationFraming deserialize(
+ JsonParser jp, DeserializationContext ctxt) throws IOException, JsonProcessingException {
+ JsonNode tree = jp.readValueAsTree();
+ Object deserialized = null;
+ Object tmp = null;
+ boolean typeCoercion = ctxt.isEnabled(MapperFeature.ALLOW_COERCION_OF_SCALARS);
+ int match = 0;
+ JsonToken token = tree.traverse(jp.getCodec()).nextToken();
+ // deserialize ObservabilityPipelineSocketDestinationFramingNewlineDelimited
+ try {
+ boolean attemptParsing = true;
+ // ensure that we respect type coercion as set on the client ObjectMapper
+ if (ObservabilityPipelineSocketDestinationFramingNewlineDelimited.class.equals(
+ Integer.class)
+ || ObservabilityPipelineSocketDestinationFramingNewlineDelimited.class.equals(
+ Long.class)
+ || ObservabilityPipelineSocketDestinationFramingNewlineDelimited.class.equals(
+ Float.class)
+ || ObservabilityPipelineSocketDestinationFramingNewlineDelimited.class.equals(
+ Double.class)
+ || ObservabilityPipelineSocketDestinationFramingNewlineDelimited.class.equals(
+ Boolean.class)
+ || ObservabilityPipelineSocketDestinationFramingNewlineDelimited.class.equals(
+ String.class)) {
+ attemptParsing = typeCoercion;
+ if (!attemptParsing) {
+ attemptParsing |=
+ ((ObservabilityPipelineSocketDestinationFramingNewlineDelimited.class.equals(
+ Integer.class)
+ || ObservabilityPipelineSocketDestinationFramingNewlineDelimited.class
+ .equals(Long.class))
+ && token == JsonToken.VALUE_NUMBER_INT);
+ attemptParsing |=
+ ((ObservabilityPipelineSocketDestinationFramingNewlineDelimited.class.equals(
+ Float.class)
+ || ObservabilityPipelineSocketDestinationFramingNewlineDelimited.class
+ .equals(Double.class))
+ && (token == JsonToken.VALUE_NUMBER_FLOAT
+ || token == JsonToken.VALUE_NUMBER_INT));
+ attemptParsing |=
+ (ObservabilityPipelineSocketDestinationFramingNewlineDelimited.class.equals(
+ Boolean.class)
+ && (token == JsonToken.VALUE_FALSE || token == JsonToken.VALUE_TRUE));
+ attemptParsing |=
+ (ObservabilityPipelineSocketDestinationFramingNewlineDelimited.class.equals(
+ String.class)
+ && token == JsonToken.VALUE_STRING);
+ }
+ }
+ if (attemptParsing) {
+ tmp =
+ tree.traverse(jp.getCodec())
+ .readValueAs(ObservabilityPipelineSocketDestinationFramingNewlineDelimited.class);
+ // TODO: there is no validation against JSON schema constraints
+ // (min, max, enum, pattern...), this does not perform a strict JSON
+ // validation, which means the 'match' count may be higher than it should be.
+ if (!((ObservabilityPipelineSocketDestinationFramingNewlineDelimited) tmp).unparsed) {
+ deserialized = tmp;
+ match++;
+ }
+ log.log(
+ Level.FINER,
+ "Input data matches schema"
+ + " 'ObservabilityPipelineSocketDestinationFramingNewlineDelimited'");
+ }
+ } catch (Exception e) {
+ // deserialization failed, continue
+ log.log(
+ Level.FINER,
+ "Input data does not match schema"
+ + " 'ObservabilityPipelineSocketDestinationFramingNewlineDelimited'",
+ e);
+ }
+
+ // deserialize ObservabilityPipelineSocketDestinationFramingBytes
+ try {
+ boolean attemptParsing = true;
+ // ensure that we respect type coercion as set on the client ObjectMapper
+ if (ObservabilityPipelineSocketDestinationFramingBytes.class.equals(Integer.class)
+ || ObservabilityPipelineSocketDestinationFramingBytes.class.equals(Long.class)
+ || ObservabilityPipelineSocketDestinationFramingBytes.class.equals(Float.class)
+ || ObservabilityPipelineSocketDestinationFramingBytes.class.equals(Double.class)
+ || ObservabilityPipelineSocketDestinationFramingBytes.class.equals(Boolean.class)
+ || ObservabilityPipelineSocketDestinationFramingBytes.class.equals(String.class)) {
+ attemptParsing = typeCoercion;
+ if (!attemptParsing) {
+ attemptParsing |=
+ ((ObservabilityPipelineSocketDestinationFramingBytes.class.equals(Integer.class)
+ || ObservabilityPipelineSocketDestinationFramingBytes.class.equals(
+ Long.class))
+ && token == JsonToken.VALUE_NUMBER_INT);
+ attemptParsing |=
+ ((ObservabilityPipelineSocketDestinationFramingBytes.class.equals(Float.class)
+ || ObservabilityPipelineSocketDestinationFramingBytes.class.equals(
+ Double.class))
+ && (token == JsonToken.VALUE_NUMBER_FLOAT
+ || token == JsonToken.VALUE_NUMBER_INT));
+ attemptParsing |=
+ (ObservabilityPipelineSocketDestinationFramingBytes.class.equals(Boolean.class)
+ && (token == JsonToken.VALUE_FALSE || token == JsonToken.VALUE_TRUE));
+ attemptParsing |=
+ (ObservabilityPipelineSocketDestinationFramingBytes.class.equals(String.class)
+ && token == JsonToken.VALUE_STRING);
+ }
+ }
+ if (attemptParsing) {
+ tmp =
+ tree.traverse(jp.getCodec())
+ .readValueAs(ObservabilityPipelineSocketDestinationFramingBytes.class);
+ // TODO: there is no validation against JSON schema constraints
+ // (min, max, enum, pattern...), this does not perform a strict JSON
+ // validation, which means the 'match' count may be higher than it should be.
+ if (!((ObservabilityPipelineSocketDestinationFramingBytes) tmp).unparsed) {
+ deserialized = tmp;
+ match++;
+ }
+ log.log(
+ Level.FINER,
+ "Input data matches schema 'ObservabilityPipelineSocketDestinationFramingBytes'");
+ }
+ } catch (Exception e) {
+ // deserialization failed, continue
+ log.log(
+ Level.FINER,
+ "Input data does not match schema 'ObservabilityPipelineSocketDestinationFramingBytes'",
+ e);
+ }
+
+ // deserialize ObservabilityPipelineSocketDestinationFramingCharacterDelimited
+ try {
+ boolean attemptParsing = true;
+ // ensure that we respect type coercion as set on the client ObjectMapper
+ if (ObservabilityPipelineSocketDestinationFramingCharacterDelimited.class.equals(
+ Integer.class)
+ || ObservabilityPipelineSocketDestinationFramingCharacterDelimited.class.equals(
+ Long.class)
+ || ObservabilityPipelineSocketDestinationFramingCharacterDelimited.class.equals(
+ Float.class)
+ || ObservabilityPipelineSocketDestinationFramingCharacterDelimited.class.equals(
+ Double.class)
+ || ObservabilityPipelineSocketDestinationFramingCharacterDelimited.class.equals(
+ Boolean.class)
+ || ObservabilityPipelineSocketDestinationFramingCharacterDelimited.class.equals(
+ String.class)) {
+ attemptParsing = typeCoercion;
+ if (!attemptParsing) {
+ attemptParsing |=
+ ((ObservabilityPipelineSocketDestinationFramingCharacterDelimited.class.equals(
+ Integer.class)
+ || ObservabilityPipelineSocketDestinationFramingCharacterDelimited.class
+ .equals(Long.class))
+ && token == JsonToken.VALUE_NUMBER_INT);
+ attemptParsing |=
+ ((ObservabilityPipelineSocketDestinationFramingCharacterDelimited.class.equals(
+ Float.class)
+ || ObservabilityPipelineSocketDestinationFramingCharacterDelimited.class
+ .equals(Double.class))
+ && (token == JsonToken.VALUE_NUMBER_FLOAT
+ || token == JsonToken.VALUE_NUMBER_INT));
+ attemptParsing |=
+ (ObservabilityPipelineSocketDestinationFramingCharacterDelimited.class.equals(
+ Boolean.class)
+ && (token == JsonToken.VALUE_FALSE || token == JsonToken.VALUE_TRUE));
+ attemptParsing |=
+ (ObservabilityPipelineSocketDestinationFramingCharacterDelimited.class.equals(
+ String.class)
+ && token == JsonToken.VALUE_STRING);
+ }
+ }
+ if (attemptParsing) {
+ tmp =
+ tree.traverse(jp.getCodec())
+ .readValueAs(
+ ObservabilityPipelineSocketDestinationFramingCharacterDelimited.class);
+ // TODO: there is no validation against JSON schema constraints
+ // (min, max, enum, pattern...), this does not perform a strict JSON
+ // validation, which means the 'match' count may be higher than it should be.
+ if (!((ObservabilityPipelineSocketDestinationFramingCharacterDelimited) tmp).unparsed) {
+ deserialized = tmp;
+ match++;
+ }
+ log.log(
+ Level.FINER,
+ "Input data matches schema"
+ + " 'ObservabilityPipelineSocketDestinationFramingCharacterDelimited'");
+ }
+ } catch (Exception e) {
+ // deserialization failed, continue
+ log.log(
+ Level.FINER,
+ "Input data does not match schema"
+ + " 'ObservabilityPipelineSocketDestinationFramingCharacterDelimited'",
+ e);
+ }
+
+ ObservabilityPipelineSocketDestinationFraming ret =
+ new ObservabilityPipelineSocketDestinationFraming();
+ if (match == 1) {
+ ret.setActualInstance(deserialized);
+ } else {
+ Map res =
+ new ObjectMapper()
+ .readValue(
+ tree.traverse(jp.getCodec()).readValueAsTree().toString(),
+ new TypeReference