squads_temporal_client

Trait SlotProvider

Source 
pub trait SlotProvider: Debug {
    // Required methods
    fn namespace(&self) -> &str;
    fn task_queue(&self) -> &str;
    fn try_reserve_wft_slot(&self) -> Option<Box<dyn Slot + Send>>;
}
Expand description

This trait is implemented by an object associated with a worker, which provides WFT processing slots.

Required Methods§

Source

fn namespace(&self) -> &str

The namespace for the WFTs that it can process.

Source

fn task_queue(&self) -> &str

The task queue this provider listens to.

Source

fn try_reserve_wft_slot(&self) -> Option<Box<dyn Slot + Send>>

Try to reserve a slot on this worker.

Implementors§