orlando-cluster 0.1.0

A virtual actor framework in Rust, inspired by Microsoft Orleans.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60

mod auth;
mod cluster_gateway;
mod cluster_grain_ref;
mod cluster_silo;
mod connection_pool;
mod cross_cluster_directory;
pub mod discovery;
mod error;
mod failover;
mod failure_detector;
mod hash_ring;
pub mod health_server;
mod membership;
mod message_registry;
mod multi_cluster;
mod network_message;
mod placement;
mod rebalancer;
mod replication_consumer;
mod replication_producer;
pub(crate) mod store_wrapper;
pub(crate) mod swim;
mod retry;
mod transport;

#[cfg(feature = "tcp-transport")]
pub mod tcp_transport;

pub mod proto {
    tonic::include_proto!("orlando.cluster");
}

pub use auth::{ClusterAuth, SharedSecretAuth};
pub use cluster_gateway::ClusterGatewayService;
pub use cluster_grain_ref::ClusterGrainRef;
pub use cluster_silo::{ClusterSilo, ClusterSiloBuilder};
pub use orlando_core::ClusterId;
pub use connection_pool::ConnectionPool;
pub use cross_cluster_directory::{
    CrossClusterDirectory, DirectoryError, GrainOwnership, InMemoryCrossClusterDirectory,
};
pub use error::ClusterError;
pub use failover::{FailoverConfig, FailoverManager, FailoverPhase};
pub use failure_detector::{FailureDetector, FailureDetectorConfig, MembershipChange};
pub use hash_ring::{HashRing, SiloAddress};
pub use health_server::{StoreProbe, run_health_server};
pub use membership::MembershipService;
pub use message_registry::MessageRegistry;
pub use multi_cluster::{ClusterHealth, MultiClusterConfig, PeerStatus};
pub use network_message::{Encoding, NetworkMessage};
pub use placement::{HashBasedPlacement, PlacementStrategy, PreferLocalPlacement, RandomPlacement};
pub use discovery::{DnsMembershipProvider, MembershipProvider, StaticSeedProvider};
#[cfg(feature = "consul")]
pub use discovery::ConsulMembershipProvider;
pub use rebalancer::Rebalancer;
pub use replication_consumer::ReplicationConsumer;
pub use replication_producer::spawn_replication_pump;
pub use store_wrapper::{ReplicaEntry, ReplicaStore};
pub use retry::RetryPolicy;
pub use transport::GrainTransportService;