Crate speare

Source

Structs§

Ctx
The context surrounding the current Actor.
Handle
A handle to send messages to or stop a Proccess.
Node
A Node owns a collection of unsupervised top-level actors. If the Node is dropped, all of its actors are stopped.
Request
Represents a request sent to a Actor. Request holds the data sent to a Actor and provides a channel to reply back to the sender.
Response
Response<Res> is used to asynchronously wait for and retrieve the result of a Request<Req, Res> sent to a Actor.
SharedErr
A thin wrapper around Arc<E> with custom fmt::Debug and fmt::Display implementations for better error logging.
Supervision
Supervision strategies determine how parent actors respond to child-actor failures, allowing for automated recovery and error handling. Strategies can be customized with max restarts, incremental backoff and conditional directives based on error type.

Enums§

Backoff
How long to wait before restarting a Actor that errored.
Directive
Action to take after a Actor errors.
ExitReason
Enumerates the reasons why a Actor might exit.
Limit
Specifies limits for [Actor] restarts in Supervision strategies.
ReqErr
Represents a failure when waiting for a Response<_>

Traits§

Actor
A thin abstraction over tokio tasks and flume channels, allowing for easy message passing with a supervision tree to handle failures.
IntoLimit

Functions§

req_res
Creates a paired Request<Req, Res> and Response<Res> for communication between speare actors.