Struct GlueSchemaCache 

pub struct GlueSchemaCache {
    cache: BTreeMap<Uuid, Result<Schema, Error>>,
    glue_client: Client,
    expected_registry: String,
}

Glue-side analogue of SchemaCache.

Differences from the CSR cache:

• Keys are UUIDs (Glue schema-version IDs), not i32s.
• Glue schemas are single definitions — no references field on GetSchemaVersion, so the cache does not chase a dependency graph.
• No outer retry layer. aws-sdk-glue ships a “standard” retry policy by default that handles transient errors; layering our own Retry::default() on top would only amplify backoff.

Fields

cache: BTreeMap<Uuid, Result<Schema, Error>>

glue_client: Client

expected_registry: String

The registry name the catalog connection points at. Per-UUID fetches are cross-checked against this; mismatches become decode errors. See type-level docs.

Implementations

impl GlueSchemaCache

fn new(glue_client: Client, expected_registry: String) -> Self

async fn get( &mut self, uuid: Uuid, reader_schema: &Schema, ) -> Result<Result<&Schema>>

Look up the writer schema for uuid, fetching from Glue on a cache miss. Mirrors SchemaCache::get: the outer Result surfaces transient errors (network, auth, throttling — already retried by the SDK) that the caller may retry on; the inner Result carries permanent failures (schema not found, non-Available lifecycle, registry mismatch, parse failure) that get cached so the same bad UUID does not re-hit Glue on every record.

fn parse_version( version: SchemaVersion, uuid: Uuid, expected_registry: &str, reader_schema: &Schema, ) -> Result<Schema, AvroError>

Validate and parse a fetched mz_aws_glue_schema_registry::SchemaVersion into an Avro schema.

All failures here are permanent (a retry would return the same SchemaVersion) and get cached by the caller.

Trait Implementations

impl Debug for GlueSchemaCache

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

Formats the value using the given formatter.