Struct nakadion::components::connector::Connector

pub struct Connector<C> { /* fields omitted */ }

A Connector to connect to a Nakadi Stream

on_retry

A closure to be called before a retry. The error which caused the retry and the time until the retry will be made is passed. This closure overrides the current one and will be used for all subsequent clones of this instance. This allows users to give context on the call site.

Methods

impl<C> Connector<C> where
    C: SubscriptionStreamApi + Send + Sync + 'static, 

pub fn new_with_config(stream_client: C, config: ConnectConfig) -> Self

pub fn new(stream_client: C) -> Self

pub fn set_logger<L: Logger>(&mut self, logger: L)

pub fn logger<L: Logger>(self, logger: L) -> Self

pub fn instrumentation(&self) -> Instrumentation

pub async fn connect<'_>(
    &'_ self,
    subscription_id: SubscriptionId
) -> Result<SubscriptionStreamChunks, ConnectError>

pub async fn connect_abortable<'_, F>(
    &'_ self,
    subscription_id: SubscriptionId,
    abort: F
) -> Result<SubscriptionStreamChunks, ConnectError> where
    F: FnMut() -> bool + Send, 

pub fn set_flow_id(&mut self, flow_id: FlowId)

pub fn configure(self, config: ConnectConfig) -> Self

pub fn set_config(&mut self, config: ConnectConfig)

pub fn set_instrumentation(&mut self, instrumentation: Instrumentation)

pub fn stream_parameters_mut(&mut self) -> &mut StreamParameters

pub fn config(&self) -> &ConnectConfig

pub fn config_mut(&mut self) -> &mut ConnectConfig

pub async fn frame_stream<'_>(
    &'_ self,
    subscription_id: SubscriptionId
) -> Result<(StreamId, FramesStream), ConnectError>

Get a stream of frames(lines) directly from Nakadi.

pub async fn batch_stream<'_>(
    &'_ self,
    subscription_id: SubscriptionId
) -> Result<(StreamId, BatchStream), ConnectError>

Get a stream of analyzed lines.

pub async fn events_stream<'_, E: DeserializeOwned>(
    &'_ self,
    subscription_id: SubscriptionId
) -> Result<(StreamId, EventsStream<E>), ConnectError>

Get a stream of deserialized events.