Commit Graph

1120 Commits

Author SHA1 Message Date
Mark Paluch
e987f33248 DATAREDIS-1199 - Polishing.
Improve test synchronization.
2020-08-12 09:14:17 +02:00
Mark Paluch
e68a383045 DATAREDIS-1195 - Polishing.
Simplify Expiration.from(…) construction.

Original pull request: #553.
2020-07-31 09:08:33 +02:00
Andre Prata
c4a320cc3c DATAREDIS-1195 - Make putIfAbsent atomic when TTL is set.
Original pull request: #553.
2020-07-31 09:08:31 +02:00
Mark Paluch
406e030d92 DATAREDIS-1191 - Guard calls to RedisConverter.read(…) to avoid empty objects.
We now check if the RedisBucket is empty to avoid empty objects being materialized from EntityReader.
2020-07-28 14:42:59 +02:00
Mark Paluch
cd64b5fade DATAREDIS-1189 - Consistently translate Lettuce connection exceptions.
We now translate consistently connection/pooling exceptions in LettuceConnectionFactory by wrapping LettuceConnectionProvider with a variant that considers exception translation.
2020-07-28 14:19:00 +02:00
Mark Paluch
dd77c1b8ec DATAREDIS-1168 - Prepare 2.3.2 (Neumann SR2). 2020-07-22 10:20:45 +02:00
Mark Paluch
fb9cd78e3c DATAREDIS-1168 - Updated changelog. 2020-07-22 10:20:40 +02:00
Mark Paluch
35dc91fdf1 DATAREDIS-1167 - Updated changelog. 2020-07-22 10:08:50 +02:00
Mark Paluch
019fbbf76e DATAREDIS-1166 - Updated changelog. 2020-07-22 09:44:35 +02:00
Mark Paluch
164bdc97fb DATAREDIS-1173 - Polishing.
Add Override annotations and Javadoc. Reformat test.

Original Pull Request: #549
2020-07-21 14:57:57 +02:00
Mark Paluch
27c3d0962d DATAREDIS-1173 - Correctly unsubscribe from patterns/channels through LettuceSubscription.
doPUnsubscribe(…) and doUnsubscribe(…) now consider the all flag to unsubscribe from all subscribed patterns/channels. Previously, both methods didn't consider all and were invoked with an empty byte array which unsubscribed from an empty pattern/channel name and left subscriptions active.

Original Pull Request: #549
2020-07-21 14:57:46 +02:00
Sarah
aa20c4ede3 DATAREDIS-1173 - Fix channel unsubscribe on close.
Original Pull Request: #540
2020-07-21 14:57:35 +02:00
Mark Paluch
fbccc05d5b DATAREDIS-1172 - Polishing.
Suppress rawtypes/unchecked warnings. Use static imports for mockito.

Original pull request: #542.
2020-07-15 11:58:17 +02:00
Eddie McDaniel
6152dfa3c7 DATAREDIS-1172 - Fix parameter type of hash value serializer in StreamReceiver.
Original pull request: #542.
2020-07-15 11:58:04 +02:00
Mark Paluch
f401be7e7a DATAREDIS-1179 - Polishing.
Reorder methods. Make MappingRedisConverter(RedisMappingContext) public. Tweak docs wording.

Original pull request: #548.
2020-07-15 11:16:42 +02:00
Christoph Strobl
6c633947c1 DATAREDIS-1179 - Polishing.
Transition Tests to Junit Jupiter.
Fix C/P error in callout within reference documentation.

Original pull request: #548.
2020-07-15 10:51:28 +02:00
Christoph Strobl
2847e5e37b DATAREDIS-1179 - Allow reuse of RedisConverter in ObjectHashMapper.
Original pull request: #548.
2020-07-15 10:51:28 +02:00
Mark Paluch
6387bfd029 DATAREDIS-1175 - Polishing.
Reformat code. Add missing nullability annotations and enforce non-null values to prevent potential null dereference.

Original pull request: #546.
2020-07-15 09:34:27 +02:00
Christoph Strobl
e1f9c4552c DATAREDIS-1175 - Allow direct mapping of Collection like structures like java.util.List via MappingRedisConverter.
It is now possible to hand a plain list to the converter that is then converted into a hash structure using index numbers as keys.

Original pull request: #546.
2020-07-15 09:34:15 +02:00
Christoph Strobl
6a29e0802e DATAREDIS-1178 - Pass ScanOptions on to connection.sScan when using ReactiveSetOperations. 2020-07-07 08:23:08 +02:00
Mark Paluch
da89c83932 DATAREDIS-1147 - Updated changelog. 2020-06-25 12:00:23 +02:00
Christoph Strobl
cf3846c2bd DATAREDIS-1150 - Polishing
Defer cluster topology resolution, update Javadoc and add tests.

Original Pull Request: #533
2020-06-17 10:11:04 +02:00
Mark Paluch
4760feb33b DATAREDIS-1150 - Polishing.
Reorder implementation methods according to interface order.

original Pull Request: #533
2020-06-17 10:10:53 +02:00
Mark Paluch
e7d6909024 DATAREDIS-1150 - Add ReactiveRedisClusterCommands.
We now provide Redis Cluster commands (CLUSTER INFO, CLUSTER NODES, …) exposed through a reactive API.

