Struct ConfluentCloudAPI

pub struct ConfluentCloudAPI { /* private fields */ }

Manage your Datadog Confluent Cloud integration accounts and account resources directly through the Datadog API. See the Confluent Cloud page for more information.

Implementations

impl ConfluentCloudAPI

pub fn new() -> Self

pub fn with_config(config: Configuration) -> Self

Examples found in repository

examples/v2_confluent-cloud_ListConfluentAccount.rs (line 8)

async fn main() {
    let configuration = datadog::Configuration::new();
    let api = ConfluentCloudAPI::with_config(configuration);
    let resp = api.list_confluent_account().await;
    if let Ok(value) = resp {
        println!("{:#?}", value);
    } else {
        println!("{:#?}", resp.unwrap_err());
    }
}

examples/v2_confluent-cloud_ListConfluentResource.rs (line 8)

async fn main() {
    let configuration = datadog::Configuration::new();
    let api = ConfluentCloudAPI::with_config(configuration);
    let resp = api.list_confluent_resource("account_id".to_string()).await;
    if let Ok(value) = resp {
        println!("{:#?}", value);
    } else {
        println!("{:#?}", resp.unwrap_err());
    }
}

examples/v2_confluent-cloud_GetConfluentResource.rs (line 8)

async fn main() {
    let configuration = datadog::Configuration::new();
    let api = ConfluentCloudAPI::with_config(configuration);
    let resp = api
        .get_confluent_resource("account_id".to_string(), "resource_id".to_string())
        .await;
    if let Ok(value) = resp {
        println!("{:#?}", value);
    } else {
        println!("{:#?}", resp.unwrap_err());
    }
}

examples/v2_confluent-cloud_DeleteConfluentResource.rs (line 8)

async fn main() {
    let configuration = datadog::Configuration::new();
    let api = ConfluentCloudAPI::with_config(configuration);
    let resp = api
        .delete_confluent_resource("account_id".to_string(), "resource_id".to_string())
        .await;
    if let Ok(value) = resp {
        println!("{:#?}", value);
    } else {
        println!("{:#?}", resp.unwrap_err());
    }
}

examples/v2_confluent-cloud_GetConfluentAccount.rs (line 10)

async fn main() {
    // there is a valid "confluent_account" in the system
    let confluent_account_data_id = std::env::var("CONFLUENT_ACCOUNT_DATA_ID").unwrap();
    let configuration = datadog::Configuration::new();
    let api = ConfluentCloudAPI::with_config(configuration);
    let resp = api
        .get_confluent_account(confluent_account_data_id.clone())
        .await;
    if let Ok(value) = resp {
        println!("{:#?}", value);
    } else {
        println!("{:#?}", resp.unwrap_err());
    }
}

examples/v2_confluent-cloud_DeleteConfluentAccount.rs (line 10)

async fn main() {
    // there is a valid "confluent_account" in the system
    let confluent_account_data_id = std::env::var("CONFLUENT_ACCOUNT_DATA_ID").unwrap();
    let configuration = datadog::Configuration::new();
    let api = ConfluentCloudAPI::with_config(configuration);
    let resp = api
        .delete_confluent_account(confluent_account_data_id.clone())
        .await;
    if let Ok(value) = resp {
        println!("{:#?}", value);
    } else {
        println!("{:#?}", resp.unwrap_err());
    }
}

Additional examples can be found in:

• examples/v2_confluent-cloud_UpdateConfluentResource.rs
• examples/v2_confluent-cloud_CreateConfluentResource.rs
• examples/v2_confluent-cloud_CreateConfluentAccount.rs
• examples/v2_confluent-cloud_UpdateConfluentAccount.rs

pub fn with_client_and_config( config: Configuration, client: ClientWithMiddleware, ) -> Self

pub async fn create_confluent_account( &self, body: ConfluentAccountCreateRequest, ) -> Result<ConfluentAccountResponse, Error<CreateConfluentAccountError>>

Create a Confluent account.

Examples found in repository

