Struct SqliteClaimStore 

pub struct SqliteClaimStore { /* private fields */ }

SQLite-backed ClaimPort with BEGIN IMMEDIATE CAS claiming.

Implementations

impl SqliteClaimStore

pub fn open(path: &str) -> Result<Self, StoreError>

Open (or create) a claim store at the given file path.

pub fn open_in_memory() -> Result<Self, StoreError>

Open a transient in-memory store (useful in tests).

Trait Implementations

impl ClaimPort for SqliteClaimStore

type Error = StoreError

Error type returned by store operations.

fn enqueue(&self, queue: &str, body: &str) -> Result<Uuid, StoreError>

Enqueue a new pending item; returns its id.

fn claim_next( &self, queue: &str, worker_id: &str, ) -> Result<Option<WorkItem>, StoreError>

Atomically claim the oldest pending item in queue for worker_id.

fn is_near_duplicate(&self, queue: &str, body: &str) -> Result<bool, StoreError>

Returns true if body is a near-duplicate of an existing item.