Struct EventCodecRegistry 

pub struct EventCodecRegistry<E: Send + 'static> { /* private fields */ }

Manifest -> decoder map plus an optional catch-all decoder.

Implementations

impl<E: Send + 'static> EventCodecRegistry<E>

pub fn new() -> Self

pub fn register<F>(self, manifest: impl Into<String>, decode: F) -> Self

where F: Fn(&[u8]) -> Result<E, String> + Send + Sync + 'static,

Register decode as the decoder for events written with manifest.

pub fn with_default<F>(self, decode: F) -> Self

where F: Fn(&[u8]) -> Result<E, String> + Send + Sync + 'static,

Set a catch-all decoder used when no manifest matches.

pub fn decode(&self, manifest: &str, bytes: &[u8]) -> Option<Result<E, String>>

Look up a decoder for manifest or fall back to the default.

Trait Implementations

impl<E: Send + 'static> Default for EventCodecRegistry<E>

fn default() -> Self

Returns the “default value” for a type.