Releases: Netflix/dyno-queues
Releases · Netflix/dyno-queues
Move warning messages from DEBUG to WARN
Move debug messages from DEBUG to WARN Some log messages should be showed as warnings and not as DEBUG messages.
Fix zrank() return type capture
Use object form of Long for zrank() return type The Jedis docs for each command are just a copy paste of Redis docs which doesn't translate well to Java. https://github.com/xetorthio/jedis/issues/978 From some stack overflow googling, we see the right way to use zrank(), and this patch changes the code to comply with that.
Clearer debug message for popMsgWithId()
v2.0.11-rc3 Make debug message clearer in popWithMsgId()
Clearer debug message for popMsgWithId()
Add unsafePopWithMsgIdAllShards() API Similar to popWithMsgId(), but attempts to pop from any shard. Hence, prefixed with unsafe. Testing: Added a test to the DynoQueueDemo.
New APIs; New ShardSupplier; Bug fixes
- Add a new ShardSupplier to address issues with DynoShardSupplier
- Allow containsPredicate()/getMsgWithPredicate() to filter on local shard
- Add unsafePopWithMsgIdAllShards() API
- unsafePopAllShards() should use the prefetched IDs from the unsafe Map (to pop from local shard first)
Expose unsafe functions and fix process unacks
Add unsafePeekAllShards() and unsafePopAllShards() functions This patch exposes 2 new APIs that allow the calling application to peek into and pop from all shards of the queue. The APIs are prepended with unsafe* because if multiple client app instances call these APIs concurrently, it's possible that duplicate items may be returned to the application across client instances. Hence, these APIs must not be used unless the calling application's use case is okay with handling duplicate items. The DynoQueueDemo is updated to use these new APIs. Additionally, a lot of the code is refactored in V1.
Misc fixes
- processUnacks() should use nonQuorumConn to look over a range in the zset
- Make peekIds() use nonQuorumConn.
- Add logging for processUnacks()
New queue APIs and bug fixes
- New API: popWithMsgId().
- containsPredicate() and getMsgWithPredicate() use Lua pattern matching now.
- Fixed remove() from returning incorrect return value in some cases.
- More tests added to V1 demo
Update dyno dependency to dyno-1.7.1
Update APIs to compile with dyno-1.7.1 - All Host() objects are changed to be created with a HostBuilder. - Slight Demo API change
Improved logging for processUnacks() and make peekIds() non quorum based
v2.0.0-rc9 Pin to dyno-1.6.5-rc.4