Struct EventStoreConfig 

pub struct EventStoreConfig {
    pub base_dir: PathBuf,
    pub identity: RunIdentity,
    pub retention: RetentionMode,
    pub replay_from_run_id: Option<String>,
    pub data_markers: Option<DataMarkerConfig>,
    pub channel_capacity: usize,
    pub max_batch_entries: usize,
    pub max_batch_latency: Duration,
    pub halt_threshold: Duration,
    pub run_started_timeout: Duration,
}

Configuration for the kernel-managed event store run lifecycle.

Fields

base_dir: PathBuf

Root directory; the backend creates <base_dir>/<instance_id>/<run_id>.redb.

identity: RunIdentity

Stable identification for this trader instance and binary.

retention: RetentionMode

How the supervisor reclaims sealed run files.

replay_from_run_id: Option<String>

Sealed run to restore cache state from before opening a fresh run.

When set, this enables event-store replay: the kernel restores cache state from this run, records it as the parent link for the fresh child run, and then skips engines, clients, trader startup, and live reconciliation. Quarantined runs are rejected.

data_markers: Option<DataMarkerConfig>

Data-marker sidecar settings. None disables marker capture for the run.

channel_capacity: usize

Capacity of the writer’s bounded submit channel.

max_batch_entries: usize

Maximum entries collected before the writer forces a commit.

max_batch_latency: Duration

Maximum time a batch may accumulate before the writer forces a commit.

halt_threshold: Duration

Submit-side stall ceiling that triggers writer fail-stop.

run_started_timeout: Duration

Maximum time to wait for the RunStarted entry to durably commit before the kernel surfaces an event-store boot error.

Trait Implementations

impl Clone for EventStoreConfig

fn clone(&self) -> EventStoreConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventStoreConfig

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

Formats the value using the given formatter.

impl Default for EventStoreConfig

fn default() -> EventStoreConfig

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for EventStoreConfig

fn deserialize<__D>( __deserializer: __D, ) -> Result<EventStoreConfig, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for EventStoreConfig

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.