Struct BusCaptureAdapter 

pub struct BusCaptureAdapter { /* private fields */ }

Captures bus traffic and forwards encoded entries to the EventStoreWriter.

One adapter instance owns one writer; the kernel constructs the adapter after spawning the writer, then registers it with the bus dispatch wrappers. The adapter is Send + Sync so it can be shared between bus subscribers, but in practice the message bus is single-threaded and the adapter lives on the engine thread.

Implementations

impl BusCaptureAdapter

pub fn new( writer: Arc<EventStoreWriter>, registry: Arc<EncoderRegistry>, halt: HaltCallback, ) -> Self

Constructs a new adapter over writer, registry, and halt.

halt is the adapter-level fail-stop callback. The writer carries its own halt callback for backend and backpressure failures; the adapter callback fires on any submit error so SubmitError::Closed (which can originate outside the writer’s own halt path, e.g. an external close) still reaches the kernel.

pub fn with_submit_counter(self, submit_counter: Arc<AtomicU64>) -> Self

Shares an entry-submit counter with the data-marker capture path.

pub fn is_halted(&self) -> bool

Returns whether the adapter has fail-stopped.

pub fn registry(&self) -> &EncoderRegistry

Returns the encoder allow-list this adapter consults.

pub fn high_watermark(&self) -> u64

Returns the wrapped writer’s current durable high-watermark.

pub fn capture<T: 'static>( &self, topic: Topic, message: &T, headers: Headers, ts_init: UnixNanos, ) -> Result<bool, CaptureError>

Captures a state-affecting bus message.

Looks up the encoder for T, builds an EntryDraft, and forwards it to the writer. Returns Ok(false) when the type has no registered encoder so the adapter can be wired into bus dispatch paths that carry a mix of state-affecting and non-state-affecting messages without surfacing per-message errors, and when the message’s registered identity was already captured on another dispatch hop (the same order event reaches the tap via the portfolio endpoint send and the strategy topic publish; the log records it once).

topic is the bus topic the message was dispatched on, headers are the dispatch-time correlation headers (defaulting to Headers::empty until header propagation lands across all message types), and ts_init is the domain timestamp from AtomicTime (typically the message’s own ts_init field).

Errors

Returns:

• CaptureError::Halted when a prior capture already observed a writer failure and the adapter has fail-stopped.
• CaptureError::Encode when the registered encoder rejects the message.
• CaptureError::Submit when the writer rejects the submit; the adapter halt callback fires before this error returns.

pub fn capture_any( &self, topic: Topic, message: &dyn Any, headers: Headers, ts_init: UnixNanos, ) -> Result<bool, CaptureError>

Type-erased counterpart to Self::capture.

Bus dispatch hands messages to the tap as &dyn Any because the static type is not in scope at the registration site. This method dispatches on the concrete type behind the trait object and follows the same fail-stop semantics as Self::capture.

Errors

See Self::capture.

Trait Implementations

impl Debug for BusCaptureAdapter

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

Formats the value using the given formatter.