Struct LocalScheduleStore 

pub struct LocalScheduleStore { /* private fields */ }

SQLite-backed schedule store for local embedded hosts.

Implementations

impl LocalScheduleStore

pub fn new( db: SqliteDb, org_id: i64, owner_principal_id: PrincipalId, ) -> Result<Self>

Open (and migrate) a schedule store over db, scoped to org_id.

pub async fn create_schedule_with_metadata( &self, session_id: SessionId, description: String, cron_expression: Option<String>, scheduled_at: Option<DateTime<Utc>>, timezone: String, metadata: Value, ) -> Result<SessionSchedule>

Create a schedule and persist caller-supplied extra fields in the local metadata column. This is the additive seam that satisfies the “extensible metadata bag” criterion without changing the core primitive.

pub async fn get_metadata( &self, schedule_id: ScheduleId, ) -> Result<Option<Value>>

Read back the metadata bag previously stored for a schedule. Returns None when the schedule does not exist in this org scope.

Trait Implementations

impl Clone for LocalScheduleStore

fn clone(&self) -> LocalScheduleStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl SessionScheduleStore for LocalScheduleStore

fn create_schedule<'life0, 'async_trait>( &'life0 self, session_id: SessionId, description: String, cron_expression: Option<String>, scheduled_at: Option<DateTime<Utc>>, timezone: String, ) -> Pin<Box<dyn Future<Output = Result<SessionSchedule>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Create a new schedule for a session.

fn cancel_schedule<'life0, 'async_trait>( &'life0 self, _session_id: SessionId, schedule_id: ScheduleId, ) -> Pin<Box<dyn Future<Output = Result<SessionSchedule>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Cancel (disable) a schedule.

fn list_schedules<'life0, 'async_trait>( &'life0 self, session_id: SessionId, ) -> Pin<Box<dyn Future<Output = Result<Vec<SessionSchedule>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List schedules for a session.

fn count_active_schedules<'life0, 'async_trait>( &'life0 self, session_id: SessionId, ) -> Pin<Box<dyn Future<Output = Result<u32>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Count active (enabled) schedules for a session.

fn count_active_org_schedules<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<u32>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Count active (enabled) schedules across the whole org this store is scoped to. Used to enforce a per-org cap independent of session count: count_active_schedules only bounds one session, so unlimited sessions would otherwise imply unlimited active schedules per org.