Struct KeyedCommand 

pub struct KeyedCommand<A, Key, Role, Job, WorkerResult>
where
    A: Address + EndpointAddress,
{ /* private fields */ }

One application command accepted by a keyed pool.

Implementations

impl<A, Key, Role, Job, WorkerResult> KeyedCommand<A, Key, Role, Job, WorkerResult>

where A: Address + EndpointAddress,

pub fn submit<Route>( submission: SubmissionId, key: Key, payload: Job, customer: Route, ) -> Self

where Route: Into<ReplyRoute<MessageProtocol<A, KeyedOutcome<Key, Role, Job, WorkerResult>>>>,

Submit one affinity key, payload, correlation, and customer capability.

pub fn rebalance<Route>( request: BindingRequestId, key: Key, expected: BindingExpectation, target: Role, reply: Route, ) -> Self

where Route: Into<ReplyRoute<MessageProtocol<A, BindingReply<A, Key, Role>>>>,

Request generation-exact affinity for an absent or retained key.

pub fn unbind<Route>( request: BindingRequestId, key: Key, expected: BindingExpectation, reply: Route, ) -> Self

where Route: Into<ReplyRoute<MessageProtocol<A, BindingReply<A, Key, Role>>>>,

Remove one exact retained binding or report that absence was current.

pub const fn binding(command: BindingCommand<A, Key, Role>) -> Self

Retry a complete binding command returned by an earlier reply.

pub const fn shutdown() -> Self

Close admission and retire the complete owned actor graph.