pub struct ObservabilityPipelinesAPI { /* private fields */ }
Expand description
Observability Pipelines allows you to collect and process logs within your own infrastructure, and then route them to downstream integrations.
Implementations§
Source§impl ObservabilityPipelinesAPI
impl ObservabilityPipelinesAPI
pub fn new() -> Self
Sourcepub fn with_config(config: Configuration) -> Self
pub fn with_config(config: Configuration) -> Self
Examples found in repository?
examples/v2_observability-pipelines_ListPipelines.rs (line 10)
7async fn main() {
8 let mut configuration = datadog::Configuration::new();
9 configuration.set_unstable_operation_enabled("v2.ListPipelines", true);
10 let api = ObservabilityPipelinesAPI::with_config(configuration);
11 let resp = api
12 .list_pipelines(ListPipelinesOptionalParams::default())
13 .await;
14 if let Ok(value) = resp {
15 println!("{:#?}", value);
16 } else {
17 println!("{:#?}", resp.unwrap_err());
18 }
19}
More examples
examples/v2_observability-pipelines_GetPipeline.rs (line 11)
6async fn main() {
7 // there is a valid "pipeline" in the system
8 let pipeline_data_id = std::env::var("PIPELINE_DATA_ID").unwrap();
9 let mut configuration = datadog::Configuration::new();
10 configuration.set_unstable_operation_enabled("v2.GetPipeline", true);
11 let api = ObservabilityPipelinesAPI::with_config(configuration);
12 let resp = api.get_pipeline(pipeline_data_id.clone()).await;
13 if let Ok(value) = resp {
14 println!("{:#?}", value);
15 } else {
16 println!("{:#?}", resp.unwrap_err());
17 }
18}
examples/v2_observability-pipelines_DeletePipeline.rs (line 11)
6async fn main() {
7 // there is a valid "pipeline" in the system
8 let pipeline_data_id = std::env::var("PIPELINE_DATA_ID").unwrap();
9 let mut configuration = datadog::Configuration::new();
10 configuration.set_unstable_operation_enabled("v2.DeletePipeline", true);
11 let api = ObservabilityPipelinesAPI::with_config(configuration);
12 let resp = api.delete_pipeline(pipeline_data_id.clone()).await;
13 if let Ok(value) = resp {
14 println!("{:#?}", value);
15 } else {
16 println!("{:#?}", resp.unwrap_err());
17 }
18}
examples/v2_observability-pipelines_CreatePipeline.rs (line 67)
19async fn main() {
20 let body =
21 ObservabilityPipelineSpec::new(
22 ObservabilityPipelineSpecData::new(
23 ObservabilityPipelineDataAttributes::new(
24 ObservabilityPipelineConfig::new(
25 vec![
26 ObservabilityPipelineConfigDestinationItem::ObservabilityPipelineDatadogLogsDestination(
27 Box::new(
28 ObservabilityPipelineDatadogLogsDestination::new(
29 "datadog-logs-destination".to_string(),
30 vec!["filter-processor".to_string()],
31 ObservabilityPipelineDatadogLogsDestinationType::DATADOG_LOGS,
32 ),
33 ),
34 )
35 ],
36 vec![
37 ObservabilityPipelineConfigSourceItem::ObservabilityPipelineDatadogAgentSource(
38 Box::new(
39 ObservabilityPipelineDatadogAgentSource::new(
40 "datadog-agent-source".to_string(),
41 ObservabilityPipelineDatadogAgentSourceType::DATADOG_AGENT,
42 ),
43 ),
44 )
45 ],
46 ).processors(
47 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 ),
57 )
58 ],
59 ),
60 "Main Observability Pipeline".to_string(),
61 ),
62 "pipelines".to_string(),
63 ),
64 );
65 let mut configuration = datadog::Configuration::new();
66 configuration.set_unstable_operation_enabled("v2.CreatePipeline", true);
67 let api = ObservabilityPipelinesAPI::with_config(configuration);
68 let resp = api.create_pipeline(body).await;
69 if let Ok(value) = resp {
70 println!("{:#?}", value);
71 } else {
72 println!("{:#?}", resp.unwrap_err());
73 }
74}
examples/v2_observability-pipelines_ValidatePipeline.rs (line 67)
19async fn main() {
20 let body =
21 ObservabilityPipelineSpec::new(
22 ObservabilityPipelineSpecData::new(
23 ObservabilityPipelineDataAttributes::new(
24 ObservabilityPipelineConfig::new(
25 vec![
26 ObservabilityPipelineConfigDestinationItem::ObservabilityPipelineDatadogLogsDestination(
27 Box::new(
28 ObservabilityPipelineDatadogLogsDestination::new(
29 "datadog-logs-destination".to_string(),
30 vec!["filter-processor".to_string()],
31 ObservabilityPipelineDatadogLogsDestinationType::DATADOG_LOGS,
32 ),
33 ),
34 )
35 ],
36 vec![
37 ObservabilityPipelineConfigSourceItem::ObservabilityPipelineDatadogAgentSource(
38 Box::new(
39 ObservabilityPipelineDatadogAgentSource::new(
40 "datadog-agent-source".to_string(),
41 ObservabilityPipelineDatadogAgentSourceType::DATADOG_AGENT,
42 ),
43 ),
44 )
45 ],
46 ).processors(
47 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 ),
57 )
58 ],
59 ),
60 "Main Observability Pipeline".to_string(),
61 ),
62 "pipelines".to_string(),
63 ),
64 );
65 let mut configuration = datadog::Configuration::new();
66 configuration.set_unstable_operation_enabled("v2.ValidatePipeline", true);
67 let api = ObservabilityPipelinesAPI::with_config(configuration);
68 let resp = api.validate_pipeline(body).await;
69 if let Ok(value) = resp {
70 println!("{:#?}", value);
71 } else {
72 println!("{:#?}", resp.unwrap_err());
73 }
74}
examples/v2_observability-pipelines_UpdatePipeline.rs (line 70)
19async fn main() {
20 // there is a valid "pipeline" in the system
21 let pipeline_data_id = std::env::var("PIPELINE_DATA_ID").unwrap();
22 let body =
23 ObservabilityPipeline::new(
24 ObservabilityPipelineData::new(
25 ObservabilityPipelineDataAttributes::new(
26 ObservabilityPipelineConfig::new(
27 vec![
28 ObservabilityPipelineConfigDestinationItem::ObservabilityPipelineDatadogLogsDestination(
29 Box::new(
30 ObservabilityPipelineDatadogLogsDestination::new(
31 "updated-datadog-logs-destination-id".to_string(),
32 vec!["filter-processor".to_string()],
33 ObservabilityPipelineDatadogLogsDestinationType::DATADOG_LOGS,
34 ),
35 ),
36 )
37 ],
38 vec![
39 ObservabilityPipelineConfigSourceItem::ObservabilityPipelineDatadogAgentSource(
40 Box::new(
41 ObservabilityPipelineDatadogAgentSource::new(
42 "datadog-agent-source".to_string(),
43 ObservabilityPipelineDatadogAgentSourceType::DATADOG_AGENT,
44 ),
45 ),
46 )
47 ],
48 ).processors(
49 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 ),
59 )
60 ],
61 ),
62 "Updated Pipeline Name".to_string(),
63 ),
64 pipeline_data_id.clone(),
65 "pipelines".to_string(),
66 ),
67 );
68 let mut configuration = datadog::Configuration::new();
69 configuration.set_unstable_operation_enabled("v2.UpdatePipeline", true);
70 let api = ObservabilityPipelinesAPI::with_config(configuration);
71 let resp = api.update_pipeline(pipeline_data_id.clone(), body).await;
72 if let Ok(value) = resp {
73 println!("{:#?}", value);
74 } else {
75 println!("{:#?}", resp.unwrap_err());
76 }
77}
pub fn with_client_and_config( config: Configuration, client: ClientWithMiddleware, ) -> Self
Sourcepub async fn create_pipeline(
&self,
body: ObservabilityPipelineSpec,
) -> Result<ObservabilityPipeline, Error<CreatePipelineError>>
pub async fn create_pipeline( &self, body: ObservabilityPipelineSpec, ) -> Result<ObservabilityPipeline, Error<CreatePipelineError>>
Create a new pipeline.
Examples found in repository?
examples/v2_observability-pipelines_CreatePipeline.rs (line 68)
19async fn main() {
20 let body =
21 ObservabilityPipelineSpec::new(
22 ObservabilityPipelineSpecData::new(
23 ObservabilityPipelineDataAttributes::new(
24 ObservabilityPipelineConfig::new(
25 vec![
26 ObservabilityPipelineConfigDestinationItem::ObservabilityPipelineDatadogLogsDestination(
27 Box::new(
28 ObservabilityPipelineDatadogLogsDestination::new(
29 "datadog-logs-destination".to_string(),
30 vec!["filter-processor".to_string()],
31 ObservabilityPipelineDatadogLogsDestinationType::DATADOG_LOGS,
32 ),
33 ),
34 )
35 ],
36 vec![
37 ObservabilityPipelineConfigSourceItem::ObservabilityPipelineDatadogAgentSource(
38 Box::new(
39 ObservabilityPipelineDatadogAgentSource::new(
40 "datadog-agent-source".to_string(),
41 ObservabilityPipelineDatadogAgentSourceType::DATADOG_AGENT,
42 ),
43 ),
44 )
45 ],
46 ).processors(
47 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 ),
57 )
58 ],
59 ),
60 "Main Observability Pipeline".to_string(),
61 ),
62 "pipelines".to_string(),
63 ),
64 );
65 let mut configuration = datadog::Configuration::new();
66 configuration.set_unstable_operation_enabled("v2.CreatePipeline", true);
67 let api = ObservabilityPipelinesAPI::with_config(configuration);
68 let resp = api.create_pipeline(body).await;
69 if let Ok(value) = resp {
70 println!("{:#?}", value);
71 } else {
72 println!("{:#?}", resp.unwrap_err());
73 }
74}
Sourcepub async fn create_pipeline_with_http_info(
&self,
body: ObservabilityPipelineSpec,
) -> Result<ResponseContent<ObservabilityPipeline>, Error<CreatePipelineError>>
pub async fn create_pipeline_with_http_info( &self, body: ObservabilityPipelineSpec, ) -> Result<ResponseContent<ObservabilityPipeline>, Error<CreatePipelineError>>
Create a new pipeline.
Sourcepub async fn delete_pipeline(
&self,
pipeline_id: String,
) -> Result<(), Error<DeletePipelineError>>
pub async fn delete_pipeline( &self, pipeline_id: String, ) -> Result<(), Error<DeletePipelineError>>
Delete a pipeline.
Examples found in repository?
examples/v2_observability-pipelines_DeletePipeline.rs (line 12)
6async fn main() {
7 // there is a valid "pipeline" in the system
8 let pipeline_data_id = std::env::var("PIPELINE_DATA_ID").unwrap();
9 let mut configuration = datadog::Configuration::new();
10 configuration.set_unstable_operation_enabled("v2.DeletePipeline", true);
11 let api = ObservabilityPipelinesAPI::with_config(configuration);
12 let resp = api.delete_pipeline(pipeline_data_id.clone()).await;
13 if let Ok(value) = resp {
14 println!("{:#?}", value);
15 } else {
16 println!("{:#?}", resp.unwrap_err());
17 }
18}
Sourcepub async fn delete_pipeline_with_http_info(
&self,
pipeline_id: String,
) -> Result<ResponseContent<()>, Error<DeletePipelineError>>
pub async fn delete_pipeline_with_http_info( &self, pipeline_id: String, ) -> Result<ResponseContent<()>, Error<DeletePipelineError>>
Delete a pipeline.
Sourcepub async fn get_pipeline(
&self,
pipeline_id: String,
) -> Result<ObservabilityPipeline, Error<GetPipelineError>>
pub async fn get_pipeline( &self, pipeline_id: String, ) -> Result<ObservabilityPipeline, Error<GetPipelineError>>
Get a specific pipeline by its ID.
Examples found in repository?
examples/v2_observability-pipelines_GetPipeline.rs (line 12)
6async fn main() {
7 // there is a valid "pipeline" in the system
8 let pipeline_data_id = std::env::var("PIPELINE_DATA_ID").unwrap();
9 let mut configuration = datadog::Configuration::new();
10 configuration.set_unstable_operation_enabled("v2.GetPipeline", true);
11 let api = ObservabilityPipelinesAPI::with_config(configuration);
12 let resp = api.get_pipeline(pipeline_data_id.clone()).await;
13 if let Ok(value) = resp {
14 println!("{:#?}", value);
15 } else {
16 println!("{:#?}", resp.unwrap_err());
17 }
18}
Sourcepub async fn get_pipeline_with_http_info(
&self,
pipeline_id: String,
) -> Result<ResponseContent<ObservabilityPipeline>, Error<GetPipelineError>>
pub async fn get_pipeline_with_http_info( &self, pipeline_id: String, ) -> Result<ResponseContent<ObservabilityPipeline>, Error<GetPipelineError>>
Get a specific pipeline by its ID.
Sourcepub async fn list_pipelines(
&self,
params: ListPipelinesOptionalParams,
) -> Result<ListPipelinesResponse, Error<ListPipelinesError>>
pub async fn list_pipelines( &self, params: ListPipelinesOptionalParams, ) -> Result<ListPipelinesResponse, Error<ListPipelinesError>>
Retrieve a list of pipelines.
Examples found in repository?
examples/v2_observability-pipelines_ListPipelines.rs (line 12)
7async fn main() {
8 let mut configuration = datadog::Configuration::new();
9 configuration.set_unstable_operation_enabled("v2.ListPipelines", true);
10 let api = ObservabilityPipelinesAPI::with_config(configuration);
11 let resp = api
12 .list_pipelines(ListPipelinesOptionalParams::default())
13 .await;
14 if let Ok(value) = resp {
15 println!("{:#?}", value);
16 } else {
17 println!("{:#?}", resp.unwrap_err());
18 }
19}
Sourcepub async fn list_pipelines_with_http_info(
&self,
params: ListPipelinesOptionalParams,
) -> Result<ResponseContent<ListPipelinesResponse>, Error<ListPipelinesError>>
pub async fn list_pipelines_with_http_info( &self, params: ListPipelinesOptionalParams, ) -> Result<ResponseContent<ListPipelinesResponse>, Error<ListPipelinesError>>
Retrieve a list of pipelines.
Sourcepub async fn update_pipeline(
&self,
pipeline_id: String,
body: ObservabilityPipeline,
) -> Result<ObservabilityPipeline, Error<UpdatePipelineError>>
pub async fn update_pipeline( &self, pipeline_id: String, body: ObservabilityPipeline, ) -> Result<ObservabilityPipeline, Error<UpdatePipelineError>>
Update a pipeline.
Examples found in repository?
examples/v2_observability-pipelines_UpdatePipeline.rs (line 71)
19async fn main() {
20 // there is a valid "pipeline" in the system
21 let pipeline_data_id = std::env::var("PIPELINE_DATA_ID").unwrap();
22 let body =
23 ObservabilityPipeline::new(
24 ObservabilityPipelineData::new(
25 ObservabilityPipelineDataAttributes::new(
26 ObservabilityPipelineConfig::new(
27 vec![
28 ObservabilityPipelineConfigDestinationItem::ObservabilityPipelineDatadogLogsDestination(
29 Box::new(
30 ObservabilityPipelineDatadogLogsDestination::new(
31 "updated-datadog-logs-destination-id".to_string(),
32 vec!["filter-processor".to_string()],
33 ObservabilityPipelineDatadogLogsDestinationType::DATADOG_LOGS,
34 ),
35 ),
36 )
37 ],
38 vec![
39 ObservabilityPipelineConfigSourceItem::ObservabilityPipelineDatadogAgentSource(
40 Box::new(
41 ObservabilityPipelineDatadogAgentSource::new(
42 "datadog-agent-source".to_string(),
43 ObservabilityPipelineDatadogAgentSourceType::DATADOG_AGENT,
44 ),
45 ),
46 )
47 ],
48 ).processors(
49 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 ),
59 )
60 ],
61 ),
62 "Updated Pipeline Name".to_string(),
63 ),
64 pipeline_data_id.clone(),
65 "pipelines".to_string(),
66 ),
67 );
68 let mut configuration = datadog::Configuration::new();
69 configuration.set_unstable_operation_enabled("v2.UpdatePipeline", true);
70 let api = ObservabilityPipelinesAPI::with_config(configuration);
71 let resp = api.update_pipeline(pipeline_data_id.clone(), body).await;
72 if let Ok(value) = resp {
73 println!("{:#?}", value);
74 } else {
75 println!("{:#?}", resp.unwrap_err());
76 }
77}
Sourcepub async fn update_pipeline_with_http_info(
&self,
pipeline_id: String,
body: ObservabilityPipeline,
) -> Result<ResponseContent<ObservabilityPipeline>, Error<UpdatePipelineError>>
pub async fn update_pipeline_with_http_info( &self, pipeline_id: String, body: ObservabilityPipeline, ) -> Result<ResponseContent<ObservabilityPipeline>, Error<UpdatePipelineError>>
Update a pipeline.
Sourcepub async fn validate_pipeline(
&self,
body: ObservabilityPipelineSpec,
) -> Result<ValidationResponse, Error<ValidatePipelineError>>
pub async fn validate_pipeline( &self, body: ObservabilityPipelineSpec, ) -> Result<ValidationResponse, Error<ValidatePipelineError>>
Validates a pipeline configuration without creating or updating any resources. Returns a list of validation errors, if any.
Examples found in repository?
examples/v2_observability-pipelines_ValidatePipeline.rs (line 68)
19async fn main() {
20 let body =
21 ObservabilityPipelineSpec::new(
22 ObservabilityPipelineSpecData::new(
23 ObservabilityPipelineDataAttributes::new(
24 ObservabilityPipelineConfig::new(
25 vec![
26 ObservabilityPipelineConfigDestinationItem::ObservabilityPipelineDatadogLogsDestination(
27 Box::new(
28 ObservabilityPipelineDatadogLogsDestination::new(
29 "datadog-logs-destination".to_string(),
30 vec!["filter-processor".to_string()],
31 ObservabilityPipelineDatadogLogsDestinationType::DATADOG_LOGS,
32 ),
33 ),
34 )
35 ],
36 vec![
37 ObservabilityPipelineConfigSourceItem::ObservabilityPipelineDatadogAgentSource(
38 Box::new(
39 ObservabilityPipelineDatadogAgentSource::new(
40 "datadog-agent-source".to_string(),
41 ObservabilityPipelineDatadogAgentSourceType::DATADOG_AGENT,
42 ),
43 ),
44 )
45 ],
46 ).processors(
47 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 ),
57 )
58 ],
59 ),
60 "Main Observability Pipeline".to_string(),
61 ),
62 "pipelines".to_string(),
63 ),
64 );
65 let mut configuration = datadog::Configuration::new();
66 configuration.set_unstable_operation_enabled("v2.ValidatePipeline", true);
67 let api = ObservabilityPipelinesAPI::with_config(configuration);
68 let resp = api.validate_pipeline(body).await;
69 if let Ok(value) = resp {
70 println!("{:#?}", value);
71 } else {
72 println!("{:#?}", resp.unwrap_err());
73 }
74}
Sourcepub async fn validate_pipeline_with_http_info(
&self,
body: ObservabilityPipelineSpec,
) -> Result<ResponseContent<ValidationResponse>, Error<ValidatePipelineError>>
pub async fn validate_pipeline_with_http_info( &self, body: ObservabilityPipelineSpec, ) -> Result<ResponseContent<ValidationResponse>, Error<ValidatePipelineError>>
Validates a pipeline configuration without creating or updating any resources. Returns a list of validation errors, if any.
Trait Implementations§
Source§impl Clone for ObservabilityPipelinesAPI
impl Clone for ObservabilityPipelinesAPI
Source§fn clone(&self) -> ObservabilityPipelinesAPI
fn clone(&self) -> ObservabilityPipelinesAPI
Returns a duplicate of the value. Read more
1.0.0 · Source§const fn clone_from(&mut self, source: &Self)
const fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moreSource§impl Debug for ObservabilityPipelinesAPI
impl Debug for ObservabilityPipelinesAPI
Auto Trait Implementations§
impl Freeze for ObservabilityPipelinesAPI
impl !RefUnwindSafe for ObservabilityPipelinesAPI
impl Send for ObservabilityPipelinesAPI
impl Sync for ObservabilityPipelinesAPI
impl Unpin for ObservabilityPipelinesAPI
impl !UnwindSafe for ObservabilityPipelinesAPI
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more