Struct nakadion::streaming_client::NakadiStreamingClient

pub struct NakadiStreamingClient<M> { /* fields omitted */ }

Connects to Nakadi via HTTP and creates an iterator of lines from the data received from Nakadi.

Methods

impl<M> NakadiStreamingClient<M> where
    M: MetricsCollector, 

pub fn new<T: ProvidesAccessToken + Send + Sync + 'static>(
    config: Config,
    token_provider: T,
    metrics_collector: M
) -> Result<NakadiStreamingClient<M>, Error>

Create a new NakadiStreamingClient<M>.

pub fn without_metrics<T: ProvidesAccessToken + Send + Sync + 'static>(
    config: Config,
    token_provider: T
) -> Result<NakadiStreamingClient<DevNullMetricsCollector>, Error>

Create a new NakadiStreamingClient<DevNullMetricsCollector>.

pub fn with_shared_access_token_provider(
    config: Config,
    token_provider: Arc<ProvidesAccessToken + Send + Sync + 'static>,
    metrics_collector: M
) -> Result<NakadiStreamingClient<M>, Error>

Create a new NakadiStreamingClient<M>.

Trait Implementations

impl<M: Clone> Clone for NakadiStreamingClient<M>

fn clone(&self) -> NakadiStreamingClient<M>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<M> StreamingClient for NakadiStreamingClient<M> where
    M: MetricsCollector, 

type LineIterator = NakadiLineIterator

fn connect(
    &self,
    subscription_id: &SubscriptionId,
    flow_id: FlowId
) -> Result<(StreamId, NakadiLineIterator), ConnectError>

Establish a connection for stream consumption.