Struct LogStore 

pub struct LogStore {
    pub dir: PathBuf,
    pub quota_bytes: u64,
}

Manages the on-disk log storage directory and disk-quota policy.

Cheap to clone — only holds a PathBuf and a u64.

Fields

dir: PathBuf

Directory where task logs are stored.

quota_bytes: u64

Maximum total size of all logs before oldest-first eviction.

Implementations

impl LogStore

pub fn new(dir: PathBuf, quota_bytes: u64) -> Self

Create a new LogStore pointing at dir with the given quota.

The directory is created lazily on first write.

pub fn log_path(&self, task_id: TaskId) -> PathBuf

Uncompressed log path for task_id.

pub fn gz_path(&self, task_id: TaskId) -> PathBuf

Compressed log path for task_id.

pub async fn open_writer(&self, task_id: TaskId) -> Result<LogWriter>

Open a new LogWriter for task_id, creating the directory if needed. Any pre-existing log for this task ID is overwritten.

pub async fn list_entries(&self) -> Result<Vec<LogEntry>>

List all log entries (.log and .log.gz) in the store directory.

Returns an empty Vec if the directory does not yet exist.

pub async fn total_size(&self) -> Result<u64>

Total disk usage across all log files.

pub async fn enforce_quota(&self) -> Result<Vec<PathBuf>>

Delete oldest log files until total usage is within Self::quota_bytes.

Returns the paths of all deleted files.

pub async fn read_log(&self, task_id: TaskId) -> Result<Vec<String>>

Read all lines from a stored log.

Prefers .log.gz if present; falls back to .log. Returns an empty Vec if neither exists.

Trait Implementations

impl Clone for LogStore

fn clone(&self) -> LogStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LogStore

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

Formats the value using the given formatter.