Enum WriterSchemaProvider 

pub enum WriterSchemaProvider {
    None,
    Confluent {
        cache: Option<SchemaCache>,
    },
    Glue {
        cache: Option<GlueSchemaCache>,
    },
}

Provides writer schemas to an AvroSchemaResolver.

Mirrors the WireFormat<C> enum on the catalog side: a decoder can run without any wire-format framing, with Confluent framing, or with AWS Glue framing (each of the framed variants optionally without a registry to fetch from). Each variant owns its cache type by construction, so the resolver cannot mis-route a key to the wrong cache.

Variants

None

No wire-format framing. The resolver always returns the reader schema and never consumes header bytes.

Confluent

Confluent framing. cache: None means strip-and-discard the schema id (no registry attached); cache: Some means fetch from the cache.

Fields

cache: Option<SchemaCache>

Glue

AWS Glue framing. cache: None means strip-and-discard the UUID (no registry attached); cache: Some means fetch from the cache.

Fields

cache: Option<GlueSchemaCache>

Implementations

impl WriterSchemaProvider

pub fn confluent(ccsr_client: Option<Client>) -> Self

Build the Confluent variant from an optional CCSR client. None means “Confluent framing but no registry to fetch from” — the resolver will strip the header and fall back to the reader schema.

pub fn glue(client_with_registry: Option<(Client, String)>) -> Self

Build the Glue variant from an optional (client, registry-name) pair. None means “Glue framing but no registry to fetch from” — the resolver strips the UUID header and falls back to the reader schema. When the pair is supplied, the registry name is the one the catalog connection points at; the cache rejects any UUID whose SchemaArn doesn’t sit under that registry. (Schema names aren’t unique across Glue registries, so the registry name is the only meaningful scope here.) Pairing the two in a tuple makes the “no client → no registry name” case unrepresentable.

Trait Implementations

impl Debug for WriterSchemaProvider

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

Formats the value using the given formatter.