Skip to main content

create_ephemeral_consumer

cellos_server::jetstream

Function create_ephemeral_consumer 

Source 
pub async fn create_ephemeral_consumer(
    stream: &Stream,
    policy: DeliverPolicy,
    subject: Option<&str>,
) -> Result<Consumer<Config>>
Expand description

Create an ephemeral pull consumer against the canonical stream.

start_seq follows the same convention as deliver_policy_for: None → DeliverPolicy::All, Some(N) → DeliverPolicy::ByStartSequence { N+1 }. subject optionally filters to a sub-tree of cellos.events.> so a tenant-scoped WebSocket sees only its tenant’s events.

Always ephemeral (durable_name = None), AckPolicy::None, and gated by EPHEMERAL_INACTIVE_THRESHOLD for broker-side GC — see module docs and that constant.