Skip to content

Commit f47b0f7

Browse files
author
ci.datadog-api-spec
committed
Regenerate client from commit 7d1dff0 of spec repo
1 parent 37d739b commit f47b0f7

27 files changed

+614
-427
lines changed

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

Lines changed: 161 additions & 169 deletions
Large diffs are not rendered by default.

‎examples/v2_observability-pipelines_CreatePipeline.rs‎

Lines changed: 19 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@ use datadog_api_client::datadog;
33
use datadog_api_client::datadogV2::api_observability_pipelines::ObservabilityPipelinesAPI;
44
use datadog_api_client::datadogV2::model::ObservabilityPipelineConfig;
55
use datadog_api_client::datadogV2::model::ObservabilityPipelineConfigDestinationItem;
6+
use datadog_api_client::datadogV2::model::ObservabilityPipelineConfigProcessorGroup;
67
use datadog_api_client::datadogV2::model::ObservabilityPipelineConfigProcessorItem;
78
use datadog_api_client::datadogV2::model::ObservabilityPipelineConfigSourceItem;
89
use datadog_api_client::datadogV2::model::ObservabilityPipelineDataAttributes;
@@ -27,7 +28,7 @@ async fn main() {
2728
Box::new(
2829
ObservabilityPipelineDatadogLogsDestination::new(
2930
"datadog-logs-destination".to_string(),
30-
vec!["filter-processor".to_string()],
31+
vec!["my-processor-group".to_string()],
3132
ObservabilityPipelineDatadogLogsDestinationType::DATADOG_LOGS,
3233
),
3334
),
@@ -45,15 +46,23 @@ async fn main() {
4546
],
4647
).processors(
4748
vec![
48-
ObservabilityPipelineConfigProcessorItem::ObservabilityPipelineFilterProcessor(
49-
Box::new(
50-
ObservabilityPipelineFilterProcessor::new(
51-
"filter-processor".to_string(),
52-
"service:my-service".to_string(),
53-
vec!["datadog-agent-source".to_string()],
54-
ObservabilityPipelineFilterProcessorType::FILTER,
55-
),
56-
),
49+
ObservabilityPipelineConfigProcessorGroup::new(
50+
true,
51+
"my-processor-group".to_string(),
52+
"service:my-service".to_string(),
53+
vec!["datadog-agent-source".to_string()],
54+
vec![
55+
ObservabilityPipelineConfigProcessorItem::ObservabilityPipelineFilterProcessor(
56+
Box::new(
57+
ObservabilityPipelineFilterProcessor::new(
58+
true,
59+
"filter-processor".to_string(),
60+
"status:error".to_string(),
61+
ObservabilityPipelineFilterProcessorType::FILTER,
62+
),
63+
),
64+
)
65+
],
5766
)
5867
],
5968
),

‎examples/v2_observability-pipelines_UpdatePipeline.rs‎

Lines changed: 19 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@ use datadog_api_client::datadogV2::api_observability_pipelines::ObservabilityPip
44
use datadog_api_client::datadogV2::model::ObservabilityPipeline;
55
use datadog_api_client::datadogV2::model::ObservabilityPipelineConfig;
66
use datadog_api_client::datadogV2::model::ObservabilityPipelineConfigDestinationItem;
7+
use datadog_api_client::datadogV2::model::ObservabilityPipelineConfigProcessorGroup;
78
use datadog_api_client::datadogV2::model::ObservabilityPipelineConfigProcessorItem;
89
use datadog_api_client::datadogV2::model::ObservabilityPipelineConfigSourceItem;
910
use datadog_api_client::datadogV2::model::ObservabilityPipelineData;
@@ -29,7 +30,7 @@ async fn main() {
2930
Box::new(
3031
ObservabilityPipelineDatadogLogsDestination::new(
3132
"updated-datadog-logs-destination-id".to_string(),
32-
vec!["filter-processor".to_string()],
33+
vec!["my-processor-group".to_string()],
3334
ObservabilityPipelineDatadogLogsDestinationType::DATADOG_LOGS,
3435
),
3536
),
@@ -47,15 +48,23 @@ async fn main() {
4748
],
4849
).processors(
4950
vec![
50-
ObservabilityPipelineConfigProcessorItem::ObservabilityPipelineFilterProcessor(
51-
Box::new(
52-
ObservabilityPipelineFilterProcessor::new(
53-
"filter-processor".to_string(),
54-
"service:my-service".to_string(),
55-
vec!["datadog-agent-source".to_string()],
56-
ObservabilityPipelineFilterProcessorType::FILTER,
57-
),
58-
),
51+
ObservabilityPipelineConfigProcessorGroup::new(
52+
true,
53+
"my-processor-group".to_string(),
54+
"service:my-service".to_string(),
55+
vec!["datadog-agent-source".to_string()],
56+
vec![
57+
ObservabilityPipelineConfigProcessorItem::ObservabilityPipelineFilterProcessor(
58+
Box::new(
59+
ObservabilityPipelineFilterProcessor::new(
60+
true,
61+
"filter-processor".to_string(),
62+
"status:error".to_string(),
63+
ObservabilityPipelineFilterProcessorType::FILTER,
64+
),
65+
),
66+
)
67+
],
5968
)
6069
],
6170
),

‎examples/v2_observability-pipelines_ValidatePipeline.rs‎

Lines changed: 19 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@ use datadog_api_client::datadog;
33
use datadog_api_client::datadogV2::api_observability_pipelines::ObservabilityPipelinesAPI;
44
use datadog_api_client::datadogV2::model::ObservabilityPipelineConfig;
55
use datadog_api_client::datadogV2::model::ObservabilityPipelineConfigDestinationItem;
6+
use datadog_api_client::datadogV2::model::ObservabilityPipelineConfigProcessorGroup;
67
use datadog_api_client::datadogV2::model::ObservabilityPipelineConfigProcessorItem;
78
use datadog_api_client::datadogV2::model::ObservabilityPipelineConfigSourceItem;
89
use datadog_api_client::datadogV2::model::ObservabilityPipelineDataAttributes;
@@ -27,7 +28,7 @@ async fn main() {
2728
Box::new(
2829
ObservabilityPipelineDatadogLogsDestination::new(
2930
"datadog-logs-destination".to_string(),
30-
vec!["filter-processor".to_string()],
31+
vec!["my-processor-group".to_string()],
3132
ObservabilityPipelineDatadogLogsDestinationType::DATADOG_LOGS,
3233
),
3334
),
@@ -45,15 +46,23 @@ async fn main() {
4546
],
4647
).processors(
4748
vec![
48-
ObservabilityPipelineConfigProcessorItem::ObservabilityPipelineFilterProcessor(
49-
Box::new(
50-
ObservabilityPipelineFilterProcessor::new(
51-
"filter-processor".to_string(),
52-
"service:my-service".to_string(),
53-
vec!["datadog-agent-source".to_string()],
54-
ObservabilityPipelineFilterProcessorType::FILTER,
55-
),
56-
),
49+
ObservabilityPipelineConfigProcessorGroup::new(
50+
true,
51+
"my-processor-group".to_string(),
52+
"service:my-service".to_string(),
53+
vec!["datadog-agent-source".to_string()],
54+
vec![
55+
ObservabilityPipelineConfigProcessorItem::ObservabilityPipelineFilterProcessor(
56+
Box::new(
57+
ObservabilityPipelineFilterProcessor::new(
58+
true,
59+
"filter-processor".to_string(),
60+
"status:error".to_string(),
61+
ObservabilityPipelineFilterProcessorType::FILTER,
62+
),
63+
),
64+
)
65+
],
5766
)
5867
],
5968
),

‎src/datadogV2/model/mod.rs‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4944,6 +4944,8 @@ pub mod model_observability_pipeline_google_pub_sub_destination_type;
49444944
pub use self::model_observability_pipeline_google_pub_sub_destination_type::ObservabilityPipelineGooglePubSubDestinationType;
49454945
pub mod model_observability_pipeline_config_destination_item;
49464946
pub use self::model_observability_pipeline_config_destination_item::ObservabilityPipelineConfigDestinationItem;
4947+
pub mod model_observability_pipeline_config_processor_group;
4948+
pub use self::model_observability_pipeline_config_processor_group::ObservabilityPipelineConfigProcessorGroup;
49474949
pub mod model_observability_pipeline_filter_processor;
49484950
pub use self::model_observability_pipeline_filter_processor::ObservabilityPipelineFilterProcessor;
49494951
pub mod model_observability_pipeline_filter_processor_type;

‎src/datadogV2/model/model_observability_pipeline_add_env_vars_processor.rs‎

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -11,15 +11,15 @@ use std::fmt::{self, Formatter};
1111
#[skip_serializing_none]
1212
#[derive(Clone, Debug, PartialEq, Serialize)]
1313
pub struct ObservabilityPipelineAddEnvVarsProcessor {
14+
/// Whether this processor is enabled.
15+
#[serde(rename = "enabled")]
16+
pub enabled: bool,
1417
/// The unique identifier for this component. Used to reference this processor in the pipeline.
1518
#[serde(rename = "id")]
1619
pub id: String,
1720
/// A Datadog search query used to determine which logs this processor targets.
1821
#[serde(rename = "include")]
1922
pub include: String,
20-
/// A list of component IDs whose output is used as the input for this processor.
21-
#[serde(rename = "inputs")]
22-
pub inputs: Vec<String>,
2323
/// The processor type. The value should always be `add_env_vars`.
2424
#[serde(rename = "type")]
2525
pub type_: crate::datadogV2::model::ObservabilityPipelineAddEnvVarsProcessorType,
@@ -35,16 +35,16 @@ pub struct ObservabilityPipelineAddEnvVarsProcessor {
3535

3636
impl ObservabilityPipelineAddEnvVarsProcessor {
3737
pub fn new(
38+
enabled: bool,
3839
id: String,
3940
include: String,
40-
inputs: Vec<String>,
4141
type_: crate::datadogV2::model::ObservabilityPipelineAddEnvVarsProcessorType,
4242
variables: Vec<crate::datadogV2::model::ObservabilityPipelineAddEnvVarsProcessorVariable>,
4343
) -> ObservabilityPipelineAddEnvVarsProcessor {
4444
ObservabilityPipelineAddEnvVarsProcessor {
45+
enabled,
4546
id,
4647
include,
47-
inputs,
4848
type_,
4949
variables,
5050
additional_properties: std::collections::BTreeMap::new(),
@@ -78,9 +78,9 @@ impl<'de> Deserialize<'de> for ObservabilityPipelineAddEnvVarsProcessor {
7878
where
7979
M: MapAccess<'a>,
8080
{
81+
let mut enabled: Option<bool> = None;
8182
let mut id: Option<String> = None;
8283
let mut include: Option<String> = None;
83-
let mut inputs: Option<Vec<String>> = None;
8484
let mut type_: Option<
8585
crate::datadogV2::model::ObservabilityPipelineAddEnvVarsProcessorType,
8686
> = None;
@@ -95,15 +95,15 @@ impl<'de> Deserialize<'de> for ObservabilityPipelineAddEnvVarsProcessor {
9595

9696
while let Some((k, v)) = map.next_entry::<String, serde_json::Value>()? {
9797
match k.as_str() {
98+
"enabled" => {
99+
enabled = Some(serde_json::from_value(v).map_err(M::Error::custom)?);
100+
}
98101
"id" => {
99102
id = Some(serde_json::from_value(v).map_err(M::Error::custom)?);
100103
}
101104
"include" => {
102105
include = Some(serde_json::from_value(v).map_err(M::Error::custom)?);
103106
}
104-
"inputs" => {
105-
inputs = Some(serde_json::from_value(v).map_err(M::Error::custom)?);
106-
}
107107
"type" => {
108108
type_ = Some(serde_json::from_value(v).map_err(M::Error::custom)?);
109109
if let Some(ref _type_) = type_ {
@@ -125,16 +125,16 @@ impl<'de> Deserialize<'de> for ObservabilityPipelineAddEnvVarsProcessor {
125125
}
126126
}
127127
}
128+
let enabled = enabled.ok_or_else(|| M::Error::missing_field("enabled"))?;
128129
let id = id.ok_or_else(|| M::Error::missing_field("id"))?;
129130
let include = include.ok_or_else(|| M::Error::missing_field("include"))?;
130-
let inputs = inputs.ok_or_else(|| M::Error::missing_field("inputs"))?;
131131
let type_ = type_.ok_or_else(|| M::Error::missing_field("type_"))?;
132132
let variables = variables.ok_or_else(|| M::Error::missing_field("variables"))?;
133133

134134
let content = ObservabilityPipelineAddEnvVarsProcessor {
135+
enabled,
135136
id,
136137
include,
137-
inputs,
138138
type_,
139139
variables,
140140
additional_properties,

‎src/datadogV2/model/model_observability_pipeline_add_fields_processor.rs‎

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,9 @@ use std::fmt::{self, Formatter};
1111
#[skip_serializing_none]
1212
#[derive(Clone, Debug, PartialEq, Serialize)]
1313
pub struct ObservabilityPipelineAddFieldsProcessor {
14+
/// Whether this processor is enabled.
15+
#[serde(rename = "enabled")]
16+
pub enabled: bool,
1417
/// A list of static fields (key-value pairs) that is added to each log event processed by this component.
1518
#[serde(rename = "fields")]
1619
pub fields: Vec<crate::datadogV2::model::ObservabilityPipelineFieldValue>,
@@ -20,9 +23,6 @@ pub struct ObservabilityPipelineAddFieldsProcessor {
2023
/// A Datadog search query used to determine which logs this processor targets.
2124
#[serde(rename = "include")]
2225
pub include: String,
23-
/// A list of component IDs whose output is used as the `input` for this component.
24-
#[serde(rename = "inputs")]
25-
pub inputs: Vec<String>,
2626
/// The processor type. The value should always be `add_fields`.
2727
#[serde(rename = "type")]
2828
pub type_: crate::datadogV2::model::ObservabilityPipelineAddFieldsProcessorType,
@@ -35,17 +35,17 @@ pub struct ObservabilityPipelineAddFieldsProcessor {
3535

3636
impl ObservabilityPipelineAddFieldsProcessor {
3737
pub fn new(
38+
enabled: bool,
3839
fields: Vec<crate::datadogV2::model::ObservabilityPipelineFieldValue>,
3940
id: String,
4041
include: String,
41-
inputs: Vec<String>,
4242
type_: crate::datadogV2::model::ObservabilityPipelineAddFieldsProcessorType,
4343
) -> ObservabilityPipelineAddFieldsProcessor {
4444
ObservabilityPipelineAddFieldsProcessor {
45+
enabled,
4546
fields,
4647
id,
4748
include,
48-
inputs,
4949
type_,
5050
additional_properties: std::collections::BTreeMap::new(),
5151
_unparsed: false,
@@ -78,12 +78,12 @@ impl<'de> Deserialize<'de> for ObservabilityPipelineAddFieldsProcessor {
7878
where
7979
M: MapAccess<'a>,
8080
{
81+
let mut enabled: Option<bool> = None;
8182
let mut fields: Option<
8283
Vec<crate::datadogV2::model::ObservabilityPipelineFieldValue>,
8384
> = None;
8485
let mut id: Option<String> = None;
8586
let mut include: Option<String> = None;
86-
let mut inputs: Option<Vec<String>> = None;
8787
let mut type_: Option<
8888
crate::datadogV2::model::ObservabilityPipelineAddFieldsProcessorType,
8989
> = None;
@@ -95,6 +95,9 @@ impl<'de> Deserialize<'de> for ObservabilityPipelineAddFieldsProcessor {
9595

9696
while let Some((k, v)) = map.next_entry::<String, serde_json::Value>()? {
9797
match k.as_str() {
98+
"enabled" => {
99+
enabled = Some(serde_json::from_value(v).map_err(M::Error::custom)?);
100+
}
98101
"fields" => {
99102
fields = Some(serde_json::from_value(v).map_err(M::Error::custom)?);
100103
}
@@ -104,9 +107,6 @@ impl<'de> Deserialize<'de> for ObservabilityPipelineAddFieldsProcessor {
104107
"include" => {
105108
include = Some(serde_json::from_value(v).map_err(M::Error::custom)?);
106109
}
107-
"inputs" => {
108-
inputs = Some(serde_json::from_value(v).map_err(M::Error::custom)?);
109-
}
110110
"type" => {
111111
type_ = Some(serde_json::from_value(v).map_err(M::Error::custom)?);
112112
if let Some(ref _type_) = type_ {
@@ -125,17 +125,17 @@ impl<'de> Deserialize<'de> for ObservabilityPipelineAddFieldsProcessor {
125125
}
126126
}
127127
}
128+
let enabled = enabled.ok_or_else(|| M::Error::missing_field("enabled"))?;
128129
let fields = fields.ok_or_else(|| M::Error::missing_field("fields"))?;
129130
let id = id.ok_or_else(|| M::Error::missing_field("id"))?;
130131
let include = include.ok_or_else(|| M::Error::missing_field("include"))?;
131-
let inputs = inputs.ok_or_else(|| M::Error::missing_field("inputs"))?;
132132
let type_ = type_.ok_or_else(|| M::Error::missing_field("type_"))?;
133133

134134
let content = ObservabilityPipelineAddFieldsProcessor {
135+
enabled,
135136
fields,
136137
id,
137138
include,
138-
inputs,
139139
type_,
140140
additional_properties,
141141
_unparsed,

0 commit comments

Comments
 (0)