summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Quorum queue: API to reclaim quorum memorydcorbacho2020-09-162-2/+46
| | | | | Operator can choose to force a garbage collection and flush of the WAL on a specific quorum queue
* Merge pull request #2407 from rabbitmq/qq-reject-publishKarl Nilsson2020-09-1519-499/+4672
|\ | | | | reject-publish strategy support for quorum queues
| * Add system time to unit testqq-reject-publishdcorbacho2020-09-141-1/+2
| |
| * Add a couple of more fields to overviewkjnilsson2020-09-071-1/+4
| |
| * rabbit_fifo: lower min snapshot intervalkjnilsson2020-09-072-19/+17
| | | | | | | | | | As the current default is way to large for queues that never empty but only keep a small backlog.
| * Quorum queue 'Queue TTL' support.kjnilsson2020-09-076-152/+318
| | | | | | | | | | | | The quorum queue will track the timestamp of whenever a consumer was removed and periodically check if the queue should be deleted based on it's expiry configuration.
| * Add some unused fields to rabbit_fifo recordskjnilsson2020-09-071-6/+11
| | | | | | | | | | To allow for future extensions without necessitating a machine version upgrade
| * Don't assert on message countkjnilsson2020-09-071-1/+1
| | | | | | | | | | As depending on which is the current leader this may or may not be returned.
| * rabbit_fifo test changekjnilsson2020-09-071-1/+3
| |
| * rabbit_fifo: convert enqueuerskjnilsson2020-09-071-1/+8
| | | | | | | | To v0 version which has an additional field.
| * fix typokjnilsson2020-09-071-1/+1
| |
| * Better handle version checkkjnilsson2020-09-071-1/+1
| | | | | | | | when the rabbit_fifo:version/0 function is missing.
| * Skip more testskjnilsson2020-09-073-9/+51
| |
| * quorum_queue_SUITE skip 2 node tests for mixed versionskjnilsson2020-09-071-32/+38
| |
| * Skip test that cannot work with mixed machine versionskjnilsson2020-09-071-2/+7
| | | | | | | | Growing shrinking does not necessarily work in mixed versions.
| * Switch to 3 node clusters instead of 2kjnilsson2020-09-073-3/+3
| | | | | | | | As this works better with mixed Ra machine versions
| * Skip test in mixed modekjnilsson2020-09-071-40/+44
| | | | | | | | that cannot pass due to Ra machine versioning restrictions.
| * Test fixeskjnilsson2020-09-073-15/+26
| |
| * Make some test suite 3 node instead of 2kjnilsson2020-09-075-37/+43
| | | | | | | | | | | | | | QQs cannot be declared in two node clusters with different machine versions. This setup should be an anomaly so changing some suites to better represent sensible conigurations. This should also allow some mixed-versions tests to pass.
| * test fixeskjnilsson2020-09-073-3/+22
| |
| * Remove debug log statementkjnilsson2020-09-071-6/+2
| |
| * Implement reject_publish for QQskjnilsson2020-09-077-143/+461
| | | | | | | | | | | | | | | | | | | | | | | | | | | | The reject publish overflow strategy for quorum queues is an inexact implementation that relies on the cooperation of publishing channels. When a channel first wants to publish to a quorum queue it first issues a synchonous register_enqueuer command which will return the current queue overflow state as reject_publish if the queue is full. The queue will also notify any active enqueuers when it reaches the limit but will continue to accept any enqueues it receives after that. Once the queue size goes below 80% of the limit(s) the queue will again notify enqueuers that they can resume publishin inte the queue.
| * Leave release cursors as they arekjnilsson2020-09-071-6/+1
| |
| * rabbit_fifo: convert statekjnilsson2020-09-073-26/+69
| |
| * rabbit_fifo: Fixes for move to lqueuekjnilsson2020-09-074-270/+280
| | | | | | | | | | Also rename v0 state back to rabbit_fifo else it could never work with old state!
| * rabbit_fifo: change messages map to queuekjnilsson2020-09-074-86/+96
| | | | | | | | This results in a lower memory use per message.
| * rabbit_fifo machine version 1kjnilsson2020-09-074-1/+3527
| | | | | | | | | | First commit in a series that will evolve the rabbit_fifo state machine into version 1.
* | More debug logging for runtime parameter updatesMichael Klishin2020-09-141-0/+3
| | | | | | | | for VESC-984
* | Merge pull request #2443 from rabbitmq/mk-new-ra-wal-settings-in-conf-schemaMichael Klishin2020-09-101-0/+28
|\ \ | |/ |/| Support recently introduced Ra WAL settings in rabbitmq.conf
| * Support recently introduced Ra WAL settings in rabbitmq.confMichael Klishin2020-09-101-0/+28
|/
* Adjustments for test flakesPhilip Kuryloski2020-09-031-2/+3
|
* GitHub Actions: Run recently added testsuitesJean-Sébastien Pédron2020-09-032-0/+576
|
* Run dead lettering test cases sequentiallyJean-Sébastien Pédron2020-09-021-3/+4
| | | | | | Concourse has recently had a high rate of false positives at clustering stage. The suite still finishes in a very reasonable amount of time.
* per_vhost_connection_limit_SUITE: Use ↵Jean-Sébastien Pédron2020-09-021-5/+5
| | | | | | | | | | | | | | rabbit_connection_tracking:clear_tracked_connection_tables_for_this_node/0 ... instead of rabbit_connection_tracking:clear_all_connection_tracking_tables/0. They latter calls the former and the former exists in all release branches. This fixes the undef exception when running the testsuite with mixed-versions clusters. While here use rabbit_ct_broker_helpers:rpc_all() instead of having a loop to call rabbit_ct_broker_helpers:rpc().
* Merge branch 'lrb-add-multicall-timeout-to-force-event-refresh'Michael Klishin2020-09-023-6/+10
|\ | | | | | | | | | | | | Conflicts: src/rabbit_channel.erl src/rabbit_direct.erl src/rabbit_networking.erl
| * Revert "tcp_listener_sup: use maps for supervisor flags and child spec"Luke Bakken2020-09-022-17/+6
| | | | | | | | This reverts commit e86fa81a3f90599d03b2f9beaaa56cfb6a4226f1.
| * 'make dialyze' passes past the per-user limit changesMichael Klishin2020-09-026-25/+55
| |
| * README: link to Kubernetes Cluster OperatorMichael Klishin2020-09-021-0/+1
| |
| * Remove a stray README linkMichael Klishin2020-09-021-2/+0
| |
| * README badge for the Erlang 23.0 workflowMichael Klishin2020-09-021-0/+3
| |
| * Correct typos detected by xrefMichael Klishin2020-09-022-3/+3
| |
| * Rework a flaky testMichael Klishin2020-09-021-18/+3
| |
| * More per_user_connection_channel_limit suite massagingMichael Klishin2020-09-021-87/+177
| | | | | | | | to reduce sporadic failures.
| * Cleanly close connections in this testMichael Klishin2020-09-021-4/+3
| | | | | | | | | | Killing a local connection process makes the test flaky. For the purpose of this suite, a clean close is good enough.
| * Try to address more of per_user_connection_channel_limit suite test flakesMichael Klishin2020-09-021-14/+12
| |
| * Use rabbit_ct_helpers:await_condition/1 for assertionsMichael Klishin2020-09-021-193/+473
| | | | | | | | | | they are time-sensitive since we observe connection tracking effects from the outside.
| * Refer to running nodes using rabbit_nodes:all_running/0Michael Klishin2020-09-0212-37/+34
| | | | | | | | to simplify the move to Mnevis in the future.
| * Minor improvements to log message formattingMichael Klishin2020-09-022-3/+3
| |
| * A typoMichael Klishin2020-09-021-1/+1
| |
| * set_user_limits/3: return an error if feature flag is disabledMichael Klishin2020-09-021-7/+14
| |