Struct DaemonControllerV1 

pub struct DaemonControllerV1 { /* private fields */ }

Implementations

impl DaemonControllerV1

pub fn namespace( root_path: impl AsRef<Path>, name: impl Into<String>, owner: impl Into<String>, ) -> DaemonNamespaceV1

pub fn open( root_path: impl AsRef<Path>, namespace: DaemonNamespaceV1, owner: impl Into<String>, ) -> Result<Self, DaemonError>

pub fn open_read_only( root_path: impl AsRef<Path>, namespace: DaemonNamespaceV1, ) -> Result<Self, DaemonError>

pub fn queue_root(&self) -> PathBuf

pub fn namespace_id(&self) -> ArtifactId

pub fn enqueue_schedule_occurrence( &self, schedule_id: impl Into<String>, occurrence_key: impl Into<String>, due_at: DateTime<Utc>, payload: Value, risk: CanonicalToolSideEffectClass, ) -> Result<QueueEnqueueOutcomeV1, DaemonError>

pub fn enqueue_wake_signal( &self, source: impl Into<String>, signal_key: impl Into<String>, payload: Value, risk: CanonicalToolSideEffectClass, ) -> Result<QueueEnqueueOutcomeV1, DaemonError>

pub fn enqueue_job( &self, job: JobV1, ) -> Result<QueueEnqueueOutcomeV1, DaemonError>

pub fn acquire_next( &self, owner: impl Into<String>, ttl_seconds: i64, ) -> Result<Option<QueueLeaseOutcomeV1>, DaemonError>

pub fn cancel( &self, job_id: &ArtifactId, reason: impl Into<String>, ) -> Result<QueueHopReportV1, DaemonError>

pub fn complete( &self, job_id: &ArtifactId, lease: &QueueLeaseV1, ) -> Result<QueueHopReportV1, DaemonError>

pub fn set_safe_mode( &self, enabled: bool, reason: impl Into<String>, ) -> Result<SafeModeReportV1, DaemonError>

pub fn drain( &self, reason: impl Into<String>, ) -> Result<Vec<QueueHopReportV1>, DaemonError>

pub fn snapshot(&self) -> Result<QueueSnapshotV1, DaemonError>

Trait Implementations

impl Clone for DaemonControllerV1

fn clone(&self) -> DaemonControllerV1

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DaemonControllerV1

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.