[−][src]Trait nakadion::components::connector::Connects
Can connect to a Nakadi Stream
Required methods
fn connect(
&self,
subscription_id: SubscriptionId
) -> ConnectFuture<SubscriptionStreamChunks>
&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
)
&mut self,
connect_stream_timeout: ConnectStreamTimeoutSecs
)
fn set_instrumentation(&mut self, instrumentation: Instrumentation)
fn stream_parameters_mut(&mut self) -> &mut StreamParameters
Provided methods
fn instrumentation(&self) -> Instrumentation
Return instrumentation.
Returns Instrumentation::default()
by default.
Implementations on Foreign Types
impl Connects for Box<dyn Connects + Send + Sync>
[src]
fn instrumentation(&self) -> Instrumentation
[src]
fn connect(
&self,
subscription_id: SubscriptionId
) -> ConnectFuture<SubscriptionStreamChunks>
[src]
&self,
subscription_id: SubscriptionId
) -> ConnectFuture<SubscriptionStreamChunks>
Get a stream of chunks directly from Nakadi.
fn set_flow_id(&mut self, flow_id: FlowId)
[src]
fn set_connect_stream_timeout_secs(
&mut self,
connect_stream_timeout_secs: ConnectStreamTimeoutSecs
)
[src]
&mut self,
connect_stream_timeout_secs: ConnectStreamTimeoutSecs
)
fn set_instrumentation(&mut self, instrumentation: Instrumentation)
[src]
fn stream_parameters_mut(&mut self) -> &mut StreamParameters
[src]
Implementors
impl<C> Connects for Connector<C> where
C: SubscriptionApi + Sync + Send + 'static,
[src]
C: SubscriptionApi + Sync + Send + 'static,
fn instrumentation(&self) -> Instrumentation
[src]
fn connect(
&self,
subscription_id: SubscriptionId
) -> ConnectFuture<SubscriptionStreamChunks>
[src]
&self,
subscription_id: SubscriptionId
) -> ConnectFuture<SubscriptionStreamChunks>
fn set_flow_id(&mut self, flow_id: FlowId)
[src]
fn set_connect_stream_timeout_secs(
&mut self,
connect_stream_timeout_secs: ConnectStreamTimeoutSecs
)
[src]
&mut self,
connect_stream_timeout_secs: ConnectStreamTimeoutSecs
)