[go: up one dir, main page]

Module prelude

Module prelude 

Source
Expand description

Prelude of Bastion

Re-exports§

pub use crate::child_ref::ChildRef;
pub use crate::children::Children;
pub use crate::children_ref::ChildrenRef;
pub use crate::context::BastionContext;
pub use crate::context::BastionId;
pub use crate::context::NIL_ID;
pub use crate::dispatcher::BroadcastTarget;
pub use crate::dispatcher::DefaultDispatcherHandler;
pub use crate::dispatcher::Dispatcher;
pub use crate::dispatcher::DispatcherHandler;
pub use crate::dispatcher::DispatcherMap;
pub use crate::dispatcher::DispatcherType;
pub use crate::dispatcher::NotificationType;
pub use crate::distributor::Distributor;
pub use crate::envelope::RefAddr;
pub use crate::envelope::SignedMessage;
pub use crate::message::Answer;
pub use crate::message::AnswerSender;
pub use crate::message::Message;
pub use crate::message::MessageHandler;
pub use crate::message::Msg;
pub use crate::path::BastionPath;
pub use crate::path::BastionPathElement;
pub use crate::resizer::OptimalSizeExploringResizer;
pub use crate::resizer::UpperBound;
pub use crate::resizer::UpscaleStrategy;
pub use crate::supervisor::ActorRestartStrategy;
pub use crate::supervisor::RestartPolicy;
pub use crate::supervisor::RestartStrategy;
pub use crate::supervisor::SupervisionStrategy;
pub use crate::supervisor::Supervisor;
pub use crate::supervisor::SupervisorRef;
pub use crate::children;
pub use crate::children;
pub use crate::supervisor;
pub use crate::supervisor;
pub use crate::errors::*;
pub use crate::io::*;
pub use crate::distributed::*;distributed

Macros§

answer
Answers to a given message, with the given answer.
blocking
Spawns a blocking task, which will run on the blocking thread pool, and returns the handle.
children
This macro creates a new children group with the given amount of worker callbacks, and a closure that will be executed when a message is received.
msg
Matches a Msg (as returned by BastionContext::recv or BastionContext::try_recv) with different types.
run
This macro blocks the current thread until passed future is resolved with an output (including the panic).
spawn
Spawn a given future onto the executor from the global level.
supervisor
This macro creates a new supervisor with the given strategy and the given callbacks. Children can be specified by using the children / child macro. You can provide as many children groups as you want. Supervised supervisors are currently not yet supported.

Structs§

ArtilleryAPClusterdistributed
ArtilleryAPClusterConfigdistributed
ArtilleryEpidemicdistributed
ArtilleryMemberdistributed
ArtilleryMemberListdistributed
ArtilleryMessagedistributed
ArtilleryStateChangedistributed
Bastion
A struct allowing to access the system’s API to initialize it, start, stop and kill it and to create new supervisors and top-level children groups.
Callbacks
A set of methods that will get called at different states of a Supervisor or Children life.
Clusterdistributed
ClusterConfigdistributed
Config
The configuration that should be used to initialize the system using Bastion::init_with.
TargetedRequestdistributed

Enums§

ArtilleryClusterRequestdistributed
ArtilleryMemberEventdistributed
ArtilleryMemberStatedistributed

Functions§

most_uptodate_member_datadistributed

Type Aliases§

ArtilleryClusterEventdistributed
ClusterReactordistributed
DiscoveryLaunchdistributed
WaitListdistributed