Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Bump (c) year | Michael Klishin | 2021-01-22 | 1 | -1/+1 |
| | |||||
* | Stream: Channel resend on leader change | kjnilsson | 2021-01-13 | 1 | -0/+104 |
| | | | | | | | | Detect when a new stream leader is elected and make stream_queues re-send any unconfirmed, pending messages to ensure they did not get lost during the leader change. This is done using the osiris deduplication feature to ensure the resend does not create duplicates of messages in the stream. | ||||
* | Apply retention policy in all osiris members | dcorbacho | 2021-01-12 | 1 | -8/+32 |
| | |||||
* | Update retention when only stream retention policy has changed | dcorbacho | 2021-01-12 | 1 | -0/+10 |
| | | | | In any other case, the worker needs to be restarted | ||||
* | Convert AMQP 091 timestamp to millisecond | Arnaud Cogoluègnes | 2020-11-27 | 1 | -2/+2 |
| | | | | For start offset in stream queue. | ||||
* | Merge remote-tracking branch 'origin/master' into stream-timestamp-offsetstream-timestamp-offset | dcorbacho | 2020-11-18 | 1 | -0/+83 |
| | |||||
* | Change repo "root" to deps/rabbit | Philip Kuryloski | 2020-11-13 | 1 | -0/+1527 |
rabbit must not be the monorepo root application, as other applications depend on it |