examples/v2_confluent-cloud_CreateConfluentAccount.rs (line 28)

async fn main() {
    let body = ConfluentAccountCreateRequest::new(ConfluentAccountCreateRequestData::new(
        ConfluentAccountCreateRequestAttributes::new(
            "TESTAPIKEY123".to_string(),
            "test-api-secret-123".to_string(),
        )
        .resources(vec![ConfluentAccountResourceAttributes::new(
            "kafka".to_string(),
        )
        .enable_custom_metrics(false)
        .id("resource-id-123".to_string())
        .tags(vec!["myTag".to_string(), "myTag2:myValue".to_string()])])
        .tags(vec!["myTag".to_string(), "myTag2:myValue".to_string()]),
        ConfluentAccountType::CONFLUENT_CLOUD_ACCOUNTS,
    ));
    let configuration = datadog::Configuration::new();
    let api = ConfluentCloudAPI::with_config(configuration);
    let resp = api.create_confluent_account(body).await;
    if let Ok(value) = resp {
        println!("{:#?}", value);
    } else {
        println!("{:#?}", resp.unwrap_err());
    }
}

pub async fn create_confluent_account_with_http_info( &self, body: ConfluentAccountCreateRequest, ) -> Result<ResponseContent<ConfluentAccountResponse>, Error<CreateConfluentAccountError>>

Create a Confluent account.

pub async fn create_confluent_resource( &self, account_id: String, body: ConfluentResourceRequest, ) -> Result<ConfluentResourceResponse, Error<CreateConfluentResourceError>>

Create a Confluent resource for the account associated with the provided ID.

Examples found in repository

examples/v2_confluent-cloud_CreateConfluentResource.rs (line 23)

async fn main() {
    // there is a valid "confluent_account" in the system
    let confluent_account_data_id = std::env::var("CONFLUENT_ACCOUNT_DATA_ID").unwrap();
    let body = ConfluentResourceRequest::new(ConfluentResourceRequestData::new(
        ConfluentResourceRequestAttributes::new("kafka".to_string())
            .enable_custom_metrics(false)
            .tags(vec!["myTag".to_string(), "myTag2:myValue".to_string()]),
        "exampleconfluentcloud".to_string(),
        ConfluentResourceType::CONFLUENT_CLOUD_RESOURCES,
    ));
    let configuration = datadog::Configuration::new();
    let api = ConfluentCloudAPI::with_config(configuration);
    let resp = api
        .create_confluent_resource(confluent_account_data_id.clone(), body)
        .await;
    if let Ok(value) = resp {
        println!("{:#?}", value);
    } else {
        println!("{:#?}", resp.unwrap_err());
    }
}

pub async fn create_confluent_resource_with_http_info( &self, account_id: String, body: ConfluentResourceRequest, ) -> Result<ResponseContent<ConfluentResourceResponse>, Error<CreateConfluentResourceError>>

Create a Confluent resource for the account associated with the provided ID.

pub async fn delete_confluent_account( &self, account_id: String, ) -> Result<(), Error<DeleteConfluentAccountError>>

Delete a Confluent account with the provided account ID.

Examples found in repository

examples/v2_confluent-cloud_DeleteConfluentAccount.rs (line 12)

async fn main() {
    // there is a valid "confluent_account" in the system
    let confluent_account_data_id = std::env::var("CONFLUENT_ACCOUNT_DATA_ID").unwrap();
    let configuration = datadog::Configuration::new();
    let api = ConfluentCloudAPI::with_config(configuration);
    let resp = api
        .delete_confluent_account(confluent_account_data_id.clone())
        .await;
    if let Ok(value) = resp {
        println!("{:#?}", value);
    } else {
        println!("{:#?}", resp.unwrap_err());
    }
}

pub async fn delete_confluent_account_with_http_info( &self, account_id: String, ) -> Result<ResponseContent<()>, Error<DeleteConfluentAccountError>>

Delete a Confluent account with the provided account ID.

pub async fn delete_confluent_resource( &self, account_id: String, resource_id: String, ) -> Result<(), Error<DeleteConfluentResourceError>>