Original Pull Request: #533
2020-06-17 10:10:41 +02:00
Mark Paluch
dc796ed34f DATAREDIS-1146 - Prepare 2.3.1 (Neumann SR1). 2020-06-10 14:01:59 +02:00
Mark Paluch
5ec2a4a9d0 DATAREDIS-1146 - Updated changelog. 2020-06-10 14:01:54 +02:00
Mark Paluch
524118a0ac DATAREDIS-1134 - Updated changelog. 2020-06-10 12:29:56 +02:00
Mark Paluch
61f9511cd3 DATAREDIS-1133 - Updated changelog. 2020-06-10 11:36:59 +02:00
Tamer Soliman
5851cfcbe0 DATAREDIS-1159 - Unify return type of RedisStaticMasterReplicaConfiguration.node(…) methods.
RedisStaticMasterReplicaConfiguration.node(…) now returns the more specific RedisStaticMasterReplicaConfiguration type instead of returning the StaticMasterReplicaConfiguration interface.

Original pull request: #536.
2020-06-10 09:23:50 +02:00
Mark Paluch
c2aa7b8d02 DATAREDIS-1161 - Avoid returning null in ReactiveHashCommands.hGet(…).
We now use flatMapIterable(…).next() to return the first value from the hash. Previously, if the returned list was empty, we could return a null value in the mapping function which might have caused an exception.

Original Pull Request: #538
2020-06-10 08:40:33 +02:00
Mark Paluch
13f822fd6d DATAREDIS-1135 - Prepare 2.3 GA (Neumann). 2020-05-12 12:27:59 +02:00
Mark Paluch
c1c1ca0361 DATAREDIS-1135 - Updated changelog. 2020-05-12 12:27:56 +02:00
andrea.como
2d04af6a99 DATAREDIS-1142 - Use Lettuce reactive cluster connection if configured.
Original Pull Request: #529
2020-05-12 11:07:08 +02:00
Mark Paluch
22332e16ef DATAREDIS-1135 - Update reference documentation. 2020-05-07 16:00:44 +02:00
Mark Paluch
8c59586fc8 DATAREDIS-1042 - Polishing.
Set MKSTREAM by default when calling createGroup on the operations API as that should be the default behavior in the first place. Reformat code. Add since tags.

Original pull request: #527.
2020-05-07 16:00:44 +02:00
Tugdual Grall
d7b8d9b018 DATAREDIS-1042 - Allow consumer group creation without an existing stream.
Original pull request: #527.
2020-05-07 15:47:20 +02:00
Mark Paluch
c4623ef059 DATAREDIS-1139 - Fix command constants.
Deprecate constants with typos. Fix mode of ZREMRANGEBYSCORE.

Original Pull Request: #528
2020-05-06 15:23:51 +02:00
Mark Paluch
3b9de23297 DATAREDIS-1138 - Polishing.
Add missing Nullable annotations.

Original Pull Request: #528
2020-05-06 15:22:53 +02:00
Mark Paluch
f4676edbd2 DATAREDIS-1138 - Fix detection whether XREAD is blocking.
We now correctly check if a BLOCK option is configured using a timeout of zero or higher. Previously we only checked if the configured value is greater than zero and didn't consider that a timeout of zero blocks indefinitely.

Original Pull Request: #528
2020-05-06 15:22:09 +02:00
Mark Paluch
2fef09efed DATAREDIS-1124 - Prepare 2.3 RC2 (Neumann). 2020-04-28 15:03:33 +02:00
Mark Paluch
224298ee2a DATAREDIS-1124 - Updated changelog. 2020-04-28 15:03:31 +02:00
Mark Paluch
7eec3a6136 DATAREDIS-1120 - Updated changelog. 2020-04-28 14:46:49 +02:00
Mark Paluch
cfeb294fb7 DATAREDIS-1107 - Updated changelog. 2020-04-28 11:59:00 +02:00
Mark Paluch
0e0519ce25 DATAREDIS-1128 - Improve test stability.
Replace condition-based polling/waiting with Awaitility. Improve assertions for timing-based checks. Increase number of HyperLogLog samples to reduce probability of clashing elements.

Remove long-waiting sleeps that did not lead to an assertion.

Original Pull Request: #525
2020-04-27 09:53:23 +02:00
Christoph Strobl
73da68a6f4 DATAREDIS-1127 - Polishing.
Add issue reference.

Original Pull Request: #524
2020-04-22 09:44:38 +02:00
Ajith Kumar
964c55959a DATAREDIS-1127 - Handling ping failures for getSentinelConnection method.
Original Pull Request: #524
2020-04-22 09:44:32 +02:00
Mark Paluch
254d60e820 DATAREDIS-1119 - Polishing.
Add getAndMap(…) method to simplify post-retrieval mapping of non-null values. Require key on XInfoCommand command construction.

Tweak javadoc. Reformat code.

Original pull request: #519.
2020-04-20 11:54:11 +02:00
Christoph Strobl
3f5533ea9a DATAREDIS-1119 - Support XINFO via ReactiveStreamCommands.
Original pull request: #519.
2020-04-20 11:54:09 +02:00
Christoph Strobl
c010472c42 DATAREDIS-1119 - Support XINFO via RedisStreamCommands.
Original pull request: #519.
2020-04-20 11:54:03 +02:00
Mark Paluch
0d2e4474f8 DATAREDIS-1122 - Consistently use as(StepVerivier::create) in tests.
Original pull request: #523.
2020-04-20 11:13:18 +02:00