Struct FlowWorker 

pub struct FlowWorker { /* private fields */ }

Worker that handles queued workflow tasks against a FlowEngine.

Implementations

impl FlowWorker

pub fn new(engine: FlowEngine, queue: Arc<dyn FlowTaskQueue>) -> Self

pub fn in_memory(engine: FlowEngine) -> Self

pub fn engine(&self) -> &FlowEngine

pub fn queue(&self) -> Arc<dyn FlowTaskQueue>

pub fn with_heartbeat_interval(self, interval: Duration) -> Result<Self>

Enables periodic lease heartbeats while a task is being handled.

Every successful heartbeat rotates the lease fencing token. If a heartbeat reports that the lease was lost, the in-progress handling future is dropped and its outcome is not acknowledged.

pub fn heartbeat_interval(&self) -> Option<Duration>

pub async fn enqueue(&self, task: FlowTask) -> Result<()>

pub async fn handle(&self, task: FlowTask) -> Result<FlowTaskOutcome>

pub async fn run_once(&self) -> Result<Option<FlowTaskOutcome>>

pub async fn run_until_idle(&self) -> Result<Vec<FlowTaskOutcome>>

Trait Implementations

impl Clone for FlowWorker

fn clone(&self) -> FlowWorker

Returns a duplicate of the value.

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

Performs copy-assignment from source.