Struct EntryRepository 

pub struct EntryRepository { /* private fields */ }

Repository for persisting relay entries to SQLite.

Thread-safe via internal Mutex. Uses WAL mode for better concurrency.

Implementations

impl EntryRepository

pub fn new(path: Option<&Path>, max_entries: usize) -> Result<Self>

Creates a new repository.

Arguments

• path - File path for SQLite database, or None for in-memory database
• max_entries - Maximum entries before LRU eviction (oldest by created_at)

Errors

Returns error if database connection or schema creation fails.

pub fn insert( &self, id: &str, body: &[u8], content_type: Option<&str>, expires_at: i64, ) -> Result<()>

Inserts or replaces an entry in the database.

If the entry count exceeds max_entries, the oldest entry (by created_at) is deleted first to make room (LRU eviction).

Arguments

• id - Unique identifier for the entry
• body - Message body bytes
• content_type - Optional content type header
• expires_at - Unix timestamp when entry expires

pub fn get(&self, id: &str) -> Result<Option<StoredEntry>>

Retrieves an entry by ID.

Returns None if the entry doesn’t exist.

pub fn ack(&self, id: &str) -> Result<bool>

Marks an entry as acknowledged and clears its message body.

Returns true if an entry was updated, false if the entry didn’t exist.

pub fn delete(&self, id: &str) -> Result<bool>

Deletes an entry by ID.

Returns true if an entry was deleted, false if the entry didn’t exist.

pub fn cleanup_expired(&self) -> Result<usize>

Deletes all expired entries.

Returns the number of entries deleted.

pub fn count(&self) -> Result<usize>

Returns the total number of entries in the database.