Struct nakadion::HyperClientConnector

pub struct HyperClientConnector { /* fields omitted */ }

A NakadiConnector using Hyper for dispatching requests.

Methods

impl HyperClientConnector

fn new(
    token_provider: Box<ProvidesToken + Send + Sync>,
    nakadi_host: Url
) -> HyperClientConnector

fn with_client(
    client: Client,
    token_provider: Box<ProvidesToken + Send + Sync>,
    nakadi_host: Url
) -> HyperClientConnector

fn with_settings(
    token_provider: Box<ProvidesToken + Send + Sync>,
    settings: ConnectorSettings
) -> HyperClientConnector

fn with_client_and_settings(
    client: Client,
    token_provider: Box<ProvidesToken + Send + Sync>,
    settings: ConnectorSettings
) -> HyperClientConnector

fn from_env(
    token_provider: Box<ProvidesToken + Send + Sync>
) -> Result<HyperClientConnector, String>

fn from_env_with_client(
    client: Client,
    token_provider: Box<ProvidesToken + Send + Sync>
) -> Result<HyperClientConnector, String>

Trait Implementations

impl NakadiConnector for HyperClientConnector

fn settings(&self) -> &ConnectorSettings

impl ReadsStream for HyperClientConnector

type StreamingSource = Response

fn read(
    &self,
    subscription: &SubscriptionId
) -> ClientResult<(Self::StreamingSource, StreamId)>

Attempts to get data from the stream. Also returns the StreamId which must be used for checkpointing.

impl Checkpoints for HyperClientConnector

fn checkpoint(
    &self,
    stream_id: &StreamId,
    subscription: &SubscriptionId,
    cursors: &[Cursor]
) -> ClientResult<()>

Checkpoint Cursors. Make sure you use the same StreamId with which you retrieved the cursor.

impl ProvidesStreamInfo for HyperClientConnector

fn stream_info(&self, subscription: &SubscriptionId) -> ClientResult<StreamInfo>