[−][src]Trait nakadion::components::connector::Connects

pub trait Connects {
    fn connect(
        &self, 
        subscription_id: SubscriptionId
    ) -> ConnectFuture<SubscriptionStreamChunks>;

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

    fn set_connect_stream_timeout_secs(
        &mut self, 
        connect_stream_timeout: ConnectStreamTimeoutSecs
    );

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

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

    fn instrumentation(&self) -> Instrumentation { ... }
}

Can connect to a Nakadi Stream

Required methods

fn connect(
    &self,
    subscription_id: SubscriptionId
) -> ConnectFuture<SubscriptionStreamChunks>

Get a stream of chunks directly from Nakadi.

fn set_flow_id(&mut self, flow_id: FlowId)

fn set_connect_stream_timeout_secs(
    &mut self,
    connect_stream_timeout: ConnectStreamTimeoutSecs
)

fn set_instrumentation(&mut self, instrumentation: Instrumentation)

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

Loading content...

Provided methods

fn instrumentation(&self) -> Instrumentation

Return instrumentation.

Returns Instrumentation::default() by default.

Loading content...

Implementations on Foreign Types

impl Connects for Box<dyn Connects + Send + Sync>[src]

fn connect(
    &self,
    subscription_id: SubscriptionId
) -> ConnectFuture<SubscriptionStreamChunks>[src]

Get a stream of chunks directly from Nakadi.

Loading content...

Implementors

impl<C> Connects for Connector<C> where
    C: SubscriptionApi + Sync + Send + 'static, [src]

Loading content...