Source file "io/lettuce/core/cluster/RedisClusterClient.java" was not found during generation of report.
| Element | Missed Instructions | Cov. | Missed Branches | Cov. | Missed | Cxty | Missed | Lines | Missed | Methods |
| Total | 1,618 of 1,618 | 0% | 100 of 100 | 0% | 148 | 148 | 333 | 333 | 98 | 98 |
| connectClusterPubSubAsync(RedisCodec) | 0% | 0% | 5 | 5 | 27 | 27 | 1 | 1 | ||
| connectClusterAsync(RedisCodec) | 0% | 0% | 5 | 5 | 26 | 26 | 1 | 1 | ||
| assertSameOptions(Iterable) | 0% | 0% | 8 | 8 | 18 | 18 | 1 | 1 | ||
| connectPubSubToNodeAsync(RedisCodec, String, Mono) | 0% | 0% | 3 | 3 | 15 | 15 | 1 | 1 | ||
| connectToNodeAsync(RedisCodec, String, RedisChannelWriter, Mono) | 0% | 0% | 3 | 3 | 13 | 13 | 1 | 1 | ||
| createConnectionBuilder(RedisChannelHandler, ConnectionState, DefaultEndpoint, RedisURI, Mono, Supplier) | 0% | 0% | 2 | 2 | 16 | 16 | 1 | 1 | ||
| refreshPartitionsAsync() | 0% | 0% | 3 | 3 | 11 | 11 | 1 | 1 | ||
| lambda$fetchPartitions$30(Iterable, Map) | 0% | 0% | 4 | 4 | 11 | 11 | 1 | 1 | ||
| getTopologyRefreshSource() | 0% | 0% | 6 | 6 | 9 | 9 | 1 | 1 | ||
| RedisClusterClient(ClientResources, Iterable) | 0% | n/a | 1 | 1 | 10 | 10 | 1 | 1 | ||
| lambda$refreshPartitionsAsync$21(Partitions) | 0% | 0% | 2 | 2 | 8 | 8 | 1 | 1 | ||
| loadPartitionsAsync() | 0% | 0% | 2 | 2 | 7 | 7 | 1 | 1 | ||
| lambda$loadPartitionsAsync$28(CompletableFuture, Iterable, Partitions, Throwable) | 0% | 0% | 4 | 4 | 7 | 7 | 1 | 1 | ||
| lambda$loadPartitionsAsync$29(Predicate, Partitions) | 0% | 0% | 3 | 3 | 7 | 7 | 1 | 1 | ||
| RedisClusterClient() | 0% | n/a | 1 | 1 | 6 | 6 | 1 | 1 | ||
| get(CompletableFuture, Function) | 0% | 0% | 2 | 2 | 7 | 7 | 1 | 1 | ||
| getViewedBy(Map, Partitions) | 0% | 0% | 3 | 3 | 5 | 5 | 1 | 1 | ||
| forEachCloseable(Predicate, Consumer) | 0% | 0% | 3 | 3 | 5 | 5 | 1 | 1 | ||
| connectStatefulAsync(StatefulRedisClusterConnectionImpl, DefaultEndpoint, RedisURI, Mono, Supplier) | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | ||
| connectStatefulAsync(StatefulRedisConnectionImpl, DefaultEndpoint, RedisURI, Mono, Supplier) | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | ||
| lambda$null$27(Throwable, CompletableFuture, Partitions, Throwable) | 0% | 0% | 2 | 2 | 7 | 7 | 1 | 1 | ||
| fetchPartitions(Iterable) | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | ||
| getSocketAddressSupplier(Supplier, Function) | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | ||
| lambda$getSocketAddressSupplier$32(RoundRobinSocketAddressSupplier) | 0% | 0% | 2 | 2 | 3 | 3 | 1 | 1 | ||
| lambda$null$31() | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | ||
| lambda$connectClusterPubSubAsync$15(StatefulRedisClusterPubSubConnectionImpl, ClusterDistributionChannelWriter, ClusterPubSubConnectionProvider, StatefulRedisClusterPubSubConnectionImpl) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$connectClusterAsync$8(StatefulRedisClusterConnectionImpl, ClusterDistributionChannelWriter, PooledClusterConnectionProvider, StatefulRedisClusterConnectionImpl) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| connect(Mono, DefaultEndpoint, StatefulRedisClusterConnectionImpl, Supplier) | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | ||
| connect(Mono, DefaultEndpoint, StatefulRedisConnectionImpl, Supplier) | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | ||
| create(ClientResources, Iterable) | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | ||
| determinePartitions(Partitions, Map) | 0% | 0% | 2 | 2 | 3 | 3 | 1 | 1 | ||
| create(ClientResources, String) | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | ||
| getPartitions() | 0% | 0% | 2 | 2 | 3 | 3 | 1 | 1 | ||
| getFirstUri() | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | ||
| lambda$transformAsyncConnectionException$35(Iterable, Object, Throwable) | 0% | 0% | 2 | 2 | 3 | 3 | 1 | 1 | ||
| create(Iterable) | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | ||
| create(ClientResources, RedisURI) | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | ||
| connectToNode(SocketAddress) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| connectToNode(RedisCodec, String, RedisChannelWriter, Mono) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$connectClusterPubSubAsync$12(RedisCodec, PubSubClusterEndpoint) | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | ||
| lambda$connectPubSubToNodeAsync$3(RedisCodec, PubSubEndpoint) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| connect(RedisCodec) | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | ||
| connectPubSub(RedisCodec) | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | ||
| updatePartitionsInConnections() | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | ||
| assertInitialPartitions() | 0% | 0% | 2 | 2 | 3 | 3 | 1 | 1 | ||
| shutdownAsync(long, long, TimeUnit) | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | ||
| createTopologyRefresh() | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| transformAsyncConnectionException(CompletionStage, Iterable) | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | ||
| assertNotEmpty(Iterable) | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | ||
| lambda$connectClusterAsync$5(DefaultEndpoint) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$connectToNodeAsync$1(ClusterNodeEndpoint) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| create(String) | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | ||
| newStatefulRedisConnection(RedisChannelWriter, PushHandler, RedisCodec, Duration) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| newStatefulRedisClusterConnection(RedisChannelWriter, ClusterPushHandler, RedisCodec, Duration) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| create(RedisURI) | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | ||
| connectAsync(RedisCodec) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| connectPubSubAsync(RedisCodec) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| refreshPartitions() | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | ||
| useDynamicRefreshSources() | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | ||
| lambda$connectClusterPubSubAsync$14(Mono, PubSubClusterEndpoint, StatefulRedisClusterPubSubConnectionImpl, Supplier, Throwable) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$connectClusterPubSubAsync$13(Mono, PubSubClusterEndpoint, StatefulRedisClusterPubSubConnectionImpl, Supplier) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$connectClusterAsync$7(Mono, DefaultEndpoint, StatefulRedisClusterConnectionImpl, Supplier, Throwable) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$connectClusterAsync$6(Mono, DefaultEndpoint, StatefulRedisClusterConnectionImpl, Supplier) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| getConnectionAttempts() | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| initializePartitions() | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| loadPartitions() | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$assertInitialPartitions$26(RedisException) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$refreshPartitions$19(RedisException) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$connectPubSubToNodeAsync$4(StatefulRedisPubSubConnectionImpl, StatefulRedisPubSubConnection, Throwable) | 0% | 0% | 2 | 2 | 3 | 3 | 1 | 1 | ||
| lambda$connectToNodeAsync$2(StatefulRedisConnectionImpl, StatefulRedisConnection, Throwable) | 0% | 0% | 2 | 2 | 3 | 3 | 1 | 1 | ||
| lambda$getPartitions$0(RedisException) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| connect() | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| connectPubSub() | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| forEachClusterConnection(Consumer) | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | ||
| forEachClusterPubSubConnection(Consumer) | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | ||
| assertNotNull(RedisURI) | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | ||
| lambda$initializePartitions$25(Partitions) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$updatePartitionsInConnections$24(StatefulRedisClusterPubSubConnectionImpl) | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | ||
| lambda$updatePartitionsInConnections$23(StatefulRedisClusterConnectionImpl) | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | ||
| lambda$connect$11(Throwable) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$connect$10(Throwable) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| setOptions(ClusterClientOptions) | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | ||
| setPartitions(Partitions) | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | ||
| getClusterClientOptions() | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| assertNotNull(RedisCodec) | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | ||
| assertNotNull(ClientResources) | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | ||
| static {...} | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| reloadPartitions() | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | ||
| getInitialUris() | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$forEachClusterPubSubConnection$34(Closeable) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$forEachClusterConnection$33(Closeable) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$refreshPartitionsAsync$22(EventRecorder.RecordableEvent, Void, Throwable) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$refreshPartitionsAsync$20(EventRecorder.RecordableEvent, Void, Throwable) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| newStringStringCodec() | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$connectStatefulAsync$18(StatefulRedisConnectionImpl, RedisChannelHandler) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$connectStatefulAsync$17(StatefulRedisClusterConnectionImpl, RedisChannelHandler) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$connectClusterPubSubAsync$16(StatefulRedisClusterPubSubConnectionImpl) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$connectClusterAsync$9(StatefulRedisClusterConnectionImpl) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 |