rmqtt-plugins 0.22.0

Plugin collection for rmqtt, providing authentication, storage, bridges, clustering, and other extensions.
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
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76

[**English**](README.md) | [简体中文](README-CN.md)

# rmqtt-plugins

[![crates.io page](https://img.shields.io/crates/v/rmqtt-plugins.svg)](https://crates.io/crates/rmqtt-plugins)
[![docs.rs page](https://docs.rs/rmqtt-plugins/badge.svg)](https://docs.rs/rmqtt-plugins/latest/rmqtt_plugins)

Plugin collection meta-crate for the [RMQTT](https://github.com/rmqtt/rmqtt) MQTT broker. Each plugin is conditionally re-exported via feature flags (`#![deny(missing_docs)]`).

## Re-exported modules (24 total)

### Core plugins (7)

| Module | Feature flag |
|--------|-------------|
| `acl` | `acl` |
| `retainer` | `retainer` / `retainer-ram` / `retainer-sled` / `retainer-redis` |
| `http_api` | `http-api` |
| `counter` | `counter` |
| `auth_http` | `auth-http` |
| `auth_jwt` | `auth-jwt` |
| `auto_subscription` | `auto-subscription` |

### Bridge plugins (9)

| Module | Feature flag |
|--------|-------------|
| `bridge_egress_kafka` | `bridge-egress-kafka` |
| `bridge_ingress_kafka` | `bridge-ingress-kafka` |
| `bridge_egress_mqtt` | `bridge-egress-mqtt` |
| `bridge_ingress_mqtt` | `bridge-ingress-mqtt` |
| `bridge_egress_pulsar` | `bridge-egress-pulsar` |
| `bridge_ingress_pulsar` | `bridge-ingress-pulsar` |
| `bridge_egress_nats` | `bridge-egress-nats` |
| `bridge_egress_reductstore` | `bridge-egress-reductstore` |
| `bridge_origin` | `bridge-origin` |

Note: `bridge-ingress-nats` feature exists in `Cargo.toml` but is **not** re-exported from `lib.rs`.

### Storage plugins (2)

| Module | Feature flag |
|--------|-------------|
| `message_storage` | `message-storage` / `message-storage-ram` / `message-storage-redis` / `message-storage-redis-cluster` |
| `session_storage` | `session-storage` / `session-storage-sled` / `session-storage-redis` / `session-storage-redis-cluster` |

### Utility plugins (4)

| Module | Feature flag |
|--------|-------------|
| `sys_topic` | `sys-topic` |
| `topic_rewrite` | `topic-rewrite` |
| `web_hook` | `web-hook` |
| `p2p_messaging` | `p2p-messaging` |

### Cluster plugins (2)

| Module | Feature flag |
|--------|-------------|
| `cluster_raft` | `cluster-raft` |
| `cluster_broadcast` | `cluster-broadcast` |

## Usage

Each re-exported module provides a `register_named()` function:

```rust
use rmqtt_plugins;

rmqtt_plugins::acl::register_named(&scx, "rmqtt-acl", true, false).await?;
rmqtt_plugins::http_api::register_named(&scx, "rmqtt-http-api", true, false).await?;
```

## License

MIT OR Apache-2.0