Trait nakadion::api_client::ApiClient

pub trait ApiClient {
    fn commit_cursors_budgeted<T: AsRef<[u8]>>(
        &self, 
        subscription_id: &SubscriptionId, 
        stream_id: &StreamId, 
        cursors: &[T], 
        flow_id: FlowId, 
        budget: Duration
    ) -> Result<CommitStatus, CommitError>;
    fn delete_event_type(
        &self, 
        event_type_name: &str
    ) -> Result<(), DeleteEventTypeError>;
    fn create_event_type(
        &self, 
        event_type: &EventTypeDefinition
    ) -> Result<(), CreateEventTypeError>;
    fn create_subscription(
        &self, 
        request: &CreateSubscriptionRequest
    ) -> Result<CreateSubscriptionStatus, CreateSubscriptionError>;
    fn delete_subscription(
        &self, 
        id: &SubscriptionId
    ) -> Result<(), DeleteSubscriptionError>;

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

A client to the Nakadi Event Broker

Required Methods

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

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

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

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

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

Provided Methods

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

Implementors

• impl ApiClient for NakadiApiClient