Struct DeleteStreamRequest 

pub struct DeleteStreamRequest {
    pub stream: String,
    pub if_exists: bool,
}

Delete stream request.

Fields

stream: String

Stream name.

if_exists: bool

Delete stream if it exists else do nothing.

Implementations

impl DeleteStreamRequest

pub fn new(stream: impl Into<String>) -> Self

Create a new request.

Examples found in repository

examples/delete_stream.rs (line 15)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let token = std::env::var("S2_ACCESS_TOKEN")?;
    let config = ClientConfig::new(token);
    let basin: BasinName = "my-favorite-basin".parse()?;
    let basin_client = BasinClient::new(config, basin);

    let stream = "my-favorite-stream";

    let delete_stream_request = DeleteStreamRequest::new(stream);

    basin_client.delete_stream(delete_stream_request).await?;

    Ok(())
}

pub fn with_if_exists(self, if_exists: bool) -> Self

Overwrite the if exists parameter.

Trait Implementations

impl Clone for DeleteStreamRequest

fn clone(&self) -> DeleteStreamRequest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DeleteStreamRequest

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

Formats the value using the given formatter.