Enum apalis_core::storage::StorageWorkerPulse

#[non_exhaustive]
pub enum StorageWorkerPulse {
    EnqueueScheduled {
        count: i32,
    },
    RenqueueOrpharned {
        count: i32,
    },
}

Available on crate feature storage only.

Each [Worker] sends heartbeat messages to storage

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

EnqueueScheduled

Fields

count: i32

the count of jobs to be scheduled

Push scheduled jobs into the active set

RenqueueOrpharned

Fields

count: i32

the count of orphaned jobs

Resque any orphaned jobs

Trait Implementations

impl Clone for StorageWorkerPulse

fn clone(&self) -> StorageWorkerPulse

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for StorageWorkerPulse

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

Formats the value using the given formatter.

impl<T: 'static, S: 'static, H: 'static, F> Handler<StorageWorkerPulse> for StorageWorker<T, S, H> where
    S: Storage<Output = T> + Unpin + Send + Sync,
    T: Job + Serialize + Debug + DeserializeOwned + Send,
    H: Service<JobRequest<T>, Response = JobResult, Error = JobError, Future = F> + Unpin + Send + 'static,
    F: Future<Output = Result<JobResult, JobError>> + Send, 

type Result = ()

Available on crate feature worker only.

Result of handler

fn handle<'life0, 'async_trait>(
    &'life0 mut self,
    beat: StorageWorkerPulse
) -> Pin<Box<dyn Future<Output = Self::Result> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Available on crate feature worker only.

Message handler

impl Hash for StorageWorkerPulse

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H) where
    H: Hasher, 

Feeds a slice of this type into the given Hasher.

impl Message for StorageWorkerPulse

type Result = ()

Available on crate feature worker only.

Result type of message

impl PartialEq<StorageWorkerPulse> for StorageWorkerPulse

fn eq(&self, other: &StorageWorkerPulse) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &StorageWorkerPulse) -> bool

This method tests for !=.

impl Eq for StorageWorkerPulse

impl StructuralEq for StorageWorkerPulse

impl StructuralPartialEq for StorageWorkerPulse