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

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

    fn create_event_type<T: Into<FlowId>>(
        &self, 
        event_type: &EventType, 
        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: FlowId
) -> ApiFuture<Vec<EventType>>

Returns a list of all registered EventTypes

See also Nakadi Manual

fn create_event_type<T: Into<FlowId>>(
    &self,
    event_type: &EventType,
    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

Loading content...

Implementors

impl SchemaRegistryApi for ApiClient[src]

fn list_event_types<T: Into<FlowId>>(
    &self,
    flow_id: FlowId
) -> 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: &EventType,
    flow_id: T
) -> ApiFuture<()>[src]

Creates a new EventType.

See also Nakadi Manual

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

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

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

Deletes an EventType identified by its name.

See also Nakadi Manual

Loading content...