Trait nakadion::worker::Worker

pub trait Worker {
    fn is_running(&self) -> bool;
    fn stop(&self);
    fn subscription_id(&self) -> &SubscriptionId;
}

Common fuctionality a worker must provide.

Required Methods

fn is_running(&self) -> bool

Returns true if the worker is still running.

fn stop(&self)

Stops the worker.

fn subscription_id(&self) -> &SubscriptionId

Gets the SubscriptionId the worker is listening to.

Implementors

• impl Worker for NakadiWorker
• impl<C: NakadiConnector> Worker for NakadiClient<C>