Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions .generated-info
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
{
"spec_repo_commit": "04d09cb",
"generated": "2025-07-23 09:22:24.045"
"spec_repo_commit": "4727afe",
"generated": "2025-07-23 15:36:20.048"
}
67 changes: 67 additions & 0 deletions .generator/schemas/v1/openapi.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -5547,6 +5547,72 @@ components:
type: string
x-enum-varnames:
- DATE_REMAPPER
LogsDecoderProcessor:
description: 'The decoder processor decodes any source attribute containing
a

base64/base16-encoded UTF-8/ASCII string back to its original value, storing
the

result in a target attribute.'
properties:
binary_to_text_encoding:
$ref: '#/components/schemas/LogsDecoderProcessorBinaryToTextEncoding'
input_representation:
$ref: '#/components/schemas/LogsDecoderProcessorInputRepresentation'
is_enabled:
default: false
description: Whether the processor is enabled.
type: boolean
name:
description: Name of the processor.
type: string
source:
description: Name of the log attribute with the encoded data.
example: encoded.field
type: string
target:
description: Name of the log attribute that contains the decoded data.
example: decoded.field
type: string
type:
$ref: '#/components/schemas/LogsDecoderProcessorType'
required:
- source
- target
- binary_to_text_encoding
- input_representation
- type
type: object
LogsDecoderProcessorBinaryToTextEncoding:
description: The encoding used to represent the binary data.
enum:
- base64
- base16
example: base64
type: string
x-enum-varnames:
- BASE64
- BASE16
LogsDecoderProcessorInputRepresentation:
description: The original representation of input string.
enum:
- utf_8
- integer
example: utf_8
type: string
x-enum-varnames:
- UTF_8
- INTEGER
LogsDecoderProcessorType:
default: decoder-processor
description: Type of logs decoder processor.
enum:
- decoder-processor
example: decoder-processor
type: string
x-enum-varnames:
- DECODER_PROCESSOR
LogsExclusion:
description: Represents the index exclusion filter object from configuration
API.
Expand Down Expand Up @@ -6215,6 +6281,7 @@ components:
- $ref: '#/components/schemas/LogsTraceRemapper'
- $ref: '#/components/schemas/LogsSpanRemapper'
- $ref: '#/components/schemas/LogsArrayProcessor'
- $ref: '#/components/schemas/LogsDecoderProcessor'
LogsQueryCompute:
description: Define computation for a log query.
properties:
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
2025-07-22T13:27:59.975Z

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

24 changes: 24 additions & 0 deletions examples/v1/logs-pipelines/CreateLogsPipeline_3336967838.rb
Original file line number Diff line number Diff line change
@@ -0,0 +1,24 @@
# Create a pipeline with Decoder Processor returns "OK" response

require "datadog_api_client"
api_instance = DatadogAPIClient::V1::LogsPipelinesAPI.new

body = DatadogAPIClient::V1::LogsPipeline.new({
filter: DatadogAPIClient::V1::LogsFilter.new({
query: "source:python",
}),
name: "testDecoderProcessor",
processors: [
DatadogAPIClient::V1::LogsDecoderProcessor.new({
type: DatadogAPIClient::V1::LogsDecoderProcessorType::DECODER_PROCESSOR,
is_enabled: true,
name: "test_decoder",
source: "encoded.field",
target: "decoded.field",
binary_to_text_encoding: DatadogAPIClient::V1::LogsDecoderProcessorBinaryToTextEncoding::BASE16,
input_representation: DatadogAPIClient::V1::LogsDecoderProcessorInputRepresentation::UTF_8,
}),
],
tags: [],
})
p api_instance.create_logs_pipeline(body)
7 changes: 7 additions & 0 deletions features/v1/logs_pipelines.feature
Original file line number Diff line number Diff line change
Expand Up @@ -70,6 +70,13 @@ Feature: Logs Pipelines
When the request is sent
Then the response status is 200 OK

@team:DataDog/event-platform-experience
Scenario: Create a pipeline with Decoder Processor returns "OK" response
Given new "CreateLogsPipeline" request
And body with value {"filter": {"query": "source:python"}, "name": "testDecoderProcessor", "processors": [{"type": "decoder-processor", "is_enabled": true, "name": "test_decoder", "source": "encoded.field", "target": "decoded.field", "binary_to_text_encoding": "base16", "input_representation": "utf_8"}], "tags": []}
When the request is sent
Then the response status is 200 OK

@team:DataDog/event-platform-experience
Scenario: Create a pipeline with Span Id Remapper returns "OK" response
Given new "CreateLogsPipeline" request
Expand Down
4 changes: 4 additions & 0 deletions lib/datadog_api_client/inflector.rb
Original file line number Diff line number Diff line change
Expand Up @@ -248,6 +248,10 @@ def overrides
"v1.logs_daily_limit_reset" => "LogsDailyLimitReset",
"v1.logs_date_remapper" => "LogsDateRemapper",
"v1.logs_date_remapper_type" => "LogsDateRemapperType",
"v1.logs_decoder_processor" => "LogsDecoderProcessor",
"v1.logs_decoder_processor_binary_to_text_encoding" => "LogsDecoderProcessorBinaryToTextEncoding",
"v1.logs_decoder_processor_input_representation" => "LogsDecoderProcessorInputRepresentation",
"v1.logs_decoder_processor_type" => "LogsDecoderProcessorType",
"v1.logs_exclusion" => "LogsExclusion",
"v1.logs_exclusion_filter" => "LogsExclusionFilter",
"v1.logs_filter" => "LogsFilter",
Expand Down
Loading
Loading