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
7b151a7651
More missed (c) header updates
2024-01-22 23:44:47 -05:00
Arnaud Cogoluègnes
739928153e
Add --binding-keys to add_super_stream command
...
It is meant to replace --routing-keys, which
is still available but not documented anymore.
This is to be consistent with AMQP 0.9.1 terminology.
2023-11-15 14:00:07 +01:00
Arnaud Cogoluègnes
388608143d
Add super stream add/delete protocol commands
2023-11-13 10:30:25 +01:00
Arnaud Cogoluègnes
c04d324b9f
Fix list_stream_consumer_groups validation
...
It had been broken in a refactoring to squash
dialyzer warnings.
2023-10-10 16:44:05 +02:00
Arnaud Cogoluègnes
b541be658e
Use tracking_value for column header
2023-10-10 09:14:24 +02:00
Arnaud Cogoluègnes
048a4998ed
Add list_stream_tracking
2023-10-10 09:14:23 +02:00
Arnaud Cogoluègnes
944b34e4e0
Add pid and node columns to list_stream_connections
...
Fixes #9555
2023-09-30 14:59:25 -04:00
Arnaud Cogoluègnes
db65caa91f
Add node column to list_stream_publishers/consumers
...
Fixes #9582
2023-09-30 14:59:25 -04:00
Arnaud Cogoluègnes
7bc26154b5
Add stream filtering feature flag
2023-07-10 15:21:53 +02:00
Michal Kuratczyk
d04b3afe9b
verify_none in a couple of tests
2023-04-24 13:11:44 +00:00
Michael Klishin
ec4f1dba7d
(c) year bump: 2022 => 2023
2023-01-01 23:17:36 -05:00
Arnaud Cogoluègnes
5ad9e349e0
Add list_stream_group_consumers CLI command
...
References #3753
2022-05-09 10:52:31 +02:00
Arnaud Cogoluègnes
434d7b5c54
Add colums argument to list_stream_consumer_groups
...
References #3753
2022-05-09 10:52:30 +02:00
Arnaud Cogoluègnes
1ec49a7aa3
Add list_stream_consumer_groups CLI command
...
References #3753
2022-05-09 10:52:29 +02:00
Michael Klishin
c38a3d697d
Bump (c) year
2022-03-21 01:21:56 +04:00
Arnaud Cogoluègnes
6b9589bae4
Handle stream arguments in add_super_stream command
...
max-age, leader-locator, etc.
2021-10-11 16:50:03 +02:00
Arnaud Cogoluègnes
ecbd969834
Embed RPC call function in test
2021-10-11 16:50:02 +02:00
Arnaud Cogoluègnes
8ae60bef73
Fix group spec in test
2021-10-11 16:50:02 +02:00
Arnaud Cogoluègnes
b0bd5f8a00
Add delete_super_stream CLI command
2021-10-11 16:50:02 +02:00
Arnaud Cogoluègnes
a73b1a3d0d
Add add_super_stream CLI command
2021-10-11 16:50:01 +02:00
Arnaud Cogoluègnes
8f207e3c5f
Make stream protocol route command return several streams
...
We expect to have 1 stream for each routing key, but
as binding can return several queues for a given key we
let that possibility open in the stream protocol.
2021-09-13 17:53:25 +02:00
Karl Nilsson
3513fa0ea8
rabbitmq_stream formatting
2021-09-09 09:45:13 +01:00
Philip Kuryloski
a3c97d491f
Update additional test skipping for 3.8/3.9 mixed versions
2021-06-25 11:17:46 +02:00
Philip Kuryloski
bb75157fc1
Mark deps/rabbitmq_stream:commands_SUITE as flaky
2021-06-24 12:56:20 +02:00
dcorbacho
38f474688f
Stream common library
2021-06-11 17:24:00 +02:00
Arnaud Cogoluègnes
761af0a7a0
Extract publishing IDs from batch publishing
...
In stream plugin, to e.g. send publish errors in case the stream
does not exist. Batches were not taken into account.
2021-05-31 15:35:10 +02:00
Philip Kuryloski
f251815002
Replace rabbitmq_stream test helper with common version
...
from rabbitmq_ct_helpers
and update default app env for bazel, to match Makefile
2021-05-27 12:26:51 +02:00
Arnaud Cogoluègnes
2ab5cb22ca
Expose TLS info for stream connections (CLI, REST API)
2021-05-27 10:43:33 +02:00
Arnaud Cogoluègnes
69ad6969e6
Add stream.advertised_tls_port setting
2021-05-26 11:08:43 +02:00
Karl Nilsson
4a9d8115f8
rebase fixes
...
post rebase test fixes
Make socket initialisation more lenient
correct return types
fix
remove commented code
2021-05-24 15:53:10 +01:00
Karl Nilsson
79502ef663
fix tests
2021-05-17 10:39:55 +01:00
Arnaud Cogoluègnes
2f903843e0
Add list_stream_publishers CLI command
2021-01-19 14:49:30 +01:00
Arnaud Cogoluègnes
1e6244990c
Add list_stream_consumers CLI command
2021-01-19 11:31:39 +01:00