Struct rabbitmq_stream_client::Environment

pub struct Environment { /* private fields */ }

Main access point to a node

Implementations

impl Environment

pub fn builder() -> EnvironmentBuilder

pub fn stream_creator(&self) -> StreamCreator

Returns a builder for creating a stream with a specific configuration

pub fn producer(&self) -> ProducerBuilder<NoDedup>

Returns a builder for creating a producer

pub fn consumer(&self) -> ConsumerBuilder

Returns a builder for creating a consumer

pub async fn delete_stream(&self, stream: &str) -> Result<(), StreamDeleteError>

Delete a stream

Trait Implementations

impl Clone for Environment

fn clone(&self) -> Environment

Returns a copy of the value.

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

Performs copy-assignment from source.