Struct EncoderRegistry 

pub struct EncoderRegistry { /* private fields */ }

Allow-list of capturable Rust message types and their encoders.

Registration is keyed by std::any::TypeId; the adapter dispatches by TypeId so callers can capture a typed message without naming the encoder concretely. A type registered twice replaces the prior entry: the SPEC’s encoder rules require one canonical mapping per Rust type, and the registry would otherwise hide the conflict.

Implementations

impl EncoderRegistry

pub fn new() -> Self

Creates a new empty registry.

pub fn register<T, F>(&mut self, payload_type: PayloadType, func: F)

where T: 'static, F: Fn(&T) -> Result<EncodedPayload, EncodeError> + Send + Sync + 'static,

Registers func as the encoder for T and stamps every captured entry with payload_type. Captures yield Headers::empty until Self::register_headers records an extractor for T.

Replaces any encoder previously registered for T; capture flows hold the registry as Arc<EncoderRegistry> so registration must happen before the adapter is constructed.

pub fn register_with_headers<T, F, H>( &mut self, payload_type: PayloadType, func: F, headers_fn: H, )

where T: 'static, F: Fn(&T) -> Result<EncodedPayload, EncodeError> + Send + Sync + 'static, H: Fn(&T) -> Headers + Send + Sync + 'static,

Registers func as the encoder for T and headers_fn as the matching headers extractor in one call.

pub fn register_encoder<T: 'static>( &mut self, payload_type: PayloadType, encoder: Arc<dyn Encode>, )

Registers an already-built Encode implementer for T. Captures yield Headers::empty until Self::register_headers records an extractor.

Useful when the encoder owns state (e.g., a schema cache) the closure form cannot express ergonomically.

pub fn register_headers<T, H>(&mut self, headers_fn: H)

where T: 'static, H: Fn(&T) -> Headers + Send + Sync + 'static,

Registers headers_fn as the headers extractor for T.

Call after Self::register when the encoder is preregistered through a shared helper but the call site wants a typed headers extractor. Replaces any prior extractor for T. Returns silently when T has no encoder registered: callers that care about the contract should rely on Self::contains.

pub fn register_identity<T, F>(&mut self, identity_fn: F)

where T: 'static, F: Fn(&T) -> Option<UUID4> + Send + Sync + 'static,

Registers identity_fn as the identity extractor for T.

Call after Self::register. Replaces any prior extractor for T. Returns silently when T has no encoder registered: callers that care about the contract should rely on Self::contains.

pub fn len(&self) -> usize

Returns the number of registered encoders.

pub fn is_empty(&self) -> bool

Returns whether the registry is empty.

pub fn contains<T: 'static>(&self) -> bool

Returns whether an encoder is registered for T.

pub fn encode<T: 'static>( &self, message: &T, ) -> Result<Option<(PayloadType, EncodedPayload)>, EncodeError>

Encodes message if a typed encoder is registered for T.

Returns Ok(None) when no encoder is registered for T so the adapter can drop the message at the dispatch boundary without surfacing it as an error: the allow-list is the source of truth for the captured surface, and out-of-list messages are non-state-affecting by definition.

Errors

Returns the encoder’s EncodeError when an encoder is registered but rejects the message.

pub fn encode_any( &self, message: &dyn Any, ) -> Result<Option<(PayloadType, EncodedPayload)>, EncodeError>

Encodes a type-erased message if an encoder is registered for the concrete type.

Mirror of Self::encode for &dyn Any callers; the bus tap reaches the capture path through this entry point because dispatch returns a &dyn Any and the static type is not in scope.

Errors

Returns the encoder’s EncodeError when an encoder is registered for the concrete type but rejects the message.

pub fn headers_for_any(&self, message: &dyn Any) -> Option<Headers>

Returns the headers carried by message if a registration exists for its concrete type. Returns None when no encoder is registered: the adapter then drops the message without further work.

pub fn identity_for_any(&self, message: &dyn Any) -> Option<UUID4>

Returns the logical identity carried by message if its registration has an identity extractor. Returns None when the type is unregistered or carries no extractor; the adapter then captures per dispatch.

Trait Implementations

impl Clone for EncoderRegistry

fn clone(&self) -> EncoderRegistry

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for EncoderRegistry

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

Formats the value using the given formatter.

impl Default for EncoderRegistry

fn default() -> EncoderRegistry

Returns the “default value” for a type.