Enum SchemaRegistryRequest 

pub enum SchemaRegistryRequest {
    Register {
        entry: SchemaEntry,
    },
    Get {
        name: String,
        version: Option<SchemaVersion>,
    },
    List {
        prefix: Option<String>,
    },
    Check {
        name: String,
        version: SchemaVersion,
    },
    Evolve {
        name: String,
        from_version: SchemaVersion,
        to_entry: SchemaEntry,
    },
}

Registry operations for schema management.

Variants

Register

Register a new schema (declaration)

Fields

entry: SchemaEntry

Get

Retrieve a schema by name (consumption)

Fields

name: String

version: Option<SchemaVersion>

List

List all available schemas

Fields

prefix: Option<String>

Check

Check if schema exists and get compatibility info

Fields

name: String

version: SchemaVersion

Evolve

Evolve an existing schema (migration)

Fields

name: String

from_version: SchemaVersion

to_entry: SchemaEntry

Trait Implementations

impl Archive for SchemaRegistryRequest

where SchemaEntry: Archive, String: Archive, Option<SchemaVersion>: Archive, Option<String>: Archive, SchemaVersion: Archive,

type Archived = ArchivedSchemaRegistryRequest

The archived representation of this type.

type Resolver = SchemaRegistryRequestResolver

The resolver for this type. It must contain all the additional information from serializing needed to make the archived type from the normal type.

unsafe fn resolve( &self, pos: usize, resolver: <Self as Archive>::Resolver, out: *mut <Self as Archive>::Archived, )

Creates the archived version of this value at the given position and writes it to the given output.

impl Clone for SchemaRegistryRequest

fn clone(&self) -> SchemaRegistryRequest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SchemaRegistryRequest

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SchemaRegistryRequest

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<__D: Fallible + ?Sized> Deserialize<SchemaRegistryRequest, __D> for Archived<SchemaRegistryRequest>

where SchemaEntry: Archive, Archived<SchemaEntry>: Deserialize<SchemaEntry, __D>, String: Archive, Archived<String>: Deserialize<String, __D>, Option<SchemaVersion>: Archive, Archived<Option<SchemaVersion>>: Deserialize<Option<SchemaVersion>, __D>, Option<String>: Archive, Archived<Option<String>>: Deserialize<Option<String>, __D>, SchemaVersion: Archive, Archived<SchemaVersion>: Deserialize<SchemaVersion, __D>,

fn deserialize( &self, deserializer: &mut __D, ) -> Result<SchemaRegistryRequest, __D::Error>

Deserializes using the given deserializer

impl<__S: Fallible + ?Sized> Serialize<__S> for SchemaRegistryRequest

where SchemaEntry: Serialize<__S>, String: Serialize<__S>, Option<SchemaVersion>: Serialize<__S>, Option<String>: Serialize<__S>, SchemaVersion: Serialize<__S>,

fn serialize( &self, serializer: &mut __S, ) -> Result<<Self as Archive>::Resolver, __S::Error>

Writes the dependencies for the object and returns a resolver that can create the archived type.

impl Serialize for SchemaRegistryRequest

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.