From b4e64d3d45fe7c4b2b069a25705259075cdfecc9 Mon Sep 17 00:00:00 2001 From: "ci.datadog-api-spec" Date: Wed, 5 Nov 2025 12:08:56 +0000 Subject: [PATCH] Regenerate client from commit f47923e of spec repo --- .generator/schemas/v2/openapi.yaml | 275 +++++++++++---- .../CreatePipeline.java | 25 +- .../UpdatePipeline.java | 25 +- .../ValidatePipeline.java | 25 +- ...ervabilityPipelineAddEnvVarsProcessor.java | 44 ++- ...servabilityPipelineAddFieldsProcessor.java | 44 ++- .../v2/model/ObservabilityPipelineConfig.java | 26 +- ...rvabilityPipelineConfigProcessorGroup.java | 279 +++++++++++++++ ...ObservabilityPipelineConfigProcessors.java | 319 ++++++++++++++++++ .../ObservabilityPipelineCustomProcessor.java | 44 ++- ...rvabilityPipelineDatadogTagsProcessor.java | 43 ++- .../ObservabilityPipelineDedupeProcessor.java | 44 ++- ...ilityPipelineEnrichmentTableProcessor.java | 45 ++- .../ObservabilityPipelineFilterProcessor.java | 44 ++- ...ilityPipelineGenerateMetricsProcessor.java | 60 +++- ...ervabilityPipelineOcsfMapperProcessor.java | 44 ++- ...servabilityPipelineParseGrokProcessor.java | 42 ++- ...servabilityPipelineParseJSONProcessor.java | 44 ++- .../ObservabilityPipelineQuotaProcessor.java | 41 ++- .../ObservabilityPipelineReduceProcessor.java | 45 ++- ...vabilityPipelineRemoveFieldsProcessor.java | 44 ++- ...vabilityPipelineRenameFieldsProcessor.java | 44 ++- .../ObservabilityPipelineSampleProcessor.java | 44 ++- ...PipelineSensitiveDataScannerProcessor.java | 44 ++- ...bservabilityPipelineThrottleProcessor.java | 44 ++- 25 files changed, 1531 insertions(+), 247 deletions(-) create mode 100644 src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineConfigProcessorGroup.java create mode 100644 src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineConfigProcessors.java diff --git a/.generator/schemas/v2/openapi.yaml b/.generator/schemas/v2/openapi.yaml index 6ed4b42368e..93ec43887f9 100644 --- a/.generator/schemas/v2/openapi.yaml +++ b/.generator/schemas/v2/openapi.yaml @@ -33063,6 +33063,10 @@ components: description: The `add_env_vars` processor adds environment variable values to log events. properties: + enabled: + description: Whether this processor is enabled. + example: true + type: boolean id: description: The unique identifier for this component. Used to reference this processor in the pipeline. @@ -33074,8 +33078,9 @@ components: example: service:my-service type: string inputs: - description: A list of component IDs whose output is used as the input for - this processor. + description: A list of component IDs whose output is used as input for this + processor. Required when used as a standalone processor, omit when used + within a processor group. example: - datadog-agent-source items: @@ -33092,7 +33097,6 @@ components: - id - type - include - - inputs - variables type: object ObservabilityPipelineAddEnvVarsProcessorType: @@ -33122,6 +33126,10 @@ components: ObservabilityPipelineAddFieldsProcessor: description: The `add_fields` processor adds static key-value fields to logs. properties: + enabled: + description: Whether this processor is enabled. + example: true + type: boolean fields: description: A list of static fields (key-value pairs) that is added to each log event processed by this component. @@ -33140,8 +33148,9 @@ components: example: service:my-service type: string inputs: - description: A list of component IDs whose output is used as the `input` - for this component. + description: A list of component IDs whose output is used as input for this + processor. Required when used as a standalone processor, omit when used + within a processor group. example: - datadog-agent-source items: @@ -33154,7 +33163,6 @@ components: - type - include - fields - - inputs type: object ObservabilityPipelineAddFieldsProcessorType: default: add_fields @@ -33457,16 +33465,7 @@ components: $ref: '#/components/schemas/ObservabilityPipelineConfigDestinationItem' type: array processors: - description: A list of processors that transform or enrich log data. - example: - - id: filter-processor - include: service:my-service - inputs: - - datadog-agent-source - type: filter - items: - $ref: '#/components/schemas/ObservabilityPipelineConfigProcessorItem' - type: array + $ref: '#/components/schemas/ObservabilityPipelineConfigProcessors' sources: description: A list of configured data sources for the pipeline. example: @@ -33501,6 +33500,72 @@ components: - $ref: '#/components/schemas/ObservabilityPipelineAmazonSecurityLakeDestination' - $ref: '#/components/schemas/ObservabilityPipelineCrowdStrikeNextGenSiemDestination' - $ref: '#/components/schemas/ObservabilityPipelineGooglePubSubDestination' + ObservabilityPipelineConfigProcessorGroup: + description: A group of processors. + example: + id: my-processor-group + include: service:my-service + inputs: + - datadog-agent-source + processors: + - fields: + - name: env + value: prod + id: add-fields-processor + include: '*' + type: add_fields + - id: filter-processor + include: status:error + type: filter + properties: + enabled: + description: Whether this processor group is enabled. + example: true + type: boolean + id: + description: The unique identifier for the processor group. + example: grouped-processors + type: string + include: + description: Conditional expression for when this processor group should + execute. + example: service:my-service + type: string + inputs: + description: A list of component IDs whose output is used as the input for + this processor group. + example: + - datadog-agent-source + items: + type: string + type: array + processors: + description: Processors applied sequentially within this group. No `inputs` + fields required - events flow through each processor in order. + example: + - fields: + - name: env + value: prod + id: add-fields-processor + include: '*' + type: add_fields + - id: filter-processor + include: status:error + type: filter + items: + $ref: '#/components/schemas/ObservabilityPipelineConfigProcessorItem' + type: array + required: + - id + - include + - inputs + - processors + type: object + ObservabilityPipelineConfigProcessorGroups: + description: A list of processor groups. + items: + $ref: '#/components/schemas/ObservabilityPipelineConfigProcessorGroup' + type: array ObservabilityPipelineConfigProcessorItem: description: A processor for the pipeline. oneOf: @@ -33522,6 +33587,23 @@ components: - $ref: '#/components/schemas/ObservabilityPipelineThrottleProcessor' - $ref: '#/components/schemas/ObservabilityPipelineCustomProcessor' - $ref: '#/components/schemas/ObservabilityPipelineDatadogTagsProcessor' + ObservabilityPipelineConfigProcessors: + description: A list of processors that transform or enrich log data, or a list + of grouped processor configurations. + oneOf: + - $ref: '#/components/schemas/ObservabilityPipelineConfigProcessorsList' + - $ref: '#/components/schemas/ObservabilityPipelineConfigProcessorGroups' + ObservabilityPipelineConfigProcessorsList: + description: A list of standalone processors that transform or enrich log data. + example: + - id: filter-processor + include: service:my-service + inputs: + - datadog-agent-source + type: filter + items: + $ref: '#/components/schemas/ObservabilityPipelineConfigProcessorItem' + type: array ObservabilityPipelineConfigSourceItem: description: A data source for the pipeline. oneOf: @@ -33618,6 +33700,10 @@ components: Remap Language (VRL)](https://vector.dev/docs/reference/vrl/) scripts with advanced filtering capabilities. properties: + enabled: + description: Whether this processor is enabled. + example: true + type: boolean id: description: The unique identifier for this processor. example: remap-vrl-processor @@ -33630,8 +33716,9 @@ components: example: '*' type: string inputs: - description: A list of component IDs whose output is used as the input for - this processor. + description: A list of component IDs whose output is used as input for this + processor. Required when used as a standalone processor, omit when used + within a processor group. example: - datadog-agent-source items: @@ -33650,7 +33737,6 @@ components: - type - include - remaps - - inputs type: object ObservabilityPipelineCustomProcessorRemap: description: Defines a single VRL remap rule with its own filtering and transformation @@ -33790,6 +33876,10 @@ components: properties: action: $ref: '#/components/schemas/ObservabilityPipelineDatadogTagsProcessorAction' + enabled: + description: Whether this processor is enabled. + example: true + type: boolean id: description: The unique identifier for this component. Used to reference this component in other parts of the pipeline (for example, as the `input` @@ -33802,8 +33892,9 @@ components: example: service:my-service type: string inputs: - description: A list of component IDs whose output is used as the `input` - for this component. + description: A list of component IDs whose output is used as input for this + processor. Required when used as a standalone processor, omit when used + within a processor group. example: - datadog-agent-source items: @@ -33829,7 +33920,6 @@ components: - mode - action - keys - - inputs type: object ObservabilityPipelineDatadogTagsProcessorAction: description: The action to take on tags with matching keys. @@ -33875,6 +33965,10 @@ components: ObservabilityPipelineDedupeProcessor: description: The `dedupe` processor removes duplicate fields in log events. properties: + enabled: + description: Whether this processor is enabled. + example: true + type: boolean fields: description: A list of log field paths to check for duplicates. example: @@ -33893,8 +33987,9 @@ components: example: service:my-service type: string inputs: - description: A list of component IDs whose output is used as the input for - this processor. + description: A list of component IDs whose output is used as input for this + processor. Required when used as a standalone processor, omit when used + within a processor group. example: - parse-json-processor items: @@ -33908,7 +34003,6 @@ components: - id - type - include - - inputs - fields - mode type: object @@ -34116,6 +34210,10 @@ components: description: The `enrichment_table` processor enriches logs using a static CSV file or GeoIP database. properties: + enabled: + description: Whether this processor is enabled. + example: true + type: boolean file: $ref: '#/components/schemas/ObservabilityPipelineEnrichmentTableFile' geoip: @@ -34130,8 +34228,9 @@ components: example: source:my-source type: string inputs: - description: A list of component IDs whose output is used as the input for - this processor. + description: A list of component IDs whose output is used as input for this + processor. Required when used as a standalone processor, omit when used + within a processor group. example: - add-fields-processor items: @@ -34147,7 +34246,6 @@ components: - id - type - include - - inputs - target type: object ObservabilityPipelineEnrichmentTableProcessorType: @@ -34179,6 +34277,10 @@ components: on a Datadog search query. Logs that match the `include` query are passed through; others are discarded. properties: + enabled: + description: Whether this processor is enabled. + example: true + type: boolean id: description: The unique identifier for this component. Used to reference this component in other parts of the pipeline (for example, as the `input` @@ -34192,8 +34294,9 @@ components: example: service:my-service type: string inputs: - description: A list of component IDs whose output is used as the `input` - for this component. + description: A list of component IDs whose output is used as input for this + processor. Required when used as a standalone processor, omit when used + within a processor group. example: - datadog-agent-source items: @@ -34205,7 +34308,6 @@ components: - id - type - include - - inputs type: object ObservabilityPipelineFilterProcessorType: default: filter @@ -34285,6 +34387,10 @@ components: Metrics can be counters, gauges, or distributions and optionally grouped by log fields.' properties: + enabled: + description: Whether this processor is enabled. + example: true + type: boolean id: description: The unique identifier for this component. Used to reference this component in other parts of the pipeline. @@ -34296,8 +34402,9 @@ components: example: service:my-service type: string inputs: - description: A list of component IDs whose output is used as the `input` - for this processor. + description: A list of component IDs whose output is used as input for this + processor. Required when used as a standalone processor, omit when used + within a processor group. example: - source-id items: @@ -34313,9 +34420,6 @@ components: required: - id - type - - inputs - - include - - metrics type: object ObservabilityPipelineGenerateMetricsProcessorType: default: generate_datadog_metrics @@ -34916,6 +35020,10 @@ components: description: The `ocsf_mapper` processor transforms logs into the OCSF schema using a predefined mapping configuration. properties: + enabled: + description: Whether this processor is enabled. + example: true + type: boolean id: description: The unique identifier for this component. Used to reference this component in other parts of the pipeline. @@ -34927,8 +35035,9 @@ components: example: service:my-service type: string inputs: - description: A list of component IDs whose output is used as the `input` - for this processor. + description: A list of component IDs whose output is used as input for this + processor. Required when used as a standalone processor, omit when used + within a processor group. example: - filter-processor items: @@ -34945,7 +35054,6 @@ components: - id - type - include - - inputs - mappings type: object ObservabilityPipelineOcsfMapperProcessorMapping: @@ -35051,6 +35159,10 @@ components: by Datadog. example: true type: boolean + enabled: + description: Whether this processor is enabled. + example: true + type: boolean id: description: A unique identifier for this processor. example: parse-grok-processor @@ -35061,8 +35173,9 @@ components: example: service:my-service type: string inputs: - description: A list of component IDs whose output is used as the `input` - for this component. + description: A list of component IDs whose output is used as input for this + processor. Required when used as a standalone processor, omit when used + within a processor group. example: - datadog-agent-source items: @@ -35081,7 +35194,6 @@ components: - id - type - include - - inputs - rules type: object ObservabilityPipelineParseGrokProcessorRule: @@ -35167,6 +35279,10 @@ components: and flattens it into the event. This is useful when logs contain embedded JSON as a string. properties: + enabled: + description: Whether this processor is enabled. + example: true + type: boolean field: description: The name of the log field that contains a JSON string. example: message @@ -35183,8 +35299,9 @@ components: example: service:my-service type: string inputs: - description: A list of component IDs whose output is used as the `input` - for this component. + description: A list of component IDs whose output is used as input for this + processor. Required when used as a standalone processor, omit when used + within a processor group. example: - datadog-agent-source items: @@ -35197,7 +35314,6 @@ components: - type - include - field - - inputs type: object ObservabilityPipelineParseJSONProcessorType: default: parse_json @@ -35230,6 +35346,10 @@ components: the filter query continue through the pipeline. example: false type: boolean + enabled: + description: Whether this processor is enabled. + example: true + type: boolean id: description: The unique identifier for this component. Used to reference this component in other parts of the pipeline (for example, as the `input` @@ -35246,8 +35366,9 @@ components: example: service:my-service type: string inputs: - description: A list of component IDs whose output is used as the `input` - for this component. + description: A list of component IDs whose output is used as input for this + processor. Required when used as a standalone processor, omit when used + within a processor group. example: - datadog-agent-source items: @@ -35284,7 +35405,6 @@ components: - name - drop_events - limit - - inputs type: object ObservabilityPipelineQuotaProcessorLimit: description: The maximum amount of data or number of events allowed before the @@ -35360,6 +35480,10 @@ components: description: The `reduce` processor aggregates and merges logs based on matching keys and merge strategies. properties: + enabled: + description: Whether this processor is enabled. + example: true + type: boolean group_by: description: A list of fields used to group log events for merging. example: @@ -35378,8 +35502,9 @@ components: example: env:prod type: string inputs: - description: A list of component IDs whose output is used as the input for - this processor. + description: A list of component IDs whose output is used as input for this + processor. Required when used as a standalone processor, omit when used + within a processor group. example: - parse-json-processor items: @@ -35397,7 +35522,6 @@ components: - id - type - include - - inputs - group_by - merge_strategies type: object @@ -35456,6 +35580,10 @@ components: ObservabilityPipelineRemoveFieldsProcessor: description: The `remove_fields` processor deletes specified fields from logs. properties: + enabled: + description: Whether this processor is enabled. + example: true + type: boolean fields: description: A list of field names to be removed from each log event. example: @@ -35476,7 +35604,9 @@ components: example: service:my-service type: string inputs: - description: The `PipelineRemoveFieldsProcessor` `inputs`. + description: A list of component IDs whose output is used as input for this + processor. Required when used as a standalone processor, omit when used + within a processor group. example: - datadog-agent-source items: @@ -35489,7 +35619,6 @@ components: - type - include - fields - - inputs type: object ObservabilityPipelineRemoveFieldsProcessorType: default: remove_fields @@ -35503,6 +35632,10 @@ components: ObservabilityPipelineRenameFieldsProcessor: description: The `rename_fields` processor changes field names. properties: + enabled: + description: Whether this processor is enabled. + example: true + type: boolean fields: description: A list of rename rules specifying which fields to rename in the event, what to rename them to, and whether to preserve the original @@ -35522,8 +35655,9 @@ components: example: service:my-service type: string inputs: - description: A list of component IDs whose output is used as the `input` - for this component. + description: A list of component IDs whose output is used as input for this + processor. Required when used as a standalone processor, omit when used + within a processor group. example: - datadog-agent-source items: @@ -35536,7 +35670,6 @@ components: - type - include - fields - - inputs type: object ObservabilityPipelineRenameFieldsProcessorField: description: Defines how to rename a field in log events. @@ -35642,6 +35775,10 @@ components: description: The `sample` processor allows probabilistic sampling of logs at a fixed rate. properties: + enabled: + description: Whether this processor is enabled. + example: true + type: boolean id: description: The unique identifier for this component. Used to reference this component in other parts of the pipeline (for example, as the `input` @@ -35654,8 +35791,9 @@ components: example: service:my-service type: string inputs: - description: A list of component IDs whose output is used as the `input` - for this component. + description: A list of component IDs whose output is used as input for this + processor. Required when used as a standalone processor, omit when used + within a processor group. example: - datadog-agent-source items: @@ -35678,7 +35816,6 @@ components: - id - type - include - - inputs type: object ObservabilityPipelineSampleProcessorType: default: sample @@ -35693,6 +35830,10 @@ components: description: The `sensitive_data_scanner` processor detects and optionally redacts sensitive data in log events. properties: + enabled: + description: Whether this processor is enabled. + example: true + type: boolean id: description: The unique identifier for this component. Used to reference this component in other parts of the pipeline (e.g., as input to downstream @@ -35705,8 +35846,9 @@ components: example: source:prod type: string inputs: - description: A list of component IDs whose output is used as the `input` - for this component. + description: A list of component IDs whose output is used as input for this + processor. Required when used as a standalone processor, omit when used + within a processor group. example: - parse-json-processor items: @@ -35724,7 +35866,6 @@ components: - id - type - include - - inputs - rules type: object ObservabilityPipelineSensitiveDataScannerProcessorAction: @@ -36686,6 +36827,10 @@ components: description: The `throttle` processor limits the number of events that pass through over a given time window. properties: + enabled: + description: Whether this processor is enabled. + example: true + type: boolean group_by: description: Optional list of fields used to group events before the threshold has been reached. @@ -36704,8 +36849,9 @@ components: example: env:prod type: string inputs: - description: A list of component IDs whose output is used as the input for - this processor. + description: A list of component IDs whose output is used as input for this + processor. Required when used as a standalone processor, omit when used + within a processor group. example: - datadog-agent-source items: @@ -36728,7 +36874,6 @@ components: - id - type - include - - inputs - threshold - window type: object diff --git a/examples/v2/observability-pipelines/CreatePipeline.java b/examples/v2/observability-pipelines/CreatePipeline.java index 01a6027125b..7b8ebf904aa 100644 --- a/examples/v2/observability-pipelines/CreatePipeline.java +++ b/examples/v2/observability-pipelines/CreatePipeline.java @@ -7,6 +7,7 @@ import com.datadog.api.client.v2.model.ObservabilityPipelineConfig; import com.datadog.api.client.v2.model.ObservabilityPipelineConfigDestinationItem; import com.datadog.api.client.v2.model.ObservabilityPipelineConfigProcessorItem; +import com.datadog.api.client.v2.model.ObservabilityPipelineConfigProcessors; import com.datadog.api.client.v2.model.ObservabilityPipelineConfigSourceItem; import com.datadog.api.client.v2.model.ObservabilityPipelineDataAttributes; import com.datadog.api.client.v2.model.ObservabilityPipelineDatadogAgentSource; @@ -45,17 +46,19 @@ public static void main(String[] args) { ObservabilityPipelineDatadogLogsDestinationType .DATADOG_LOGS)))) .processors( - Collections.singletonList( - new ObservabilityPipelineConfigProcessorItem( - new ObservabilityPipelineFilterProcessor() - .id("filter-processor") - .include("service:my-service") - .inputs( - Collections.singletonList( - "datadog-agent-source")) - .type( - ObservabilityPipelineFilterProcessorType - .FILTER)))) + ObservabilityPipelineConfigProcessors + .fromObservabilityPipelineConfigProcessorItemList( + Collections.singletonList( + new ObservabilityPipelineConfigProcessorItem( + new ObservabilityPipelineFilterProcessor() + .id("filter-processor") + .include("service:my-service") + .inputs( + Collections.singletonList( + "datadog-agent-source")) + .type( + ObservabilityPipelineFilterProcessorType + .FILTER))))) .sources( Collections.singletonList( new ObservabilityPipelineConfigSourceItem( diff --git a/examples/v2/observability-pipelines/UpdatePipeline.java b/examples/v2/observability-pipelines/UpdatePipeline.java index 0f8df0509d3..eee0721b6e0 100644 --- a/examples/v2/observability-pipelines/UpdatePipeline.java +++ b/examples/v2/observability-pipelines/UpdatePipeline.java @@ -7,6 +7,7 @@ import com.datadog.api.client.v2.model.ObservabilityPipelineConfig; import com.datadog.api.client.v2.model.ObservabilityPipelineConfigDestinationItem; import com.datadog.api.client.v2.model.ObservabilityPipelineConfigProcessorItem; +import com.datadog.api.client.v2.model.ObservabilityPipelineConfigProcessors; import com.datadog.api.client.v2.model.ObservabilityPipelineConfigSourceItem; import com.datadog.api.client.v2.model.ObservabilityPipelineData; import com.datadog.api.client.v2.model.ObservabilityPipelineDataAttributes; @@ -47,17 +48,19 @@ public static void main(String[] args) { ObservabilityPipelineDatadogLogsDestinationType .DATADOG_LOGS)))) .processors( - Collections.singletonList( - new ObservabilityPipelineConfigProcessorItem( - new ObservabilityPipelineFilterProcessor() - .id("filter-processor") - .include("service:my-service") - .inputs( - Collections.singletonList( - "datadog-agent-source")) - .type( - ObservabilityPipelineFilterProcessorType - .FILTER)))) + ObservabilityPipelineConfigProcessors + .fromObservabilityPipelineConfigProcessorItemList( + Collections.singletonList( + new ObservabilityPipelineConfigProcessorItem( + new ObservabilityPipelineFilterProcessor() + .id("filter-processor") + .include("service:my-service") + .inputs( + Collections.singletonList( + "datadog-agent-source")) + .type( + ObservabilityPipelineFilterProcessorType + .FILTER))))) .sources( Collections.singletonList( new ObservabilityPipelineConfigSourceItem( diff --git a/examples/v2/observability-pipelines/ValidatePipeline.java b/examples/v2/observability-pipelines/ValidatePipeline.java index 159cd0640e6..f98d5acb64d 100644 --- a/examples/v2/observability-pipelines/ValidatePipeline.java +++ b/examples/v2/observability-pipelines/ValidatePipeline.java @@ -6,6 +6,7 @@ import com.datadog.api.client.v2.model.ObservabilityPipelineConfig; import com.datadog.api.client.v2.model.ObservabilityPipelineConfigDestinationItem; import com.datadog.api.client.v2.model.ObservabilityPipelineConfigProcessorItem; +import com.datadog.api.client.v2.model.ObservabilityPipelineConfigProcessors; import com.datadog.api.client.v2.model.ObservabilityPipelineConfigSourceItem; import com.datadog.api.client.v2.model.ObservabilityPipelineDataAttributes; import com.datadog.api.client.v2.model.ObservabilityPipelineDatadogAgentSource; @@ -45,17 +46,19 @@ public static void main(String[] args) { ObservabilityPipelineDatadogLogsDestinationType .DATADOG_LOGS)))) .processors( - Collections.singletonList( - new ObservabilityPipelineConfigProcessorItem( - new ObservabilityPipelineFilterProcessor() - .id("filter-processor") - .include("service:my-service") - .inputs( - Collections.singletonList( - "datadog-agent-source")) - .type( - ObservabilityPipelineFilterProcessorType - .FILTER)))) + ObservabilityPipelineConfigProcessors + .fromObservabilityPipelineConfigProcessorItemList( + Collections.singletonList( + new ObservabilityPipelineConfigProcessorItem( + new ObservabilityPipelineFilterProcessor() + .id("filter-processor") + .include("service:my-service") + .inputs( + Collections.singletonList( + "datadog-agent-source")) + .type( + ObservabilityPipelineFilterProcessorType + .FILTER))))) .sources( Collections.singletonList( new ObservabilityPipelineConfigSourceItem( diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAddEnvVarsProcessor.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAddEnvVarsProcessor.java index 694f833d9ec..af2246d9d9f 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAddEnvVarsProcessor.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAddEnvVarsProcessor.java @@ -21,6 +21,7 @@ /** The add_env_vars processor adds environment variable values to log events. */ @JsonPropertyOrder({ + ObservabilityPipelineAddEnvVarsProcessor.JSON_PROPERTY_ENABLED, ObservabilityPipelineAddEnvVarsProcessor.JSON_PROPERTY_ID, ObservabilityPipelineAddEnvVarsProcessor.JSON_PROPERTY_INCLUDE, ObservabilityPipelineAddEnvVarsProcessor.JSON_PROPERTY_INPUTS, @@ -31,6 +32,9 @@ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator") public class ObservabilityPipelineAddEnvVarsProcessor { @JsonIgnore public boolean unparsed = false; + public static final String JSON_PROPERTY_ENABLED = "enabled"; + private Boolean enabled; + public static final String JSON_PROPERTY_ID = "id"; private String id; @@ -38,7 +42,7 @@ public class ObservabilityPipelineAddEnvVarsProcessor { private String include; public static final String JSON_PROPERTY_INPUTS = "inputs"; - private List inputs = new ArrayList<>(); + private List inputs = null; public static final String JSON_PROPERTY_TYPE = "type"; private ObservabilityPipelineAddEnvVarsProcessorType type = @@ -53,19 +57,38 @@ public ObservabilityPipelineAddEnvVarsProcessor() {} public ObservabilityPipelineAddEnvVarsProcessor( @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_TYPE) ObservabilityPipelineAddEnvVarsProcessorType type, @JsonProperty(required = true, value = JSON_PROPERTY_VARIABLES) List variables) { this.id = id; this.include = include; - this.inputs = inputs; this.type = type; this.unparsed |= !type.isValid(); this.variables = variables; } + public ObservabilityPipelineAddEnvVarsProcessor enabled(Boolean enabled) { + this.enabled = enabled; + return this; + } + + /** + * Whether this processor is enabled. + * + * @return enabled + */ + @jakarta.annotation.Nullable + @JsonProperty(JSON_PROPERTY_ENABLED) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) + public Boolean getEnabled() { + return enabled; + } + + public void setEnabled(Boolean enabled) { + this.enabled = enabled; + } + public ObservabilityPipelineAddEnvVarsProcessor id(String id) { this.id = id; return this; @@ -112,17 +135,22 @@ public ObservabilityPipelineAddEnvVarsProcessor inputs(List inputs) { } public ObservabilityPipelineAddEnvVarsProcessor addInputsItem(String inputsItem) { + if (this.inputs == null) { + this.inputs = new ArrayList<>(); + } this.inputs.add(inputsItem); return this; } /** - * A list of component IDs whose output is used as the input for this processor. + * A list of component IDs whose output is used as input for this processor. Required when used as + * a standalone processor, omit when used within a processor group. * * @return inputs */ + @jakarta.annotation.Nullable @JsonProperty(JSON_PROPERTY_INPUTS) - @JsonInclude(value = JsonInclude.Include.ALWAYS) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) public List getInputs() { return inputs; } @@ -244,7 +272,8 @@ public boolean equals(Object o) { } ObservabilityPipelineAddEnvVarsProcessor observabilityPipelineAddEnvVarsProcessor = (ObservabilityPipelineAddEnvVarsProcessor) o; - return Objects.equals(this.id, observabilityPipelineAddEnvVarsProcessor.id) + return Objects.equals(this.enabled, observabilityPipelineAddEnvVarsProcessor.enabled) + && Objects.equals(this.id, observabilityPipelineAddEnvVarsProcessor.id) && Objects.equals(this.include, observabilityPipelineAddEnvVarsProcessor.include) && Objects.equals(this.inputs, observabilityPipelineAddEnvVarsProcessor.inputs) && Objects.equals(this.type, observabilityPipelineAddEnvVarsProcessor.type) @@ -256,13 +285,14 @@ public boolean equals(Object o) { @Override public int hashCode() { - return Objects.hash(id, include, inputs, type, variables, additionalProperties); + return Objects.hash(enabled, id, include, inputs, type, variables, additionalProperties); } @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineAddEnvVarsProcessor {\n"); + sb.append(" enabled: ").append(toIndentedString(enabled)).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"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAddFieldsProcessor.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAddFieldsProcessor.java index 942e68603c8..4ff05cae97a 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAddFieldsProcessor.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAddFieldsProcessor.java @@ -21,6 +21,7 @@ /** The add_fields processor adds static key-value fields to logs. */ @JsonPropertyOrder({ + ObservabilityPipelineAddFieldsProcessor.JSON_PROPERTY_ENABLED, ObservabilityPipelineAddFieldsProcessor.JSON_PROPERTY_FIELDS, ObservabilityPipelineAddFieldsProcessor.JSON_PROPERTY_ID, ObservabilityPipelineAddFieldsProcessor.JSON_PROPERTY_INCLUDE, @@ -31,6 +32,9 @@ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator") public class ObservabilityPipelineAddFieldsProcessor { @JsonIgnore public boolean unparsed = false; + public static final String JSON_PROPERTY_ENABLED = "enabled"; + private Boolean enabled; + public static final String JSON_PROPERTY_FIELDS = "fields"; private List fields = new ArrayList<>(); @@ -41,7 +45,7 @@ public class ObservabilityPipelineAddFieldsProcessor { private String include; public static final String JSON_PROPERTY_INPUTS = "inputs"; - private List inputs = new ArrayList<>(); + private List inputs = null; public static final String JSON_PROPERTY_TYPE = "type"; private ObservabilityPipelineAddFieldsProcessorType type = @@ -55,17 +59,36 @@ public ObservabilityPipelineAddFieldsProcessor( List fields, @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_TYPE) ObservabilityPipelineAddFieldsProcessorType type) { this.fields = fields; this.id = id; this.include = include; - this.inputs = inputs; this.type = type; this.unparsed |= !type.isValid(); } + public ObservabilityPipelineAddFieldsProcessor enabled(Boolean enabled) { + this.enabled = enabled; + return this; + } + + /** + * Whether this processor is enabled. + * + * @return enabled + */ + @jakarta.annotation.Nullable + @JsonProperty(JSON_PROPERTY_ENABLED) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) + public Boolean getEnabled() { + return enabled; + } + + public void setEnabled(Boolean enabled) { + this.enabled = enabled; + } + public ObservabilityPipelineAddFieldsProcessor fields( List fields) { this.fields = fields; @@ -145,17 +168,22 @@ public ObservabilityPipelineAddFieldsProcessor inputs(List inputs) { } public ObservabilityPipelineAddFieldsProcessor addInputsItem(String inputsItem) { + if (this.inputs == null) { + this.inputs = new ArrayList<>(); + } this.inputs.add(inputsItem); return this; } /** - * A list of component IDs whose output is used as the input for this component. + * A list of component IDs whose output is used as input for this processor. Required when used as + * a standalone processor, omit when used within a processor group. * * @return inputs */ + @jakarta.annotation.Nullable @JsonProperty(JSON_PROPERTY_INPUTS) - @JsonInclude(value = JsonInclude.Include.ALWAYS) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) public List getInputs() { return inputs; } @@ -246,7 +274,8 @@ public boolean equals(Object o) { } ObservabilityPipelineAddFieldsProcessor observabilityPipelineAddFieldsProcessor = (ObservabilityPipelineAddFieldsProcessor) o; - return Objects.equals(this.fields, observabilityPipelineAddFieldsProcessor.fields) + return Objects.equals(this.enabled, observabilityPipelineAddFieldsProcessor.enabled) + && Objects.equals(this.fields, observabilityPipelineAddFieldsProcessor.fields) && Objects.equals(this.id, observabilityPipelineAddFieldsProcessor.id) && Objects.equals(this.include, observabilityPipelineAddFieldsProcessor.include) && Objects.equals(this.inputs, observabilityPipelineAddFieldsProcessor.inputs) @@ -258,13 +287,14 @@ public boolean equals(Object o) { @Override public int hashCode() { - return Objects.hash(fields, id, include, inputs, type, additionalProperties); + return Objects.hash(enabled, fields, id, include, inputs, type, additionalProperties); } @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineAddFieldsProcessor {\n"); + sb.append(" enabled: ").append(toIndentedString(enabled)).append("\n"); sb.append(" fields: ").append(toIndentedString(fields)).append("\n"); sb.append(" id: ").append(toIndentedString(id)).append("\n"); sb.append(" include: ").append(toIndentedString(include)).append("\n"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineConfig.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineConfig.java index cf7863c4c01..9b3afe2d9dc 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineConfig.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineConfig.java @@ -33,7 +33,7 @@ public class ObservabilityPipelineConfig { private List destinations = new ArrayList<>(); public static final String JSON_PROPERTY_PROCESSORS = "processors"; - private List processors = null; + private ObservabilityPipelineConfigProcessors processors; public static final String JSON_PROPERTY_SOURCES = "sources"; private List sources = new ArrayList<>(); @@ -81,38 +81,26 @@ public void setDestinations(List des this.destinations = destinations; } - public ObservabilityPipelineConfig processors( - List processors) { + public ObservabilityPipelineConfig processors(ObservabilityPipelineConfigProcessors processors) { this.processors = processors; - for (ObservabilityPipelineConfigProcessorItem item : processors) { - this.unparsed |= item.unparsed; - } - return this; - } - - public ObservabilityPipelineConfig addProcessorsItem( - ObservabilityPipelineConfigProcessorItem processorsItem) { - if (this.processors == null) { - this.processors = new ArrayList<>(); - } - this.processors.add(processorsItem); - this.unparsed |= processorsItem.unparsed; + this.unparsed |= processors.unparsed; return this; } /** - * A list of processors that transform or enrich log data. + * A list of processors that transform or enrich log data, or a list of grouped processor + * configurations. * * @return processors */ @jakarta.annotation.Nullable @JsonProperty(JSON_PROPERTY_PROCESSORS) @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) - public List getProcessors() { + public ObservabilityPipelineConfigProcessors getProcessors() { return processors; } - public void setProcessors(List processors) { + public void setProcessors(ObservabilityPipelineConfigProcessors processors) { this.processors = processors; } diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineConfigProcessorGroup.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineConfigProcessorGroup.java new file mode 100644 index 00000000000..f0e19268c5d --- /dev/null +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineConfigProcessorGroup.java @@ -0,0 +1,279 @@ +/* + * 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; + +/** A group of processors. */ +@JsonPropertyOrder({ + ObservabilityPipelineConfigProcessorGroup.JSON_PROPERTY_ENABLED, + ObservabilityPipelineConfigProcessorGroup.JSON_PROPERTY_ID, + ObservabilityPipelineConfigProcessorGroup.JSON_PROPERTY_INCLUDE, + ObservabilityPipelineConfigProcessorGroup.JSON_PROPERTY_INPUTS, + ObservabilityPipelineConfigProcessorGroup.JSON_PROPERTY_PROCESSORS +}) +@jakarta.annotation.Generated( + value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator") +public class ObservabilityPipelineConfigProcessorGroup { + @JsonIgnore public boolean unparsed = false; + public static final String JSON_PROPERTY_ENABLED = "enabled"; + private Boolean enabled; + + 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_PROCESSORS = "processors"; + private List processors = new ArrayList<>(); + + public ObservabilityPipelineConfigProcessorGroup() {} + + @JsonCreator + public ObservabilityPipelineConfigProcessorGroup( + @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_PROCESSORS) + List processors) { + this.id = id; + this.include = include; + this.inputs = inputs; + this.processors = processors; + } + + public ObservabilityPipelineConfigProcessorGroup enabled(Boolean enabled) { + this.enabled = enabled; + return this; + } + + /** + * Whether this processor group is enabled. + * + * @return enabled + */ + @jakarta.annotation.Nullable + @JsonProperty(JSON_PROPERTY_ENABLED) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) + public Boolean getEnabled() { + return enabled; + } + + public void setEnabled(Boolean enabled) { + this.enabled = enabled; + } + + public ObservabilityPipelineConfigProcessorGroup id(String id) { + this.id = id; + return this; + } + + /** + * The unique identifier for the processor group. + * + * @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 ObservabilityPipelineConfigProcessorGroup include(String include) { + this.include = include; + return this; + } + + /** + * Conditional expression for when this processor group should execute. + * + * @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 ObservabilityPipelineConfigProcessorGroup inputs(List inputs) { + this.inputs = inputs; + return this; + } + + public ObservabilityPipelineConfigProcessorGroup addInputsItem(String inputsItem) { + this.inputs.add(inputsItem); + return this; + } + + /** + * A list of component IDs whose output is used as the input for this processor group. + * + * @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 ObservabilityPipelineConfigProcessorGroup processors( + List processors) { + this.processors = processors; + for (ObservabilityPipelineConfigProcessorItem item : processors) { + this.unparsed |= item.unparsed; + } + return this; + } + + public ObservabilityPipelineConfigProcessorGroup addProcessorsItem( + ObservabilityPipelineConfigProcessorItem processorsItem) { + this.processors.add(processorsItem); + this.unparsed |= processorsItem.unparsed; + return this; + } + + /** + * Processors applied sequentially within this group. No inputs fields required - + * events flow through each processor in order. + * + * @return processors + */ + @JsonProperty(JSON_PROPERTY_PROCESSORS) + @JsonInclude(value = JsonInclude.Include.ALWAYS) + public List getProcessors() { + return processors; + } + + public void setProcessors(List processors) { + this.processors = processors; + } + + /** + * 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 ObservabilityPipelineConfigProcessorGroup + */ + @JsonAnySetter + public ObservabilityPipelineConfigProcessorGroup 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 ObservabilityPipelineConfigProcessorGroup object is equal to o. */ + @Override + public boolean equals(Object o) { + if (this == o) { + return true; + } + if (o == null || getClass() != o.getClass()) { + return false; + } + ObservabilityPipelineConfigProcessorGroup observabilityPipelineConfigProcessorGroup = + (ObservabilityPipelineConfigProcessorGroup) o; + return Objects.equals(this.enabled, observabilityPipelineConfigProcessorGroup.enabled) + && Objects.equals(this.id, observabilityPipelineConfigProcessorGroup.id) + && Objects.equals(this.include, observabilityPipelineConfigProcessorGroup.include) + && Objects.equals(this.inputs, observabilityPipelineConfigProcessorGroup.inputs) + && Objects.equals(this.processors, observabilityPipelineConfigProcessorGroup.processors) + && Objects.equals( + this.additionalProperties, + observabilityPipelineConfigProcessorGroup.additionalProperties); + } + + @Override + public int hashCode() { + return Objects.hash(enabled, id, include, inputs, processors, additionalProperties); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder(); + sb.append("class ObservabilityPipelineConfigProcessorGroup {\n"); + sb.append(" enabled: ").append(toIndentedString(enabled)).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(" processors: ").append(toIndentedString(processors)).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/ObservabilityPipelineConfigProcessors.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineConfigProcessors.java new file mode 100644 index 00000000000..2a201a68453 --- /dev/null +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineConfigProcessors.java @@ -0,0 +1,319 @@ +/* + * 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.List; +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 = + ObservabilityPipelineConfigProcessors.ObservabilityPipelineConfigProcessorsDeserializer + .class) +@JsonSerialize( + using = + ObservabilityPipelineConfigProcessors.ObservabilityPipelineConfigProcessorsSerializer.class) +public class ObservabilityPipelineConfigProcessors extends AbstractOpenApiSchema { + private static final Logger log = + Logger.getLogger(ObservabilityPipelineConfigProcessors.class.getName()); + + @JsonIgnore public boolean unparsed = false; + + public static class ObservabilityPipelineConfigProcessorsSerializer + extends StdSerializer { + public ObservabilityPipelineConfigProcessorsSerializer( + Class t) { + super(t); + } + + public ObservabilityPipelineConfigProcessorsSerializer() { + this(null); + } + + @Override + public void serialize( + ObservabilityPipelineConfigProcessors value, + JsonGenerator jgen, + SerializerProvider provider) + throws IOException, JsonProcessingException { + jgen.writeObject(value.getActualInstance()); + } + } + + public static class ObservabilityPipelineConfigProcessorsDeserializer + extends StdDeserializer { + public ObservabilityPipelineConfigProcessorsDeserializer() { + this(ObservabilityPipelineConfigProcessors.class); + } + + public ObservabilityPipelineConfigProcessorsDeserializer(Class vc) { + super(vc); + } + + @Override + public ObservabilityPipelineConfigProcessors 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 List + try { + boolean attemptParsing = true; + // ensure that we respect type coercion as set on the client ObjectMapper + if (List.class.equals(Integer.class) + || List.class.equals(Long.class) + || List.class.equals(Float.class) + || List.class.equals(Double.class) + || List.class.equals(Boolean.class) + || List.class.equals(String.class)) { + attemptParsing = typeCoercion; + if (!attemptParsing) { + attemptParsing |= + ((List.class.equals(Integer.class) || List.class.equals(Long.class)) + && token == JsonToken.VALUE_NUMBER_INT); + attemptParsing |= + ((List.class.equals(Float.class) || List.class.equals(Double.class)) + && (token == JsonToken.VALUE_NUMBER_FLOAT + || token == JsonToken.VALUE_NUMBER_INT)); + attemptParsing |= + (List.class.equals(Boolean.class) + && (token == JsonToken.VALUE_FALSE || token == JsonToken.VALUE_TRUE)); + attemptParsing |= (List.class.equals(String.class) && token == JsonToken.VALUE_STRING); + } + } + if (attemptParsing) { + tmp = + tree.traverse(jp.getCodec()) + .readValueAs( + new TypeReference>() {}); + // 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. + deserialized = tmp; + match++; + + log.log( + Level.FINER, + "Input data matches schema 'List'"); + } + } catch (Exception e) { + // deserialization failed, continue + log.log( + Level.FINER, + "Input data does not match schema 'List'", + e); + } + + // deserialize List + try { + boolean attemptParsing = true; + // ensure that we respect type coercion as set on the client ObjectMapper + if (List.class.equals(Integer.class) + || List.class.equals(Long.class) + || List.class.equals(Float.class) + || List.class.equals(Double.class) + || List.class.equals(Boolean.class) + || List.class.equals(String.class)) { + attemptParsing = typeCoercion; + if (!attemptParsing) { + attemptParsing |= + ((List.class.equals(Integer.class) || List.class.equals(Long.class)) + && token == JsonToken.VALUE_NUMBER_INT); + attemptParsing |= + ((List.class.equals(Float.class) || List.class.equals(Double.class)) + && (token == JsonToken.VALUE_NUMBER_FLOAT + || token == JsonToken.VALUE_NUMBER_INT)); + attemptParsing |= + (List.class.equals(Boolean.class) + && (token == JsonToken.VALUE_FALSE || token == JsonToken.VALUE_TRUE)); + attemptParsing |= (List.class.equals(String.class) && token == JsonToken.VALUE_STRING); + } + } + if (attemptParsing) { + tmp = + tree.traverse(jp.getCodec()) + .readValueAs( + new TypeReference>() {}); + // 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. + deserialized = tmp; + match++; + + log.log( + Level.FINER, + "Input data matches schema 'List'"); + } + } catch (Exception e) { + // deserialization failed, continue + log.log( + Level.FINER, + "Input data does not match schema 'List'", + e); + } + + ObservabilityPipelineConfigProcessors ret = new ObservabilityPipelineConfigProcessors(); + if (match == 1) { + ret.setActualInstance(deserialized); + } else { + Map res = + new ObjectMapper() + .readValue( + tree.traverse(jp.getCodec()).readValueAsTree().toString(), + new TypeReference>() {}); + ret.setActualInstance(new UnparsedObject(res)); + } + return ret; + } + + /** Handle deserialization of the 'null' value. */ + @Override + public ObservabilityPipelineConfigProcessors getNullValue(DeserializationContext ctxt) + throws JsonMappingException { + throw new JsonMappingException( + ctxt.getParser(), "ObservabilityPipelineConfigProcessors cannot be null"); + } + } + + // store a list of schema names defined in oneOf + public static final Map schemas = new HashMap(); + + public ObservabilityPipelineConfigProcessors() { + super("oneOf", Boolean.FALSE); + } + + public static ObservabilityPipelineConfigProcessors + fromObservabilityPipelineConfigProcessorItemList( + List o) { + ObservabilityPipelineConfigProcessors instance = new ObservabilityPipelineConfigProcessors(); + instance.setActualInstance(o); + return instance; + } + + public static ObservabilityPipelineConfigProcessors + fromObservabilityPipelineConfigProcessorGroupList( + List o) { + ObservabilityPipelineConfigProcessors instance = new ObservabilityPipelineConfigProcessors(); + instance.setActualInstance(o); + return instance; + } + + static { + schemas.put( + "List", + new GenericType>() {}); + schemas.put( + "List", + new GenericType>() {}); + JSON.registerDescendants( + ObservabilityPipelineConfigProcessors.class, Collections.unmodifiableMap(schemas)); + } + + @Override + public Map getSchemas() { + return ObservabilityPipelineConfigProcessors.schemas; + } + + /** + * Set the instance that matches the oneOf child schema, check the instance parameter is valid + * against the oneOf child schemas: List<ObservabilityPipelineConfigProcessorItem>, + * List<ObservabilityPipelineConfigProcessorGroup> + * + *

It could be an instance of the 'oneOf' schemas. The oneOf child schemas may themselves be a + * composed schema (allOf, anyOf, oneOf). + */ + @Override + public void setActualInstance(Object instance) { + if (JSON.isInstanceOf(List.class, instance, new HashSet>())) { + super.setActualInstance(instance); + return; + } + if (JSON.isInstanceOf(List.class, instance, new HashSet>())) { + super.setActualInstance(instance); + return; + } + + if (JSON.isInstanceOf(UnparsedObject.class, instance, new HashSet>())) { + super.setActualInstance(instance); + return; + } + throw new RuntimeException( + "Invalid instance type. Must be List," + + " List"); + } + + /** + * Get the actual instance, which can be the following: + * List<ObservabilityPipelineConfigProcessorItem>, + * List<ObservabilityPipelineConfigProcessorGroup> + * + * @return The actual instance (List<ObservabilityPipelineConfigProcessorItem>, + * List<ObservabilityPipelineConfigProcessorGroup>) + */ + @Override + public Object getActualInstance() { + return super.getActualInstance(); + } + + /** + * Get the actual instance of `List<ObservabilityPipelineConfigProcessorItem>`. If the + * actual instance is not `List<ObservabilityPipelineConfigProcessorItem>`, the + * ClassCastException will be thrown. + * + * @return The actual instance of `List<ObservabilityPipelineConfigProcessorItem>` + * @throws ClassCastException if the instance is not + * `List<ObservabilityPipelineConfigProcessorItem>` + */ + public List + getObservabilityPipelineConfigProcessorItemList() throws ClassCastException { + return (List) super.getActualInstance(); + } + + /** + * Get the actual instance of `List<ObservabilityPipelineConfigProcessorGroup>`. If the + * actual instance is not `List<ObservabilityPipelineConfigProcessorGroup>`, the + * ClassCastException will be thrown. + * + * @return The actual instance of `List<ObservabilityPipelineConfigProcessorGroup>` + * @throws ClassCastException if the instance is not + * `List<ObservabilityPipelineConfigProcessorGroup>` + */ + public List + getObservabilityPipelineConfigProcessorGroupList() throws ClassCastException { + return (List) super.getActualInstance(); + } +} 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 index 00901ad1ebf..cbd50cfa5ef 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineCustomProcessor.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineCustomProcessor.java @@ -25,6 +25,7 @@ * advanced filtering capabilities. */ @JsonPropertyOrder({ + ObservabilityPipelineCustomProcessor.JSON_PROPERTY_ENABLED, ObservabilityPipelineCustomProcessor.JSON_PROPERTY_ID, ObservabilityPipelineCustomProcessor.JSON_PROPERTY_INCLUDE, ObservabilityPipelineCustomProcessor.JSON_PROPERTY_INPUTS, @@ -35,6 +36,9 @@ 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_ENABLED = "enabled"; + private Boolean enabled; + public static final String JSON_PROPERTY_ID = "id"; private String id; @@ -42,7 +46,7 @@ public class ObservabilityPipelineCustomProcessor { private String include = "*"; public static final String JSON_PROPERTY_INPUTS = "inputs"; - private List inputs = new ArrayList<>(); + private List inputs = null; public static final String JSON_PROPERTY_REMAPS = "remaps"; private List remaps = new ArrayList<>(); @@ -57,19 +61,38 @@ public ObservabilityPipelineCustomProcessor() {} 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 enabled(Boolean enabled) { + this.enabled = enabled; + return this; + } + + /** + * Whether this processor is enabled. + * + * @return enabled + */ + @jakarta.annotation.Nullable + @JsonProperty(JSON_PROPERTY_ENABLED) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) + public Boolean getEnabled() { + return enabled; + } + + public void setEnabled(Boolean enabled) { + this.enabled = enabled; + } + public ObservabilityPipelineCustomProcessor id(String id) { this.id = id; return this; @@ -117,17 +140,22 @@ public ObservabilityPipelineCustomProcessor inputs(List inputs) { } public ObservabilityPipelineCustomProcessor addInputsItem(String inputsItem) { + if (this.inputs == null) { + this.inputs = new ArrayList<>(); + } this.inputs.add(inputsItem); return this; } /** - * A list of component IDs whose output is used as the input for this processor. + * A list of component IDs whose output is used as input for this processor. Required when used as + * a standalone processor, omit when used within a processor group. * * @return inputs */ + @jakarta.annotation.Nullable @JsonProperty(JSON_PROPERTY_INPUTS) - @JsonInclude(value = JsonInclude.Include.ALWAYS) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) public List getInputs() { return inputs; } @@ -248,7 +276,8 @@ public boolean equals(Object o) { } ObservabilityPipelineCustomProcessor observabilityPipelineCustomProcessor = (ObservabilityPipelineCustomProcessor) o; - return Objects.equals(this.id, observabilityPipelineCustomProcessor.id) + return Objects.equals(this.enabled, observabilityPipelineCustomProcessor.enabled) + && Objects.equals(this.id, observabilityPipelineCustomProcessor.id) && Objects.equals(this.include, observabilityPipelineCustomProcessor.include) && Objects.equals(this.inputs, observabilityPipelineCustomProcessor.inputs) && Objects.equals(this.remaps, observabilityPipelineCustomProcessor.remaps) @@ -259,13 +288,14 @@ public boolean equals(Object o) { @Override public int hashCode() { - return Objects.hash(id, include, inputs, remaps, type, additionalProperties); + return Objects.hash(enabled, id, include, inputs, remaps, type, additionalProperties); } @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineCustomProcessor {\n"); + sb.append(" enabled: ").append(toIndentedString(enabled)).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"); 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 index c38aacab4bf..d9473f15f15 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineDatadogTagsProcessor.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineDatadogTagsProcessor.java @@ -24,6 +24,7 @@ */ @JsonPropertyOrder({ ObservabilityPipelineDatadogTagsProcessor.JSON_PROPERTY_ACTION, + ObservabilityPipelineDatadogTagsProcessor.JSON_PROPERTY_ENABLED, ObservabilityPipelineDatadogTagsProcessor.JSON_PROPERTY_ID, ObservabilityPipelineDatadogTagsProcessor.JSON_PROPERTY_INCLUDE, ObservabilityPipelineDatadogTagsProcessor.JSON_PROPERTY_INPUTS, @@ -38,6 +39,9 @@ public class ObservabilityPipelineDatadogTagsProcessor { public static final String JSON_PROPERTY_ACTION = "action"; private ObservabilityPipelineDatadogTagsProcessorAction action; + public static final String JSON_PROPERTY_ENABLED = "enabled"; + private Boolean enabled; + public static final String JSON_PROPERTY_ID = "id"; private String id; @@ -45,7 +49,7 @@ public class ObservabilityPipelineDatadogTagsProcessor { private String include; public static final String JSON_PROPERTY_INPUTS = "inputs"; - private List inputs = new ArrayList<>(); + private List inputs = null; public static final String JSON_PROPERTY_KEYS = "keys"; private List keys = new ArrayList<>(); @@ -65,7 +69,6 @@ public ObservabilityPipelineDatadogTagsProcessor( 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, @@ -75,7 +78,6 @@ public ObservabilityPipelineDatadogTagsProcessor( this.unparsed |= !action.isValid(); this.id = id; this.include = include; - this.inputs = inputs; this.keys = keys; this.mode = mode; this.unparsed |= !mode.isValid(); @@ -108,6 +110,27 @@ public void setAction(ObservabilityPipelineDatadogTagsProcessorAction action) { this.action = action; } + public ObservabilityPipelineDatadogTagsProcessor enabled(Boolean enabled) { + this.enabled = enabled; + return this; + } + + /** + * Whether this processor is enabled. + * + * @return enabled + */ + @jakarta.annotation.Nullable + @JsonProperty(JSON_PROPERTY_ENABLED) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) + public Boolean getEnabled() { + return enabled; + } + + public void setEnabled(Boolean enabled) { + this.enabled = enabled; + } + public ObservabilityPipelineDatadogTagsProcessor id(String id) { this.id = id; return this; @@ -155,17 +178,22 @@ public ObservabilityPipelineDatadogTagsProcessor inputs(List inputs) { } public ObservabilityPipelineDatadogTagsProcessor addInputsItem(String inputsItem) { + if (this.inputs == null) { + this.inputs = new ArrayList<>(); + } this.inputs.add(inputsItem); return this; } /** - * A list of component IDs whose output is used as the input for this component. + * A list of component IDs whose output is used as input for this processor. Required when used as + * a standalone processor, omit when used within a processor group. * * @return inputs */ + @jakarta.annotation.Nullable @JsonProperty(JSON_PROPERTY_INPUTS) - @JsonInclude(value = JsonInclude.Include.ALWAYS) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) public List getInputs() { return inputs; } @@ -307,6 +335,7 @@ public boolean equals(Object o) { ObservabilityPipelineDatadogTagsProcessor observabilityPipelineDatadogTagsProcessor = (ObservabilityPipelineDatadogTagsProcessor) o; return Objects.equals(this.action, observabilityPipelineDatadogTagsProcessor.action) + && Objects.equals(this.enabled, observabilityPipelineDatadogTagsProcessor.enabled) && Objects.equals(this.id, observabilityPipelineDatadogTagsProcessor.id) && Objects.equals(this.include, observabilityPipelineDatadogTagsProcessor.include) && Objects.equals(this.inputs, observabilityPipelineDatadogTagsProcessor.inputs) @@ -320,7 +349,8 @@ public boolean equals(Object o) { @Override public int hashCode() { - return Objects.hash(action, id, include, inputs, keys, mode, type, additionalProperties); + return Objects.hash( + action, enabled, id, include, inputs, keys, mode, type, additionalProperties); } @Override @@ -328,6 +358,7 @@ public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineDatadogTagsProcessor {\n"); sb.append(" action: ").append(toIndentedString(action)).append("\n"); + sb.append(" enabled: ").append(toIndentedString(enabled)).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"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineDedupeProcessor.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineDedupeProcessor.java index 68d0ca28d10..e53fb160784 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineDedupeProcessor.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineDedupeProcessor.java @@ -21,6 +21,7 @@ /** The dedupe processor removes duplicate fields in log events. */ @JsonPropertyOrder({ + ObservabilityPipelineDedupeProcessor.JSON_PROPERTY_ENABLED, ObservabilityPipelineDedupeProcessor.JSON_PROPERTY_FIELDS, ObservabilityPipelineDedupeProcessor.JSON_PROPERTY_ID, ObservabilityPipelineDedupeProcessor.JSON_PROPERTY_INCLUDE, @@ -32,6 +33,9 @@ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator") public class ObservabilityPipelineDedupeProcessor { @JsonIgnore public boolean unparsed = false; + public static final String JSON_PROPERTY_ENABLED = "enabled"; + private Boolean enabled; + public static final String JSON_PROPERTY_FIELDS = "fields"; private List fields = new ArrayList<>(); @@ -42,7 +46,7 @@ public class ObservabilityPipelineDedupeProcessor { private String include; public static final String JSON_PROPERTY_INPUTS = "inputs"; - private List inputs = new ArrayList<>(); + private List inputs = null; public static final String JSON_PROPERTY_MODE = "mode"; private ObservabilityPipelineDedupeProcessorMode mode; @@ -58,7 +62,6 @@ public ObservabilityPipelineDedupeProcessor( @JsonProperty(required = true, value = JSON_PROPERTY_FIELDS) List fields, @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_MODE) ObservabilityPipelineDedupeProcessorMode mode, @JsonProperty(required = true, value = JSON_PROPERTY_TYPE) @@ -66,13 +69,33 @@ public ObservabilityPipelineDedupeProcessor( this.fields = fields; this.id = id; this.include = include; - this.inputs = inputs; this.mode = mode; this.unparsed |= !mode.isValid(); this.type = type; this.unparsed |= !type.isValid(); } + public ObservabilityPipelineDedupeProcessor enabled(Boolean enabled) { + this.enabled = enabled; + return this; + } + + /** + * Whether this processor is enabled. + * + * @return enabled + */ + @jakarta.annotation.Nullable + @JsonProperty(JSON_PROPERTY_ENABLED) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) + public Boolean getEnabled() { + return enabled; + } + + public void setEnabled(Boolean enabled) { + this.enabled = enabled; + } + public ObservabilityPipelineDedupeProcessor fields(List fields) { this.fields = fields; return this; @@ -144,17 +167,22 @@ public ObservabilityPipelineDedupeProcessor inputs(List inputs) { } public ObservabilityPipelineDedupeProcessor addInputsItem(String inputsItem) { + if (this.inputs == null) { + this.inputs = new ArrayList<>(); + } this.inputs.add(inputsItem); return this; } /** - * A list of component IDs whose output is used as the input for this processor. + * A list of component IDs whose output is used as input for this processor. Required when used as + * a standalone processor, omit when used within a processor group. * * @return inputs */ + @jakarta.annotation.Nullable @JsonProperty(JSON_PROPERTY_INPUTS) - @JsonInclude(value = JsonInclude.Include.ALWAYS) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) public List getInputs() { return inputs; } @@ -268,7 +296,8 @@ public boolean equals(Object o) { } ObservabilityPipelineDedupeProcessor observabilityPipelineDedupeProcessor = (ObservabilityPipelineDedupeProcessor) o; - return Objects.equals(this.fields, observabilityPipelineDedupeProcessor.fields) + return Objects.equals(this.enabled, observabilityPipelineDedupeProcessor.enabled) + && Objects.equals(this.fields, observabilityPipelineDedupeProcessor.fields) && Objects.equals(this.id, observabilityPipelineDedupeProcessor.id) && Objects.equals(this.include, observabilityPipelineDedupeProcessor.include) && Objects.equals(this.inputs, observabilityPipelineDedupeProcessor.inputs) @@ -280,13 +309,14 @@ public boolean equals(Object o) { @Override public int hashCode() { - return Objects.hash(fields, id, include, inputs, mode, type, additionalProperties); + return Objects.hash(enabled, fields, id, include, inputs, mode, type, additionalProperties); } @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineDedupeProcessor {\n"); + sb.append(" enabled: ").append(toIndentedString(enabled)).append("\n"); sb.append(" fields: ").append(toIndentedString(fields)).append("\n"); sb.append(" id: ").append(toIndentedString(id)).append("\n"); sb.append(" include: ").append(toIndentedString(include)).append("\n"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineEnrichmentTableProcessor.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineEnrichmentTableProcessor.java index e4ad7c5a190..9d6beacbc85 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineEnrichmentTableProcessor.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineEnrichmentTableProcessor.java @@ -24,6 +24,7 @@ * database. */ @JsonPropertyOrder({ + ObservabilityPipelineEnrichmentTableProcessor.JSON_PROPERTY_ENABLED, ObservabilityPipelineEnrichmentTableProcessor.JSON_PROPERTY_FILE, ObservabilityPipelineEnrichmentTableProcessor.JSON_PROPERTY_GEOIP, ObservabilityPipelineEnrichmentTableProcessor.JSON_PROPERTY_ID, @@ -36,6 +37,9 @@ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator") public class ObservabilityPipelineEnrichmentTableProcessor { @JsonIgnore public boolean unparsed = false; + public static final String JSON_PROPERTY_ENABLED = "enabled"; + private Boolean enabled; + public static final String JSON_PROPERTY_FILE = "file"; private ObservabilityPipelineEnrichmentTableFile file; @@ -49,7 +53,7 @@ public class ObservabilityPipelineEnrichmentTableProcessor { private String include; public static final String JSON_PROPERTY_INPUTS = "inputs"; - private List inputs = new ArrayList<>(); + private List inputs = null; public static final String JSON_PROPERTY_TARGET = "target"; private String target; @@ -64,18 +68,37 @@ public ObservabilityPipelineEnrichmentTableProcessor() {} public ObservabilityPipelineEnrichmentTableProcessor( @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_TARGET) String target, @JsonProperty(required = true, value = JSON_PROPERTY_TYPE) ObservabilityPipelineEnrichmentTableProcessorType type) { this.id = id; this.include = include; - this.inputs = inputs; this.target = target; this.type = type; this.unparsed |= !type.isValid(); } + public ObservabilityPipelineEnrichmentTableProcessor enabled(Boolean enabled) { + this.enabled = enabled; + return this; + } + + /** + * Whether this processor is enabled. + * + * @return enabled + */ + @jakarta.annotation.Nullable + @JsonProperty(JSON_PROPERTY_ENABLED) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) + public Boolean getEnabled() { + return enabled; + } + + public void setEnabled(Boolean enabled) { + this.enabled = enabled; + } + public ObservabilityPipelineEnrichmentTableProcessor file( ObservabilityPipelineEnrichmentTableFile file) { this.file = file; @@ -168,17 +191,22 @@ public ObservabilityPipelineEnrichmentTableProcessor inputs(List inputs) } public ObservabilityPipelineEnrichmentTableProcessor addInputsItem(String inputsItem) { + if (this.inputs == null) { + this.inputs = new ArrayList<>(); + } this.inputs.add(inputsItem); return this; } /** - * A list of component IDs whose output is used as the input for this processor. + * A list of component IDs whose output is used as input for this processor. Required when used as + * a standalone processor, omit when used within a processor group. * * @return inputs */ + @jakarta.annotation.Nullable @JsonProperty(JSON_PROPERTY_INPUTS) - @JsonInclude(value = JsonInclude.Include.ALWAYS) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) public List getInputs() { return inputs; } @@ -290,7 +318,8 @@ public boolean equals(Object o) { } ObservabilityPipelineEnrichmentTableProcessor observabilityPipelineEnrichmentTableProcessor = (ObservabilityPipelineEnrichmentTableProcessor) o; - return Objects.equals(this.file, observabilityPipelineEnrichmentTableProcessor.file) + return Objects.equals(this.enabled, observabilityPipelineEnrichmentTableProcessor.enabled) + && Objects.equals(this.file, observabilityPipelineEnrichmentTableProcessor.file) && Objects.equals(this.geoip, observabilityPipelineEnrichmentTableProcessor.geoip) && Objects.equals(this.id, observabilityPipelineEnrichmentTableProcessor.id) && Objects.equals(this.include, observabilityPipelineEnrichmentTableProcessor.include) @@ -304,13 +333,15 @@ public boolean equals(Object o) { @Override public int hashCode() { - return Objects.hash(file, geoip, id, include, inputs, target, type, additionalProperties); + return Objects.hash( + enabled, file, geoip, id, include, inputs, target, type, additionalProperties); } @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineEnrichmentTableProcessor {\n"); + sb.append(" enabled: ").append(toIndentedString(enabled)).append("\n"); sb.append(" file: ").append(toIndentedString(file)).append("\n"); sb.append(" geoip: ").append(toIndentedString(geoip)).append("\n"); sb.append(" id: ").append(toIndentedString(id)).append("\n"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineFilterProcessor.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineFilterProcessor.java index 8eeee9526e2..120fef6a209 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineFilterProcessor.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineFilterProcessor.java @@ -24,6 +24,7 @@ * query. Logs that match the include query are passed through; others are discarded. */ @JsonPropertyOrder({ + ObservabilityPipelineFilterProcessor.JSON_PROPERTY_ENABLED, ObservabilityPipelineFilterProcessor.JSON_PROPERTY_ID, ObservabilityPipelineFilterProcessor.JSON_PROPERTY_INCLUDE, ObservabilityPipelineFilterProcessor.JSON_PROPERTY_INPUTS, @@ -33,6 +34,9 @@ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator") public class ObservabilityPipelineFilterProcessor { @JsonIgnore public boolean unparsed = false; + public static final String JSON_PROPERTY_ENABLED = "enabled"; + private Boolean enabled; + public static final String JSON_PROPERTY_ID = "id"; private String id; @@ -40,7 +44,7 @@ public class ObservabilityPipelineFilterProcessor { private String include; public static final String JSON_PROPERTY_INPUTS = "inputs"; - private List inputs = new ArrayList<>(); + private List inputs = null; public static final String JSON_PROPERTY_TYPE = "type"; private ObservabilityPipelineFilterProcessorType type = @@ -52,16 +56,35 @@ public ObservabilityPipelineFilterProcessor() {} public ObservabilityPipelineFilterProcessor( @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_TYPE) ObservabilityPipelineFilterProcessorType type) { this.id = id; this.include = include; - this.inputs = inputs; this.type = type; this.unparsed |= !type.isValid(); } + public ObservabilityPipelineFilterProcessor enabled(Boolean enabled) { + this.enabled = enabled; + return this; + } + + /** + * Whether this processor is enabled. + * + * @return enabled + */ + @jakarta.annotation.Nullable + @JsonProperty(JSON_PROPERTY_ENABLED) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) + public Boolean getEnabled() { + return enabled; + } + + public void setEnabled(Boolean enabled) { + this.enabled = enabled; + } + public ObservabilityPipelineFilterProcessor id(String id) { this.id = id; return this; @@ -110,17 +133,22 @@ public ObservabilityPipelineFilterProcessor inputs(List inputs) { } public ObservabilityPipelineFilterProcessor addInputsItem(String inputsItem) { + if (this.inputs == null) { + this.inputs = new ArrayList<>(); + } this.inputs.add(inputsItem); return this; } /** - * A list of component IDs whose output is used as the input for this component. + * A list of component IDs whose output is used as input for this processor. Required when used as + * a standalone processor, omit when used within a processor group. * * @return inputs */ + @jakarta.annotation.Nullable @JsonProperty(JSON_PROPERTY_INPUTS) - @JsonInclude(value = JsonInclude.Include.ALWAYS) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) public List getInputs() { return inputs; } @@ -210,7 +238,8 @@ public boolean equals(Object o) { } ObservabilityPipelineFilterProcessor observabilityPipelineFilterProcessor = (ObservabilityPipelineFilterProcessor) o; - return Objects.equals(this.id, observabilityPipelineFilterProcessor.id) + return Objects.equals(this.enabled, observabilityPipelineFilterProcessor.enabled) + && Objects.equals(this.id, observabilityPipelineFilterProcessor.id) && Objects.equals(this.include, observabilityPipelineFilterProcessor.include) && Objects.equals(this.inputs, observabilityPipelineFilterProcessor.inputs) && Objects.equals(this.type, observabilityPipelineFilterProcessor.type) @@ -220,13 +249,14 @@ public boolean equals(Object o) { @Override public int hashCode() { - return Objects.hash(id, include, inputs, type, additionalProperties); + return Objects.hash(enabled, id, include, inputs, type, additionalProperties); } @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineFilterProcessor {\n"); + sb.append(" enabled: ").append(toIndentedString(enabled)).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"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineGenerateMetricsProcessor.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineGenerateMetricsProcessor.java index 9a17ba776eb..14765c336d1 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineGenerateMetricsProcessor.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineGenerateMetricsProcessor.java @@ -25,6 +25,7 @@ * fields. */ @JsonPropertyOrder({ + ObservabilityPipelineGenerateMetricsProcessor.JSON_PROPERTY_ENABLED, ObservabilityPipelineGenerateMetricsProcessor.JSON_PROPERTY_ID, ObservabilityPipelineGenerateMetricsProcessor.JSON_PROPERTY_INCLUDE, ObservabilityPipelineGenerateMetricsProcessor.JSON_PROPERTY_INPUTS, @@ -35,6 +36,9 @@ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator") public class ObservabilityPipelineGenerateMetricsProcessor { @JsonIgnore public boolean unparsed = false; + public static final String JSON_PROPERTY_ENABLED = "enabled"; + private Boolean enabled; + public static final String JSON_PROPERTY_ID = "id"; private String id; @@ -42,10 +46,10 @@ public class ObservabilityPipelineGenerateMetricsProcessor { private String include; public static final String JSON_PROPERTY_INPUTS = "inputs"; - private List inputs = new ArrayList<>(); + private List inputs = null; public static final String JSON_PROPERTY_METRICS = "metrics"; - private List metrics = new ArrayList<>(); + private List metrics = null; public static final String JSON_PROPERTY_TYPE = "type"; private ObservabilityPipelineGenerateMetricsProcessorType type = @@ -56,20 +60,34 @@ public ObservabilityPipelineGenerateMetricsProcessor() {} @JsonCreator public ObservabilityPipelineGenerateMetricsProcessor( @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_METRICS) - List metrics, @JsonProperty(required = true, value = JSON_PROPERTY_TYPE) ObservabilityPipelineGenerateMetricsProcessorType type) { this.id = id; - this.include = include; - this.inputs = inputs; - this.metrics = metrics; this.type = type; this.unparsed |= !type.isValid(); } + public ObservabilityPipelineGenerateMetricsProcessor enabled(Boolean enabled) { + this.enabled = enabled; + return this; + } + + /** + * Whether this processor is enabled. + * + * @return enabled + */ + @jakarta.annotation.Nullable + @JsonProperty(JSON_PROPERTY_ENABLED) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) + public Boolean getEnabled() { + return enabled; + } + + public void setEnabled(Boolean enabled) { + this.enabled = enabled; + } + public ObservabilityPipelineGenerateMetricsProcessor id(String id) { this.id = id; return this; @@ -101,8 +119,9 @@ public ObservabilityPipelineGenerateMetricsProcessor include(String include) { * * @return include */ + @jakarta.annotation.Nullable @JsonProperty(JSON_PROPERTY_INCLUDE) - @JsonInclude(value = JsonInclude.Include.ALWAYS) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) public String getInclude() { return include; } @@ -117,17 +136,22 @@ public ObservabilityPipelineGenerateMetricsProcessor inputs(List inputs) } public ObservabilityPipelineGenerateMetricsProcessor addInputsItem(String inputsItem) { + if (this.inputs == null) { + this.inputs = new ArrayList<>(); + } this.inputs.add(inputsItem); return this; } /** - * A list of component IDs whose output is used as the input for this processor. + * A list of component IDs whose output is used as input for this processor. Required when used as + * a standalone processor, omit when used within a processor group. * * @return inputs */ + @jakarta.annotation.Nullable @JsonProperty(JSON_PROPERTY_INPUTS) - @JsonInclude(value = JsonInclude.Include.ALWAYS) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) public List getInputs() { return inputs; } @@ -147,6 +171,9 @@ public ObservabilityPipelineGenerateMetricsProcessor metrics( public ObservabilityPipelineGenerateMetricsProcessor addMetricsItem( ObservabilityPipelineGeneratedMetric metricsItem) { + if (this.metrics == null) { + this.metrics = new ArrayList<>(); + } this.metrics.add(metricsItem); this.unparsed |= metricsItem.unparsed; return this; @@ -157,8 +184,9 @@ public ObservabilityPipelineGenerateMetricsProcessor addMetricsItem( * * @return metrics */ + @jakarta.annotation.Nullable @JsonProperty(JSON_PROPERTY_METRICS) - @JsonInclude(value = JsonInclude.Include.ALWAYS) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) public List getMetrics() { return metrics; } @@ -250,7 +278,8 @@ public boolean equals(Object o) { } ObservabilityPipelineGenerateMetricsProcessor observabilityPipelineGenerateMetricsProcessor = (ObservabilityPipelineGenerateMetricsProcessor) o; - return Objects.equals(this.id, observabilityPipelineGenerateMetricsProcessor.id) + return Objects.equals(this.enabled, observabilityPipelineGenerateMetricsProcessor.enabled) + && Objects.equals(this.id, observabilityPipelineGenerateMetricsProcessor.id) && Objects.equals(this.include, observabilityPipelineGenerateMetricsProcessor.include) && Objects.equals(this.inputs, observabilityPipelineGenerateMetricsProcessor.inputs) && Objects.equals(this.metrics, observabilityPipelineGenerateMetricsProcessor.metrics) @@ -262,13 +291,14 @@ public boolean equals(Object o) { @Override public int hashCode() { - return Objects.hash(id, include, inputs, metrics, type, additionalProperties); + return Objects.hash(enabled, id, include, inputs, metrics, type, additionalProperties); } @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineGenerateMetricsProcessor {\n"); + sb.append(" enabled: ").append(toIndentedString(enabled)).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"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineOcsfMapperProcessor.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineOcsfMapperProcessor.java index ce5e0b78369..d2d773674d3 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineOcsfMapperProcessor.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineOcsfMapperProcessor.java @@ -24,6 +24,7 @@ * mapping configuration. */ @JsonPropertyOrder({ + ObservabilityPipelineOcsfMapperProcessor.JSON_PROPERTY_ENABLED, ObservabilityPipelineOcsfMapperProcessor.JSON_PROPERTY_ID, ObservabilityPipelineOcsfMapperProcessor.JSON_PROPERTY_INCLUDE, ObservabilityPipelineOcsfMapperProcessor.JSON_PROPERTY_INPUTS, @@ -34,6 +35,9 @@ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator") public class ObservabilityPipelineOcsfMapperProcessor { @JsonIgnore public boolean unparsed = false; + public static final String JSON_PROPERTY_ENABLED = "enabled"; + private Boolean enabled; + public static final String JSON_PROPERTY_ID = "id"; private String id; @@ -41,7 +45,7 @@ public class ObservabilityPipelineOcsfMapperProcessor { private String include; public static final String JSON_PROPERTY_INPUTS = "inputs"; - private List inputs = new ArrayList<>(); + private List inputs = null; public static final String JSON_PROPERTY_MAPPINGS = "mappings"; private List mappings = new ArrayList<>(); @@ -56,19 +60,38 @@ public ObservabilityPipelineOcsfMapperProcessor() {} public ObservabilityPipelineOcsfMapperProcessor( @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_MAPPINGS) List mappings, @JsonProperty(required = true, value = JSON_PROPERTY_TYPE) ObservabilityPipelineOcsfMapperProcessorType type) { this.id = id; this.include = include; - this.inputs = inputs; this.mappings = mappings; this.type = type; this.unparsed |= !type.isValid(); } + public ObservabilityPipelineOcsfMapperProcessor enabled(Boolean enabled) { + this.enabled = enabled; + return this; + } + + /** + * Whether this processor is enabled. + * + * @return enabled + */ + @jakarta.annotation.Nullable + @JsonProperty(JSON_PROPERTY_ENABLED) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) + public Boolean getEnabled() { + return enabled; + } + + public void setEnabled(Boolean enabled) { + this.enabled = enabled; + } + public ObservabilityPipelineOcsfMapperProcessor id(String id) { this.id = id; return this; @@ -116,17 +139,22 @@ public ObservabilityPipelineOcsfMapperProcessor inputs(List inputs) { } public ObservabilityPipelineOcsfMapperProcessor addInputsItem(String inputsItem) { + if (this.inputs == null) { + this.inputs = new ArrayList<>(); + } this.inputs.add(inputsItem); return this; } /** - * A list of component IDs whose output is used as the input for this processor. + * A list of component IDs whose output is used as input for this processor. Required when used as + * a standalone processor, omit when used within a processor group. * * @return inputs */ + @jakarta.annotation.Nullable @JsonProperty(JSON_PROPERTY_INPUTS) - @JsonInclude(value = JsonInclude.Include.ALWAYS) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) public List getInputs() { return inputs; } @@ -248,7 +276,8 @@ public boolean equals(Object o) { } ObservabilityPipelineOcsfMapperProcessor observabilityPipelineOcsfMapperProcessor = (ObservabilityPipelineOcsfMapperProcessor) o; - return Objects.equals(this.id, observabilityPipelineOcsfMapperProcessor.id) + return Objects.equals(this.enabled, observabilityPipelineOcsfMapperProcessor.enabled) + && Objects.equals(this.id, observabilityPipelineOcsfMapperProcessor.id) && Objects.equals(this.include, observabilityPipelineOcsfMapperProcessor.include) && Objects.equals(this.inputs, observabilityPipelineOcsfMapperProcessor.inputs) && Objects.equals(this.mappings, observabilityPipelineOcsfMapperProcessor.mappings) @@ -260,13 +289,14 @@ public boolean equals(Object o) { @Override public int hashCode() { - return Objects.hash(id, include, inputs, mappings, type, additionalProperties); + return Objects.hash(enabled, id, include, inputs, mappings, type, additionalProperties); } @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineOcsfMapperProcessor {\n"); + sb.append(" enabled: ").append(toIndentedString(enabled)).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"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineParseGrokProcessor.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineParseGrokProcessor.java index 4679da1d243..7a8240e7bb3 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineParseGrokProcessor.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineParseGrokProcessor.java @@ -25,6 +25,7 @@ */ @JsonPropertyOrder({ ObservabilityPipelineParseGrokProcessor.JSON_PROPERTY_DISABLE_LIBRARY_RULES, + ObservabilityPipelineParseGrokProcessor.JSON_PROPERTY_ENABLED, ObservabilityPipelineParseGrokProcessor.JSON_PROPERTY_ID, ObservabilityPipelineParseGrokProcessor.JSON_PROPERTY_INCLUDE, ObservabilityPipelineParseGrokProcessor.JSON_PROPERTY_INPUTS, @@ -38,6 +39,9 @@ public class ObservabilityPipelineParseGrokProcessor { public static final String JSON_PROPERTY_DISABLE_LIBRARY_RULES = "disable_library_rules"; private Boolean disableLibraryRules = false; + public static final String JSON_PROPERTY_ENABLED = "enabled"; + private Boolean enabled; + public static final String JSON_PROPERTY_ID = "id"; private String id; @@ -45,7 +49,7 @@ public class ObservabilityPipelineParseGrokProcessor { private String include; public static final String JSON_PROPERTY_INPUTS = "inputs"; - private List inputs = new ArrayList<>(); + private List inputs = null; public static final String JSON_PROPERTY_RULES = "rules"; private List rules = new ArrayList<>(); @@ -60,14 +64,12 @@ public ObservabilityPipelineParseGrokProcessor() {} public ObservabilityPipelineParseGrokProcessor( @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_RULES) List rules, @JsonProperty(required = true, value = JSON_PROPERTY_TYPE) ObservabilityPipelineParseGrokProcessorType type) { this.id = id; this.include = include; - this.inputs = inputs; this.rules = rules; this.type = type; this.unparsed |= !type.isValid(); @@ -94,6 +96,27 @@ public void setDisableLibraryRules(Boolean disableLibraryRules) { this.disableLibraryRules = disableLibraryRules; } + public ObservabilityPipelineParseGrokProcessor enabled(Boolean enabled) { + this.enabled = enabled; + return this; + } + + /** + * Whether this processor is enabled. + * + * @return enabled + */ + @jakarta.annotation.Nullable + @JsonProperty(JSON_PROPERTY_ENABLED) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) + public Boolean getEnabled() { + return enabled; + } + + public void setEnabled(Boolean enabled) { + this.enabled = enabled; + } + public ObservabilityPipelineParseGrokProcessor id(String id) { this.id = id; return this; @@ -140,17 +163,22 @@ public ObservabilityPipelineParseGrokProcessor inputs(List inputs) { } public ObservabilityPipelineParseGrokProcessor addInputsItem(String inputsItem) { + if (this.inputs == null) { + this.inputs = new ArrayList<>(); + } this.inputs.add(inputsItem); return this; } /** - * A list of component IDs whose output is used as the input for this component. + * A list of component IDs whose output is used as input for this processor. Required when used as + * a standalone processor, omit when used within a processor group. * * @return inputs */ + @jakarta.annotation.Nullable @JsonProperty(JSON_PROPERTY_INPUTS) - @JsonInclude(value = JsonInclude.Include.ALWAYS) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) public List getInputs() { return inputs; } @@ -275,6 +303,7 @@ public boolean equals(Object o) { (ObservabilityPipelineParseGrokProcessor) o; return Objects.equals( this.disableLibraryRules, observabilityPipelineParseGrokProcessor.disableLibraryRules) + && Objects.equals(this.enabled, observabilityPipelineParseGrokProcessor.enabled) && Objects.equals(this.id, observabilityPipelineParseGrokProcessor.id) && Objects.equals(this.include, observabilityPipelineParseGrokProcessor.include) && Objects.equals(this.inputs, observabilityPipelineParseGrokProcessor.inputs) @@ -288,7 +317,7 @@ public boolean equals(Object o) { @Override public int hashCode() { return Objects.hash( - disableLibraryRules, id, include, inputs, rules, type, additionalProperties); + disableLibraryRules, enabled, id, include, inputs, rules, type, additionalProperties); } @Override @@ -298,6 +327,7 @@ public String toString() { sb.append(" disableLibraryRules: ") .append(toIndentedString(disableLibraryRules)) .append("\n"); + sb.append(" enabled: ").append(toIndentedString(enabled)).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"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineParseJSONProcessor.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineParseJSONProcessor.java index b46a50b9ecf..07e047c4105 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineParseJSONProcessor.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineParseJSONProcessor.java @@ -24,6 +24,7 @@ * the event. This is useful when logs contain embedded JSON as a string. */ @JsonPropertyOrder({ + ObservabilityPipelineParseJSONProcessor.JSON_PROPERTY_ENABLED, ObservabilityPipelineParseJSONProcessor.JSON_PROPERTY_FIELD, ObservabilityPipelineParseJSONProcessor.JSON_PROPERTY_ID, ObservabilityPipelineParseJSONProcessor.JSON_PROPERTY_INCLUDE, @@ -34,6 +35,9 @@ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator") public class ObservabilityPipelineParseJSONProcessor { @JsonIgnore public boolean unparsed = false; + public static final String JSON_PROPERTY_ENABLED = "enabled"; + private Boolean enabled; + public static final String JSON_PROPERTY_FIELD = "field"; private String field; @@ -44,7 +48,7 @@ public class ObservabilityPipelineParseJSONProcessor { private String include; public static final String JSON_PROPERTY_INPUTS = "inputs"; - private List inputs = new ArrayList<>(); + private List inputs = null; public static final String JSON_PROPERTY_TYPE = "type"; private ObservabilityPipelineParseJSONProcessorType type = @@ -57,17 +61,36 @@ public ObservabilityPipelineParseJSONProcessor( @JsonProperty(required = true, value = JSON_PROPERTY_FIELD) String field, @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_TYPE) ObservabilityPipelineParseJSONProcessorType type) { this.field = field; this.id = id; this.include = include; - this.inputs = inputs; this.type = type; this.unparsed |= !type.isValid(); } + public ObservabilityPipelineParseJSONProcessor enabled(Boolean enabled) { + this.enabled = enabled; + return this; + } + + /** + * Whether this processor is enabled. + * + * @return enabled + */ + @jakarta.annotation.Nullable + @JsonProperty(JSON_PROPERTY_ENABLED) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) + public Boolean getEnabled() { + return enabled; + } + + public void setEnabled(Boolean enabled) { + this.enabled = enabled; + } + public ObservabilityPipelineParseJSONProcessor field(String field) { this.field = field; return this; @@ -135,17 +158,22 @@ public ObservabilityPipelineParseJSONProcessor inputs(List inputs) { } public ObservabilityPipelineParseJSONProcessor addInputsItem(String inputsItem) { + if (this.inputs == null) { + this.inputs = new ArrayList<>(); + } this.inputs.add(inputsItem); return this; } /** - * A list of component IDs whose output is used as the input for this component. + * A list of component IDs whose output is used as input for this processor. Required when used as + * a standalone processor, omit when used within a processor group. * * @return inputs */ + @jakarta.annotation.Nullable @JsonProperty(JSON_PROPERTY_INPUTS) - @JsonInclude(value = JsonInclude.Include.ALWAYS) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) public List getInputs() { return inputs; } @@ -236,7 +264,8 @@ public boolean equals(Object o) { } ObservabilityPipelineParseJSONProcessor observabilityPipelineParseJsonProcessor = (ObservabilityPipelineParseJSONProcessor) o; - return Objects.equals(this.field, observabilityPipelineParseJsonProcessor.field) + return Objects.equals(this.enabled, observabilityPipelineParseJsonProcessor.enabled) + && Objects.equals(this.field, observabilityPipelineParseJsonProcessor.field) && Objects.equals(this.id, observabilityPipelineParseJsonProcessor.id) && Objects.equals(this.include, observabilityPipelineParseJsonProcessor.include) && Objects.equals(this.inputs, observabilityPipelineParseJsonProcessor.inputs) @@ -248,13 +277,14 @@ public boolean equals(Object o) { @Override public int hashCode() { - return Objects.hash(field, id, include, inputs, type, additionalProperties); + return Objects.hash(enabled, field, id, include, inputs, type, additionalProperties); } @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineParseJSONProcessor {\n"); + sb.append(" enabled: ").append(toIndentedString(enabled)).append("\n"); sb.append(" field: ").append(toIndentedString(field)).append("\n"); sb.append(" id: ").append(toIndentedString(id)).append("\n"); sb.append(" include: ").append(toIndentedString(include)).append("\n"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineQuotaProcessor.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineQuotaProcessor.java index 589a76b0604..4b0357abe45 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineQuotaProcessor.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineQuotaProcessor.java @@ -25,6 +25,7 @@ */ @JsonPropertyOrder({ ObservabilityPipelineQuotaProcessor.JSON_PROPERTY_DROP_EVENTS, + ObservabilityPipelineQuotaProcessor.JSON_PROPERTY_ENABLED, ObservabilityPipelineQuotaProcessor.JSON_PROPERTY_ID, ObservabilityPipelineQuotaProcessor.JSON_PROPERTY_IGNORE_WHEN_MISSING_PARTITIONS, ObservabilityPipelineQuotaProcessor.JSON_PROPERTY_INCLUDE, @@ -43,6 +44,9 @@ public class ObservabilityPipelineQuotaProcessor { public static final String JSON_PROPERTY_DROP_EVENTS = "drop_events"; private Boolean dropEvents; + public static final String JSON_PROPERTY_ENABLED = "enabled"; + private Boolean enabled; + public static final String JSON_PROPERTY_ID = "id"; private String id; @@ -54,7 +58,7 @@ public class ObservabilityPipelineQuotaProcessor { private String include; public static final String JSON_PROPERTY_INPUTS = "inputs"; - private List inputs = new ArrayList<>(); + private List inputs = null; public static final String JSON_PROPERTY_LIMIT = "limit"; private ObservabilityPipelineQuotaProcessorLimit limit; @@ -82,7 +86,6 @@ public ObservabilityPipelineQuotaProcessor( @JsonProperty(required = true, value = JSON_PROPERTY_DROP_EVENTS) Boolean dropEvents, @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_LIMIT) ObservabilityPipelineQuotaProcessorLimit limit, @JsonProperty(required = true, value = JSON_PROPERTY_NAME) String name, @@ -91,7 +94,6 @@ public ObservabilityPipelineQuotaProcessor( this.dropEvents = dropEvents; this.id = id; this.include = include; - this.inputs = inputs; this.limit = limit; this.unparsed |= limit.unparsed; this.name = name; @@ -121,6 +123,27 @@ public void setDropEvents(Boolean dropEvents) { this.dropEvents = dropEvents; } + public ObservabilityPipelineQuotaProcessor enabled(Boolean enabled) { + this.enabled = enabled; + return this; + } + + /** + * Whether this processor is enabled. + * + * @return enabled + */ + @jakarta.annotation.Nullable + @JsonProperty(JSON_PROPERTY_ENABLED) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) + public Boolean getEnabled() { + return enabled; + } + + public void setEnabled(Boolean enabled) { + this.enabled = enabled; + } + public ObservabilityPipelineQuotaProcessor id(String id) { this.id = id; return this; @@ -191,17 +214,22 @@ public ObservabilityPipelineQuotaProcessor inputs(List inputs) { } public ObservabilityPipelineQuotaProcessor addInputsItem(String inputsItem) { + if (this.inputs == null) { + this.inputs = new ArrayList<>(); + } this.inputs.add(inputsItem); return this; } /** - * A list of component IDs whose output is used as the input for this component. + * A list of component IDs whose output is used as input for this processor. Required when used as + * a standalone processor, omit when used within a processor group. * * @return inputs */ + @jakarta.annotation.Nullable @JsonProperty(JSON_PROPERTY_INPUTS) - @JsonInclude(value = JsonInclude.Include.ALWAYS) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) public List getInputs() { return inputs; } @@ -428,6 +456,7 @@ public boolean equals(Object o) { ObservabilityPipelineQuotaProcessor observabilityPipelineQuotaProcessor = (ObservabilityPipelineQuotaProcessor) o; return Objects.equals(this.dropEvents, observabilityPipelineQuotaProcessor.dropEvents) + && Objects.equals(this.enabled, observabilityPipelineQuotaProcessor.enabled) && Objects.equals(this.id, observabilityPipelineQuotaProcessor.id) && Objects.equals( this.ignoreWhenMissingPartitions, @@ -448,6 +477,7 @@ public boolean equals(Object o) { public int hashCode() { return Objects.hash( dropEvents, + enabled, id, ignoreWhenMissingPartitions, include, @@ -466,6 +496,7 @@ public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineQuotaProcessor {\n"); sb.append(" dropEvents: ").append(toIndentedString(dropEvents)).append("\n"); + sb.append(" enabled: ").append(toIndentedString(enabled)).append("\n"); sb.append(" id: ").append(toIndentedString(id)).append("\n"); sb.append(" ignoreWhenMissingPartitions: ") .append(toIndentedString(ignoreWhenMissingPartitions)) diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineReduceProcessor.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineReduceProcessor.java index ed70215b4b3..fa08bd49f82 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineReduceProcessor.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineReduceProcessor.java @@ -24,6 +24,7 @@ * strategies. */ @JsonPropertyOrder({ + ObservabilityPipelineReduceProcessor.JSON_PROPERTY_ENABLED, ObservabilityPipelineReduceProcessor.JSON_PROPERTY_GROUP_BY, ObservabilityPipelineReduceProcessor.JSON_PROPERTY_ID, ObservabilityPipelineReduceProcessor.JSON_PROPERTY_INCLUDE, @@ -35,6 +36,9 @@ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator") public class ObservabilityPipelineReduceProcessor { @JsonIgnore public boolean unparsed = false; + public static final String JSON_PROPERTY_ENABLED = "enabled"; + private Boolean enabled; + public static final String JSON_PROPERTY_GROUP_BY = "group_by"; private List groupBy = new ArrayList<>(); @@ -45,7 +49,7 @@ public class ObservabilityPipelineReduceProcessor { private String include; public static final String JSON_PROPERTY_INPUTS = "inputs"; - private List inputs = new ArrayList<>(); + private List inputs = null; public static final String JSON_PROPERTY_MERGE_STRATEGIES = "merge_strategies"; private List mergeStrategies = @@ -62,7 +66,6 @@ public ObservabilityPipelineReduceProcessor( @JsonProperty(required = true, value = JSON_PROPERTY_GROUP_BY) List groupBy, @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_MERGE_STRATEGIES) List mergeStrategies, @JsonProperty(required = true, value = JSON_PROPERTY_TYPE) @@ -70,12 +73,32 @@ public ObservabilityPipelineReduceProcessor( this.groupBy = groupBy; this.id = id; this.include = include; - this.inputs = inputs; this.mergeStrategies = mergeStrategies; this.type = type; this.unparsed |= !type.isValid(); } + public ObservabilityPipelineReduceProcessor enabled(Boolean enabled) { + this.enabled = enabled; + return this; + } + + /** + * Whether this processor is enabled. + * + * @return enabled + */ + @jakarta.annotation.Nullable + @JsonProperty(JSON_PROPERTY_ENABLED) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) + public Boolean getEnabled() { + return enabled; + } + + public void setEnabled(Boolean enabled) { + this.enabled = enabled; + } + public ObservabilityPipelineReduceProcessor groupBy(List groupBy) { this.groupBy = groupBy; return this; @@ -147,17 +170,22 @@ public ObservabilityPipelineReduceProcessor inputs(List inputs) { } public ObservabilityPipelineReduceProcessor addInputsItem(String inputsItem) { + if (this.inputs == null) { + this.inputs = new ArrayList<>(); + } this.inputs.add(inputsItem); return this; } /** - * A list of component IDs whose output is used as the input for this processor. + * A list of component IDs whose output is used as input for this processor. Required when used as + * a standalone processor, omit when used within a processor group. * * @return inputs */ + @jakarta.annotation.Nullable @JsonProperty(JSON_PROPERTY_INPUTS) - @JsonInclude(value = JsonInclude.Include.ALWAYS) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) public List getInputs() { return inputs; } @@ -279,7 +307,8 @@ public boolean equals(Object o) { } ObservabilityPipelineReduceProcessor observabilityPipelineReduceProcessor = (ObservabilityPipelineReduceProcessor) o; - return Objects.equals(this.groupBy, observabilityPipelineReduceProcessor.groupBy) + return Objects.equals(this.enabled, observabilityPipelineReduceProcessor.enabled) + && Objects.equals(this.groupBy, observabilityPipelineReduceProcessor.groupBy) && Objects.equals(this.id, observabilityPipelineReduceProcessor.id) && Objects.equals(this.include, observabilityPipelineReduceProcessor.include) && Objects.equals(this.inputs, observabilityPipelineReduceProcessor.inputs) @@ -292,13 +321,15 @@ public boolean equals(Object o) { @Override public int hashCode() { - return Objects.hash(groupBy, id, include, inputs, mergeStrategies, type, additionalProperties); + return Objects.hash( + enabled, groupBy, id, include, inputs, mergeStrategies, type, additionalProperties); } @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineReduceProcessor {\n"); + sb.append(" enabled: ").append(toIndentedString(enabled)).append("\n"); sb.append(" groupBy: ").append(toIndentedString(groupBy)).append("\n"); sb.append(" id: ").append(toIndentedString(id)).append("\n"); sb.append(" include: ").append(toIndentedString(include)).append("\n"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineRemoveFieldsProcessor.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineRemoveFieldsProcessor.java index bd36b694985..e01f119f347 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineRemoveFieldsProcessor.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineRemoveFieldsProcessor.java @@ -21,6 +21,7 @@ /** The remove_fields processor deletes specified fields from logs. */ @JsonPropertyOrder({ + ObservabilityPipelineRemoveFieldsProcessor.JSON_PROPERTY_ENABLED, ObservabilityPipelineRemoveFieldsProcessor.JSON_PROPERTY_FIELDS, ObservabilityPipelineRemoveFieldsProcessor.JSON_PROPERTY_ID, ObservabilityPipelineRemoveFieldsProcessor.JSON_PROPERTY_INCLUDE, @@ -31,6 +32,9 @@ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator") public class ObservabilityPipelineRemoveFieldsProcessor { @JsonIgnore public boolean unparsed = false; + public static final String JSON_PROPERTY_ENABLED = "enabled"; + private Boolean enabled; + public static final String JSON_PROPERTY_FIELDS = "fields"; private List fields = new ArrayList<>(); @@ -41,7 +45,7 @@ public class ObservabilityPipelineRemoveFieldsProcessor { private String include; public static final String JSON_PROPERTY_INPUTS = "inputs"; - private List inputs = new ArrayList<>(); + private List inputs = null; public static final String JSON_PROPERTY_TYPE = "type"; private ObservabilityPipelineRemoveFieldsProcessorType type = @@ -54,17 +58,36 @@ public ObservabilityPipelineRemoveFieldsProcessor( @JsonProperty(required = true, value = JSON_PROPERTY_FIELDS) List fields, @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_TYPE) ObservabilityPipelineRemoveFieldsProcessorType type) { this.fields = fields; this.id = id; this.include = include; - this.inputs = inputs; this.type = type; this.unparsed |= !type.isValid(); } + public ObservabilityPipelineRemoveFieldsProcessor enabled(Boolean enabled) { + this.enabled = enabled; + return this; + } + + /** + * Whether this processor is enabled. + * + * @return enabled + */ + @jakarta.annotation.Nullable + @JsonProperty(JSON_PROPERTY_ENABLED) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) + public Boolean getEnabled() { + return enabled; + } + + public void setEnabled(Boolean enabled) { + this.enabled = enabled; + } + public ObservabilityPipelineRemoveFieldsProcessor fields(List fields) { this.fields = fields; return this; @@ -137,17 +160,22 @@ public ObservabilityPipelineRemoveFieldsProcessor inputs(List inputs) { } public ObservabilityPipelineRemoveFieldsProcessor addInputsItem(String inputsItem) { + if (this.inputs == null) { + this.inputs = new ArrayList<>(); + } this.inputs.add(inputsItem); return this; } /** - * The PipelineRemoveFieldsProcessor inputs. + * A list of component IDs whose output is used as input for this processor. Required when used as + * a standalone processor, omit when used within a processor group. * * @return inputs */ + @jakarta.annotation.Nullable @JsonProperty(JSON_PROPERTY_INPUTS) - @JsonInclude(value = JsonInclude.Include.ALWAYS) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) public List getInputs() { return inputs; } @@ -239,7 +267,8 @@ public boolean equals(Object o) { } ObservabilityPipelineRemoveFieldsProcessor observabilityPipelineRemoveFieldsProcessor = (ObservabilityPipelineRemoveFieldsProcessor) o; - return Objects.equals(this.fields, observabilityPipelineRemoveFieldsProcessor.fields) + return Objects.equals(this.enabled, observabilityPipelineRemoveFieldsProcessor.enabled) + && Objects.equals(this.fields, observabilityPipelineRemoveFieldsProcessor.fields) && Objects.equals(this.id, observabilityPipelineRemoveFieldsProcessor.id) && Objects.equals(this.include, observabilityPipelineRemoveFieldsProcessor.include) && Objects.equals(this.inputs, observabilityPipelineRemoveFieldsProcessor.inputs) @@ -251,13 +280,14 @@ public boolean equals(Object o) { @Override public int hashCode() { - return Objects.hash(fields, id, include, inputs, type, additionalProperties); + return Objects.hash(enabled, fields, id, include, inputs, type, additionalProperties); } @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineRemoveFieldsProcessor {\n"); + sb.append(" enabled: ").append(toIndentedString(enabled)).append("\n"); sb.append(" fields: ").append(toIndentedString(fields)).append("\n"); sb.append(" id: ").append(toIndentedString(id)).append("\n"); sb.append(" include: ").append(toIndentedString(include)).append("\n"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineRenameFieldsProcessor.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineRenameFieldsProcessor.java index 232d14b56ab..fbf51566f6e 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineRenameFieldsProcessor.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineRenameFieldsProcessor.java @@ -21,6 +21,7 @@ /** The rename_fields processor changes field names. */ @JsonPropertyOrder({ + ObservabilityPipelineRenameFieldsProcessor.JSON_PROPERTY_ENABLED, ObservabilityPipelineRenameFieldsProcessor.JSON_PROPERTY_FIELDS, ObservabilityPipelineRenameFieldsProcessor.JSON_PROPERTY_ID, ObservabilityPipelineRenameFieldsProcessor.JSON_PROPERTY_INCLUDE, @@ -31,6 +32,9 @@ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator") public class ObservabilityPipelineRenameFieldsProcessor { @JsonIgnore public boolean unparsed = false; + public static final String JSON_PROPERTY_ENABLED = "enabled"; + private Boolean enabled; + public static final String JSON_PROPERTY_FIELDS = "fields"; private List fields = new ArrayList<>(); @@ -41,7 +45,7 @@ public class ObservabilityPipelineRenameFieldsProcessor { private String include; public static final String JSON_PROPERTY_INPUTS = "inputs"; - private List inputs = new ArrayList<>(); + private List inputs = null; public static final String JSON_PROPERTY_TYPE = "type"; private ObservabilityPipelineRenameFieldsProcessorType type = @@ -55,17 +59,36 @@ public ObservabilityPipelineRenameFieldsProcessor( List fields, @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_TYPE) ObservabilityPipelineRenameFieldsProcessorType type) { this.fields = fields; this.id = id; this.include = include; - this.inputs = inputs; this.type = type; this.unparsed |= !type.isValid(); } + public ObservabilityPipelineRenameFieldsProcessor enabled(Boolean enabled) { + this.enabled = enabled; + return this; + } + + /** + * Whether this processor is enabled. + * + * @return enabled + */ + @jakarta.annotation.Nullable + @JsonProperty(JSON_PROPERTY_ENABLED) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) + public Boolean getEnabled() { + return enabled; + } + + public void setEnabled(Boolean enabled) { + this.enabled = enabled; + } + public ObservabilityPipelineRenameFieldsProcessor fields( List fields) { this.fields = fields; @@ -145,17 +168,22 @@ public ObservabilityPipelineRenameFieldsProcessor inputs(List inputs) { } public ObservabilityPipelineRenameFieldsProcessor addInputsItem(String inputsItem) { + if (this.inputs == null) { + this.inputs = new ArrayList<>(); + } this.inputs.add(inputsItem); return this; } /** - * A list of component IDs whose output is used as the input for this component. + * A list of component IDs whose output is used as input for this processor. Required when used as + * a standalone processor, omit when used within a processor group. * * @return inputs */ + @jakarta.annotation.Nullable @JsonProperty(JSON_PROPERTY_INPUTS) - @JsonInclude(value = JsonInclude.Include.ALWAYS) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) public List getInputs() { return inputs; } @@ -247,7 +275,8 @@ public boolean equals(Object o) { } ObservabilityPipelineRenameFieldsProcessor observabilityPipelineRenameFieldsProcessor = (ObservabilityPipelineRenameFieldsProcessor) o; - return Objects.equals(this.fields, observabilityPipelineRenameFieldsProcessor.fields) + return Objects.equals(this.enabled, observabilityPipelineRenameFieldsProcessor.enabled) + && Objects.equals(this.fields, observabilityPipelineRenameFieldsProcessor.fields) && Objects.equals(this.id, observabilityPipelineRenameFieldsProcessor.id) && Objects.equals(this.include, observabilityPipelineRenameFieldsProcessor.include) && Objects.equals(this.inputs, observabilityPipelineRenameFieldsProcessor.inputs) @@ -259,13 +288,14 @@ public boolean equals(Object o) { @Override public int hashCode() { - return Objects.hash(fields, id, include, inputs, type, additionalProperties); + return Objects.hash(enabled, fields, id, include, inputs, type, additionalProperties); } @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineRenameFieldsProcessor {\n"); + sb.append(" enabled: ").append(toIndentedString(enabled)).append("\n"); sb.append(" fields: ").append(toIndentedString(fields)).append("\n"); sb.append(" id: ").append(toIndentedString(id)).append("\n"); sb.append(" include: ").append(toIndentedString(include)).append("\n"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSampleProcessor.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSampleProcessor.java index c865cfaf352..335f0c8e341 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSampleProcessor.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSampleProcessor.java @@ -21,6 +21,7 @@ /** The sample processor allows probabilistic sampling of logs at a fixed rate. */ @JsonPropertyOrder({ + ObservabilityPipelineSampleProcessor.JSON_PROPERTY_ENABLED, ObservabilityPipelineSampleProcessor.JSON_PROPERTY_ID, ObservabilityPipelineSampleProcessor.JSON_PROPERTY_INCLUDE, ObservabilityPipelineSampleProcessor.JSON_PROPERTY_INPUTS, @@ -32,6 +33,9 @@ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator") public class ObservabilityPipelineSampleProcessor { @JsonIgnore public boolean unparsed = false; + public static final String JSON_PROPERTY_ENABLED = "enabled"; + private Boolean enabled; + public static final String JSON_PROPERTY_ID = "id"; private String id; @@ -39,7 +43,7 @@ public class ObservabilityPipelineSampleProcessor { private String include; public static final String JSON_PROPERTY_INPUTS = "inputs"; - private List inputs = new ArrayList<>(); + private List inputs = null; public static final String JSON_PROPERTY_PERCENTAGE = "percentage"; private Double percentage; @@ -57,16 +61,35 @@ public ObservabilityPipelineSampleProcessor() {} public ObservabilityPipelineSampleProcessor( @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_TYPE) ObservabilityPipelineSampleProcessorType type) { this.id = id; this.include = include; - this.inputs = inputs; this.type = type; this.unparsed |= !type.isValid(); } + public ObservabilityPipelineSampleProcessor enabled(Boolean enabled) { + this.enabled = enabled; + return this; + } + + /** + * Whether this processor is enabled. + * + * @return enabled + */ + @jakarta.annotation.Nullable + @JsonProperty(JSON_PROPERTY_ENABLED) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) + public Boolean getEnabled() { + return enabled; + } + + public void setEnabled(Boolean enabled) { + this.enabled = enabled; + } + public ObservabilityPipelineSampleProcessor id(String id) { this.id = id; return this; @@ -114,17 +137,22 @@ public ObservabilityPipelineSampleProcessor inputs(List inputs) { } public ObservabilityPipelineSampleProcessor addInputsItem(String inputsItem) { + if (this.inputs == null) { + this.inputs = new ArrayList<>(); + } this.inputs.add(inputsItem); return this; } /** - * A list of component IDs whose output is used as the input for this component. + * A list of component IDs whose output is used as input for this processor. Required when used as + * a standalone processor, omit when used within a processor group. * * @return inputs */ + @jakarta.annotation.Nullable @JsonProperty(JSON_PROPERTY_INPUTS) - @JsonInclude(value = JsonInclude.Include.ALWAYS) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) public List getInputs() { return inputs; } @@ -256,7 +284,8 @@ public boolean equals(Object o) { } ObservabilityPipelineSampleProcessor observabilityPipelineSampleProcessor = (ObservabilityPipelineSampleProcessor) o; - return Objects.equals(this.id, observabilityPipelineSampleProcessor.id) + return Objects.equals(this.enabled, observabilityPipelineSampleProcessor.enabled) + && Objects.equals(this.id, observabilityPipelineSampleProcessor.id) && Objects.equals(this.include, observabilityPipelineSampleProcessor.include) && Objects.equals(this.inputs, observabilityPipelineSampleProcessor.inputs) && Objects.equals(this.percentage, observabilityPipelineSampleProcessor.percentage) @@ -268,13 +297,14 @@ public boolean equals(Object o) { @Override public int hashCode() { - return Objects.hash(id, include, inputs, percentage, rate, type, additionalProperties); + return Objects.hash(enabled, id, include, inputs, percentage, rate, type, additionalProperties); } @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineSampleProcessor {\n"); + sb.append(" enabled: ").append(toIndentedString(enabled)).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"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSensitiveDataScannerProcessor.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSensitiveDataScannerProcessor.java index 95be5eb4465..8e3b53a566a 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSensitiveDataScannerProcessor.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineSensitiveDataScannerProcessor.java @@ -24,6 +24,7 @@ * in log events. */ @JsonPropertyOrder({ + ObservabilityPipelineSensitiveDataScannerProcessor.JSON_PROPERTY_ENABLED, ObservabilityPipelineSensitiveDataScannerProcessor.JSON_PROPERTY_ID, ObservabilityPipelineSensitiveDataScannerProcessor.JSON_PROPERTY_INCLUDE, ObservabilityPipelineSensitiveDataScannerProcessor.JSON_PROPERTY_INPUTS, @@ -34,6 +35,9 @@ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator") public class ObservabilityPipelineSensitiveDataScannerProcessor { @JsonIgnore public boolean unparsed = false; + public static final String JSON_PROPERTY_ENABLED = "enabled"; + private Boolean enabled; + public static final String JSON_PROPERTY_ID = "id"; private String id; @@ -41,7 +45,7 @@ public class ObservabilityPipelineSensitiveDataScannerProcessor { private String include; public static final String JSON_PROPERTY_INPUTS = "inputs"; - private List inputs = new ArrayList<>(); + private List inputs = null; public static final String JSON_PROPERTY_RULES = "rules"; private List rules = new ArrayList<>(); @@ -56,19 +60,38 @@ public ObservabilityPipelineSensitiveDataScannerProcessor() {} public ObservabilityPipelineSensitiveDataScannerProcessor( @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_RULES) List rules, @JsonProperty(required = true, value = JSON_PROPERTY_TYPE) ObservabilityPipelineSensitiveDataScannerProcessorType type) { this.id = id; this.include = include; - this.inputs = inputs; this.rules = rules; this.type = type; this.unparsed |= !type.isValid(); } + public ObservabilityPipelineSensitiveDataScannerProcessor enabled(Boolean enabled) { + this.enabled = enabled; + return this; + } + + /** + * Whether this processor is enabled. + * + * @return enabled + */ + @jakarta.annotation.Nullable + @JsonProperty(JSON_PROPERTY_ENABLED) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) + public Boolean getEnabled() { + return enabled; + } + + public void setEnabled(Boolean enabled) { + this.enabled = enabled; + } + public ObservabilityPipelineSensitiveDataScannerProcessor id(String id) { this.id = id; return this; @@ -116,17 +139,22 @@ public ObservabilityPipelineSensitiveDataScannerProcessor inputs(List in } public ObservabilityPipelineSensitiveDataScannerProcessor addInputsItem(String inputsItem) { + if (this.inputs == null) { + this.inputs = new ArrayList<>(); + } this.inputs.add(inputsItem); return this; } /** - * A list of component IDs whose output is used as the input for this component. + * A list of component IDs whose output is used as input for this processor. Required when used as + * a standalone processor, omit when used within a processor group. * * @return inputs */ + @jakarta.annotation.Nullable @JsonProperty(JSON_PROPERTY_INPUTS) - @JsonInclude(value = JsonInclude.Include.ALWAYS) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) public List getInputs() { return inputs; } @@ -252,7 +280,8 @@ public boolean equals(Object o) { ObservabilityPipelineSensitiveDataScannerProcessor observabilityPipelineSensitiveDataScannerProcessor = (ObservabilityPipelineSensitiveDataScannerProcessor) o; - return Objects.equals(this.id, observabilityPipelineSensitiveDataScannerProcessor.id) + return Objects.equals(this.enabled, observabilityPipelineSensitiveDataScannerProcessor.enabled) + && Objects.equals(this.id, observabilityPipelineSensitiveDataScannerProcessor.id) && Objects.equals(this.include, observabilityPipelineSensitiveDataScannerProcessor.include) && Objects.equals(this.inputs, observabilityPipelineSensitiveDataScannerProcessor.inputs) && Objects.equals(this.rules, observabilityPipelineSensitiveDataScannerProcessor.rules) @@ -264,13 +293,14 @@ public boolean equals(Object o) { @Override public int hashCode() { - return Objects.hash(id, include, inputs, rules, type, additionalProperties); + return Objects.hash(enabled, id, include, inputs, rules, type, additionalProperties); } @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineSensitiveDataScannerProcessor {\n"); + sb.append(" enabled: ").append(toIndentedString(enabled)).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"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineThrottleProcessor.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineThrottleProcessor.java index 6110d8603d0..c32ad41b633 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineThrottleProcessor.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineThrottleProcessor.java @@ -24,6 +24,7 @@ * time window. */ @JsonPropertyOrder({ + ObservabilityPipelineThrottleProcessor.JSON_PROPERTY_ENABLED, ObservabilityPipelineThrottleProcessor.JSON_PROPERTY_GROUP_BY, ObservabilityPipelineThrottleProcessor.JSON_PROPERTY_ID, ObservabilityPipelineThrottleProcessor.JSON_PROPERTY_INCLUDE, @@ -36,6 +37,9 @@ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator") public class ObservabilityPipelineThrottleProcessor { @JsonIgnore public boolean unparsed = false; + public static final String JSON_PROPERTY_ENABLED = "enabled"; + private Boolean enabled; + public static final String JSON_PROPERTY_GROUP_BY = "group_by"; private List groupBy = null; @@ -46,7 +50,7 @@ public class ObservabilityPipelineThrottleProcessor { private String include; public static final String JSON_PROPERTY_INPUTS = "inputs"; - private List inputs = new ArrayList<>(); + private List inputs = null; public static final String JSON_PROPERTY_THRESHOLD = "threshold"; private Long threshold; @@ -64,20 +68,39 @@ public ObservabilityPipelineThrottleProcessor() {} public ObservabilityPipelineThrottleProcessor( @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_THRESHOLD) Long threshold, @JsonProperty(required = true, value = JSON_PROPERTY_TYPE) ObservabilityPipelineThrottleProcessorType type, @JsonProperty(required = true, value = JSON_PROPERTY_WINDOW) Double window) { this.id = id; this.include = include; - this.inputs = inputs; this.threshold = threshold; this.type = type; this.unparsed |= !type.isValid(); this.window = window; } + public ObservabilityPipelineThrottleProcessor enabled(Boolean enabled) { + this.enabled = enabled; + return this; + } + + /** + * Whether this processor is enabled. + * + * @return enabled + */ + @jakarta.annotation.Nullable + @JsonProperty(JSON_PROPERTY_ENABLED) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) + public Boolean getEnabled() { + return enabled; + } + + public void setEnabled(Boolean enabled) { + this.enabled = enabled; + } + public ObservabilityPipelineThrottleProcessor groupBy(List groupBy) { this.groupBy = groupBy; return this; @@ -153,17 +176,22 @@ public ObservabilityPipelineThrottleProcessor inputs(List inputs) { } public ObservabilityPipelineThrottleProcessor addInputsItem(String inputsItem) { + if (this.inputs == null) { + this.inputs = new ArrayList<>(); + } this.inputs.add(inputsItem); return this; } /** - * A list of component IDs whose output is used as the input for this processor. + * A list of component IDs whose output is used as input for this processor. Required when used as + * a standalone processor, omit when used within a processor group. * * @return inputs */ + @jakarta.annotation.Nullable @JsonProperty(JSON_PROPERTY_INPUTS) - @JsonInclude(value = JsonInclude.Include.ALWAYS) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) public List getInputs() { return inputs; } @@ -295,7 +323,8 @@ public boolean equals(Object o) { } ObservabilityPipelineThrottleProcessor observabilityPipelineThrottleProcessor = (ObservabilityPipelineThrottleProcessor) o; - return Objects.equals(this.groupBy, observabilityPipelineThrottleProcessor.groupBy) + return Objects.equals(this.enabled, observabilityPipelineThrottleProcessor.enabled) + && Objects.equals(this.groupBy, observabilityPipelineThrottleProcessor.groupBy) && Objects.equals(this.id, observabilityPipelineThrottleProcessor.id) && Objects.equals(this.include, observabilityPipelineThrottleProcessor.include) && Objects.equals(this.inputs, observabilityPipelineThrottleProcessor.inputs) @@ -309,13 +338,14 @@ public boolean equals(Object o) { @Override public int hashCode() { return Objects.hash( - groupBy, id, include, inputs, threshold, type, window, additionalProperties); + enabled, groupBy, id, include, inputs, threshold, type, window, additionalProperties); } @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("class ObservabilityPipelineThrottleProcessor {\n"); + sb.append(" enabled: ").append(toIndentedString(enabled)).append("\n"); sb.append(" groupBy: ").append(toIndentedString(groupBy)).append("\n"); sb.append(" id: ").append(toIndentedString(id)).append("\n"); sb.append(" include: ").append(toIndentedString(include)).append("\n");