Struct ActrDispatch 

pub struct ActrDispatch<W: Workload> { /* private fields */ }

Pure business dispatcher

Holds an Arc<W> workload instance and optional ACL rules, exposing dispatch() and lifecycle methods.

Implementations

impl<W: Workload> ActrDispatch<W>

pub fn new(workload: Arc<W>, acl: Option<Acl>) -> Self

Create a dispatcher

Arguments

• workload: Business Workload instance (wrapped in Arc)
• acl: Optional ACL rule set; None means all calls are allowed by default

pub fn workload(&self) -> &W

Get Workload reference

pub async fn on_start<C: Context>(&self, ctx: &C) -> ActorResult<()>

Forward on_start lifecycle hook

pub async fn on_stop<C: Context>(&self, ctx: &C) -> ActorResult<()>

Forward on_stop lifecycle hook

pub async fn dispatch<C: Context>( &self, self_id: &ActrId, caller_id: Option<&ActrId>, envelope: RpcEnvelope, ctx: &C, ) -> ActorResult<Bytes>

Dispatch inbound message: ACL check -> routing -> handler execution

Arguments

• self_id: Current Actor’s ID
• caller_id: Caller ID (None for local calls)
• envelope: RPC envelope (contains route_key and payload)
• ctx: Execution context (generic, provided by upper layer)

Returns

Serialized response bytes, or ActrError

Trait Implementations

impl<W: Workload> Clone for ActrDispatch<W>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<W: Workload> Debug for ActrDispatch<W>

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

Formats the value using the given formatter.