List of all items
Structs
- AckColdGcResponse
- AppendBatchRequest
- AppendBatchResponse
- AppendExternalRequest
- AppendRequest
- AppendResponse
- BootstrapStreamRequest
- BootstrapStreamResponse
- BootstrapUpdate
- CloseStreamRequest
- CloseStreamResponse
- ColdConfig
- ColdFlushCandidate
- ColdGcEntry
- ColdHotBacklog
- ColdReadCacheParams
- ColdStore
- ColdStoreFault
- ColdStoreFaultContext
- ColdStoreFaultEffect
- ColdStoreInfo
- ColdWriteAdmission
- CreateStreamExternalRequest
- CreateStreamRequest
- CreateStreamResponse
- DeleteSnapshotRequest
- DeleteStreamRequest
- DeleteStreamResponse
- FlushColdRequest
- FlushColdResponse
- GetStreamAttrsRequest
- GetStreamAttrsResponse
- GroupAppendBatchResponse
- GroupEngineMetrics
- GroupLeaderHint
- GroupReadStreamParts
- GroupSnapshot
- HeadStreamRequest
- HeadStreamResponse
- InMemoryGroupEngine
- InMemoryGroupEngineFactory
- InlineSnapshotStore
- PlanColdFlushRequest
- PlanGroupColdFlushRequest
- PublishSnapshotRequest
- PublishSnapshotResponse
- RaftUncommittedAdmission
- ReadSnapshotRequest
- ReadSnapshotResponse
- ReadStreamRequest
- ReadStreamResponse
- RuntimeConfig
- RuntimeMailboxSnapshot
- RuntimeMetrics
- RuntimeMetricsSnapshot
- S3SnapshotStore
- ShardRuntime
- SnapshotKey
- SnapshotPointer
- StreamAppendCount
- StreamAttrs
- StreamIntegritySnapshot
- StreamRecordRange
- TouchStreamAccessResponse
- UpdateStreamAttrsRequest
- UpdateStreamAttrsResponse
- cold_index::ColdIndexPage
- cold_index::ColdIndexPageCache
- cold_index::ColdIndexPageKey
- cold_index::ColdIndexPageRollback
- cold_index::ColdStoreColdIndexPageStore
- cold_index::InMemoryColdIndexPageStore
- journal::JournalWriter
- journal::JsonCodec
Enums
- ColdGcTarget
- ColdStoreEvent
- ColdStoreOperation
- ErrorStatus
- GroupEngineError
- GroupInfraError
- GroupReadStreamBody
- GroupWriteCommand
- GroupWriteResponse
- RuntimeError
- RuntimeThreading
- SnapshotCompression
- SnapshotLocation
- SnapshotStoreError
- StreamErrorCode
- StreamErrorContext
Traits
Functions
- cold_index::cold_index_prefix
- cold_index::rollback_cold_index_pages
- cold_index::write_cold_chunk_index_pages
- cold_index::write_cold_chunk_index_pages_with_rollback
- cold_index::write_external_segment_index_pages
- cold_worker::spawn_cold_flush_worker_if_configured
- cold_worker::spawn_cold_gc_worker_if_configured
- default_snapshot_store
- journal::decode_frames
- journal::replay
- journal::truncate_to
- new_cold_chunk_path
- new_external_payload_path
- snapshot_store_from_config
Type Aliases
- ColdChunkRef
- ColdStoreHandle
- ExternalPayloadRef
- GroupAckColdGcFuture
- GroupAppendBatchFuture
- GroupAppendFuture
- GroupBootstrapStreamFuture
- GroupCloseStreamFuture
- GroupColdHotBacklogFuture
- GroupCreateStreamFuture
- GroupDeleteSnapshotFuture
- GroupDeleteStreamFuture
- GroupEngineCreateFuture
- GroupFlushColdFuture
- GroupGetStreamAttrsFuture
- GroupHeadStreamFuture
- GroupInstallSnapshotFuture
- GroupPlanColdFlushFuture
- GroupPlanColdGcFuture
- GroupPlanNextColdFlushBatchFuture
- GroupPublishSnapshotFuture
- GroupReadSnapshotFuture
- GroupReadStreamFuture
- GroupReadStreamPartsFuture
- GroupRequireLiveReadOwnerFuture
- GroupShutdownFuture
- GroupSnapshotFuture
- GroupTouchStreamAccessFuture
- GroupUpdateStreamAttrsFuture
- GroupWriteBatchFuture
- GroupWriteFuture
- ProducerRequest
- SharedSnapshotStore
- SnapshotBytesIterator
- SnapshotStoreFuture
- cold_index::ColdIndexPageStoreFuture