Struct nakadion::Nakadion

pub struct Nakadion { /* fields omitted */ }

Methods

impl Nakadion

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

pub fn start<HF, P, M>(
    config: NakadionConfig,
    handler_factory: HF,
    access_token_provider: P,
    metrics_collector: M
) -> Result<Nakadion, Error> where
    HF: HandlerFactory + Sync + Send + 'static,
    P: ProvidesAccessToken + Send + Sync + 'static,
    M: MetricsCollector + Clone + Send + Sync + 'static, 

pub fn running(&self) -> bool

pub fn stop(&self)

pub fn block_until_stopped(&self)

pub fn block_until_stopped_with_interval(&self, poll_interval: Duration)

Trait Implementations