Trait nakadion::NakadiConnector
[−]
[src]
pub trait NakadiConnector: ReadsStream + Checkpoints + ProvidesStreamInfo + Send + Sync + 'static { fn settings(&self) -> &ConnectorSettings; }
Connects to Nakadi
for checkpointing and consuming events.
Required Methods
fn settings(&self) -> &ConnectorSettings
Implementors
impl NakadiConnector for HyperClientConnector