RedisClusterClient

Source file "io/lettuce/core/cluster/RedisClusterClient.java" was not found during generation of report.

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,618 of 1,6180%100 of 1000%1481483333339898
connectClusterPubSubAsync(RedisCodec)1460%80%55272711
connectClusterAsync(RedisCodec)1440%80%55262611
assertSameOptions(Iterable)930%140%88181811
connectPubSubToNodeAsync(RedisCodec, String, Mono)800%40%33151511
connectToNodeAsync(RedisCodec, String, RedisChannelWriter, Mono)670%40%33131311
createConnectionBuilder(RedisChannelHandler, ConnectionState, DefaultEndpoint, RedisURI, Mono, Supplier)600%20%22161611
refreshPartitionsAsync()490%40%33111111
lambda$fetchPartitions$30(Iterable, Map)490%60%44111111
getTopologyRefreshSource()460%100%669911
RedisClusterClient(ClientResources, Iterable)380%n/a11101011
lambda$refreshPartitionsAsync$21(Partitions)360%20%228811
loadPartitionsAsync()300%20%227711
lambda$loadPartitionsAsync$28(CompletableFuture, Iterable, Partitions, Throwable)300%60%447711
lambda$loadPartitionsAsync$29(Predicate, Partitions)290%40%337711
RedisClusterClient()240%n/a116611
get(CompletableFuture, Function)220%20%227711
getViewedBy(Map, Partitions)220%40%335511
forEachCloseable(Predicate, Consumer)200%40%335511
connectStatefulAsync(StatefulRedisClusterConnectionImpl, DefaultEndpoint, RedisURI, Mono, Supplier)190%n/a113311
connectStatefulAsync(StatefulRedisConnectionImpl, DefaultEndpoint, RedisURI, Mono, Supplier)190%n/a113311
lambda$null$27(Throwable, CompletableFuture, Partitions, Throwable)190%20%227711
fetchPartitions(Iterable)170%n/a113311
getSocketAddressSupplier(Supplier, Function)160%n/a114411
lambda$getSocketAddressSupplier$32(RoundRobinSocketAddressSupplier)150%20%223311
lambda$null$31()150%n/a113311
lambda$connectClusterPubSubAsync$15(StatefulRedisClusterPubSubConnectionImpl, ClusterDistributionChannelWriter, ClusterPubSubConnectionProvider, StatefulRedisClusterPubSubConnectionImpl)150%n/a111111
lambda$connectClusterAsync$8(StatefulRedisClusterConnectionImpl, ClusterDistributionChannelWriter, PooledClusterConnectionProvider, StatefulRedisClusterConnectionImpl)150%n/a111111
connect(Mono, DefaultEndpoint, StatefulRedisClusterConnectionImpl, Supplier)140%n/a112211
connect(Mono, DefaultEndpoint, StatefulRedisConnectionImpl, Supplier)140%n/a112211
create(ClientResources, Iterable)120%n/a114411
determinePartitions(Partitions, Map)120%20%223311
create(ClientResources, String)110%n/a113311
getPartitions()110%20%223311
getFirstUri()110%n/a113311
lambda$transformAsyncConnectionException$35(Iterable, Object, Throwable)110%20%223311
create(Iterable)100%n/a113311
create(ClientResources, RedisURI)100%n/a113311
connectToNode(SocketAddress)100%n/a111111
connectToNode(RedisCodec, String, RedisChannelWriter, Mono)100%n/a111111
lambda$connectClusterPubSubAsync$12(RedisCodec, PubSubClusterEndpoint)100%n/a112211
lambda$connectPubSubToNodeAsync$3(RedisCodec, PubSubEndpoint)100%n/a111111
connect(RedisCodec)90%n/a112211
connectPubSub(RedisCodec)90%n/a112211
updatePartitionsInConnections()90%n/a113311
assertInitialPartitions()90%20%223311
shutdownAsync(long, long, TimeUnit)90%n/a112211
createTopologyRefresh()90%n/a111111
transformAsyncConnectionException(CompletionStage, Iterable)90%n/a112211
assertNotEmpty(Iterable)90%n/a113311
lambda$connectClusterAsync$5(DefaultEndpoint)90%n/a111111
lambda$connectToNodeAsync$1(ClusterNodeEndpoint)90%n/a111111
create(String)80%n/a112211
newStatefulRedisConnection(RedisChannelWriter, PushHandler, RedisCodec, Duration)80%n/a111111
newStatefulRedisClusterConnection(RedisChannelWriter, ClusterPushHandler, RedisCodec, Duration)80%n/a111111
create(RedisURI)70%n/a112211
connectAsync(RedisCodec)70%n/a111111
connectPubSubAsync(RedisCodec)70%n/a111111
refreshPartitions()70%n/a112211
useDynamicRefreshSources()70%n/a112211
lambda$connectClusterPubSubAsync$14(Mono, PubSubClusterEndpoint, StatefulRedisClusterPubSubConnectionImpl, Supplier, Throwable)70%n/a111111
lambda$connectClusterPubSubAsync$13(Mono, PubSubClusterEndpoint, StatefulRedisClusterPubSubConnectionImpl, Supplier)70%n/a111111
lambda$connectClusterAsync$7(Mono, DefaultEndpoint, StatefulRedisClusterConnectionImpl, Supplier, Throwable)70%n/a111111
lambda$connectClusterAsync$6(Mono, DefaultEndpoint, StatefulRedisClusterConnectionImpl, Supplier)70%n/a111111
getConnectionAttempts()60%n/a111111
initializePartitions()60%n/a111111
loadPartitions()60%n/a111111
lambda$assertInitialPartitions$26(RedisException)60%n/a111111
lambda$refreshPartitions$19(RedisException)60%n/a111111
lambda$connectPubSubToNodeAsync$4(StatefulRedisPubSubConnectionImpl, StatefulRedisPubSubConnection, Throwable)60%20%223311
lambda$connectToNodeAsync$2(StatefulRedisConnectionImpl, StatefulRedisConnection, Throwable)60%20%223311
lambda$getPartitions$0(RedisException)60%n/a111111
connect()50%n/a111111
connectPubSub()50%n/a111111
forEachClusterConnection(Consumer)50%n/a112211
forEachClusterPubSubConnection(Consumer)50%n/a112211
assertNotNull(RedisURI)50%n/a112211
lambda$initializePartitions$25(Partitions)50%n/a111111
lambda$updatePartitionsInConnections$24(StatefulRedisClusterPubSubConnectionImpl)50%n/a112211
lambda$updatePartitionsInConnections$23(StatefulRedisClusterConnectionImpl)50%n/a112211
lambda$connect$11(Throwable)50%n/a111111
lambda$connect$10(Throwable)50%n/a111111
setOptions(ClusterClientOptions)40%n/a112211
setPartitions(Partitions)40%n/a112211
getClusterClientOptions()40%n/a111111
assertNotNull(RedisCodec)40%n/a112211
assertNotNull(ClientResources)40%n/a112211
static {...}40%n/a111111
reloadPartitions()30%n/a112211
getInitialUris()30%n/a111111
lambda$forEachClusterPubSubConnection$34(Closeable)30%n/a111111
lambda$forEachClusterConnection$33(Closeable)30%n/a111111
lambda$refreshPartitionsAsync$22(EventRecorder.RecordableEvent, Void, Throwable)30%n/a111111
lambda$refreshPartitionsAsync$20(EventRecorder.RecordableEvent, Void, Throwable)30%n/a111111
newStringStringCodec()20%n/a111111
lambda$connectStatefulAsync$18(StatefulRedisConnectionImpl, RedisChannelHandler)20%n/a111111
lambda$connectStatefulAsync$17(StatefulRedisClusterConnectionImpl, RedisChannelHandler)20%n/a111111
lambda$connectClusterPubSubAsync$16(StatefulRedisClusterPubSubConnectionImpl)20%n/a111111
lambda$connectClusterAsync$9(StatefulRedisClusterConnectionImpl)20%n/a111111