Struct nakadion::api::NakadiApiClient

pub struct NakadiApiClient { /* fields omitted */ }

A REST client for the Nakadi API.

This accesses the REST API only and does not provide functionality for streaming.

Methods

impl NakadiApiClient

pub fn new<T: ProvidesAccessToken + Send + Sync + 'static>(     config: Config,     token_provider: T ) -> Result<NakadiApiClient, Error>

Build a new client with an owned access token provider.

Errors

Fails if no HTTP client could be created.

pub fn with_shared_access_token_provider(     config: Config,     token_provider: Arc<ProvidesAccessToken + Send + Sync + 'static> ) -> Result<NakadiApiClient, Error>

Build a new client with a shared access token provider.

Errors

Fails if no HTTP client could be created.

Trait Implementations

impl Clone for NakadiApiClient

fn clone(&self) -> NakadiApiClient

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl ApiClient for NakadiApiClient

fn commit_cursors_budgeted<T: AsRef<[u8]>>(     &self,     subscription_id: &SubscriptionId,     stream_id: &StreamId,     cursors: &[T],     flow_id: FlowId,     budget: Duration ) -> Result<CommitStatus, CommitError>

Commit the cursors encoded in the given bytes.

fn delete_event_type(     &self,     event_type_name: &str ) -> Result<(), DeleteEventTypeError>

Deletes an event type.

fn create_event_type(     &self,     event_type: &EventTypeDefinition ) -> Result<(), CreateEventTypeError>

Creates an event type defined by EventTypeDefinition.

fn create_subscription(     &self,     request: &SubscriptionRequest ) -> Result<CreateSubscriptionStatus, CreateSubscriptionError>

Creates an new subscription defined by a SubscriptionRequest.

fn delete_subscription(     &self,     id: &SubscriptionId ) -> Result<(), DeleteSubscriptionError>

Deletes a Subscription identified by a SubscriptionId.

fn commit_cursors<T: AsRef<[u8]>>(     &self,     subscription_id: &SubscriptionId,     stream_id: &StreamId,     cursors: &[T],     flow_id: FlowId ) -> Result<CommitStatus, CommitError>

Commit the cursors encoded in the given bytes.