dusan 9f0570d424 Add replication tests ...

Signed-off-by: dusan <borovcanindusan1@gmail.com>

2026-01-08 21:03:33 +01:00

..

raft

Add Raft to queue

2026-01-04 16:06:12 +01:00

storage

Add supprot for replicated queues

2026-01-04 16:32:28 +01:00

consumer_group_test.go

Fix tests

2025-12-31 18:43:46 +01:00

consumer_group.go

Use zero-copy ringbuffers

2026-01-02 23:36:47 +01:00

delivery_test.go

Fix queue tests

2026-01-07 21:02:11 +01:00

delivery_worker.go

Add supprot for replicated queues

2026-01-04 16:32:28 +01:00

dequeue_bench_test.go

Fix queue tests

2026-01-07 21:02:11 +01:00

dlq_test.go

Rename queue message

2026-01-03 00:35:04 +01:00

dlq.go

Rename queue message

2026-01-03 00:35:04 +01:00

e2e_bench_test.go

Fix queue tests

2026-01-07 21:02:11 +01:00

enqueue_bench_test.go

Use pooling to improve performance

2026-01-04 11:40:11 +01:00

integration_test.go

Fix queue tests

2026-01-07 21:02:11 +01:00

manager_test.go

Add queue clustering

2026-01-03 16:24:59 +01:00

manager.go

Add supprot for replicated queues

2026-01-04 16:32:28 +01:00

ordering_test.go

Rename queue message

2026-01-03 00:35:04 +01:00

ordering.go

Rename queue message

2026-01-03 00:35:04 +01:00

partition_assigner.go

Add queue scaling

2026-01-03 15:55:33 +01:00

partition_test.go

Add queue integration

2025-12-31 15:18:57 +01:00

partition_worker_test.go

Fix queue tests

2026-01-07 21:02:11 +01:00

partition_worker.go

Add supprot for replicated queues

2026-01-04 16:32:28 +01:00

partition.go

Optimize queues

2026-01-02 16:36:38 +01:00

pool.go

Remove unused code

2026-01-04 01:53:02 +01:00

queue_test.go

Add queue integration

2025-12-31 15:18:57 +01:00

queue.go

Fix tests

2025-12-31 18:43:46 +01:00

raft_manager.go

Add supprot for replicated queues

2026-01-04 16:32:28 +01:00

replication_test.go

Add replication tests

2026-01-08 21:03:33 +01:00

retention_test.go

Add retention policy

2026-01-03 13:45:50 +01:00

retry_test.go

Rename queue message

2026-01-03 00:35:04 +01:00

retry.go

Rename queue message

2026-01-03 00:35:04 +01:00