malstrom-k8s 0.1.0

Kubernetes runtime for the Malstrom stream processing framework
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

mod discovery;
mod worker_backend;
/// Intra-job communication
mod exchange {
    include!(concat!(env!("OUT_DIR"), "/malstrom_k8s.rs"));
}
/// Communication with K8S operator
mod k8s_operator {
    include!(concat!(env!("OUT_DIR"), "/malstrom_k8s.k8s_operator.rs"));
}

mod coordinator_backend;
pub(crate) mod transport;
mod util;

pub(crate) use coordinator_backend::CoordinatorGrpcBackend;
pub(crate) use worker_backend::WorkerGrpcBackend;

pub enum APICommand {
    Rescale(RescaleCommand),
}
pub struct RescaleCommand {
    pub desired: u64,
    pub on_finish: tokio::sync::oneshot::Sender<()>,
}