Crate quickwit_actors

quickwit-actors is a simplified actor framework for quickwit.

It solves the following problem:

• have sync and async tasks communicate together.
• make these task observable
• make these task modular and testable
• detect when some task is stuck and does not progress anymore

Structs

• ActorContext
• ActorHandle
  An Actor Handle serves as an address to communicate with an actor.
• KillSwitch
• Mailbox
  A mailbox is the object that makes it possible to send a message to an actor.
• Observation
• Progress
  Progress makes it possible to register some progress. It is used in lieu of healthcheck.
• ProtectedZoneGuard
• Universe
  Universe serves as the top-level context in which Actor can be spawned. It is not a singleton. A typical application will usually have only one universe hosting all of the actors but it is not a requirement.

Enums

• ActorExitStatus
  The actor exit status represents the outcome of the execution of an actor, after the end of the execution.
• ActorRunner
  The ActorRunner defines the environment in which an actor should be executed.
• ActorState
• AskError
  Error that occured while calling ActorContext::ask(..) or Universe::ask
• Command
  Commands are messages that can be send to control the behavior of an actor.
• Health
  Describes the health of a given actor.
• ObservationType
• QueueCapacity
• RecvError
• SendError

Constants

• HEARTBEAT
  Heartbeat used to verify that actors are progressing.

Traits

• Actor
  An actor has an internal state and processes a stream of messages. Each actor has a mailbox where the messages are enqueued before being processed.
• Handler
• Supervisable

Functions

• create_mailbox
• create_test_mailbox
• message_timeout