Struct JobsHost 

pub struct JobsHost {
    pub customer_app: String,
    pub scheduler_node_id: String,
    pub runtime: JobsRuntimeServices,
    pub telemetry: TelemetryCatalog,
    pub queue_topology: QueueTopology,
    pub registered_jobs: Vec<RuntimeJobDefinition>,
    pub registered_event_subscriptions: Vec<RuntimeEventSubscriptionDefinition>,
    pub jobs_domain: JobsDomain,
    pub shared_backend_namespace: String,
    /* private fields */
}

Fields

customer_app: String

scheduler_node_id: String

runtime: JobsRuntimeServices

telemetry: TelemetryCatalog

queue_topology: QueueTopology

registered_jobs: Vec<RuntimeJobDefinition>

registered_event_subscriptions: Vec<RuntimeEventSubscriptionDefinition>

jobs_domain: JobsDomain

shared_backend_namespace: String

Implementations

impl JobsHost

pub fn enqueue_spec( &mut self, spec: JobSpec, now: JobInstant, ) -> Result<JobId, RuntimeJobsError>

pub fn retry_dead_letter( &mut self, dead_letter_id: impl Into<String>, now_unix_seconds: u64, ) -> Result<JobId, RuntimeJobsError>

pub fn enqueue_job( &mut self, request: JobDispatchRequest, now: JobInstant, ) -> Result<JobId, RuntimeJobsError>

pub fn emit_domain_event( &mut self, request: DomainEventDispatchRequest, now: JobInstant, ) -> Result<DomainEventDispatch, RuntimeJobsError>

pub fn acquire_scheduler_leadership( &mut self, now: JobInstant, lease_ttl: Duration, ) -> Result<SchedulerLeadership, RuntimeJobsError>

pub fn promote_due_jobs( &mut self, now: JobInstant, ) -> Result<Vec<JobId>, RuntimeJobsError>

pub fn lease_ready_jobs( &mut self, queue: &JobQueueName, worker_id: impl Into<String>, now: JobInstant, lease_ttl: Duration, max_jobs: usize, ) -> Result<Vec<JobLease>, RuntimeJobsError>

pub fn acknowledge_completed( &mut self, lease: &JobLease, now: JobInstant, ) -> Result<(), RuntimeJobsError>

pub fn acknowledge_failed( &mut self, lease: &JobLease, now: JobInstant, reason: DeadLetterReason, error_message: impl Into<String>, ) -> Result<JobFailureDisposition, RuntimeJobsError>

pub fn coordinator(&self) -> &JobsCoordinator

pub fn queue_snapshot(&mut self) -> JobsQueueSnapshot

Trait Implementations

impl Clone for JobsHost

fn clone(&self) -> JobsHost

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for JobsHost

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

Formats the value using the given formatter.