Struct RuntimeSdk 

pub struct RuntimeSdk { /* private fields */ }

Backend-agnostic facade for runtime queue, outbox, and recurring operations.

Implementations

impl RuntimeSdk

pub fn new(runtime: RuntimeComposition) -> Self

Creates a new facade over a pre-built runtime composition.

pub async fn in_memory() -> Result<Self>

Builds an in-memory runtime facade with default wiring.

pub async fn surreal_mem( namespace: impl Into<String>, database: impl Into<String>, ) -> Result<Self>

Builds a surreal-mem runtime facade with default wiring.

pub async fn surreal_ws( endpoint: impl Into<String>, namespace: impl Into<String>, database: impl Into<String>, ) -> Result<Self>

Builds a remote websocket surreal runtime facade with default wiring.

pub async fn surreal_ws_with_auth( endpoint: impl Into<String>, namespace: impl Into<String>, database: impl Into<String>, auth: Option<SurrealAuth>, ) -> Result<Self>

Builds a remote websocket surreal runtime facade with optional root credentials.

pub async fn surreal_kv( path: impl Into<String>, namespace: impl Into<String>, database: impl Into<String>, ) -> Result<Self>

Builds an embedded surreal-kv runtime facade with default wiring.

pub async fn surreal_kv_with_auth( path: impl Into<String>, namespace: impl Into<String>, database: impl Into<String>, auth: Option<SurrealAuth>, ) -> Result<Self>

Builds an embedded surreal-kv runtime facade with optional root credentials.

pub async fn surreal_mem_with_auth( namespace: impl Into<String>, database: impl Into<String>, auth: Option<SurrealAuth>, ) -> Result<Self>

Builds a surreal-mem runtime facade with optional root credentials.

pub async fn from_builder(builder: StasisRuntimeBuilder) -> Result<Self>

Builds a runtime facade from a fully configured runtime builder.

pub fn runtime(&self) -> &RuntimeComposition

Returns a shared reference to the underlying runtime composition.

pub fn into_runtime(self) -> RuntimeComposition

Consumes this facade and returns the owned runtime composition.

pub async fn enqueue(&self, job: NewJob) -> Result<()>

Enqueues a single runtime job.

pub async fn register_recurring( &self, definition: RecurringDefinition, ) -> Result<()>

Registers a recurring job definition.

pub async fn process_once( &self, queue: &str, worker_id: &str, ) -> Result<Option<String>>

Attempts to process one job from a queue using the provided worker id.

pub async fn publish_pending_events(&self, limit: usize) -> Result<usize>

Publishes pending outbox events up to limit.

pub async fn materialize_recurring_now( &self, scheduler_id: &str, ) -> Result<usize>

Materializes any due recurring jobs at the current wall-clock time.

pub async fn stats_snapshot( &self, pending_limit: usize, ) -> Result<RuntimeStatsSnapshot>

Aggregates common runtime counts into a single snapshot.

pub async fn job_count_by_state(&self, state: JobState) -> Result<usize>

Counts jobs currently in the specified state.

pub async fn pending_outbox_count(&self, limit: usize) -> Result<usize>

Counts pending outbox events, bounded by limit.

pub async fn recurring_count(&self) -> Result<usize>

Counts registered recurring definitions.

Trait Implementations

impl Clone for RuntimeSdk

fn clone(&self) -> RuntimeSdk

Returns a duplicate of the value.

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

Performs copy-assignment from source.