Struct DispatchWorker 

pub struct DispatchWorker {
    pub worker_id: String,
    pub participant: ParticipantPid,
    pub consumer_state: ConsumerStateView,
}

Worker process visible to one dispatch routing decision.

Fields

worker_id: String

Stable worker identity used by routing decisions and recorded events.

participant: ParticipantPid

Beamr process identifier linked into the dispatch conversation.

consumer_state: ConsumerStateView

Capacity and affinity view presented to the configured routing function.

Implementations

impl DispatchWorker

pub fn new(worker_id: impl Into<String>, participant: ParticipantPid) -> Self

Creates a worker with a one-slot capacity view.

pub fn with_consumer_state( worker_id: impl Into<String>, participant: ParticipantPid, consumer_state: ConsumerStateView, ) -> Self

Creates a worker with an explicit routing view.

Trait Implementations

impl Clone for DispatchWorker

fn clone(&self) -> DispatchWorker

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DispatchWorker

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

Formats the value using the given formatter.

impl Eq for DispatchWorker

impl PartialEq for DispatchWorker

fn eq(&self, other: &DispatchWorker) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for DispatchWorker