fluvio-spu 0.2.0

Fluvio Stream Processing Unit
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

mod leader_controller;
mod leaders_state;
mod replica_state;
mod connection;
mod api_key;
mod peer_api;
mod update_offsets;
mod actions;

pub use self::leader_controller::ReplicaLeaderController;
pub use leaders_state::ReplicaLeadersState;
pub use leaders_state::SharedReplicaLeadersState;
pub use self::replica_state::LeaderReplicaState;
pub use self::connection::LeaderConnection;
pub use self::api_key::LeaderPeerApiEnum;
pub use self::peer_api::LeaderPeerRequest;
pub use self::update_offsets::UpdateOffsetRequest;
pub use self::update_offsets::ReplicaOffsetRequest;
pub use self::actions::FollowerOffsetUpdate;
pub use self::actions::LeaderReplicaControllerCommand;