rustqueue/rustqueue.example.toml at main · SamuelSupe/rustqueue · GitHub

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
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
log_format = "text"

[node]
id = 1
broadcast_address = "127.0.0.1"

[network]
tcp_address = "0.0.0.0:4150"
http_address = "0.0.0.0:4151"
advertised_tcp_port = 4150
advertised_http_port = 4151
snappy_enabled = true
deflate_enabled = true
max_deflate_level = 6

[storage]
data_path = "/data"
feature_level = 1
max_segment_bytes = 104857600
scrub_interval_seconds = 3600
scrub_bytes_per_second = 67108864
entry_cache_bytes = 67108864
message_index_cache_bytes = 67108864
payload_read_workers = 0
payload_read_queue = 4096
# Keep recovery/readiness clear of immediate full-volume maintenance I/O.
maintenance_startup_delay_seconds = 30
disk_high_watermark_percent = 85
disk_low_watermark_percent = 75
min_free_bytes = 10737418240
# Explicit opt-in: this permanently removes the oldest durable messages after
# sustained disk pressure.
protective_eviction_enabled = false
disk_pressure_grace_seconds = 60

[queue]
# The stable v7 wire limit is 100 MiB; 20 MiB remains the conservative default.
# Messages above the legacy durable-record bound require storage feature level 2
# plus correspondingly larger body, publish, delivery, and segment limits.
max_message_bytes = 20971520
# Backlog is not capped by message count. Disk watermarks are the publish limit.
message_timeout_ms = 60000
max_message_timeout_ms = 900000
max_defer_ms = 3600000
max_ack_gap = 65536
# Durable topics and each per-topic publish/channel group-commit worker class are bounded.
max_topics = 10000
# Each topic accepts at most 1024 channels to bound channel WAL/index growth.
max_publish_workers = 1024
publish_worker_idle_seconds = 60
# "durable" returns PUB success and exposes messages only after local fsync.
# "write_ack" returns after append but exposes messages only after background fsync.
# "nsq_relaxed" returns and exposes messages after append, before background fsync.
publish_ack_mode = "durable"
# Relaxed modes sync when the first message, byte, or time threshold is reached.
relaxed_sync_messages = 2500
relaxed_sync_bytes = 8388608
relaxed_sync_interval_ms = 10
# Lets consumers discover a newly owning broker without losing the first messages.
bootstrap_retention_seconds = 90
message_retention_seconds = 0
max_delivery_attempts = 16
dead_letter_suffix = ".DLQ"

[limits]
max_body_bytes = 67108864
node_publish_inflight_bytes = 536870912
connection_publish_inflight_bytes = 83886080
# Payload bodies held by slow consumers are bounded separately from the read cache.
node_delivery_inflight_bytes = 536870912
connection_delivery_inflight_bytes = 33554432
max_rdy_count = 2500
max_connections = 10000
client_handshake_timeout_ms = 5000
# Bounds a command from its first byte through its optional body. Idle connections are unaffected.
tcp_command_timeout_ms = 30000
heartbeat_interval_ms = 30000
max_heartbeat_interval_ms = 60000
output_buffer_size = 16384
max_output_buffer_size = 65536
output_buffer_timeout_ms = 250
min_output_buffer_timeout_ms = 25
max_output_buffer_timeout_ms = 30000
auth_response_bytes = 1048576
auth_timeout_ms = 5000
auth_max_ttl_seconds = 3600
auth_cache_max_entries = 10000
# Bounds concurrent auth responses plus compiled authorization sessions retained by live clients and the cache.
auth_memory_bytes = 268435456
http_body_timeout_ms = 30000

[metrics]
# Label-free aggregates are always emitted. Per-topic/channel series are opt-in and bounded.
detailed_queue_metrics = false
max_detailed_series = 1000

[shutdown]
grace_seconds = 30