Struct PulsarBroker 

pub struct PulsarBroker { /* private fields */ }

An Apache Pulsar broker for the RustStream messaging framework.

new is synchronous and records only configuration; the runtime dials once at startup via the consuming Broker::connect. That is what lets a service compose with the synchronous #[ruststream::app] builder.

Examples

use ruststream_pulsar::PulsarBroker;

let broker = PulsarBroker::new("pulsar://localhost:6650");
let secured = PulsarBroker::new("pulsar+ssl://broker:6651").token("jwt...");

Implementations

impl PulsarBroker

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

Records the service URL (pulsar:// or pulsar+ssl://). No I/O.

pub fn token(self, token: impl Into<String>) -> Self

Authenticates with a JWT token.

pub fn publisher(&self) -> PulsarPublisher

A publisher sharing this broker’s connection cell; buildable before connect.

Trait Implementations

impl Broker for PulsarBroker

type Error = PulsarError

The error type returned by broker-level operations.

type Connected = ConnectedPulsarBroker

The connected form of this broker: the typed witness that connect succeeded.

async fn connect(self) -> Result<Self::Connected, Self::Error>

Establishes the connection to the broker, consuming the unconnected form.

fn bindable(self) -> Bindable<Self>

where Self: 'static,

Wraps the broker for publisher-token minting before registration: the returned Bindable hands out Bound tokens via its bind, and is itself what with_broker takes.

impl Clone for PulsarBroker

fn clone(&self) -> PulsarBroker

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PulsarBroker

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

Formats the value using the given formatter.

impl DescribeServer for PulsarBroker

fn describe_server(&self) -> ServerSpec

Returns the server coordinates for this broker.