Struct BrokerService 

pub struct BrokerService { /* private fields */ }

Implementations

impl BrokerService

pub fn new(engine: Arc<BrokerEngine>, config: ServerConfig) -> Self

Trait Implementations

impl Broker for BrokerService

type SubscribeStream = ReceiverStream<Result<EventEnvelope, Status>>

Server streaming response type for the Subscribe method.

type SubscribeDurableStream = ReceiverStream<Result<DurableServerMessage, Status>>

Server streaming response type for the SubscribeDurable method.

fn publish<'life0, 'async_trait>( &'life0 self, request: Request<Streaming<EventEnvelope>>, ) -> Pin<Box<dyn Future<Output = Result<Response<PublishAck>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Fire-and-forget: client-streaming publish, ack at stream close

fn subscribe<'life0, 'async_trait>( &'life0 self, request: Request<SubscribeRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::SubscribeStream>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Fire-and-forget: server-streaming subscription

fn publish_durable<'life0, 'async_trait>( &'life0 self, request: Request<Streaming<EventEnvelope>>, ) -> Pin<Box<dyn Future<Output = Result<Response<PublishDurableAck>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Durable: persist before ack

fn subscribe_durable<'life0, 'async_trait>( &'life0 self, request: Request<Streaming<DurableClientMessage>>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::SubscribeDurableStream>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Durable: bidirectional stream with explicit ack/nack