Struct DiskStore 

pub struct DiskStore<T: DataPoint> { /* private fields */ }

Generic fixed-record binary writer + reader for T: DataPoint.

Layout under <storage_root>/<kind-slug>/<exchange>/<account>/<symbol>/<YYYY-MM-DD>.dat:

• .dat: append-only, T::RECORD_SIZE bytes per record (little-endian).
• .idx: sparse [u64 ts_ms, u64 file_offset] every N records.
• .blob: append-only UTF-8 byte stream (only for types where DataPoint::blob_pointer_offset is Some(_)). Each header’s trailing (blob_offset: u64, blob_len: u32) references a slice in this file.

UTC day rotation. Idx interval is configurable (default 1024).

Implementations

impl<T: DataPoint> DiskStore<T>

pub async fn new(storage_root: &Path, key: SeriesKey) -> Result<Self>

Open (or create) a DiskStore. async to match the wasm32 sibling API — the actual work is synchronous; the async wrapper is zero-cost.

pub async fn with_idx_every( storage_root: &Path, key: SeriesKey, idx_every: u32, ) -> Result<Self>

Like new but with a custom idx sparsity factor. async to match the wasm32 sibling API — synchronous internally.

pub fn append(&mut self, point: &T) -> Result<()>

Append one record, possibly rotating to a new UTC day file.

Write order: blob bytes first, header second. Crash mid-blob leaves orphan bytes (no header references them); crash between blob and header still references valid blob range only if the header itself was flushed — partial header is detected on read.

pub fn append_batch(&mut self, points: &[T]) -> Result<()>

Append many points (batch). Same per-record semantics.

pub async fn flush(&mut self) -> Result<()>

Flush OS write buffers. async to match the wasm32 sibling API — synchronous internally. The work completes before the future resolves.

pub async fn read_tail(&self, limit: usize) -> Result<Vec<T>>

Read up to limit most-recent records from the current day’s .dat. Used for warm-start. Returns oldest → newest order.

For types with blob_pointer_offset(), opens the .blob file read-only and reconstructs string fields via DataPoint::decode_blob.

async to match the wasm32 sibling API — synchronous internally.

pub fn key(&self) -> &SeriesKey

pub fn root(&self) -> &Path

Trait Implementations

impl<T: DataPoint> Debug for DiskStore<T>

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

Formats the value using the given formatter.

impl<T: DataPoint> Drop for DiskStore<T>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.