Struct Archive 

pub struct Archive {
    pub location: String,
    pub provider: &'static str,
    pub flush_every: Duration,
    pub retention_days: u32,
    /* private fields */
}

Fields

location: String

The bucket URL without credentials, for display.

provider: &'static str

flush_every: Duration

retention_days: u32

Days to keep; 0 keeps everything.

Implementations

impl Archive

pub fn open(url: &str) -> Result<Self>

Opens s3://bucket/prefix, gs://bucket/prefix, file:///path or memory://. S3 and GCS read credentials from the standard environment variables; for R2 or MinIO set AWS_ENDPOINT (and AWS_ALLOW_HTTP=true for a plain-HTTP endpoint).

pub fn with_store( store: Arc<dyn ObjectStore>, prefix: &str, location: String, provider: &'static str, ) -> Self

pub fn status(&self) -> Status

pub async fn write_chunk(&self, records: &[LogRecord]) -> Result<()>

Writes one chunk and moves the checkpoint forward. records must not be empty.

pub async fn checkpoint(&self) -> Result<Option<SystemTime>>

The newest archived line’s time, if anything has been archived.

pub async fn query( &self, filter: &Filter, limit: usize, ) -> Result<Vec<LogRecord>>

The newest limit archived lines matching filter, oldest first.

pub async fn sweep(&self, keep_days: u32, now: SystemTime) -> Result<u64>

Deletes whole days older than keep_days before now. Returns the objects removed.

pub async fn stats(&self) -> Result<Stats>