Struct LabelStore 

pub struct LabelStore { /* private fields */ }

Persistent label store backed by SQLite.

Implementations

impl LabelStore

pub fn new(db: SqlitePool) -> Self

Create a new label store using the given database pool.

pub async fn migrate(&self) -> Result<()>

Run the label store migrations (creates the atrg_labels table).

pub async fn insert(&self, label: &SignedLabel) -> Result<i64>

Insert a signed label into the store.

Returns the auto-generated row ID of the inserted label.

pub async fn query_by_uri(&self, uri: &str) -> Result<Vec<SignedLabel>>

Query labels for a given subject URI.

pub async fn query_since( &self, cursor: i64, limit: i64, ) -> Result<Vec<(i64, SignedLabel)>>

Query labels since a given cursor (row id), for subscription streaming.

Returns pairs of (id, SignedLabel) so callers can use the id as the next cursor value.