Struct rabble::Executor

pub struct Executor<T> { /* fields omitted */ }

Methods

impl<'de, T: Serialize + Deserialize<'de> + Send + Debug + Clone> Executor<T>

fn new(
    node: NodeId,
    tx: Sender<ExecutorMsg<T>>,
    rx: Receiver<ExecutorMsg<T>>,
    cluster_tx: Sender<ClusterMsg<T>>,
    logger: Logger
) -> Executor<T>

fn run(self)

Run the executor

This call blocks the current thread indefinitely.