Struct Sasl 

pub struct Sasl { /* private fields */ }

How the broker authenticates the connection, mapped onto the client’s SASL profiles.

Constructed with the per-mechanism constructors and passed to AmqpBroker::sasl. A URL of the form amqp://user:pass@host also selects PLAIN implicitly; an explicit profile set here wins.

Examples

use ruststream_amqp::prelude::*;

#[ruststream::app]
fn app() -> impl App {
    RustStream::new(AppInfo::new("orders", "0.1.0")).with_broker(
        AmqpBroker::new("amqp://broker.internal:5672").sasl(Sasl::plain("svc", "secret")),
        |b| {
            b.include(handle);
        },
    )
}

Implementations

impl Sasl

pub fn anonymous() -> Self

SASL ANONYMOUS: no credentials, for brokers that allow unauthenticated connections.

Examples

use ruststream_amqp::prelude::*;

#[ruststream::app]
fn app() -> impl App {
    RustStream::new(AppInfo::new("orders", "0.1.0")).with_broker(
        // The broker admits unauthenticated connections.
        AmqpBroker::new("amqp://broker.internal:5672").sasl(Sasl::anonymous()),
        |b| {
            b.include(handle);
        },
    )
}

pub fn plain(username: impl Into<String>, password: impl Into<String>) -> Self

SASL PLAIN: username and password.

Examples

use ruststream_amqp::prelude::*;

#[ruststream::app]
fn app() -> impl App {
    RustStream::new(AppInfo::new("orders", "0.1.0")).with_broker(
        AmqpBroker::new("amqp://broker.internal:5672").sasl(Sasl::plain("svc", "secret")),
        |b| {
            b.include(handle);
        },
    )
}

pub fn external() -> Self

SASL EXTERNAL: the broker takes an identity established outside SASL.

The connection presents no client certificate: the crate exposes no TLS configuration, and the client opens TLS without client authentication.

Examples

use ruststream_amqp::prelude::*;

#[ruststream::app]
fn app() -> impl App {
    RustStream::new(AppInfo::new("orders", "0.1.0")).with_broker(
        // The broker identifies the service outside SASL; no credentials travel here.
        AmqpBroker::new("amqps://broker.internal:5671").sasl(Sasl::external()),
        |b| {
            b.include(handle);
        },
    )
}

Trait Implementations

impl Clone for Sasl

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Sasl

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

Formats the value using the given formatter.