Tags: adjust/rmq
Tags
113 Add support for Redis clusters (#148) * fix using another wrapper to fit redis cluster and redis single node; fix using {} to replace [] - untested * update test files with new openConn; add queue_cluster_test.go welle: Remove hardcoded connection options. * Bring back the original OpenConnection() for compatibility Add new function OpenConnectionWithOptions() for the new approach. * Allow cluster tests to run against local cluster * Remove RedisClusterWrapper again Rename RedisSingleWrapper back to RedisWrapper * Bring back original OpenConnectionWithRedisClient() * Add OpenClusterConnection() To allow opening RMQ connections which use the Redis hash tags {} instead of []. This is required to make rmq work with Redis clusters. This commit also reverts the behavior of all other OpenConnection[...] functions to behave as before by still using [] instead of {}. This switch is done by using different Redis key templates. For example instead of rmq::connection::{connection}::queue::[{queue}]::consumers we would use rmq::connection::{connection}::queue::{{queue}}::consumers when using OpenClusterConnection() * Document OpenClusterConnection() in README * Use safe accessors in tests * Update deps * Create Redis cluster in CI (#150) --------- Co-authored-by: zhanglei <[email protected]> Co-authored-by: Viacheslav Poturaev <[email protected]>
PreviousNext