6 releases
0.2.11 | Jan 9, 2021 |
---|---|
0.2.8 | Jan 5, 2021 |
0.2.6 | Dec 7, 2020 |
0.2.1 | Nov 25, 2020 |
#3 in #cerk
29 downloads per month
61KB
998 lines
cerk_router_rule_based
This is a package for CERK. CERK is an open source CloudEvents Router written in Rust with a MicroKernel architecture.
Introduction
CERK lets you route your CloudEvents between different different ports. Ports are transport layer bindings over which CloudEvents can be exchanged. It is built with modularity and portability in mind.
Components
CERK comes with a couple of prefabricated components, but implementing custom components is easy.
A good overview is provided on GitHub.
This Component: Rule Based Router
The rule-based router routes events based on the given configuration.
The configurations are structured in a tree format.
One configuration tree per output port needs to be configured.
The operations And
, Or
, Contains
, StartsWith
and more are supported.
Configurations
The Socket expects a Config::String
as configuration.
The string should be a json deserialized routing_rules::RoutingTable
.
Configuration Examples
Minimal
Config::String("{}".to_string())
Extended
use serde_json;
use cerk_router_rule_based::{CloudEventFields, RoutingRules, RoutingTable};
let routing_rules: RoutingTable = [(
"dummy-logger-output".to_string(),
RoutingRules::And(vec![
RoutingRules::Exact(
CloudEventFields::Source,
Some("dummy.sequence-generator".to_string()),
),
RoutingRules::EndsWith(CloudEventFields::Id, "0".to_string()),
]),
)]
.iter()
.cloned()
.collect();
let routing_configs = serde_json::to_string(&routing_rules).unwrap();
Examples
Update Readme
The original readme text is a Rust doc comment in the lib.rs file
cargo install cargo-readme
cargo readme > README.md
License
Apache-2.0
Dependencies
~4–7MB
~149K SLoC