Skip to main content

SkipOracle

pond::adapter

Trait SkipOracle 

Source 
pub trait SkipOracle: Send + Sync {
    // Required method
    fn last_ingested_at(&self, session_id: &str) -> Option<DateTime<Utc>>;

    // Provided method
    fn is_empty(&self) -> bool { ... }
}
Expand description

Per-session watermark lookup: when did pond last write this session? Backed by Lance’s _row_last_updated_at_version joined to the manifest commit timestamp (spec.md#adapter-integrity-event-ordering). Adapter compares this to the source file’s mtime to decide whether to re-decode.

Required Methods§

Source

fn last_ingested_at(&self, session_id: &str) -> Option<DateTime<Utc>>

Provided Methods§

Source

fn is_empty(&self) -> bool

Fast-path hint: the oracle has no watermarks at all (first ingest or NoopOracle). Lets adapters skip the per-file work needed to ask last_ingested_at - typically the JSONL header peek + driver parse. Defaults to false so existing oracles stay correct without changes.

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§