PooledClusterConnectionProvider

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

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,092 of 1,0920%104 of 1040%1031032412415151
getReadConnection(int)1260%80%55262611
lambda$getReadConnection$4(int, CompletableFuture[], StatefulRedisConnection[])720%100%66151511
getWriteConnection(int)690%40%33151511
PooledClusterConnectionProvider(RedisClusterClient, RedisChannelWriter, RedisCodec, ClusterEventListener)600%n/a11151511
beforeGetConnection(ClusterConnectionProvider.Intent, String, int)460%60%449911
getReadFromConnections(List)440%40%338811
lambda$getReadConnection$1(CompletableFuture[], Void)420%80%55101011
getConnections(CompletableFuture[])390%20%228811
getConnectionAsync(ClusterConnectionProvider.Intent, int)380%80%555511
findRandomActiveConnection(CompletableFuture[], Function)380%80%558811
getConnectionAsync(ClusterConnectionProvider.Intent, String)280%20%223311
getConnection(ClusterConnectionProvider.Intent, String)270%20%223311
setPartitions(Partitions)270%40%33101011
getConnectionAsync(ClusterConnectionProvider.Intent, String, int)260%n/a116611
isStale(ClusterNodeConnectionFactory.ConnectionKey)260%80%555511
lambda$getReadConnection$3(CompletableFuture, CompletableFuture[], CompletableFuture[], Throwable)260%40%339911
isReadCandidate(RedisClusterNode, RedisClusterNode)230%60%445511
getConnection(ClusterConnectionProvider.Intent, String, int)230%n/a116611
getConnectionAsync(ClusterNodeConnectionFactory.ConnectionKey)210%n/a114411
lambda$getWriteConnection$0(int, StatefulRedisConnection)210%20%225511
closeStaleConnections()180%n/a114411
setAutoFlushCommands(boolean)170%n/a115511
resetFastConnectionCache()170%n/a115511
lambda$getConnectionAsync$6(CompletableFuture, ConnectionFuture, StatefulRedisConnection, Throwable)170%20%225511
setReadFrom(ReadFrom)160%n/a115511
getConnection(ClusterNodeConnectionFactory.ConnectionKey)150%n/a114411
connectionAttemptRejected(String)140%n/a111111
validateClusterNodeMembership()130%40%332211
isOrderSensitive(Object[])120%40%331111
getConnection(ClusterConnectionProvider.Intent, int)110%n/a113311
expireStaleConnections()110%40%331111
getReadCandidates(RedisClusterNode)100%n/a113311
getConnectionFactory(RedisClusterClient)90%n/a111111
lambda$closeStaleConnections$7(ClusterNodeConnectionFactory.ConnectionKey, StatefulRedisConnection)90%20%223311
reconfigurePartitions()80%20%224411
onPushMessage(RedisClusterNode, PushMessage)70%n/a112211
addListener(RedisClusterPushListener)60%n/a112211
removeListener(RedisClusterPushListener)60%n/a112211
closeAsync()60%n/a112211
close()50%n/a112211
reset()50%n/a112211
flushCommands()50%n/a112211
getConnectionCount()50%n/a111111
lambda$onPushMessage$9(RedisClusterNode, PushMessage, RedisClusterPushListener)50%n/a111111
lambda$setAutoFlushCommands$8(boolean, StatefulRedisConnection)40%n/a111111
lambda$getReadCandidates$5(RedisClusterNode, RedisClusterNode)40%n/a111111
static {...}40%n/a111111
getPushListeners()30%n/a111111
getPartitions()30%n/a111111
getReadFrom()30%n/a111111
lambda$getReadConnection$2(CompletableFuture[], Void)20%n/a111111