allora-core 0.0.1

Core primitives for Allora: messages, exchanges, channels, processors, patterns (EIP) for Rust integration flows.
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

# Allora Core

Core primitives for the Allora integration framework: Message, Exchange, Channels (direct & queue), Route, Processors,
and Enterprise Integration Patterns (filter, content-based router, splitter, aggregator, recipient list, correlation
initializer).

## Highlights

- Lightweight in-memory channels (direct handoff + FIFO queue)
- Async-only API (await `send` / `try_receive`; built-in correlation helpers)
- Extensible processor & route abstraction
- Common EIP patterns with thorough inline docs & doctests

## Install

```toml
[dependencies]
allora-core = "0.1"
```

## Quick Example (Async)

```rust
use allora_core::{channel::QueueChannel, PollableChannel, Exchange, Message};
use tokio::runtime::Runtime;
fn main() {
    let ch = QueueChannel::with_id("demo");
    let rt = Runtime::new().unwrap();
    rt.block_on(async {
        ch.send(Exchange::new(Message::from_text("ping"))).await.unwrap();
        let ex = ch.try_receive().await.unwrap();
        assert_eq!(ex.in_msg.body_text(), Some("ping"));
    });
}
```

## Patterns

- Filter (message predicate / early reject)
- Content-Based Router (header-driven routing)
- Splitter / Aggregator (fan-out, fan-in by correlation)
- Recipient List (sequential fan-out)
- Correlation Initializer (ensures `correlation_id` header)

## License

Apache-2.0