Enum SchemaSource 

#[non_exhaustive]
pub enum SchemaSource {
    Avro {
        schema: String,
    },
    Protobuf {
        descriptor_set: Vec<u8>,
        message_type: String,
    },
    JsonSchema {
        schema: String,
    },
    Unknown,
}

The schema payload for a schema-first codec. Internally tagged on kind ({"kind":"avro","schema":...}) so an older client tolerates a newer server’s unknown source kind: an unrecognized kind decodes to SchemaSource::Unknown instead of failing the whole reply.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Avro

An Avro writer schema as its canonical JSON text.

Fields

schema: String

Protobuf

A Protobuf FileDescriptorSet (one or more compiled .proto files) plus the fully-qualified message type to decode, e.g. "shop.Order".

Fields

descriptor_set: Vec<u8>

message_type: String

JsonSchema

A JSON Schema (draft 2020-12) as its JSON text. Validation-only: a self-describing record stamping this schema’s id on agdx.sid has its decoded payload validated by LaserData Cloud. Mismatches are counted, optionally dead-lettered, and never materialize body fields.

Fields

schema: String

Unknown

A schema kind a newer server named that this build does not know. The decode degrades to this rather than failing, so an older client can still read a schema registry that holds a source kind it cannot decode against (it must not re-register one: the original kind and its fields are lost). Same forward-compat shape as RetentionPolicy::Unknown.

Trait Implementations

impl Clone for SchemaSource

fn clone(&self) -> SchemaSource

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SchemaSource

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SchemaSource

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for SchemaSource

fn eq(&self, other: &SchemaSource) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for SchemaSource

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for SchemaSource