klukai-agent 0.1.4

Agent component for Klukai Corrosion
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

//! Agent module
//!
//! The agent runs input and output streams (with other agents and
//! clients), manages cluster memberships, and applies propagated
//! changesets to local data.

mod bi;
mod bootstrap;
mod error;
mod handlers;
mod metrics;
mod run_root;
mod setup;
mod uni;
pub mod util;

#[cfg(test)]
mod tests;

use bytes::Bytes;
use klukai_types::api::QueryEventMeta;
use std::{collections::HashMap, sync::Arc, time::Duration};
use tokio::sync::{RwLock, broadcast::Sender};
use uuid::Uuid;

// Public exports
pub use error::{SyncClientError, SyncRecvError};
pub use run_root::start_with_config;
pub use setup::{AgentOptions, setup};
pub use uni::spawn_unipayload_handler;
pub use util::process_multiple_changes;

pub const ANNOUNCE_INTERVAL: Duration = Duration::from_secs(300);
pub const RANDOM_NODES_CHOICES: usize = 10;

pub const CHECK_EMPTIES_TO_INSERT_AFTER: Duration = Duration::from_secs(120);
pub const TO_CLEAR_COUNT: usize = 1000;

pub type BcastCache = Arc<RwLock<HashMap<Uuid, Sender<(Bytes, QueryEventMeta)>>>>;

#[derive(Clone)]
pub struct CountedExecutor;

impl<F> hyper::rt::Executor<F> for CountedExecutor
where
    F: std::future::Future + Send + 'static,
    F::Output: Send,
{
    fn execute(&self, fut: F) {
        klukai_types::spawn::spawn_counted(fut);
    }
}