Struct WorkerContext 

pub struct WorkerContext { /* private fields */ }

Implementations

impl WorkerContext

pub fn new() -> Self

Create a worker context backed by an embedded, lazily-created ConversationSupervisor per dispatch channel.

Note: the embedded supervisor runs on a single-thread beamr scheduler, so all worker link monitors for a channel share one scheduler thread. This is appropriate for the single-process embedded case; deployments that register very large worker pools should front them with an externally-constructed, multi-threaded supervisor rather than relying on this default.

pub fn register_worker( &self, namespace: &str, task_queue: &str, capacity: WorkerCapacity, ) -> Result<WorkerRegistration, AionSurfaceError>

Errors

Returns when channel resolution, channel creation, or subscription opening fails.

pub fn register_worker_with_participant( &self, namespace: &str, task_queue: &str, worker_id: impl Into<String>, participant: ParticipantPid, capacity: WorkerCapacity, ) -> Result<WorkerRegistration, AionSurfaceError>

Errors

Returns when the dispatch channel cannot be resolved or subscribed.

pub fn workers_for_channel( &self, channel_name: &ChannelName, request: &ActivityRequest, ) -> Result<Vec<DispatchWorker>, AionSurfaceError>

Errors

Returns when the worker pool cannot be read.

Trait Implementations

impl Clone for WorkerContext

fn clone(&self) -> WorkerContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerContext

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

Formats the value using the given formatter.

impl Default for WorkerContext

fn default() -> Self

Returns the “default value” for a type.

impl DispatchWorkerPool for WorkerContext

fn workers_for( &self, channel_name: &ChannelName, request: &ActivityRequest, ) -> Result<Vec<DispatchWorker>, AionSurfaceError>

Returns workers currently subscribed to the dispatch channel.