Delete a Confluent resource with the provided resource id for the account associated with the provided account ID.

Examples found in repository

examples/v2_confluent-cloud_DeleteConfluentResource.rs (line 10)

async fn main() {
    let configuration = datadog::Configuration::new();
    let api = ConfluentCloudAPI::with_config(configuration);
    let resp = api
        .delete_confluent_resource("account_id".to_string(), "resource_id".to_string())
        .await;
    if let Ok(value) = resp {
        println!("{:#?}", value);
    } else {
        println!("{:#?}", resp.unwrap_err());
    }
}

pub async fn delete_confluent_resource_with_http_info( &self, account_id: String, resource_id: String, ) -> Result<ResponseContent<()>, Error<DeleteConfluentResourceError>>

Delete a Confluent resource with the provided resource id for the account associated with the provided account ID.

pub async fn get_confluent_account( &self, account_id: String, ) -> Result<ConfluentAccountResponse, Error<GetConfluentAccountError>>

Get the Confluent account with the provided account ID.

Examples found in repository

examples/v2_confluent-cloud_GetConfluentAccount.rs (line 12)

async fn main() {
    // there is a valid "confluent_account" in the system
    let confluent_account_data_id = std::env::var("CONFLUENT_ACCOUNT_DATA_ID").unwrap();
    let configuration = datadog::Configuration::new();
    let api = ConfluentCloudAPI::with_config(configuration);
    let resp = api
        .get_confluent_account(confluent_account_data_id.clone())
        .await;
    if let Ok(value) = resp {
        println!("{:#?}", value);
    } else {
        println!("{:#?}", resp.unwrap_err());
    }
}

pub async fn get_confluent_account_with_http_info( &self, account_id: String, ) -> Result<ResponseContent<ConfluentAccountResponse>, Error<GetConfluentAccountError>>

Get the Confluent account with the provided account ID.

pub async fn get_confluent_resource( &self, account_id: String, resource_id: String, ) -> Result<ConfluentResourceResponse, Error<GetConfluentResourceError>>

Get a Confluent resource with the provided resource id for the account associated with the provided account ID.

Examples found in repository

examples/v2_confluent-cloud_GetConfluentResource.rs (line 10)

async fn main() {
    let configuration = datadog::Configuration::new();
    let api = ConfluentCloudAPI::with_config(configuration);
    let resp = api
        .get_confluent_resource("account_id".to_string(), "resource_id".to_string())
        .await;
    if let Ok(value) = resp {
        println!("{:#?}", value);
    } else {
        println!("{:#?}", resp.unwrap_err());
    }
}

pub async fn get_confluent_resource_with_http_info( &self, account_id: String, resource_id: String, ) -> Result<ResponseContent<ConfluentResourceResponse>, Error<GetConfluentResourceError>>

Get a Confluent resource with the provided resource id for the account associated with the provided account ID.

pub async fn list_confluent_account( &self, ) -> Result<ConfluentAccountsResponse, Error<ListConfluentAccountError>>

List Confluent accounts.

Examples found in repository

examples/v2_confluent-cloud_ListConfluentAccount.rs (line 9)

async fn main() {
    let configuration = datadog::Configuration::new();
    let api = ConfluentCloudAPI::with_config(configuration);
    let resp = api.list_confluent_account().await;
    if let Ok(value) = resp {
        println!("{:#?}", value);
    } else {
        println!("{:#?}", resp.unwrap_err());
    }
}

pub async fn list_confluent_account_with_http_info( &self, ) -> Result<ResponseContent<ConfluentAccountsResponse>, Error<ListConfluentAccountError>>

List Confluent accounts.

pub async fn list_confluent_resource( &self, account_id: String, ) -> Result<ConfluentResourcesResponse, Error<ListConfluentResourceError>>

Get a Confluent resource for the account associated with the provided ID.

Examples found in repository

examples/v2_confluent-cloud_ListConfluentResource.rs (line 9)

