Struct nakadion::consumer::Consumer

pub struct Consumer { /* fields omitted */ }

The consumer connects to the stream and sends batch lines to the processor.

This is the top level component used by an application that wants to consume a Nakadi stream

Methods

impl Consumer

pub fn start<C, A, HF, M>(
    streaming_client: C,
    api_client: A,
    subscription_id: SubscriptionId,
    handler_factory: HF,
    commit_strategy: CommitStrategy,
    metrics_collector: M,
    min_idle_worker_lifetime: Option<Duration>
) -> Consumer where
    C: StreamingClient + Clone + Send + 'static,
    A: ApiClient + Clone + Send + 'static,
    HF: HandlerFactory + Send + Sync + 'static,
    M: MetricsCollector + Clone + Send + 'static, 

pub fn running(&self) -> bool

pub fn stop(&self)

Trait Implementations

impl Clone for Consumer

fn clone(&self) -> Consumer

Returns a copy of the value.

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

Performs copy-assignment from source.