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
21
22
23
24

mod state;
mod follower_controller;
mod api_key;
mod peer_api;
mod sync;

pub(crate) use self::follower_controller::ReplicaFollowerController;
pub use self::state::FollowersState;
pub use self::state::FollowerReplicaState;
pub use self::state::SharedFollowersState;
pub use self::api_key::FollowerPeerApiEnum;
pub use self::peer_api::FollowerPeerRequest;
pub use self::sync::PeerFileTopicResponse;
pub use self::sync::PeerFilePartitionResponse;
pub use self::sync::DefaultSyncRequest;
pub use self::sync::FileSyncRequest;

use fluvio_controlplane_metadata::partition::Replica;

#[derive(Debug)]
pub enum FollowerReplicaControllerCommand {
    AddReplica(Replica),
    UpdateReplica(Replica),
}