rocketmq-controller 0.7.0

RocketMQ Controller Module - High Availability Raft-based Controller
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
77
78
79

[package]

name = "rocketmq-controller"

version.workspace = true

authors.workspace = true

edition.workspace = true

homepage.workspace = true

repository.workspace = true

license.workspace = true

readme = "README.md"

description = "RocketMQ Controller Module - High Availability Raft-based Controller"

keywords = ["rocketmq", "controller", "raft", "distributed", "messaging"]

categories = ["network-programming", "asynchronous"]



[dependencies]

# Core async runtime

tokio = { workspace = true }

tokio-util = { workspace = true }



# Raft consensus algorithm

raft = "0.7"

raft-proto = "0.7"

prost = "0.14"

protobuf = "2.28"

slog = { version = "2.7", features = ["max_level_trace", "release_max_level_info"] }



# Serialization

serde = { workspace = true }

serde_json = { workspace = true }

bincode = "1.3"



# Networking and protocols

bytes = { workspace = true }

prost-types = "0.14"

futures = "0.3"



# Concurrent data structures

dashmap = { workspace = true }

parking_lot = { workspace = true }



# Error handling

thiserror = { workspace = true }

anyhow = { workspace = true }



# Logging and tracing

tracing = { workspace = true }

tracing-subscriber = { workspace = true }



# Time utilities

chrono = "0.4"



# Async trait support

async-trait = "0.1"



# Storage backends

rocksdb = { version = "0.24", optional = true }



# Internal dependencies (rocketmq-rust modules)

rocketmq-common = { workspace = true }

rocketmq-remoting = { workspace = true }

rocketmq-runtime = { workspace = true }

rocketmq-store = { workspace = true }

rocketmq-rust = { workspace = true }



[dev-dependencies]

criterion = { version = "0.8", features = ["async_tokio"] }

tempfile = "3.10"

env_logger = "0.11"

proptest = "1.4"



[[bench]]

name = "controller_bench"

harness = false



[features]

default = ["storage-file"]

storage-rocksdb = ["rocksdb"]

storage-file = []

metrics = []

debug = []