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 fn register_query<F, Fut>( &mut self, workflow_type: impl Into<String>, query_name: impl Into<String>, handler: F, )

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

Register a named, read-only query handler for a workflow type.

The workflow type must also be registered with Worker::register_workflow before the worker runs. The handler receives only an immutable committed state snapshot and normalized query arguments.

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 duplicate of the value.

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

Performs copy-assignment from source.