List of all items
Structs
- DataMarkerConfig
- EventStoreConfig
- RegisteredComponents
- RunIdentity
- backend::AppendEntry
- backend::IndexKey
- backend::memory::MemoryBackend
- backend::redb::RedbBackend
- capture::adapter::BusCaptureAdapter
- capture::encoder::EncodedPayload
- capture::encoder::TypedEncoder
- capture::registry::EncoderRegistry
- capture::registry::TypedHeadersExtractor
- capture::registry::TypedIdentityExtractor
- entry::EventStoreEntry
- hash::EntryHash
- headers::Headers
- kernel::EventStoreLifecycle
- kernel::EventStoreLifecycleOptions
- kernel::EventStoreSession
- kernel::HaltSignal
- kernel::RecoveredRun
- kernel::RecoveryOutcome
- manifest::RegisteredComponents
- manifest::RunManifest
- markers::CursorState
- markers::DataCursorSnapshot
- markers::DataMarkerCapture
- markers::DataMarkerConfig
- markers::DataMarkerExtractorRegistry
- markers::HiFiMarker
- markers::JoinedStream
- markers::MarkerGap
- markers::MarkerManifest
- markers::MarkerReader
- markers::MarkerVerifier
- markers::MarkerVerifyReport
- markers::MarkerWriter
- markers::MarkerWriterConfig
- markers::MemoryMarkerBackend
- markers::RedbMarkerBackend
- markers::StoredMarkerRecord
- markers::StreamCursor
- markers::StreamDictEntry
- reader::EventStoreReader
- reader::RangeScan
- reader::SnapshotReplayPlan
- replay::CacheReplayReport
- replay::CatalogReplayRecord
- replay::CatalogReplaySlice
- replay::CatalogSliceCoverage
- replay::CatalogSlicePlan
- replay::CatalogSliceQuery
- replay::CatalogSliceSelector
- replay::EventStoreReplayReport
- replay::ParquetReplayCatalog
- replay::ReplayInputPlan
- replay::ReplayInputs
- replay::ReplaySeqRange
- replay::ReplayTimeRange
- retention::RetentionPlan
- retention::RetentionRun
- snapshot::SnapshotAnchor
- verifier::GapRange
- verifier::Verifier
- verifier::VerifyReport
- writer::EntryDraft
- writer::EventStoreWriter
- writer::WriterConfig
Enums
- DataMarkerClass
- RetentionMode
- backend::IndexKind
- backend::ScanDirection
- capture::adapter::CaptureError
- capture::encoder::EncodeError
- codec::CodecError
- error::EventStoreError
- kernel::BootError
- kernel::KernelError
- manifest::RunStatus
- markers::DataClass
- markers::MarkerCountKind
- markers::MarkerFinding
- markers::MarkerGapReason
- markers::MarkerMsg
- markers::MarkerRecordKind
- replay::CacheReplayError
- replay::CatalogReplayData
- replay::ReplayInputError
- retention::SnapshotAnchorStatus
- verifier::IndexDrift
- verifier::ManifestField
- verifier::VerifyError
- verifier::VerifyFinding
- writer::SubmitError
- writer::halt::HaltReason
Traits
- backend::EventStore
- capture::encoder::Encode
- capture::registry::HeadersExtractor
- capture::registry::IdentityExtractor
- markers::DataMarkerExtractor
- markers::MarkerBackend
- replay::ReplayCatalog
Functions
- capture::builtins::default_registry
- capture::builtins::encode_account_state
- capture::builtins::encode_data_command
- capture::builtins::encode_data_response
- capture::builtins::encode_execution_report
- capture::builtins::encode_fill_report
- capture::builtins::encode_order_event_any
- capture::builtins::encode_order_filled
- capture::builtins::encode_order_status_report
- capture::builtins::encode_position_event
- capture::builtins::encode_position_status_report
- capture::builtins::encode_submit_order
- capture::builtins::encode_time_event
- capture::builtins::encode_trading_command
- capture::builtins::register_default
- codec::decode_from_slice
- codec::encode_to_vec
- hash::compute_entry_hash
- kernel::build_run_id
- kernel::open_run
- kernel::open_run_with_options
- kernel::recover_predecessors
- markers::compute_dict_hash
- markers::compute_gap_hash
- markers::compute_hifi_hash
- markers::compute_marker_hash
- markers::join_at_entry
- replay::apply_cache_replay_entry
- replay::load_catalog_replay_inputs
- replay::load_forensics_replay_inputs
- replay::open_event_store_replay_source
- replay::plan_catalog_replay_inputs
- replay::plan_forensics_replay_inputs
- replay::replay_cache_snapshot_tail
- replay::restore_cache_from_sealed_run
- replay::restore_cache_snapshot_and_replay_tail
- replay::restore_cache_snapshot_blob
- replay::validate_event_store_replay_source
- retention::list_redb_sealed_runs
- retention::plan_redb_retention
- retention::plan_retention
- snapshot::compute_snapshot_content_hash
- writer::halt::noop_halt
Type Aliases
Constants
- DEFAULT_DATA_MARKER_CHANNEL_CAPACITY
- DEFAULT_DATA_MARKER_SAFETY_FLUSH_INTERVAL
- capture::builtins::PAYLOAD_TYPE_ACCOUNT_STATE
- capture::builtins::PAYLOAD_TYPE_BARS_RESPONSE
- capture::builtins::PAYLOAD_TYPE_BATCH_CANCEL_ORDERS
- capture::builtins::PAYLOAD_TYPE_BATCH_MODIFY_ORDERS
- capture::builtins::PAYLOAD_TYPE_BOOK_DELTAS_RESPONSE
- capture::builtins::PAYLOAD_TYPE_BOOK_DEPTH_RESPONSE
- capture::builtins::PAYLOAD_TYPE_BOOK_RESPONSE
- capture::builtins::PAYLOAD_TYPE_CANCEL_ALL_ORDERS
- capture::builtins::PAYLOAD_TYPE_CANCEL_ORDER
- capture::builtins::PAYLOAD_TYPE_CUSTOM_DATA_RESPONSE
- capture::builtins::PAYLOAD_TYPE_DEFI_REQUEST_COMMAND
- capture::builtins::PAYLOAD_TYPE_DEFI_SUBSCRIBE_COMMAND
- capture::builtins::PAYLOAD_TYPE_DEFI_UNSUBSCRIBE_COMMAND
- capture::builtins::PAYLOAD_TYPE_EXECUTION_MASS_STATUS
- capture::builtins::PAYLOAD_TYPE_FILL_REPORT
- capture::builtins::PAYLOAD_TYPE_FORWARD_PRICES_RESPONSE
- capture::builtins::PAYLOAD_TYPE_FUNDING_RATES_RESPONSE
- capture::builtins::PAYLOAD_TYPE_INSTRUMENTS_RESPONSE
- capture::builtins::PAYLOAD_TYPE_INSTRUMENT_RESPONSE
- capture::builtins::PAYLOAD_TYPE_MODIFY_ORDER
- capture::builtins::PAYLOAD_TYPE_ORDER_ACCEPTED
- capture::builtins::PAYLOAD_TYPE_ORDER_CANCELED
- capture::builtins::PAYLOAD_TYPE_ORDER_CANCEL_REJECTED
- capture::builtins::PAYLOAD_TYPE_ORDER_DENIED
- capture::builtins::PAYLOAD_TYPE_ORDER_EMULATED
- capture::builtins::PAYLOAD_TYPE_ORDER_EXPIRED
- capture::builtins::PAYLOAD_TYPE_ORDER_FILLED
- capture::builtins::PAYLOAD_TYPE_ORDER_INITIALIZED
- capture::builtins::PAYLOAD_TYPE_ORDER_MODIFY_REJECTED
- capture::builtins::PAYLOAD_TYPE_ORDER_PENDING_CANCEL
- capture::builtins::PAYLOAD_TYPE_ORDER_PENDING_UPDATE
- capture::builtins::PAYLOAD_TYPE_ORDER_REJECTED
- capture::builtins::PAYLOAD_TYPE_ORDER_RELEASED
- capture::builtins::PAYLOAD_TYPE_ORDER_STATUS_REPORT
- capture::builtins::PAYLOAD_TYPE_ORDER_SUBMITTED
- capture::builtins::PAYLOAD_TYPE_ORDER_TRIGGERED
- capture::builtins::PAYLOAD_TYPE_ORDER_UPDATED
- capture::builtins::PAYLOAD_TYPE_ORDER_WITH_FILLS
- capture::builtins::PAYLOAD_TYPE_POSITION_ADJUSTED
- capture::builtins::PAYLOAD_TYPE_POSITION_CHANGED
- capture::builtins::PAYLOAD_TYPE_POSITION_CLOSED
- capture::builtins::PAYLOAD_TYPE_POSITION_OPENED
- capture::builtins::PAYLOAD_TYPE_POSITION_STATUS_REPORT
- capture::builtins::PAYLOAD_TYPE_QUERY_ACCOUNT
- capture::builtins::PAYLOAD_TYPE_QUERY_ORDER
- capture::builtins::PAYLOAD_TYPE_QUOTES_RESPONSE
- capture::builtins::PAYLOAD_TYPE_REQUEST_COMMAND
- capture::builtins::PAYLOAD_TYPE_SUBMIT_ORDER
- capture::builtins::PAYLOAD_TYPE_SUBMIT_ORDER_LIST
- capture::builtins::PAYLOAD_TYPE_SUBSCRIBE_COMMAND
- capture::builtins::PAYLOAD_TYPE_TIME_EVENT
- capture::builtins::PAYLOAD_TYPE_TRADES_RESPONSE
- capture::builtins::PAYLOAD_TYPE_UNSUBSCRIBE_COMMAND
- markers::DEFAULT_MARKER_CHANNEL_CAPACITY
- markers::DEFAULT_MARKER_MAX_BATCH
- markers::DEFAULT_MARKER_MAX_LATENCY
- reader::DEFAULT_SCAN_CHUNK_SIZE
- writer::DEFAULT_CHANNEL_CAPACITY
- writer::DEFAULT_HALT_THRESHOLD
- writer::DEFAULT_MAX_BATCH_ENTRIES
- writer::DEFAULT_MAX_BATCH_LATENCY