v2_confluent_cloud_CreateConfluentResource/
v2_confluent-cloud_CreateConfluentResource.rs

1// Add resource to Confluent account returns "OK" response
2use datadog_api_client::datadog;
3use datadog_api_client::datadogV2::api_confluent_cloud::ConfluentCloudAPI;
4use datadog_api_client::datadogV2::model::ConfluentResourceRequest;
5use datadog_api_client::datadogV2::model::ConfluentResourceRequestAttributes;
6use datadog_api_client::datadogV2::model::ConfluentResourceRequestData;
7use datadog_api_client::datadogV2::model::ConfluentResourceType;
8
9#[tokio::main]
10async fn main() {
11    // there is a valid "confluent_account" in the system
12    let confluent_account_data_id = std::env::var("CONFLUENT_ACCOUNT_DATA_ID").unwrap();
13    let body = ConfluentResourceRequest::new(ConfluentResourceRequestData::new(
14        ConfluentResourceRequestAttributes::new("kafka".to_string())
15            .enable_custom_metrics(false)
16            .tags(vec!["myTag".to_string(), "myTag2:myValue".to_string()]),
17        "exampleconfluentcloud".to_string(),
18        ConfluentResourceType::CONFLUENT_CLOUD_RESOURCES,
19    ));
20    let configuration = datadog::Configuration::new();
21    let api = ConfluentCloudAPI::with_config(configuration);
22    let resp = api
23        .create_confluent_resource(confluent_account_data_id.clone(), body)
24        .await;
25    if let Ok(value) = resp {
26        println!("{:#?}", value);
27    } else {
28        println!("{:#?}", resp.unwrap_err());
29    }
30}