Struct Environment

pub struct Environment { /* private fields */ }

Main access point to a node

Implementations

impl Environment

pub fn builder() -> EnvironmentBuilder

pub async fn from_client_option( client_options: impl Into<ClientOptions>, ) -> RabbitMQStreamResult<Self>

Create environment instance from client options. This allow to create an Environment instance from configuration.

use rabbitmq_stream_client::Environment;
use rabbitmq_stream_client::ClientOptions;

#[derive(serde::Deserialize)]
struct MyConfig {
    rabbitmq: ClientOptions
}

let j = r#"
{
    "rabbitmq": {
        "host": "localhost",
        "tls": {
            "enabled": false
        }
    }
}
        "#;
 let my_config: MyConfig = serde_json::from_str(j).unwrap();
 let env = Environment::from_client_option(my_config.rabbitmq)
    .await
    .unwrap();

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 super_stream_producer( &self, routing_strategy: RoutingStrategy, ) -> SuperStreamProducerBuilder<NoDedup>

pub fn consumer(&self) -> ConsumerBuilder

Returns a builder for creating a consumer

pub fn super_stream_consumer(&self) -> SuperStreamConsumerBuilder

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

Delete a stream

pub async fn delete_super_stream( &self, super_stream: &str, ) -> Result<(), StreamDeleteError>

Trait Implementations

impl Clone for Environment

fn clone(&self) -> Environment

Returns a duplicate of the value.

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

Performs copy-assignment from source.