Struct ockam_node::WorkerBuilder

pub struct WorkerBuilder<W> { /* private fields */ }

Start a Worker with a custom IncomingAccessControl and OutgoingAccessControl configuration

Any incoming messages for the worker will first be subject to the configured AccessControl before it is passed on to Worker::handle_message.

The Context::start_worker() function wraps this type and simply calls WorkerBuilder::with_inherited_access_control().

Varying use-cases should use the builder API to customise the underlying worker that is created.

Implementations

impl<W> WorkerBuilder<W>

pub fn worker(&self) -> &W

Getter

impl<M, W> WorkerBuilder<W>where M: Message + Send + 'static, W: Worker<Context = Context, Message = M>,

pub fn with_access_control( incoming_access_control: Arc<dyn IncomingAccessControl>, outgoing_access_control: Arc<dyn OutgoingAccessControl>, address: impl Into<Address>, worker: W ) -> Self

Create a worker which uses the given access control

pub fn with_mailboxes(mailboxes: Mailboxes, worker: W) -> Self

Create a worker which uses the access control from the given Mailboxes

pub async fn start(self, context: &Context) -> Result<Address>

Consume this builder and start a new Ockam Worker from the given context