Struct StreamCreator

pub struct StreamCreator {
    pub options: HashMap<String, String>,
    /* private fields */
}

Builder for creating a RabbitMQ stream

Fields

options: HashMap<String, String>

Implementations

impl StreamCreator

pub fn new(env: Environment) -> Self

pub async fn create(self, stream: &str) -> Result<(), StreamCreateError>

Create a stream with name and options

pub async fn create_super_stream( self, super_stream: &str, number_of_partitions: usize, binding_keys: Option<Vec<String>>, ) -> Result<(), StreamCreateError>

pub fn max_age(self, max_age: Duration) -> Self

pub fn leader_locator(self, leader_locator: LeaderLocator) -> Self

pub fn max_length(self, byte_capacity: ByteCapacity) -> Self

pub fn max_segment_size(self, byte_capacity: ByteCapacity) -> Self