[−][src]Trait nakadion::api::SchemaRegistryApi

pub trait SchemaRegistryApi {
    fn list_event_types<T: Into<FlowId>>(
        &self, 
        flow_id: T
    ) -> ApiFuture<'_, Vec<EventType>>;

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

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

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

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

Required methods

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.

Updates the EventType identified by its name. Behaviour is the same as creation of EventType (See POST /event-type) except where noted below.

The name field cannot be changed. Attempting to do so will result in a 422 failure.

Modifications to the schema are constrained by the specified compatibility_mode.

Updating the EventType is only allowed for clients that satisfy the authorization admin requirements, if it exists.

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

Loading content...

Implementors

impl SchemaRegistryApi for ApiClient[src]

fn list_event_types<T: Into<FlowId>>(
    &self,
    flow_id: T
) -> ApiFuture<'_, Vec<EventType>>[src]

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<'_, ()>[src]

Creates a new EventType.

See also Nakadi Manual

fn delete_event_type<T: Into<FlowId>>(
    &self,
    name: &EventTypeName,
    flow_id: T
) -> ApiFuture<'_, ()>[src]

Deletes an EventType identified by its name.

See also Nakadi Manual

Loading content...