Skip to content

Releases: Netflix/dyno-queues

atomicProcessUnacks() and getAllMessages()

17 Jan 22:59
Compare
Choose a tag to compare
v2.0.17

Add atomicProcessUnacks() and getAllMessages()

Fix null return from popMsgWithPredicateObeyPriority

16 Nov 00:01
Compare
Choose a tag to compare
v2.0.16-rc2

Fix null return from popMsgWithPredicateObeyPriority

Make popWithMsgPredicate() obey queue priority

15 Nov 20:05
Compare
Choose a tag to compare
Previously popWithMsgPredicate() would pop the first item it found
in the hashmap that matches the given predicate. With this patch, it
will obey the queueing priority.

Fix casting for bulk pop

15 Nov 02:26
Compare
Choose a tag to compare
v2.0.15-rc2

atomicBulkPopHelper() should cast to Message before returning

Add unsafeBulkPop() and localGet()

14 Nov 17:02
Compare
Choose a tag to compare
unsafeBulkPop() allows bulk popping from all shards.

loaclGet() does a get() with a non quorum connection.

TODO: unsafeBulkPop() will return nil if messageCount > size().
Fix this.
TODO 2: Do code cleanup.

Add atomic bulkPop() API

11 Nov 15:43
Compare
Choose a tag to compare
Add a atomic bulkPop() API

Using queues with DC_EACH_SAFE_QUORUM is quite expensive. The bulk
pop operation is meant to pop more within  a single round trip.

Add popMsgWithPredicate() API

29 Oct 20:44
Compare
Choose a tag to compare
  • Also less log spam for unsafePop*() functions.

Update dyno dependency to dyno-1.7.2-rc2

22 Oct 17:30
Compare
Choose a tag to compare
v2.0.12-rc2

Pin to dyno-1.7.2-rc2

Update dyno dependency to dyno-1.7.2

21 Oct 21:49
Compare
Choose a tag to compare
  • Dyno now has the ability to have nonQuorumConn use DC_ONE with Dynomite, rather than talking directly to Redis.

popWithMsgId() and unsafePopWithMsgId() should report metrics

11 Oct 19:07
Compare
Choose a tag to compare
v2.0.11-rc6

popWithMsgId() and unsafePopWithMsgId() should report metrics