Struct ColdStore 

pub struct ColdStore { /* private fields */ }

Implementations

impl ColdStore

pub async fn list_cold_index_pages(&self) -> Result<Vec<ColdIndexPageKey>>

Lists the authoritative cold-index pages rather than every chunk. One page covers 64 MiB of one stream, so this is the bounded discovery surface used by the background chunk compactor.

pub fn memory() -> Result<Self>

pub fn try_new(config: &ColdConfig) -> Result<Self>

Build a ColdStore from an explicit ColdConfig.

The bootstrap layer assembles the typed config before calling this method; this method is purely functional — it does not touch std::env.

Returns Err when the backend is ColdBackend::None; the caller should skip construction when cold storage is disabled.

pub fn info(&self) -> &ColdStoreInfo

pub fn with_read_cache(self, config: ColdReadCacheParams) -> Self

pub fn without_read_cache(self) -> Self

pub fn set_observer( &self, observer: impl Fn(ColdStoreEvent) + Send + Sync + 'static, )

pub fn set_fault_policy( &self, policy: impl Fn(&ColdStoreFaultContext) -> Option<ColdStoreFaultEffect> + Send + Sync + 'static, )

pub fn clear_fault_policy(&self)

pub fn set_delay_fn<F, Fut>(&self, delay_fn: F)

where F: Fn(Duration) -> Fut + Send + Sync + 'static, Fut: Future<Output = ()> + Send + 'static,

pub async fn write_chunk(&self, path: &str, payload: &[u8]) -> Result<u64>

pub async fn delete_chunk(&self, path: &str) -> Result<()>

pub async fn remove_all(&self, path: &str) -> Result<()>

pub async fn prefix_is_empty(&self, path: &str) -> Result<bool>

Proves that the object store has no file below path. Tenant purge uses this after recursive deletion; a successful delete request alone is not physical-absence evidence.

pub async fn read_chunk_range( &self, chunk: &ColdChunkRef, read_start_offset: u64, len: usize, ) -> Result<Vec<u8>>

pub async fn read_object_range_for_stream( &self, stream_id: &BucketStreamId, object: &ObjectPayloadRef, read_start_offset: u64, len: usize, ) -> Result<Vec<u8>>

pub async fn read_object_range( &self, object: &ObjectPayloadRef, read_start_offset: u64, len: usize, ) -> Result<Vec<u8>>

Trait Implementations

impl Clone for ColdStore

fn clone(&self) -> ColdStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ColdStore

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

Formats the value using the given formatter.