Struct OracleTraceStorage 

pub struct OracleTraceStorage { /* private fields */ }

Coordinates local-spool-first persistence with optional upload to a MinIO/S3 remote backend.

Every trace is atomically written to the spool directory. If a remote is configured, the record is uploaded and the local copy removed on success.

Examples

let storage = OracleTraceStorage::from_env_or_vault().await;
let result = storage.persist_result(&oracle_result).await?;

Implementations

impl OracleTraceStorage

pub async fn persist_result( &self, result: &OracleResult, ) -> Result<OracleTracePersistResult>

Convert an OracleResult to a record and persist it.

Examples

let out = storage.persist_result(&oracle_result).await?;

pub async fn persist_record( &self, record: &OracleTraceRecord, ) -> Result<OracleTracePersistResult>

Write record to local spool and attempt remote upload.

Examples

let out = storage.persist_record(&record).await?;

impl OracleTraceStorage

pub async fn from_env_or_vault() -> Self

Build from environment variables and Vault-backed MinIO credentials, falling back to local-only mode on failure.

Examples

let storage = OracleTraceStorage::from_env_or_vault().await;

impl OracleTraceStorage

pub async fn sync_pending(&self) -> Result<OracleTraceSyncStats>

Upload all pending spool records to the remote backend.

Files that fail to parse or upload remain on disk so a later invocation can retry. Returns aggregate counters.

Examples

let stats = storage.sync_pending().await?;
assert_eq!(stats.pending_after, 0);