liminal-rs 0.2.0

A conversation-based messaging bus built on beamr
Documentation
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
pub mod compiler;
pub mod dispatch;
pub mod evaluate;
pub mod function;
pub mod group;
pub mod predicate;
pub mod table;

pub use compiler::{CompiledFunction, compile};
pub use dispatch::{DispatchConversation, DispatchError, DispatchOutcome, RerouteTiming};
pub use evaluate::{FieldAccessor, FieldValueRef, evaluate};
pub use function::{
    ConsumerId, ConsumerStateView, ContentHash, FunctionError, ModuleLoader, RoutingDecision,
    RoutingFunction, RoutingMessage, RoutingModule, RoutingSlot, SupervisedExecutor,
};
pub use group::{ConsumerGroup, ConsumerGroupSnapshot, ConsumerRegistration};
pub use predicate::{ComparisonOp, FieldPath, FieldValue, Predicate};
pub use table::{RoutingTable, SubscriberId, Subscription};