Struct DurableQueueLogV1 

pub struct DurableQueueLogV1 { /* private fields */ }

Implementations

impl DurableQueueLogV1

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

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

pub fn namespace(&self) -> &DaemonNamespaceV1

pub fn root_path(&self) -> &Path

pub fn enqueue_from_schedule( &self, occurrence: ScheduleOccurrenceV1, ) -> Result<QueueEnqueueOutcomeV1, QueueError>

pub fn enqueue_from_wake( &self, signal: WakeSignalV1, ) -> Result<QueueEnqueueOutcomeV1, QueueError>

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

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

pub fn acquire_next_lease_at( &self, owner: impl Into<String>, ttl_seconds: i64, now: DateTime<Utc>, ) -> Result<Option<QueueLeaseOutcomeV1>, QueueError>

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

pub fn complete_job( &self, job_id: &ArtifactId, lease_id: Option<ArtifactId>, ) -> Result<QueueHopReportV1, QueueError>

pub fn complete_job_at( &self, job_id: &ArtifactId, lease_id: Option<ArtifactId>, now: DateTime<Utc>, ) -> Result<QueueHopReportV1, QueueError>

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

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

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

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

Trait Implementations

impl Clone for DurableQueueLogV1

fn clone(&self) -> DurableQueueLogV1

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DurableQueueLogV1

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

Formats the value using the given formatter.