Struct SubscriptionRepository 

pub struct SubscriptionRepository<'a> { /* private fields */ }

Implementations

impl<'a> SubscriptionRepository<'a>

pub const fn new(conn: &'a Connection) -> Self

pub fn upsert(&self, subscription: WebhookSubscription) -> Result<()>

pub fn get(&self, id: Uuid) -> Result<Option<WebhookSubscription>>

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

pub fn list(&self) -> Result<Vec<WebhookSubscription>>

Every subscription row, oldest first. The admin API lists through this; the delivery worker reads [matching] instead, which applies the enabled and filter predicates.

pub fn matching(&self, event: &ChangeEvent) -> Result<Vec<WebhookSubscription>>

pub fn enqueue_matching(&self, event: &ChangeEvent) -> Result<usize>