v2_spans_AggregateSpans/
v2_spans_AggregateSpans.rs

1// Aggregate spans returns "OK" response
2use datadog_api_client::datadog;
3use datadog_api_client::datadogV2::api_spans::SpansAPI;
4use datadog_api_client::datadogV2::model::SpansAggregateData;
5use datadog_api_client::datadogV2::model::SpansAggregateRequest;
6use datadog_api_client::datadogV2::model::SpansAggregateRequestAttributes;
7use datadog_api_client::datadogV2::model::SpansAggregateRequestType;
8use datadog_api_client::datadogV2::model::SpansAggregationFunction;
9use datadog_api_client::datadogV2::model::SpansCompute;
10use datadog_api_client::datadogV2::model::SpansComputeType;
11use datadog_api_client::datadogV2::model::SpansQueryFilter;
12
13#[tokio::main]
14async fn main() {
15    let body = SpansAggregateRequest::new().data(
16        SpansAggregateData::new()
17            .attributes(
18                SpansAggregateRequestAttributes::new()
19                    .compute(vec![SpansCompute::new(SpansAggregationFunction::COUNT)
20                        .interval("5m".to_string())
21                        .type_(SpansComputeType::TIMESERIES)])
22                    .filter(
23                        SpansQueryFilter::new()
24                            .from("now-15m".to_string())
25                            .query("*".to_string())
26                            .to("now".to_string()),
27                    ),
28            )
29            .type_(SpansAggregateRequestType::AGGREGATE_REQUEST),
30    );
31    let configuration = datadog::Configuration::new();
32    let api = SpansAPI::with_config(configuration);
33    let resp = api.aggregate_spans(body).await;
34    if let Ok(value) = resp {
35        println!("{:#?}", value);
36    } else {
37        println!("{:#?}", resp.unwrap_err());
38    }
39}