photon-backend-fluvio 0.1.0

Fluvio storage adapter for Photon
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

//! Fluvio replication factor from `PHOTON_FLUVIO_REPLICAS`.

/// Environment variable for topic replication factor.
pub const REPLICAS_ENV: &str = "PHOTON_FLUVIO_REPLICAS";

/// Read replication factor from env (default 1).
#[must_use]
pub fn replicas_from_env() -> i32 {
    std::env::var(REPLICAS_ENV)
        .ok()
        .and_then(|s| s.parse().ok())
        .unwrap_or(1)
        .clamp(1, 5)
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn defaults_to_one() {
        std::env::remove_var(REPLICAS_ENV);
        assert_eq!(replicas_from_env(), 1);
    }
}