Trait nakadion::api::SchemaRegistryApi [−][src]
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
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<'_, ()>
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>
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<'_, ()>
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<'_, ()>
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