summaryrefslogtreecommitdiff
path: root/deps/rabbitmq_stream
Commit message (Collapse)AuthorAgeFilesLines
* Add chunk header parameter to send_file callbackArnaud Cogoluègnes2020-12-091-1/+1
|
* Fix failure tests in stream pluginArnaud Cogoluègnes2020-12-081-3/+3
|
* Wait longer for replicas to come up in stream pluginArnaud Cogoluègnes2020-12-043-2/+2
|
* Remove stream field from publish commandArnaud Cogoluègnes2020-11-274-43/+35
| | | | | Only the publisher ID is necessary now the publisher declaration is mandatory before publishing.
* Include publisher state managementrabbitmq-stream-writer-dedupeArnaud Cogoluègnes2020-11-261-36/+80
|
* Enforce publisher ID uniquenessArnaud Cogoluègnes2020-11-261-36/+52
|
* Add query publisher sequenceArnaud Cogoluègnes2020-11-263-3/+55
|
* Declare publisher in stream testArnaud Cogoluègnes2020-11-241-6/+20
|
* Start adding publishing dedup support for streamsArnaud Cogoluègnes2020-11-244-17/+118
|
* Include publish dedup in stream protocolArnaud Cogoluègnes2020-11-203-5/+50
|
* Check if member processes are alive in metadata commandArnaud Cogoluègnes2020-11-172-73/+93
| | | | In case the Mnesia record is stale.
* Move some code to utils moduleArnaud Cogoluègnes2020-11-052-97/+119
|
* Call rabbit_log:warning/2Arnaud Cogoluègnes2020-11-031-1/+1
|
* Update rabbitmq-components.mkArnaud Cogoluègnes2020-11-031-20/+42
|
* Return Erlang node long name in metadataArnaud Cogoluègnes2020-11-031-2/+11
| | | | Fixes #2
* Use non_amqp_connection name for force_refresh_eventArnaud Cogoluègnes2020-10-231-8/+8
|
* Support shutdown call from management pluginArnaud Cogoluègnes2020-10-231-0/+9
|
* Register connections and handle force_event_refreshArnaud Cogoluègnes2020-10-231-6/+16
| | | | | | | For existing connections that must emit stats when the management plugin is enabled. References rabbitmq/rabbitmq-server#2481
* Merge branch 'master' into management-integrationArnaud Cogoluègnes2020-10-222-0/+175
|\ | | | | | | | | Conflicts: src/rabbit_stream_manager.erl
| * Support max-age in stream creationArnaud Cogoluègnes2020-10-221-0/+5
| |
| * Support leader locator strategiesArnaud Cogoluègnes2020-10-212-0/+184
| | | | | | | | References rabbitmq/rabbitmq-server#2471
* | Check stats timer in listen loopArnaud Cogoluègnes2020-10-221-1/+2
| |
* | Add event notification during authenticationArnaud Cogoluègnes2020-10-201-28/+77
| |
* | Emit stats for managementArnaud Cogoluègnes2020-10-203-27/+141
|/ | | | WIP
* Support initial-cluster-size argument on creationArnaud Cogoluègnes2020-10-163-19/+106
| | | | See rabbitmq/rabbitmq-server#2467
* Check stream name before creationArnaud Cogoluègnes2020-10-163-15/+59
| | | | | Should not start with "amq.", be empty. Strips also newline and carriage return characters.
* Add CLI command to list stream connectionsArnaud Cogoluègnes2020-10-166-9/+346
|
* Add rabbitmq_ct_client_helpers dependencyArnaud Cogoluègnes2020-10-121-1/+1
|
* Add ct_client_helpers dependencyArnaud Cogoluègnes2020-10-121-1/+1
|
* Add INI-type configuration supportArnaud Cogoluègnes2020-10-123-0/+284
|
* Set default heartbeat to 60 secondsArnaud Cogoluègnes2020-10-122-4/+3
|
* Add correlation ID field in commit offset frameArnaud Cogoluègnes2020-10-022-1/+3
| | | | | Not used yet, but can avoid a command version change if the command should have confirm response.
* Bump dependencies in Java test suiteArnaud Cogoluègnes2020-09-295-655/+785
| | | | And apply Google Java Format with Maven Spotless plugin.
* Adapt failure testsArnaud Cogoluègnes2020-09-295-15/+33
| | | | | | | | They are a bit more defensive. The subscription is also now more reliable by returning a stream-not-available code if necessary. Using also Aten poll interval to 1 second (bumped to 5 seconds in master now).
* Use rabbit_durable_queue to check if stream existsArnaud Cogoluègnes2020-09-172-0/+10
| | | | | | | This is done after checking rabbit_queue and if it returns that the queue does not exist. The coordinator may be recovering the queue, so thanks to this double check we know the queue exists but is not available, instead of thinking it does not exist at all.
* Add offset tracking commandsArnaud Cogoluègnes2020-09-153-0/+87
|
* Adapt test to additional chunk type field in chunkArnaud Cogoluègnes2020-09-031-1/+2
|
* Add publisher IDArnaud Cogoluègnes2020-09-025-29/+49
|
* Use byte for sub ID in credit notificationArnaud Cogoluègnes2020-09-011-1/+1
|
* Change sub ID to byte in protocol referenceArnaud Cogoluègnes2020-09-011-5/+5
|
* Use byte for subscription IDArnaud Cogoluègnes2020-09-014-12/+12
| | | | | Instead of integer. This is to be consistent with the introduction of a similar ID for publishers (which will be a byte as well).
* Add debug log during deletionArnaud Cogoluègnes2020-08-071-0/+6
|
* Refactor Java tests after Client package changeArnaud Cogoluègnes2020-08-063-10/+14
|
* Add function to kill connection based on nameArnaud Cogoluègnes2020-08-053-3/+22
| | | | For test purposes.
* Fix frame reading in testArnaud Cogoluègnes2020-07-231-1/+2
|
* Send heartbeat from the reader processArnaud Cogoluègnes2020-07-101-15/+16
| | | | | | | | | If the heartbeat frame is sent from a dedicated process, it interleaves between 2 socket calls from the reader process. Frames are typically sent in one call, so this is fine, but a chunk is delivered with 2 calls, one for the frame header and one send_file for the chunk. So the heartbeat frame can sneak in between these 2 calls, which makes clients fail to parse frames.
* Handle error case when creating a streamArnaud Cogoluègnes2020-07-102-2/+5
|
* Pass in monitor reference, not stream nameArnaud Cogoluègnes2020-07-092-1/+14
|
* Add consumer failure testArnaud Cogoluègnes2020-07-065-8/+191
| | | | | The node the consumer is connected to fails, the consumer connects and starts consuming where it left off.
* Add publishing failure testArnaud Cogoluègnes2020-07-034-38/+231
| | | | | | Stream leader node fails while publisher is publishing, publisher reconnects on the new leader. A consumer should read all the confirmed messages afterwards.
View Lorry Controller Status