dusan 8d2e0d14d4 Fix error handling in auto queue create ...

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

2026-02-08 20:43:57 +01:00

..

adapter_test.go

Fix error handling in auto queue create

2026-02-08 20:43:57 +01:00

adapter.go

Fix error handling in auto queue create

2026-02-08 20:43:57 +01:00

batch_test.go

Relocate log storage

2026-01-25 12:13:33 +01:00

batch.go

Relocate log storage

2026-01-25 12:13:33 +01:00

consumer_group_test.go

Add consumer_group_test

2026-02-03 16:46:29 +01:00

consumer_group.go

Rename consumer group state to consumer group

2026-02-08 14:48:23 +01:00

consumer_manager_test.go

Ditch partitions

2026-01-27 18:23:46 +01:00

consumer_manager.go

Fix gofmt formatting

2026-02-06 15:23:26 +01:00

consumer_state_test.go

Fix logstorage tests

2026-02-03 15:29:44 +01:00

consumer_state.go

Fix gofmt formatting

2026-02-06 15:23:26 +01:00

cursor_test.go

Fix logstorage tests

2026-02-03 15:29:44 +01:00

cursor.go

Remove partitions

2026-01-27 01:50:20 +01:00

encoding_test.go

Relocate log storage

2026-01-25 12:13:33 +01:00

encoding.go

Relocate log storage

2026-01-25 12:13:33 +01:00

index_test.go

Relocate log storage

2026-01-25 12:13:33 +01:00

index.go

Relocate log storage

2026-01-25 12:13:33 +01:00

manager_test.go

Add consumer_group_test

2026-02-03 16:46:29 +01:00

manager.go

Add support for cursor for AMQP consumers

2026-02-04 12:50:10 +01:00

options_test.go

Relocate log storage

2026-01-25 12:13:33 +01:00

options.go

Remove unused code

2026-02-08 14:46:16 +01:00

pel_test.go

Fix some tests

2026-01-27 15:42:07 +01:00

pel.go

Remove partitions

2026-01-27 01:50:20 +01:00

queue_config_test.go

Fix some tests

2026-01-27 15:42:07 +01:00

queue_config.go

Use queue & topics notion

2026-01-27 09:55:38 +01:00

recovery.go

Remove unused code

2026-02-08 14:46:16 +01:00

segment_test.go

Relocate log storage

2026-01-25 12:13:33 +01:00

segment.go

Remove unused code

2026-02-08 14:46:16 +01:00

store_test.go

Add consumer_group_test

2026-02-03 16:46:29 +01:00

store.go

Add support for cursor for AMQP consumers

2026-02-04 12:50:10 +01:00

timeindex_test.go

Relocate log storage

2026-01-25 12:13:33 +01:00

timeindex.go

Relocate log storage

2026-01-25 12:13:33 +01:00

types_test.go

Fix some tests

2026-01-27 15:42:07 +01:00

types.go

Fix logstorage tests

2026-02-03 15:29:44 +01:00