Struct JsonPayloadDecoderRegistry 

pub struct JsonPayloadDecoderRegistry { /* private fields */ }

Heterogeneous per-key payload decoder registry.

One registry may contain the union of keys used by several output streams. Coverage therefore requires every selected key but permits additional registrations. Keys are exact and are not trimmed or case-normalized.

This type is intentionally non-Clone because registered decoders may own caches, handles, or synchronization state with unknown clone semantics.

Implementations

impl JsonPayloadDecoderRegistry

pub fn new() -> Self

Creates an empty registry.

pub fn with_capacity(capacity: usize) -> Self

Creates an empty registry with capacity for at least capacity keys.

pub fn with_json_field<T>( self, key: impl Into<String>, ) -> Result<Self, StorageError>

where T: DeserializeOwned + Serialize + Clone + Send + 'static,

Adds a field decoded directly through Serde JSON into T.

This is the concise path for payload types whose JSON representation already matches their Rust representation. Specialized decoders remain available through JsonPayloadDecoderRegistry::register_for_field when conversion requires configuration, validation, or a different wire shape.

Errors

Returns the same empty-key or duplicate-key errors as JsonPayloadDecoderRegistry::register_for_field. Payload parse failures are reported later with their field context by the reader.

pub fn register_for_field<T, D>( &mut self, key: impl Into<String>, decoder: D, ) -> Result<(), StorageError>

where T: Serialize + Clone + Send + 'static, D: JsonPayloadDecoder<T>,

Registers one typed decoder under one exact state field key.

Successful decoded values are moved directly into SystemState; the adapter never invokes T::clone.

Errors

Returns StorageError::InvalidConfiguration for an empty key and StorageError::DuplicateDecoder for an existing key. The incoming decoder is dropped on either configuration error.

pub fn len(&self) -> usize

Returns the number of registered field keys.

pub fn is_empty(&self) -> bool

Reports whether no payload decoder is registered.

pub fn has_decoder_for_field(&self, key: &str) -> bool

Reports whether an exact field key has a registered decoder.

pub fn registered_field_names(&self) -> impl ExactSizeIterator<Item = &str>

Iterates registered keys in unspecified hash-map order.

Reader dispatch never uses this order. Callers needing stable display should sort the returned strings.

Trait Implementations

impl Debug for JsonPayloadDecoderRegistry

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

Formats sorted keys without exposing decoder internals or payloads.

impl Default for JsonPayloadDecoderRegistry

fn default() -> JsonPayloadDecoderRegistry

Returns the “default value” for a type.