Struct SqliteTimerDriver 

pub struct SqliteTimerDriver<C = SystemClock> { /* private fields */ }

SQLite-backed durable timer source.

Implementations

impl SqliteTimerDriver<SystemClock>

pub fn open(path: impl AsRef<Path>) -> DurableResult<Self>

Open or create a file-backed timer source.

pub fn in_memory() -> DurableResult<Self>

Create an in-memory timer source.

impl<C: Clock> SqliteTimerDriver<C>

pub fn open_with_clock(path: impl AsRef<Path>, clock: C) -> DurableResult<Self>

Open a file-backed timer source with an injected clock.

pub fn in_memory_with_clock(clock: C) -> DurableResult<Self>

Create an in-memory timer source with an injected clock.

pub fn schedule( &mut self, activation_id: &str, timer_id: &str, due_unix_ms: u64, value: &Value, ) -> DurableResult<()>

Schedule or exactly replay one logical timer delivery.

Trait Implementations

impl<C: Clock> WaitSourceDriver for SqliteTimerDriver<C>

fn receive( &mut self, index: &ParkedWaitIndex, max_targets: usize, ) -> DurableResult<Option<WaitDelivery>>

Return one delivery or None when no work is currently available.

fn acknowledge(&mut self, activation_id: &str) -> DurableResult<()>

Acknowledge a delivery after its M1 CAS commit.