Skip to main content

SkipOracle

Trait SkipOracle 

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

Dyn Compatibility§

This trait is dyn compatible.

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

Implementors§