Fix flush interval by Darthmineboy · Pull Request #338 · rabbitmq/rabbitmq-stream-go-client

test that consumer offset is committed after flush interval

Darthmineboy

committed

fix auto commit flush interval not triggered with constant stream of incoming messages

Darthmineboy

committed

use time.Since()

Darthmineboy

committed

update ginkgo as test summary is not showing

Darthmineboy

committed

add test reason with number of messages received

Darthmineboy

committed

try up to 50 messages

Darthmineboy

committed

fix data race

Darthmineboy

committed

tidy

Darthmineboy

committed

Merge branch 'main' into fix-flush-interval

Gsantomaggio

authored

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Fix flush interval#338

Fix flush interval#338
Gsantomaggio merged 13 commits intorabbitmq:mainfrom
Darthmineboy:fix-flush-interval

Commits on Jul 22, 2024

test that consumer offset is committed after flush interval

fix auto commit flush interval not triggered with constant stream of incoming messages

use time.Since()

update ginkgo as test summary is not showing

add test reason with number of messages received

try up to 50 messages

fix data race

tidy

Merge branch 'main' into fix-flush-interval

Commits on Jul 23, 2024

move resetting messageCountBeforeStorage to cacheStoreOffset()

Merge remote-tracking branch 'origin/fix-flush-interval' into fix-flush-interval

fix potential data race with messageCountBeforeStorage when closing consumer

have increaseMessageCountBeforeStorage() return current messageCountBeforeStorage so that we don't need getMessageCountBeforeStorage() and request the mutex twice

Fix flush interval#338Gsantomaggio merged 13 commits intorabbitmq:mainrabbitmq/rabbitmq-stream-go-client:mainfrom Darthmineboy:fix-flush-intervalDarthmineboy/rabbitmq-stream-go-client:fix-flush-intervalCopy head branch name to clipboard

Commits

Commits on Jul 22, 2024

Commits on Jul 23, 2024

Fix flush interval#338
Gsantomaggio merged 13 commits intorabbitmq:mainfrom
Darthmineboy:fix-flush-interval