Michal Kuratczyk
|
b6b766cac7
|
[skip ci] Replace logger: calls is LOG_ macros
|
2025-07-18 08:43:02 +02:00 |
Michael Klishin
|
968eefa1bb
|
Bump (c) line year
There are no functional changes to this massive diff.
|
2025-01-01 17:54:10 -05:00 |
Michael Klishin
|
a9ced75476
|
rabbitmq_stream: add a few missing license headers
|
2024-01-27 20:46:16 -05:00 |
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
|
c352eed64a
|
Fix specification
|
2023-11-13 10:30:25 +01:00 |
|
Arnaud Cogoluègnes
|
388608143d
|
Add super stream add/delete protocol commands
|
2023-11-13 10:30:25 +01:00 |
Marcial Rosales
|
b715a4d07c
|
Update secret via sasl_authentication frame
|
2023-08-25 11:32:24 +01:00 |
|
Arnaud Cogoluègnes
|
9f06fb7db9
|
Add support for stream filtering
WIP.
|
2023-07-10 15:21:52 +02:00 |
Alexey Lebedeff
|
2c4e4fb691
|
Fix all dialyzer warnings in rabbitmq_stream
There are some elixir-related messages about undefined functions, but
they don't produce warnings (yet).
|
2023-01-16 17:11:24 +01: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
|
f223845d43
|
Keep stream_* return codes
To keep compatibility with the Erlang client's users.
References #5412
|
2022-08-03 16:46:22 +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
|
95f3fdef19
|
Use "committed offset" instead of "last committed offset"
References #5307
|
2022-07-26 11:37:46 +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
|
17d0ba9317
|
Return "no offset" (19) code when stored offset is undefined
Fixes #3783
|
2021-12-01 17:59:14 +01:00 |
|
Arnaud Cogoluègnes
|
8ddff0faf8
|
Use "store" instead of "commit" for offset tracking
|
2021-07-08 11:28:33 +02:00 |
dcorbacho
|
7e5163690d
|
Remove dependency from rabbit_common
|
2021-06-14 15:47:03 +02:00 |
|
dcorbacho
|
38f474688f
|
Stream common library
|
2021-06-11 17:24:00 +02:00 |