Struct Worker

pub struct Worker { /* private fields */ }

Implementations

impl Worker

pub fn new(client: Client, task_queue: impl Into<String>) -> Self

pub fn worker_id(self, worker_id: impl Into<String>) -> Self

pub fn poll_timeout(self, timeout: Duration) -> Self

pub fn heartbeat_interval(self, interval: Duration) -> Self

pub fn on_worker_heartbeat<F>(self, observer: F) -> Self

where F: Fn(&WorkerHeartbeatObservation) + Send + Sync + 'static,

pub fn max_concurrent_workflow_tasks(self, count: usize) -> Self

pub fn max_concurrent_activity_tasks(self, count: usize) -> Self

pub fn register_workflow<F, Fut>( &mut self, workflow_type: impl Into<String>, handler: F, )

where F: Fn(WorkflowContext, Value) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<Value>> + Send + 'static,

pub fn register_activity<F, Fut>( &mut self, activity_type: impl Into<String>, handler: F, )

where F: Fn(ActivityContext, Value) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<Value>> + Send + 'static,

pub async fn register(&self) -> Result<RegisterWorkerResponse>

pub async fn run(&self) -> Result<()>

pub async fn run_until<F>(&self, shutdown: F) -> Result<()>

where F: Future<Output = ()>,

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

Trait Implementations

impl Clone for Worker

fn clone(&self) -> Worker

Returns a copy of the value.

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

Performs copy-assignment from source.