cerk 0.2.11

CERK is an open source CloudEvents Router written in Rust with a MicroKernel architecture.
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

pub use super::kernel_start::kernel_start;
use super::start_options::StartOptions;
use crate::runtime::channel::{BoxedReceiver, BoxedSender};

/// Function signature for the Kernel.
///
/// # Arguments
///
/// * `start_options` - The start options defining the components and the behavior of the router.
/// * `inbox` - The inbox channel of the Kernel, every component should send there events for the Kernel to this channel.
/// * `sender_to_scheduler` - The outbox channel for messages for the Scheduler.
///
pub type KernelFn =
    fn(start_options: StartOptions, inbox: BoxedReceiver, sender_to_scheduler: BoxedSender);

/// The `bootstrap` function is the entrance point of the CERK router.
/// This function starts the Kernel with the help of the scheduler.
/// Later, the Kernel starts all components, and the router starts working.
///
/// # Arguments
///
/// * `start_options` - The start options defining the components and the behavior of the router.
///
pub fn bootstrap(start_options: StartOptions) {
    (start_options.scheduler)(start_options, kernel_start);
}