Arnaud Cogoluègnes
|
9beda5702e
|
Use "binding key" lingo for super stream creation
Instead of "routing key".
|
2023-11-13 14:54:45 +01:00 |
|
Arnaud Cogoluègnes
|
388608143d
|
Add super stream add/delete protocol commands
|
2023-11-13 10:30:25 +01:00 |
|
Arnaud Cogoluègnes
|
9f06fb7db9
|
Add support for stream filtering
WIP.
|
2023-07-10 15:21:52 +02:00 |
|
Arnaud Cogoluègnes
|
0c1eeab92b
|
Fix keys for route and partitions responses
These 2 responses were not using the `rabbit_stream_core` utilities
so they were not using the "prefix" for responses.
Fixes #5956
|
2022-10-03 09:42:40 +02:00 |
|
Arnaud Cogoluègnes
|
93c33f2423
|
Rename StreamInfo to StreamStats
Other changes: returns a map of int64, use the new osiris:get_stats/1 API.
References #5412
|
2022-08-08 18:02:51 +02:00 |
|
Arnaud Cogoluègnes
|
8687e73c7e
|
Add StreamInfo command to stream protocol
It returns general information on a stream, the first
and committed offsets for now.
Fixes #5412
|
2022-08-03 14:38:45 +02:00 |
|
Arnaud Cogoluègnes
|
9795727b9f
|
Include last committed offset in "deliver" stream command
Fixes #5307
|
2022-07-25 16:15:04 +02:00 |
|
Arnaud Cogoluègnes
|
67aac95f3e
|
Add exchange command versions command to stream plugin
References #5308
|
2022-07-25 16:15:03 +02:00 |
|
Arnaud Cogoluègnes
|
d5ae62b1a9
|
Handle single active consumer registration
WIP. Uses a simple in-memory coordinator for now.
No failover yet.
References #3753
|
2022-05-09 10:52:20 +02:00 |
|
Arnaud Cogoluègnes
|
8ddff0faf8
|
Use "store" instead of "commit" for offset tracking
|
2021-07-08 11:28:33 +02:00 |
dcorbacho
|
38f474688f
|
Stream common library
|
2021-06-11 17:24:00 +02:00 |