Struct TypeMap 

pub struct TypeMap<Src: WireSource, S, B> { /* private fields */ }

Generic type-to-decoder registry.

Keyed by Src::TypeKey (the wire’s native type identity: Oid for pg_walstream, Arc<str> for wal2json and maxwell). Implements WireAdapter via a single HashMap::get per column.

Implementations

impl<Src: WireSource, S, B> TypeMap<Src, S, B>

pub fn new() -> Self

Empty registry.

pub fn register<D>(&mut self, key: Src::TypeKey, decoder: D) -> &mut Self

where D: Decoder<Src, S, B> + Send + Sync + 'static,

Register (or replace) the decoder for key. Returns &mut self for chaining.

pub fn with<D>(self, key: Src::TypeKey, decoder: D) -> Self

where D: Decoder<Src, S, B> + Send + Sync + 'static,

Same as register but consumes self for builder-style chaining: TypeMap::new().with(k1, d1).with(k2, d2).

pub fn len(&self) -> usize

Number of registered entries.

pub fn is_empty(&self) -> bool

True when the registry has zero entries.

impl<Src, S, B> TypeMap<Src, S, B>

where Src: TypeMapDefaults<S, B>,

pub fn defaults() -> Self

Pre-populated registry with every self-evident mapping the crate ships for this source, sugared for <Src as TypeMapDefaults<S, B>>::defaults().

Trait Implementations

impl<Src: WireSource, S, B> Default for TypeMap<Src, S, B>

fn default() -> Self

Returns the “default value” for a type.

impl<Src: WireSource, S, B> WireAdapter<Src, S, B> for TypeMap<Src, S, B>

fn decode(&self, payload: Src::Payload<'_>) -> Result<Value<S, B>, DecodeError>

Decode one column payload.