Struct nakadion::components::connector::Connector

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

A Connector to connect to a Nakadi Stream

Usage

If other than default values should be used the Connector can be configured via its mutable methods.

Implementations

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 async fn connect<'_>(
    &'_ self,
    subscription_id: SubscriptionId
) -> Result<SubscriptionStreamChunks, ConnectError>

Connect to Nakadi for a stream of byte chunks.

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

Connect to Nakadi for a stream of byte chunks.

A closure which is regularly polled must be provided for the connector to determine whether connecting to Nakadi shall be aborted.

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

Sets the logger to be used from now on.

The Logger is used mostly for emitting retry warnings.

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

Sets the logger to be used from now on in a builder method style.

The Logger is used mostly for emitting retry warnings.

pub fn instrumentation(&self) -> Instrumentation

Get the currently used instrumentation

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

Sets the FlowId for the next connect attempts.

If not set, a random FlowId will be generated.

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

Set the ConnectConfig in a builder style

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

Set the ConnectConfig which shall be used for the next connect attempt

pub fn config(&self) -> &ConnectConfig

Returns a reference to the currently used config

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

Returns a mutable reference to the currently used config

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

Sets the Instrumentation to be used with this connector.

Uses the Instrumentation of the consumer since this is a component used by the Consumer itself.

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

Gets a mutable reference to the StreamParameters of the currently used ConnectConfig

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

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

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

Get a stream of analyzed (parsed) lines.

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

Get a stream of deserialized events.