blazingly-queue 0.2.2

Runtime-neutral queue traits with an in-memory conformance adapter
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
48
49
50
51
52
53
54

# blazingly-queue

Runtime-neutral queue seam for the
[Blazingly](https://github.com/sergii-ziborov/blazingly) framework:
publish/receive/ack/nack contracts, an in-memory conformance adapter, and a
shared worker loop.

This crate defines the `Queue` trait vendor adapters implement, the
`Message` and `Delivery` payload types, the `QueueClient` wrapper that keeps
application code vendor-neutral, `MemoryQueue` — a deterministic in-memory
adapter whose visibility delays run on a logical clock, for tests and local
development — and `Worker`, which owns the retry ceiling, exponential backoff
(`RetryPolicy`), and dead-letter routing every adapter shares. Vendor
adapters live in separate repositories; `blazingly-redis` (Redis Streams) and
`blazingly-nats` (NATS JetStream) exist today.

It is fully standalone: the crate has no dependencies at all, and every
future it returns is `Send` and drivable by any executor — no framework, no
facade, and no specific runtime required. The `blazingly` facade re-exports
it unchanged as `blazingly::queue` behind the opt-in `queue` feature.

## Direct use

The example uses `futures-lite` to drive the futures; any executor works.

```rust
use blazingly_queue::{MemoryQueue, Message, Queue};

fn main() {
    futures_lite::future::block_on(async {
        let queue = MemoryQueue::default();
        queue
            .publish("jobs", Message::new("payload"))
            .await
            .expect("publish");

        let delivery = queue
            .receive("jobs")
            .await
            .expect("receive")
            .expect("one delivery");
        assert_eq!(delivery.message.body, b"payload");

        queue.ack(&delivery.receipt).await.expect("ack");
    });
}
```

## Links

- [API documentation](https://docs.rs/blazingly-queue)
- [Getting started with the framework](https://github.com/sergii-ziborov/blazingly/blob/main/docs/getting-started.md)
- [Ecosystem integration boundary](https://github.com/sergii-ziborov/blazingly/blob/main/docs/ecosystem.md)
- [Repository](https://github.com/sergii-ziborov/blazingly)