async fn main() {
    let configuration = datadog::Configuration::new();
    let api = ConfluentCloudAPI::with_config(configuration);
    let resp = api.list_confluent_resource("account_id".to_string()).await;
    if let Ok(value) = resp {
        println!("{:#?}", value);
    } else {
        println!("{:#?}", resp.unwrap_err());
    }
}

pub async fn list_confluent_resource_with_http_info( &self, account_id: String, ) -> Result<ResponseContent<ConfluentResourcesResponse>, Error<ListConfluentResourceError>>

Get a Confluent resource for the account associated with the provided ID.

pub async fn update_confluent_account( &self, account_id: String, body: ConfluentAccountUpdateRequest, ) -> Result<ConfluentAccountResponse, Error<UpdateConfluentAccountError>>

Update the Confluent account with the provided account ID.

Examples found in repository

examples/v2_confluent-cloud_UpdateConfluentAccount.rs (line 26)

async fn main() {
    // there is a valid "confluent_account" in the system
    let confluent_account_data_attributes_api_key =
        std::env::var("CONFLUENT_ACCOUNT_DATA_ATTRIBUTES_API_KEY").unwrap();
    let confluent_account_data_id = std::env::var("CONFLUENT_ACCOUNT_DATA_ID").unwrap();
    let body = ConfluentAccountUpdateRequest::new(ConfluentAccountUpdateRequestData::new(
        ConfluentAccountUpdateRequestAttributes::new(
            confluent_account_data_attributes_api_key.clone(),
            "update-secret".to_string(),
        )
        .tags(vec!["updated_tag:val".to_string()]),
        ConfluentAccountType::CONFLUENT_CLOUD_ACCOUNTS,
    ));
    let configuration = datadog::Configuration::new();
    let api = ConfluentCloudAPI::with_config(configuration);
    let resp = api
        .update_confluent_account(confluent_account_data_id.clone(), body)
        .await;
    if let Ok(value) = resp {
        println!("{:#?}", value);
    } else {
        println!("{:#?}", resp.unwrap_err());
    }
}

pub async fn update_confluent_account_with_http_info( &self, account_id: String, body: ConfluentAccountUpdateRequest, ) -> Result<ResponseContent<ConfluentAccountResponse>, Error<UpdateConfluentAccountError>>

Update the Confluent account with the provided account ID.

pub async fn update_confluent_resource( &self, account_id: String, resource_id: String, body: ConfluentResourceRequest, ) -> Result<ConfluentResourceResponse, Error<UpdateConfluentResourceError>>

Update a Confluent resource with the provided resource id for the account associated with the provided account ID.

Examples found in repository

examples/v2_confluent-cloud_UpdateConfluentResource.rs (line 21)

async fn main() {
    let body = ConfluentResourceRequest::new(ConfluentResourceRequestData::new(
        ConfluentResourceRequestAttributes::new("kafka".to_string())
            .enable_custom_metrics(false)
            .tags(vec!["myTag".to_string(), "myTag2:myValue".to_string()]),
        "resource-id-123".to_string(),
        ConfluentResourceType::CONFLUENT_CLOUD_RESOURCES,
    ));
    let configuration = datadog::Configuration::new();
    let api = ConfluentCloudAPI::with_config(configuration);
    let resp = api
        .update_confluent_resource("account_id".to_string(), "resource_id".to_string(), body)
        .await;
    if let Ok(value) = resp {
        println!("{:#?}", value);
    } else {
        println!("{:#?}", resp.unwrap_err());
    }
}

pub async fn update_confluent_resource_with_http_info( &self, account_id: String, resource_id: String, body: ConfluentResourceRequest, ) -> Result<ResponseContent<ConfluentResourceResponse>, Error<UpdateConfluentResourceError>>

Update a Confluent resource with the provided resource id for the account associated with the provided account ID.

Trait Implementations

impl Clone for ConfluentCloudAPI

fn clone(&self) -> ConfluentCloudAPI

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ConfluentCloudAPI

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ConfluentCloudAPI

fn default() -> Self

Returns the “default value” for a type.