Struct nakadion::api::ApiClient

pub struct ApiClient { /* fields omitted */ }

A client to connect to the API of Nakadi.

The actual HTTP client is pluggable via the DispatchHttpRequest trait.

The ApiClient does not do any retry or timeout management.

Methods

impl ApiClient

pub fn builder() -> Builder

pub fn new<D, P>(
    nakadi_base_url: NakadiBaseUrl,
    dispatch_http_request: D,
    access_token_provider: P
) -> Self where
    D: DispatchHttpRequest + Send + Sync + 'static,
    P: ProvidesAccessToken + Send + Sync + 'static, 

Trait Implementations

impl Clone for ApiClient

fn clone(&self) -> ApiClient

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ApiClient

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.

impl MonitoringApi for ApiClient

fn get_cursor_distances<T: Into<FlowId>>(
    &self,
    name: &EventTypeName,
    query: &CursorDistanceQuery,
    flow_id: T
) -> ApiFuture<CursorDistanceResult>

Deletes an EventType identified by its name.

fn get_cursor_lag<T: Into<FlowId>>(
    &self,
    name: &EventTypeName,
    cursors: &[Cursor],
    flow_id: T
) -> ApiFuture<Vec<Partition>>

Used when a consumer wants to know how far behind in the stream its application is lagging.

fn get_event_type_partitions<T: Into<FlowId>>(
    &self,
    event_type: &EventTypeName,
    flow_id: T
) -> ApiFuture<Vec<Partition>>

Lists the Partitions for the given event-type.

impl PublishApi for ApiClient

fn publish_events_batch<'a, B: Into<Bytes>, T: Into<FlowId>>(
    &'a self,
    event_type: &'a EventTypeName,
    events: B,
    flow_id: T
) -> PublishFuture<'a>

Publishes a batch of Events of this EventType. All items must be of the EventType identified by name.

impl SchemaRegistryApi for ApiClient

fn list_event_types<T: Into<FlowId>>(
    &self,
    flow_id: T
) -> ApiFuture<Vec<EventType>>

Returns a list of all registered EventTypes

See also Nakadi Manual

fn create_event_type<T: Into<FlowId>>(
    &self,
    event_type: &EventTypeInput,
    flow_id: T
) -> ApiFuture<()>

Creates a new EventType.

See also Nakadi Manual

fn get_event_type<T: Into<FlowId>>(
    &self,
    name: &EventTypeName,
    flow_id: T
) -> ApiFuture<EventType>

Returns the EventType identified by its name.

See also Nakadi Manual

fn update_event_type<T: Into<FlowId>>(
    &self,
    name: &EventTypeName,
    event_type: &EventType,
    flow_id: T
) -> ApiFuture<()>

Updates the EventType identified by its name.

See also Nakadi Manual

fn delete_event_type<T: Into<FlowId>>(
    &self,
    name: &EventTypeName,
    flow_id: T
) -> ApiFuture<()>

Deletes an EventType identified by its name.

See also Nakadi Manual

impl SubscriptionApi for ApiClient

fn create_subscription<T: Into<FlowId>>(
    &self,
    input: &SubscriptionInput,
    flow_id: T
) -> ApiFuture<Subscription>

This endpoint creates a subscription for EventTypes.

See also Nakadi Manual

fn get_subscription<T: Into<FlowId>>(
    &self,
    id: SubscriptionId,
    flow_id: T
) -> ApiFuture<Subscription>

Returns a subscription identified by id.

See also Nakadi Manual

fn list_subscriptions<T: Into<FlowId>>(
    &self,
    event_type: Option<&EventTypeName>,
    owning_application: Option<&OwningApplication>,
    limit: Option<usize>,
    offset: Option<usize>,
    show_status: bool,
    flow_id: T
) -> BoxStream<'static, Result<Subscription, NakadiApiError>>

Lists all subscriptions that exist in a system.

fn update_auth<T: Into<FlowId>>(
    &self,
    input: &SubscriptionInput,
    flow_id: T
) -> ApiFuture<()>

This endpoint only allows to update the authorization section of a subscription.

All other properties are immutable. This operation is restricted to subjects with administrative role. This call captures the timestamp of the update request.

See also Nakadi Manual

fn delete_subscription<T: Into<FlowId>>(
    &self,
    id: SubscriptionId,
    flow_id: T
) -> ApiFuture<()>

Deletes a subscription.

See also Nakadi Manual

fn get_subscription_cursors<T: Into<FlowId>>(
    &self,
    id: SubscriptionId,
    flow_id: T
) -> ApiFuture<Vec<SubscriptionCursor>>

Exposes the currently committed offsets of a subscription.

See also Nakadi Manual

fn get_subscription_stats<T: Into<FlowId>>(
    &self,
    id: SubscriptionId,
    show_time_lag: bool,
    flow_id: T
) -> ApiFuture<SubscriptionStats>

Exposes statistics of specified subscription.

fn reset_subscription_cursors<T: Into<FlowId>>(
    &self,
    id: SubscriptionId,
    cursors: &[SubscriptionCursorWithoutToken],
    flow_id: T
) -> ApiFuture<()>

Reset subscription offsets to specified values.

See also Nakadi Manual

fn request_stream<'a, T: Into<FlowId>>(
    &'a self,
    subscription_id: SubscriptionId,
    parameters: &StreamParameters,
    flow_id: T
) -> ApiFuture<'a, SubscriptionStreamChunks>

Starts a new stream for reading events from this subscription.

fn commit_cursors<T: Into<FlowId>>(
    &self,
    id: SubscriptionId,
    stream: StreamId,
    cursors: &[SubscriptionCursor],
    flow_id: T
) -> ApiFuture<CursorCommitResults>

Endpoint for committing offsets of the subscription.