Skip to content

Upgrading redis.clients:jedis 6 to 7

Breaking6.2.0 → 7.5.3Breaking4Deprecated2New24Changed25Fixed9Other27

BreakingUpgrade verdict

4 breaking changes.

  • Removal of deprecated sharding features - JedisSharding and related classes have been removed.
  • API cleanup - Deprecated constructors and methods have been removed to streamline the API.
  • Removed deprecated constructors, classes, and JedisSharding.
  • Automatic Failover and Failback API changes MultiCluster* classes and methods have been renamed and improved.
Top 5 of 6 that need code or config changes

redis.clients:jedis publishes official migration guides for versions 7, 7. They cover more than the release notes do.

Jedis 7.0.0 Migration Guide ↗Automatic Failover and Failback Migration Guide ↗
Breaking4
Removal of deprecated sharding features - JedisSharding and related classes have been removed.
JedisSharding
API cleanup - Deprecated constructors and methods have been removed to streamline the API.
Removed deprecated constructors, classes, and JedisSharding.
JedisSharding
Automatic Failover and Failback API changes MultiCluster* classes and methods have been renamed and improved.
MultiCluster*
Deprecated2
Backports CommandObjects deprecations to the 7.5.x line as part of the CommandObjects refactoring.
CommandObjects
Deprecates legacy SSL configuration in favor of SslOptions.
SslOptions

Generated by DepDelta from published JVM bytecode. Not mixed with prose notes.

  • removed: abstract class PipelineBase extends AbstractPipeline
  • removed: abstract class TransactionBase extends AbstractTransaction
  • removed: class JedisSharding extends UnifiedJedis
  • removed: class ShardedCommandArguments extends CommandArguments
  • removed: class ShardedCommandObjects extends CommandObjects
  • removed: class ShardedPipeline extends MultiNodePipelineBase
  • removed: ctor JedisSharding(List)
  • removed: ctor JedisSharding(List, JedisClientConfig)
  • removed: ctor JedisSharding(List, JedisClientConfig, GenericObjectPoolConfig)
  • removed: ctor JedisSharding(List, JedisClientConfig, GenericObjectPoolConfig, Hashing)
  • removed: ctor JedisSharding(List, JedisClientConfig, Hashing)
  • removed: ctor JedisSharding(ShardedConnectionProvider)
  • removed: ctor JedisSharding(ShardedConnectionProvider, Pattern)
  • removed: ctor MultiClusterClientConfig(MultiClusterClientConfig.ClusterConfig[])
  • removed: ctor MultiClusterClientConfig.Builder(List)
  • removed: ctor MultiClusterClientConfig.Builder(MultiClusterClientConfig.ClusterConfig[])
  • removed: ctor MultiClusterClientConfig.ClusterConfig(HostAndPort, JedisClientConfig)
  • removed: ctor MultiClusterClientConfig.ClusterConfig(HostAndPort, JedisClientConfig, GenericObjectPoolConfig)
  • removed: ctor PipelineBase(CommandObjects)
  • removed: ctor ShardedCommandArguments(Hashing, Pattern, ProtocolCommand)
  • removed: ctor ShardedCommandArguments(Hashing, ProtocolCommand)
  • removed: ctor ShardedCommandObjects(Hashing)
  • removed: ctor ShardedCommandObjects(Hashing, Pattern)
  • removed: ctor ShardedPipeline(List, JedisClientConfig)
  • removed: ctor ShardedPipeline(List, JedisClientConfig, GenericObjectPoolConfig, Hashing, Pattern)
  • removed: ctor ShardedPipeline(ShardedConnectionProvider)
  • removed: ctor ShardedPipeline(ShardedConnectionProvider, Pattern)
  • removed: ctor TransactionBase()
  • removed: ctor TransactionBase(CommandObjects)
  • removed: ctor UnifiedJedis(MultiClusterPooledConnectionProvider)
  • removed: ctor UnifiedJedis(Set, JedisClientConfig, GenericObjectPoolConfig, int, Duration)
  • removed: ctor UnifiedJedis(Set, JedisClientConfig, int)
  • removed: ctor UnifiedJedis(Set, JedisClientConfig, int, Duration)
  • removed: ctor UnifiedJedis(ShardedConnectionProvider)
  • removed: ctor UnifiedJedis(ShardedConnectionProvider, Pattern)
  • removed: final class MultiClusterClientConfig
  • removed: method ClientSetInfoConfig.getLibNameSuffix(): String
  • removed: method JedisSharding.pipelined(): ShardedPipeline
  • removed: method JedisSharding.transaction(boolean): AbstractTransaction
  • removed: method MultiClusterClientConfig.Builder.build(): MultiClusterClientConfig
  • removed: method MultiClusterClientConfig.Builder.circuitBreakerFailureRateThreshold(float): MultiClusterClientConfig.Builder
  • removed: method MultiClusterClientConfig.Builder.circuitBreakerFallbackExceptionList(List): MultiClusterClientConfig.Builder
  • removed: method MultiClusterClientConfig.Builder.circuitBreakerIgnoreExceptionList(List): MultiClusterClientConfig.Builder
  • removed: method MultiClusterClientConfig.Builder.circuitBreakerIncludedExceptionList(List): MultiClusterClientConfig.Builder
  • removed: method MultiClusterClientConfig.Builder.circuitBreakerSlidingWindowMinCalls(int): MultiClusterClientConfig.Builder
  • removed: method MultiClusterClientConfig.Builder.circuitBreakerSlidingWindowSize(int): MultiClusterClientConfig.Builder
  • removed: method MultiClusterClientConfig.Builder.circuitBreakerSlidingWindowType(CircuitBreakerConfig.SlidingWindowType): MultiClusterClientConfig.Builder
  • removed: method MultiClusterClientConfig.Builder.circuitBreakerSlowCallDurationThreshold(int): MultiClusterClientConfig.Builder
  • removed: method MultiClusterClientConfig.Builder.circuitBreakerSlowCallRateThreshold(float): MultiClusterClientConfig.Builder
  • removed: method MultiClusterClientConfig.Builder.fallbackExceptionList(List): MultiClusterClientConfig.Builder
  • removed: method MultiClusterClientConfig.Builder.retryIgnoreExceptionList(List): MultiClusterClientConfig.Builder
  • removed: method MultiClusterClientConfig.Builder.retryIncludedExceptionList(List): MultiClusterClientConfig.Builder
  • removed: method MultiClusterClientConfig.Builder.retryMaxAttempts(int): MultiClusterClientConfig.Builder
  • removed: method MultiClusterClientConfig.Builder.retryWaitDuration(int): MultiClusterClientConfig.Builder
  • removed: method MultiClusterClientConfig.Builder.retryWaitDurationExponentialBackoffMultiplier(int): MultiClusterClientConfig.Builder
  • removed: method MultiClusterClientConfig.ClusterConfig.getConnectionPoolConfig(): GenericObjectPoolConfig
  • removed: method MultiClusterClientConfig.ClusterConfig.getHostAndPort(): HostAndPort
  • removed: method MultiClusterClientConfig.ClusterConfig.getJedisClientConfig(): JedisClientConfig
  • removed: method MultiClusterClientConfig.ClusterConfig.getPriority(): int
  • removed: method MultiClusterClientConfig.getCircuitBreakerFailureRateThreshold(): float
  • removed: method MultiClusterClientConfig.getCircuitBreakerIgnoreExceptionList(): List
  • removed: method MultiClusterClientConfig.getCircuitBreakerIncludedExceptionList(): List
  • removed: method MultiClusterClientConfig.getCircuitBreakerSlidingWindowMinCalls(): int
  • removed: method MultiClusterClientConfig.getCircuitBreakerSlidingWindowSize(): int
  • removed: method MultiClusterClientConfig.getCircuitBreakerSlidingWindowType(): CircuitBreakerConfig.SlidingWindowType
  • removed: method MultiClusterClientConfig.getCircuitBreakerSlowCallDurationThreshold(): Duration
  • removed: method MultiClusterClientConfig.getCircuitBreakerSlowCallRateThreshold(): float
  • removed: method MultiClusterClientConfig.getClusterConfigs(): MultiClusterClientConfig.ClusterConfig[]
  • removed: method MultiClusterClientConfig.getFallbackExceptionList(): List
  • removed: method MultiClusterClientConfig.getRetryIgnoreExceptionList(): List
  • removed: method MultiClusterClientConfig.getRetryIncludedExceptionList(): List
  • removed: method MultiClusterClientConfig.getRetryMaxAttempts(): int
  • removed: method MultiClusterClientConfig.getRetryWaitDuration(): Duration
  • removed: method MultiClusterClientConfig.getRetryWaitDurationExponentialBackoffMultiplier(): int
  • removed: method ShardedCommandArguments.getKeyHash(): Long
  • removed: method ShardedCommandArguments.processKey(String): CommandArguments
  • removed: method ShardedCommandArguments.processKey(byte[]): CommandArguments
  • removed: method ShardedCommandObjects.commandArguments(ProtocolCommand): ShardedCommandArguments
  • removed: method ShardedCommandObjects.dbSize(): CommandObject
  • removed: method ShardedCommandObjects.keys(String): CommandObject
  • removed: method ShardedCommandObjects.keys(byte[]): CommandObject
  • removed: method ShardedCommandObjects.scan(String): CommandObject
  • removed: method ShardedCommandObjects.scan(String, ScanParams): CommandObject
  • removed: method ShardedCommandObjects.scan(String, ScanParams, String): CommandObject
  • removed: method ShardedCommandObjects.scan(byte[]): CommandObject
  • removed: method ShardedCommandObjects.scan(byte[], ScanParams): CommandObject
  • removed: method ShardedCommandObjects.scan(byte[], ScanParams, byte[]): CommandObject
  • removed: method ShardedCommandObjects.waitAOF(long, long, long): CommandObject
  • removed: method ShardedCommandObjects.waitReplicas(int, long): CommandObject
  • removed: method ShardedPipeline.close(): void
  • removed: method ShardedPipeline.getConnection(HostAndPort): Connection
  • removed: method ShardedPipeline.getNodeKey(CommandArguments): HostAndPort
  • removed: static class MultiClusterClientConfig.Builder
  • removed: static class MultiClusterClientConfig.ClusterConfig
  • removed: static field JedisSharding.DEFAULT_KEY_TAG_PATTERN: Pattern
  • changed: abstract class MultiNodePipelineBase extends PipelineBase → abstract class MultiNodePipelineBase extends AbstractPipeline
  • changed: class HostAndPort implements Serializable → class HostAndPort implements Serializable, Endpoint
  • changed: class Pipeline extends PipelineBase implements DatabasePipelineCommands, Closeable → class Pipeline extends AbstractPipeline implements DatabasePipelineCommands, Closeable
  • changed: class ReliableTransaction extends TransactionBase → class ReliableTransaction extends AbstractTransaction
  • changed: class Transaction extends TransactionBase → class Transaction extends AbstractTransaction
  • changed: method UnifiedJedis.pipelined(): PipelineBase → method UnifiedJedis.pipelined(): AbstractPipeline
  • added: class MultiDbClient extends UnifiedJedis
  • added: class RedisClient extends UnifiedJedis
  • added: class RedisClusterClient extends UnifiedJedis
  • added: class RedisSentinelClient extends UnifiedJedis
  • added: class StaticCommandFlagsRegistry implements CommandFlagsRegistry
  • added: ctor ClientSetInfoConfig(DriverInfo)
  • added: ctor ClusterCommandObjects(RedisProtocol)
  • added: ctor CommandObjects(RedisProtocol)
  • added: ctor Connection(Connection.Builder)
  • added: ctor Connection.Builder()
  • added: ctor ConnectionFactory(ConnectionFactory.Builder)
  • added: ctor ConnectionFactory.Builder()
  • added: ctor JedisCluster.Builder()
  • added: ctor JedisPooled.Builder()
  • added: ctor JedisSentineled.Builder()
  • added: ctor MultiDbClient.Builder()
  • added: ctor MultiDbConfig(MultiDbConfig.DatabaseConfig[])
  • added: ctor MultiDbConfig.Builder()
  • added: ctor MultiDbConfig.Builder(List)
  • added: ctor MultiDbConfig.Builder(MultiDbConfig.DatabaseConfig[])
  • added: ctor MultiDbConfig.CircuitBreakerConfig.Builder()
  • added: ctor MultiDbConfig.DatabaseConfig(Endpoint, JedisClientConfig)
  • added: ctor MultiDbConfig.DatabaseConfig.Builder(Endpoint, JedisClientConfig)
  • added: ctor MultiDbConfig.RetryConfig.Builder()
  • added: ctor RedisClient.Builder()
  • added: ctor RedisClusterClient.Builder()
  • added: ctor RedisSentinelClient.Builder()
  • added: ctor StaticCommandFlagsRegistry.Builder()
  • added: enum CommandFlagsRegistry.CommandFlag
  • added: final class DriverInfo
  • added: final class MultiDbConfig
  • added: interface CommandFlagsRegistry
  • added: interface Endpoint
  • added: interface MultiDbConfig.StrategySupplier
  • added: method ClientSetInfoConfig.getDriverInfo(): DriverInfo
  • added: method ClientSetInfoConfig.getUpstreamDrivers(): String
  • added: method ClusterCommandObjects.hotkeysGet(): CommandObject
  • added: method ClusterCommandObjects.hotkeysReset(): CommandObject
  • added: method ClusterCommandObjects.hotkeysStart(HotkeysParams): CommandObject
  • added: method ClusterCommandObjects.hotkeysStop(): CommandObject
  • added: method CommandArguments.get(int): Rawable
  • added: method CommandFlagsRegistry.getFlags(CommandArguments): EnumSet
  • added: method CommandObjects.delex(String, CompareCondition): CommandObject
  • added: method CommandObjects.delex(byte[], CompareCondition): CommandObject
  • added: method CommandObjects.digestKey(String): CommandObject
  • added: method CommandObjects.digestKey(byte[]): CommandObject
  • added: method CommandObjects.echo(String): CommandObject
  • added: method CommandObjects.ftHybrid(String, FTHybridParams): CommandObject
  • added: method CommandObjects.hotkeysGet(): CommandObject
  • added: method CommandObjects.hotkeysReset(): CommandObject
  • added: method CommandObjects.hotkeysStart(HotkeysParams): CommandObject
  • added: method CommandObjects.hotkeysStop(): CommandObject
  • added: method CommandObjects.msetex(MSetExParams, String[]): CommandObject
  • added: method CommandObjects.msetex(MSetExParams, byte[][]): CommandObject
  • added: method CommandObjects.setKeyArgumentPreProcessor(CommandKeyArgumentPreProcessor): void
  • added: method CommandObjects.xcfgset(String, XCfgSetParams): CommandObject
  • added: method CommandObjects.xcfgset(byte[], XCfgSetParams): CommandObject
  • added: method Connection.Builder.build(): Connection
  • added: method Connection.Builder.clientConfig(JedisClientConfig): Connection.Builder
  • added: method Connection.Builder.createConnection(): Connection
  • added: method Connection.Builder.getClientConfig(): JedisClientConfig
  • added: method Connection.Builder.getSocketFactory(): JedisSocketFactory
  • added: method Connection.Builder.socketFactory(JedisSocketFactory): Connection.Builder
  • added: method Connection.forceDisconnect(): void
  • added: method Connection.initializeFromClientConfig(): void
  • added: method ConnectionFactory.Builder.build(): ConnectionFactory
  • added: method ConnectionFactory.Builder.cache(Cache): ConnectionFactory.Builder
  • added: method ConnectionFactory.Builder.clientConfig(JedisClientConfig): ConnectionFactory.Builder
  • added: method ConnectionFactory.Builder.connectionBuilder(Connection.Builder): ConnectionFactory.Builder
  • added: method ConnectionFactory.Builder.getCache(): Cache
  • added: method ConnectionFactory.Builder.getClientConfig(): JedisClientConfig
  • added: method ConnectionFactory.Builder.getConnectionBuilder(): Connection.Builder
  • added: method ConnectionFactory.Builder.getJedisSocketFactory(): JedisSocketFactory
  • added: method ConnectionFactory.Builder.hostAndPort(HostAndPort): ConnectionFactory.Builder
  • added: method ConnectionFactory.Builder.socketFactory(JedisSocketFactory): ConnectionFactory.Builder
  • added: method ConnectionFactory.initialize(Connection): void
  • added: method ConnectionPool.attachAuthenticationListener(AuthXManager): void
  • added: method ConnectionPool.detachAuthenticationListener(): void
  • added: method DriverInfo.Builder.addUpstreamDriver(String): DriverInfo.Builder
  • added: method DriverInfo.Builder.addUpstreamDriver(String, String): DriverInfo.Builder
  • added: method DriverInfo.Builder.build(): DriverInfo
  • added: method DriverInfo.Builder.name(String): DriverInfo.Builder
  • added: method DriverInfo.getFormattedName(): String
  • added: method DriverInfo.getName(): String
  • added: method DriverInfo.getUpstreamDrivers(): String
  • added: method DriverInfo.toString(): String
  • added: method Endpoint.getHost(): String
  • added: method Endpoint.getPort(): int
  • added: method Jedis.delex(String, CompareCondition): long
  • added: method Jedis.delex(byte[], CompareCondition): long
  • added: method Jedis.digestKey(String): String
  • added: method Jedis.digestKey(byte[]): byte[]
  • added: method Jedis.hotkeysGet(): HotkeysInfo
  • added: method Jedis.hotkeysReset(): String
  • added: method Jedis.hotkeysStart(HotkeysParams): String
  • added: method Jedis.hotkeysStop(): String
  • added: method Jedis.msetex(MSetExParams, String[]): boolean
  • added: method Jedis.msetex(MSetExParams, byte[][]): boolean
  • added: method Jedis.xcfgset(String, XCfgSetParams): String
  • added: method Jedis.xcfgset(byte[], XCfgSetParams): byte[]
  • added: method JedisCluster.Builder.createClient(): JedisCluster
  • added: method JedisCluster.pipelined(ExecutorService): ClusterPipeline
  • added: method JedisPool.withResource(Consumer): void
  • added: method JedisPool.withResourceGet(Function): Object
  • added: method JedisPooled.Builder.createClient(): JedisPooled
  • added: method JedisSentineled.Builder.createClient(): JedisSentineled
  • added: method MultiDbClient.Builder.createClient(): MultiDbClient
  • added: method MultiDbClient.addDatabase(Endpoint, float, JedisClientConfig): void
  • added: method MultiDbClient.addDatabase(MultiDbConfig.DatabaseConfig): void
  • added: method MultiDbClient.forceActiveDatabase(Endpoint, long): void
  • added: method MultiDbClient.getActiveDatabaseEndpoint(): Endpoint
  • added: method MultiDbClient.getDatabaseEndpoints(): Set
  • added: method MultiDbClient.getWeight(Endpoint): float
  • added: method MultiDbClient.isHealthy(Endpoint): boolean
  • added: method MultiDbClient.multi(): MultiDbTransaction
  • added: method MultiDbClient.pipelined(): MultiDbPipeline
  • added: method MultiDbClient.removeDatabase(Endpoint): void
  • added: method MultiDbClient.setActiveDatabase(Endpoint): void
  • added: method MultiDbClient.setWeight(Endpoint, float): void
  • added: method MultiDbClient.transaction(boolean): MultiDbTransaction
  • added: method MultiDbConfig.Builder.build(): MultiDbConfig
  • added: method MultiDbConfig.Builder.commandRetry(MultiDbConfig.RetryConfig): MultiDbConfig.Builder
  • added: method MultiDbConfig.Builder.database(Endpoint, float, JedisClientConfig): MultiDbConfig.Builder
  • added: method MultiDbConfig.Builder.database(MultiDbConfig.DatabaseConfig): MultiDbConfig.Builder
  • added: method MultiDbConfig.Builder.delayInBetweenFailoverAttempts(int): MultiDbConfig.Builder
  • added: method MultiDbConfig.Builder.failbackCheckInterval(long): MultiDbConfig.Builder
  • added: method MultiDbConfig.Builder.failbackSupported(boolean): MultiDbConfig.Builder
  • added: method MultiDbConfig.Builder.failureDetector(MultiDbConfig.CircuitBreakerConfig): MultiDbConfig.Builder
  • added: method MultiDbConfig.Builder.fallbackExceptionList(List): MultiDbConfig.Builder
  • added: method MultiDbConfig.Builder.fastFailover(boolean): MultiDbConfig.Builder
  • added: method MultiDbConfig.Builder.gracePeriod(long): MultiDbConfig.Builder
  • added: method MultiDbConfig.Builder.initializationPolicy(InitializationPolicy): MultiDbConfig.Builder
  • added: method MultiDbConfig.Builder.maxNumFailoverAttempts(int): MultiDbConfig.Builder
  • added: method MultiDbConfig.Builder.retryOnFailover(boolean): MultiDbConfig.Builder
  • added: method MultiDbConfig.CircuitBreakerConfig.Builder.build(): MultiDbConfig.CircuitBreakerConfig
  • added: method MultiDbConfig.CircuitBreakerConfig.Builder.failureRateThreshold(float): MultiDbConfig.CircuitBreakerConfig.Builder
  • added: method MultiDbConfig.CircuitBreakerConfig.Builder.ignoreExceptionList(List): MultiDbConfig.CircuitBreakerConfig.Builder
  • added: method MultiDbConfig.CircuitBreakerConfig.Builder.includedExceptionList(List): MultiDbConfig.CircuitBreakerConfig.Builder
  • added: method MultiDbConfig.CircuitBreakerConfig.Builder.minNumOfFailures(int): MultiDbConfig.CircuitBreakerConfig.Builder
  • added: method MultiDbConfig.CircuitBreakerConfig.Builder.slidingWindowSize(int): MultiDbConfig.CircuitBreakerConfig.Builder
  • added: method MultiDbConfig.CircuitBreakerConfig.getFailureRateThreshold(): float
  • added: method MultiDbConfig.CircuitBreakerConfig.getIgnoreExceptionList(): List
  • added: method MultiDbConfig.CircuitBreakerConfig.getIncludedExceptionList(): List
  • added: method MultiDbConfig.CircuitBreakerConfig.getMinNumOfFailures(): int
  • added: method MultiDbConfig.CircuitBreakerConfig.getSlidingWindowSize(): int
  • added: method MultiDbConfig.DatabaseConfig.Builder.build(): MultiDbConfig.DatabaseConfig
  • added: method MultiDbConfig.DatabaseConfig.Builder.connectionPoolConfig(GenericObjectPoolConfig): MultiDbConfig.DatabaseConfig.Builder
  • added: method MultiDbConfig.DatabaseConfig.Builder.healthCheckEnabled(boolean): MultiDbConfig.DatabaseConfig.Builder
  • added: method MultiDbConfig.DatabaseConfig.Builder.healthCheckStrategy(HealthCheckStrategy): MultiDbConfig.DatabaseConfig.Builder
  • added: method MultiDbConfig.DatabaseConfig.Builder.healthCheckStrategySupplier(MultiDbConfig.StrategySupplier): MultiDbConfig.DatabaseConfig.Builder
  • added: method MultiDbConfig.DatabaseConfig.Builder.weight(float): MultiDbConfig.DatabaseConfig.Builder
  • added: method MultiDbConfig.DatabaseConfig.getConnectionPoolConfig(): GenericObjectPoolConfig
  • added: method MultiDbConfig.DatabaseConfig.getEndpoint(): Endpoint
  • added: method MultiDbConfig.DatabaseConfig.getHealthCheckStrategySupplier(): MultiDbConfig.StrategySupplier
  • added: method MultiDbConfig.DatabaseConfig.getJedisClientConfig(): JedisClientConfig
  • added: method MultiDbConfig.DatabaseConfig.getWeight(): float
  • added: method MultiDbConfig.DatabaseConfig.isHealthCheckEnabled(): boolean
  • added: method MultiDbConfig.RetryConfig.Builder.build(): MultiDbConfig.RetryConfig
  • added: method MultiDbConfig.RetryConfig.Builder.exponentialBackoffMultiplier(int): MultiDbConfig.RetryConfig.Builder
  • added: method MultiDbConfig.RetryConfig.Builder.ignoreExceptionList(List): MultiDbConfig.RetryConfig.Builder
  • added: method MultiDbConfig.RetryConfig.Builder.includedExceptionList(List): MultiDbConfig.RetryConfig.Builder
  • added: method MultiDbConfig.RetryConfig.Builder.maxAttempts(int): MultiDbConfig.RetryConfig.Builder
  • added: method MultiDbConfig.RetryConfig.Builder.waitDuration(int): MultiDbConfig.RetryConfig.Builder
  • added: method MultiDbConfig.RetryConfig.getExponentialBackoffMultiplier(): int
  • added: method MultiDbConfig.RetryConfig.getIgnoreExceptionList(): List
  • added: method MultiDbConfig.RetryConfig.getIncludedExceptionList(): List
  • added: method MultiDbConfig.RetryConfig.getMaxAttempts(): int
  • added: method MultiDbConfig.RetryConfig.getWaitDuration(): Duration
  • added: method MultiDbConfig.StrategySupplier.get(HostAndPort, JedisClientConfig): HealthCheckStrategy
  • added: method MultiDbConfig.getCommandRetry(): MultiDbConfig.RetryConfig
  • added: method MultiDbConfig.getDatabaseConfigs(): MultiDbConfig.DatabaseConfig[]
  • added: method MultiDbConfig.getDelayInBetweenFailoverAttempts(): int
  • added: method MultiDbConfig.getFailbackCheckInterval(): long
  • added: method MultiDbConfig.getFailureDetector(): MultiDbConfig.CircuitBreakerConfig
  • added: method MultiDbConfig.getFallbackExceptionList(): List
  • added: method MultiDbConfig.getGracePeriod(): long
  • added: method MultiDbConfig.getInitializationPolicy(): InitializationPolicy
  • added: method MultiDbConfig.getMaxNumFailoverAttempts(): int
  • added: method MultiDbConfig.isFailbackSupported(): boolean
  • added: method MultiDbConfig.isFastFailover(): boolean
  • added: method MultiDbConfig.isRetryOnFailover(): boolean
  • added: method PipeliningBase.delex(String, CompareCondition): Response
  • added: method PipeliningBase.delex(byte[], CompareCondition): Response
  • added: method PipeliningBase.digestKey(String): Response
  • added: method PipeliningBase.digestKey(byte[]): Response
  • added: method PipeliningBase.ftHybrid(String, FTHybridParams): Response
  • added: method PipeliningBase.hotkeysGet(): Response
  • added: method PipeliningBase.hotkeysReset(): Response
  • added: method PipeliningBase.hotkeysStart(HotkeysParams): Response
  • added: method PipeliningBase.hotkeysStop(): Response
  • added: method PipeliningBase.msetex(MSetExParams, String[]): Response
  • added: method PipeliningBase.msetex(MSetExParams, byte[][]): Response
  • added: method PipeliningBase.xcfgset(String, XCfgSetParams): Response
  • added: method PipeliningBase.xcfgset(byte[], XCfgSetParams): Response
  • added: method RedisClient.Builder.createClient(): RedisClient
  • added: method RedisClient.getPool(): Pool
  • added: method RedisClient.pipelined(): Pipeline
  • added: method RedisClusterClient.Builder.createClient(): RedisClusterClient
  • added: method RedisClusterClient.executeCommandToReplica(CommandObject): Object
  • added: method RedisClusterClient.getClusterNodes(): Map
  • added: method RedisClusterClient.getConnectionFromSlot(int): Connection
  • added: method RedisClusterClient.pipelined(): ClusterPipeline
  • added: method RedisClusterClient.pipelined(ExecutorService): ClusterPipeline
  • added: method RedisClusterClient.spublish(String, String): long
  • added: method RedisClusterClient.spublish(byte[], byte[]): long
  • added: method RedisClusterClient.ssubscribe(BinaryJedisShardedPubSub, byte[][]): void
  • added: method RedisClusterClient.ssubscribe(JedisShardedPubSub, String[]): void
  • added: method RedisClusterClient.transaction(boolean): AbstractTransaction
  • added: method RedisSentinelClient.Builder.createClient(): RedisSentinelClient
  • added: method RedisSentinelClient.getCurrentMaster(): HostAndPort
  • added: method RedisSentinelClient.pipelined(): Pipeline
  • added: method SslOptions.getSslVerifyMode(): SslVerifyMode
  • added: method StaticCommandFlagsRegistry.Builder.build(): StaticCommandFlagsRegistry
  • added: method StaticCommandFlagsRegistry.Builder.register(String, EnumSet): StaticCommandFlagsRegistry.Builder
  • added: method StaticCommandFlagsRegistry.Builder.register(String, String, EnumSet): StaticCommandFlagsRegistry.Builder
  • added: method StaticCommandFlagsRegistry.getFlags(CommandArguments): EnumSet
  • added: method UnifiedJedis.delex(String, CompareCondition): long
  • added: method UnifiedJedis.delex(byte[], CompareCondition): long
  • added: method UnifiedJedis.digestKey(String): String
  • added: method UnifiedJedis.digestKey(byte[]): byte[]
  • added: method UnifiedJedis.echo(String): String
  • added: method UnifiedJedis.ftHybrid(String, FTHybridParams): HybridResult
  • added: method UnifiedJedis.hotkeysGet(): HotkeysInfo
  • added: method UnifiedJedis.hotkeysReset(): String
  • added: method UnifiedJedis.hotkeysStart(HotkeysParams): String
  • added: method UnifiedJedis.hotkeysStop(): String
  • added: method UnifiedJedis.msetex(MSetExParams, String[]): boolean
  • added: method UnifiedJedis.msetex(MSetExParams, byte[][]): boolean
  • added: method UnifiedJedis.xcfgset(String, XCfgSetParams): String
  • added: method UnifiedJedis.xcfgset(byte[], XCfgSetParams): byte[]
  • added: static class Connection.Builder
  • added: static class ConnectionFactory.Builder
  • added: static class DriverInfo.Builder
  • added: static class JedisCluster.Builder extends ClusterClientBuilder
  • added: static class JedisPooled.Builder extends StandaloneClientBuilder
  • added: static class JedisSentineled.Builder extends SentinelClientBuilder
  • added: static class MultiDbClient.Builder extends MultiDbClientBuilder
  • added: static class MultiDbConfig.Builder
  • added: static class MultiDbConfig.DatabaseConfig
  • added: static class MultiDbConfig.DatabaseConfig.Builder
  • added: static class RedisClient.Builder extends StandaloneClientBuilder
  • added: static class RedisClusterClient.Builder extends ClusterClientBuilder
  • added: static class RedisSentinelClient.Builder extends SentinelClientBuilder
  • added: static class StaticCommandFlagsRegistry.Builder
  • added: static field CommandFlagsRegistry.CommandFlag.ADMIN: CommandFlagsRegistry.CommandFlag
  • added: static field CommandFlagsRegistry.CommandFlag.ALLOW_BUSY: CommandFlagsRegistry.CommandFlag
  • added: static field CommandFlagsRegistry.CommandFlag.ASKING: CommandFlagsRegistry.CommandFlag
  • added: static field CommandFlagsRegistry.CommandFlag.BLOCKING: CommandFlagsRegistry.CommandFlag
  • added: static field CommandFlagsRegistry.CommandFlag.DENYOOM: CommandFlagsRegistry.CommandFlag
  • added: static field CommandFlagsRegistry.CommandFlag.FAST: CommandFlagsRegistry.CommandFlag
  • added: static field CommandFlagsRegistry.CommandFlag.LOADING: CommandFlagsRegistry.CommandFlag
  • added: static field CommandFlagsRegistry.CommandFlag.MODULE: CommandFlagsRegistry.CommandFlag
  • added: static field CommandFlagsRegistry.CommandFlag.MOVABLEKEYS: CommandFlagsRegistry.CommandFlag
  • added: static field CommandFlagsRegistry.CommandFlag.NOSCRIPT: CommandFlagsRegistry.CommandFlag
  • added: static field CommandFlagsRegistry.CommandFlag.NO_ASYNC_LOADING: CommandFlagsRegistry.CommandFlag
  • added: static field CommandFlagsRegistry.CommandFlag.NO_AUTH: CommandFlagsRegistry.CommandFlag
  • added: static field CommandFlagsRegistry.CommandFlag.NO_MANDATORY_KEYS: CommandFlagsRegistry.CommandFlag
  • added: static field CommandFlagsRegistry.CommandFlag.NO_MULTI: CommandFlagsRegistry.CommandFlag
  • added: static field CommandFlagsRegistry.CommandFlag.PUBSUB: CommandFlagsRegistry.CommandFlag
  • added: static field CommandFlagsRegistry.CommandFlag.READONLY: CommandFlagsRegistry.CommandFlag
  • added: static field CommandFlagsRegistry.CommandFlag.SKIP_MONITOR: CommandFlagsRegistry.CommandFlag
  • added: static field CommandFlagsRegistry.CommandFlag.SKIP_SLOWLOG: CommandFlagsRegistry.CommandFlag
  • added: static field CommandFlagsRegistry.CommandFlag.SORT_FOR_SCRIPT: CommandFlagsRegistry.CommandFlag
  • added: static field CommandFlagsRegistry.CommandFlag.STALE: CommandFlagsRegistry.CommandFlag
  • added: static field CommandFlagsRegistry.CommandFlag.WRITE: CommandFlagsRegistry.CommandFlag
  • added: static field Protocol.Command.DELEX: Protocol.Command
  • added: static field Protocol.Command.DIGEST: Protocol.Command
  • added: static field Protocol.Command.HOTKEYS: Protocol.Command
  • added: static field Protocol.Command.MSETEX: Protocol.Command
  • added: static field Protocol.Command.XCFGSET: Protocol.Command
  • added: static field Protocol.Keyword.CLAIM: Protocol.Keyword
  • added: static field Protocol.Keyword.CPU: Protocol.Keyword
  • added: static field Protocol.Keyword.DURATION: Protocol.Keyword
  • added: static field Protocol.Keyword.IDMP: Protocol.Keyword
  • added: static field Protocol.Keyword.IDMPAUTO: Protocol.Keyword
  • added: static field Protocol.Keyword.IFDEQ: Protocol.Keyword
  • added: static field Protocol.Keyword.IFDNE: Protocol.Keyword
  • added: static field Protocol.Keyword.IFEQ: Protocol.Keyword
  • added: static field Protocol.Keyword.IFNE: Protocol.Keyword
  • added: static field Protocol.Keyword.MAXSIZE: Protocol.Keyword
  • added: static field Protocol.Keyword.METRICS: Protocol.Keyword
  • added: static field Protocol.Keyword.NET: Protocol.Keyword
  • added: static field Protocol.Keyword.SAMPLE: Protocol.Keyword
  • added: static field Protocol.Keyword.SLOTS: Protocol.Keyword
  • added: static field Protocol.Keyword.START: Protocol.Keyword
  • added: static field Protocol.Keyword.STOP: Protocol.Keyword
  • added: static field RedisClusterClient.DEFAULT_MAX_ATTEMPTS: int
  • added: static field RedisClusterClient.DEFAULT_TIMEOUT: int
  • added: static field RedisClusterClient.INIT_NO_ERROR_PROPERTY: String
  • added: static field StaticCommandFlagsRegistry.EMPTY_FLAGS: EnumSet
  • added: static final class MultiDbConfig.CircuitBreakerConfig
  • added: static final class MultiDbConfig.CircuitBreakerConfig.Builder
  • added: static final class MultiDbConfig.RetryConfig
  • added: static final class MultiDbConfig.RetryConfig.Builder
  • added: static method CommandFlagsRegistry.CommandFlag.valueOf(String): CommandFlagsRegistry.CommandFlag
  • added: static method CommandFlagsRegistry.CommandFlag.values(): CommandFlagsRegistry.CommandFlag[]
  • added: static method Connection.builder(): Connection.Builder
  • added: static method ConnectionFactory.builder(): ConnectionFactory.Builder
  • added: static method DefaultJedisClientConfig.builder(URI): DefaultJedisClientConfig.Builder
  • added: static method DriverInfo.builder(): DriverInfo.Builder
  • added: static method DriverInfo.builder(DriverInfo): DriverInfo.Builder
  • added: static method JedisCluster.builder(): JedisCluster.Builder
  • added: static method JedisPooled.builder(): JedisPooled.Builder
  • added: static method JedisSentineled.builder(): JedisSentineled.Builder
  • added: static method MultiDbClient.builder(): MultiDbClient.Builder
  • added: static method MultiDbConfig.CircuitBreakerConfig.builder(): MultiDbConfig.CircuitBreakerConfig.Builder
  • added: static method MultiDbConfig.DatabaseConfig.builder(Endpoint, JedisClientConfig): MultiDbConfig.DatabaseConfig.Builder
  • added: static method MultiDbConfig.RetryConfig.builder(): MultiDbConfig.RetryConfig.Builder
  • added: static method MultiDbConfig.builder(): MultiDbConfig.Builder
  • added: static method MultiDbConfig.builder(List): MultiDbConfig.Builder
  • added: static method MultiDbConfig.builder(MultiDbConfig.DatabaseConfig[]): MultiDbConfig.Builder
  • added: static method RedisClient.builder(): RedisClient.Builder
  • added: static method RedisClient.create(): RedisClient
  • added: static method RedisClient.create(HostAndPort): RedisClient
  • added: static method RedisClient.create(String): RedisClient
  • added: static method RedisClient.create(String, int): RedisClient
  • added: static method RedisClient.create(String, int, String, String): RedisClient
  • added: static method RedisClient.create(URI): RedisClient
  • added: static method RedisClusterClient.builder(): RedisClusterClient.Builder
  • added: static method RedisClusterClient.create(HostAndPort): RedisClusterClient
  • added: static method RedisClusterClient.create(Set): RedisClusterClient
  • added: static method RedisClusterClient.create(Set, String, String): RedisClusterClient
  • added: static method RedisSentinelClient.builder(): RedisSentinelClient.Builder
  • added: static method SslOptions.defaults(): SslOptions
  • added: static method StaticCommandFlagsRegistry.registry(): StaticCommandFlagsRegistry
  • added: enum HotkeysMetric implements Rawable
  • added: method HotkeysMetric.getRaw(): byte[]
  • added: static field HotkeysMetric.CPU: HotkeysMetric
  • added: static field HotkeysMetric.NET: HotkeysMetric
  • added: static method HotkeysMetric.valueOf(String): HotkeysMetric
  • added: static method HotkeysMetric.values(): HotkeysMetric[]
  • added: abstract class AbstractClientBuilder
  • added: abstract class ClusterClientBuilder extends AbstractClientBuilder
  • added: abstract class MultiDbClientBuilder extends AbstractClientBuilder
  • added: abstract class SentinelClientBuilder extends AbstractClientBuilder
  • added: abstract class StandaloneClientBuilder extends AbstractClientBuilder
  • added: ctor AbstractClientBuilder()
  • added: ctor ClusterClientBuilder()
  • added: ctor MultiDbClientBuilder()
  • added: ctor SentinelClientBuilder()
  • added: ctor StandaloneClientBuilder()
  • added: field AbstractClientBuilder.cache: Cache
  • added: field AbstractClientBuilder.cacheConfig: CacheConfig
  • added: field AbstractClientBuilder.clientConfig: JedisClientConfig
  • added: field AbstractClientBuilder.commandExecutor: CommandExecutor
  • added: field AbstractClientBuilder.commandObjects: CommandObjects
  • added: field AbstractClientBuilder.connectionProvider: ConnectionProvider
  • added: field AbstractClientBuilder.jsonObjectMapper: JsonObjectMapper
  • added: field AbstractClientBuilder.keyPreProcessor: CommandKeyArgumentPreProcessor
  • added: field AbstractClientBuilder.poolConfig: GenericObjectPoolConfig
  • added: field AbstractClientBuilder.searchDialect: int
  • added: method AbstractClientBuilder.applyCommandObjectsConfiguration(CommandObjects): void
  • added: method AbstractClientBuilder.build(): Object
  • added: method AbstractClientBuilder.cache(Cache): AbstractClientBuilder
  • added: method AbstractClientBuilder.cacheConfig(CacheConfig): AbstractClientBuilder
  • added: method AbstractClientBuilder.clientConfig(JedisClientConfig): AbstractClientBuilder
  • added: method AbstractClientBuilder.commandExecutor(CommandExecutor): AbstractClientBuilder
  • added: method AbstractClientBuilder.connectionProvider(ConnectionProvider): AbstractClientBuilder
  • added: method AbstractClientBuilder.createClient(): Object
  • added: method AbstractClientBuilder.createDefaultClientConfig(): JedisClientConfig
  • added: method AbstractClientBuilder.createDefaultCommandExecutor(): CommandExecutor
  • added: method AbstractClientBuilder.createDefaultCommandObjects(): CommandObjects
  • added: method AbstractClientBuilder.createDefaultConnectionProvider(): ConnectionProvider
  • added: method AbstractClientBuilder.jsonObjectMapper(JsonObjectMapper): AbstractClientBuilder
  • added: method AbstractClientBuilder.keyPreProcessor(CommandKeyArgumentPreProcessor): AbstractClientBuilder
  • added: method AbstractClientBuilder.poolConfig(GenericObjectPoolConfig): AbstractClientBuilder
  • added: method AbstractClientBuilder.searchDialect(int): AbstractClientBuilder
  • added: method AbstractClientBuilder.self(): AbstractClientBuilder
  • added: method AbstractClientBuilder.validateCommonConfiguration(): void
  • added: method AbstractClientBuilder.validateSpecificConfiguration(): void
  • added: method ClusterClientBuilder.commandFlags(CommandFlagsRegistry): ClusterClientBuilder
  • added: method ClusterClientBuilder.createDefaultCommandExecutor(): CommandExecutor
  • added: method ClusterClientBuilder.createDefaultCommandFlagsRegistry(): CommandFlagsRegistry
  • added: method ClusterClientBuilder.createDefaultCommandObjects(): CommandObjects
  • added: method ClusterClientBuilder.createDefaultConnectionProvider(): ConnectionProvider
  • added: method ClusterClientBuilder.maxAttempts(int): ClusterClientBuilder
  • added: method ClusterClientBuilder.maxTotalRetriesDuration(Duration): ClusterClientBuilder
  • added: method ClusterClientBuilder.nodes(Set): ClusterClientBuilder
  • added: method ClusterClientBuilder.self(): ClusterClientBuilder
  • added: method ClusterClientBuilder.topologyRefreshPeriod(Duration): ClusterClientBuilder
  • added: method ClusterClientBuilder.validateSpecificConfiguration(): void
  • added: method MultiDbClientBuilder.createDefaultCommandExecutor(): CommandExecutor
  • added: method MultiDbClientBuilder.createDefaultConnectionProvider(): ConnectionProvider
  • added: method MultiDbClientBuilder.databaseSwitchListener(Consumer): MultiDbClientBuilder
  • added: method MultiDbClientBuilder.multiDbConfig(MultiDbConfig): MultiDbClientBuilder
  • added: method MultiDbClientBuilder.self(): MultiDbClientBuilder
  • added: method MultiDbClientBuilder.validateSpecificConfiguration(): void
  • added: method SentinelClientBuilder.build(): Object
  • added: method SentinelClientBuilder.createDefaultConnectionProvider(): ConnectionProvider
  • added: method SentinelClientBuilder.masterName(String): SentinelClientBuilder
  • added: method SentinelClientBuilder.self(): SentinelClientBuilder
  • added: method SentinelClientBuilder.sentinelClientConfig(JedisClientConfig): SentinelClientBuilder
  • added: method SentinelClientBuilder.sentinelReconnectDelay(Delay): SentinelClientBuilder
  • added: method SentinelClientBuilder.sentinels(Set): SentinelClientBuilder
  • added: method SentinelClientBuilder.validateSpecificConfiguration(): void
  • added: method StandaloneClientBuilder.createDefaultConnectionProvider(): ConnectionProvider
  • added: method StandaloneClientBuilder.fromURI(String): StandaloneClientBuilder
  • added: method StandaloneClientBuilder.fromURI(URI): StandaloneClientBuilder
  • added: method StandaloneClientBuilder.hostAndPort(HostAndPort): StandaloneClientBuilder
  • added: method StandaloneClientBuilder.hostAndPort(String, int): StandaloneClientBuilder
  • added: method StandaloneClientBuilder.self(): StandaloneClientBuilder
  • added: method StandaloneClientBuilder.validateSpecificConfiguration(): void
  • added: method KeyBinaryCommands.delex(byte[], CompareCondition): long
  • added: method KeyBinaryCommands.digestKey(byte[]): byte[]
  • added: method KeyCommands.delex(String, CompareCondition): long
  • added: method KeyCommands.digestKey(String): String
  • added: method KeyPipelineBinaryCommands.delex(byte[], CompareCondition): Response
  • added: method KeyPipelineBinaryCommands.digestKey(byte[]): Response
  • added: method KeyPipelineCommands.delex(String, CompareCondition): Response
  • added: method KeyPipelineCommands.digestKey(String): Response
  • added: method ServerCommands.hotkeysGet(): HotkeysInfo
  • added: method ServerCommands.hotkeysReset(): String
  • added: method ServerCommands.hotkeysStart(HotkeysParams): String
  • added: method ServerCommands.hotkeysStop(): String
  • added: method StreamBinaryCommands.xcfgset(byte[], XCfgSetParams): byte[]
  • added: method StreamCommands.xcfgset(String, XCfgSetParams): String
  • added: method StreamPipelineBinaryCommands.xcfgset(byte[], XCfgSetParams): Response
  • added: method StreamPipelineCommands.xcfgset(String, XCfgSetParams): Response
  • added: method StringBinaryCommands.msetex(MSetExParams, byte[][]): boolean
  • added: method StringCommands.msetex(MSetExParams, String[]): boolean
  • added: method StringPipelineBinaryCommands.msetex(MSetExParams, byte[][]): Response
  • added: method StringPipelineCommands.msetex(MSetExParams, String[]): Response
  • added: method CacheConnection.Builder.clientConfig(JedisClientConfig): CacheConnection.Builder
  • added: method CacheConnection.Builder.createConnection(): Connection
  • added: method CacheConnection.Builder.getCache(): Cache
  • added: method CacheConnection.Builder.socketFactory(JedisSocketFactory): CacheConnection.Builder
  • added: static class CacheConnection.Builder extends Connection.Builder
  • added: static method CacheConnection.builder(): CacheConnection.Builder
  • added: static method CacheConnection.builder(Cache): CacheConnection.Builder
  • added: ctor ClusterCommandExecutor(ClusterConnectionProvider, int, Duration, CommandFlagsRegistry)
  • added: field ClusterCommandExecutor.flags: CommandFlagsRegistry
  • removed: class CircuitBreakerCommandExecutor extends CircuitBreakerFailoverBase implements CommandExecutor
  • removed: class CircuitBreakerFailoverBase implements AutoCloseable
  • removed: class CircuitBreakerFailoverConnectionProvider extends CircuitBreakerFailoverBase
  • removed: class MultiClusterPipeline extends PipelineBase implements Closeable
  • removed: class MultiClusterTransaction extends TransactionBase
  • removed: ctor CircuitBreakerCommandExecutor(MultiClusterPooledConnectionProvider)
  • removed: ctor CircuitBreakerFailoverBase(MultiClusterPooledConnectionProvider)
  • removed: ctor CircuitBreakerFailoverConnectionProvider(MultiClusterPooledConnectionProvider)
  • removed: ctor MultiClusterPipeline(MultiClusterPooledConnectionProvider)
  • removed: ctor MultiClusterPipeline(MultiClusterPooledConnectionProvider, CommandObjects)
  • removed: ctor MultiClusterTransaction(MultiClusterPooledConnectionProvider)
  • removed: ctor MultiClusterTransaction(MultiClusterPooledConnectionProvider, boolean)
  • removed: ctor MultiClusterTransaction(MultiClusterPooledConnectionProvider, boolean, CommandObjects)
  • removed: field CircuitBreakerFailoverBase.provider: MultiClusterPooledConnectionProvider
  • removed: method CircuitBreakerCommandExecutor.executeCommand(CommandObject): Object
  • removed: method CircuitBreakerFailoverBase.close(): void
  • removed: method CircuitBreakerFailoverBase.clusterFailover(CircuitBreaker): void
  • removed: method CircuitBreakerFailoverConnectionProvider.getConnection(): Connection
  • removed: method MultiClusterPipeline.appendCommand(CommandObject): Response
  • removed: method MultiClusterPipeline.close(): void
  • removed: method MultiClusterPipeline.sync(): void
  • removed: method MultiClusterPipeline.waitAOF(long, long, long): Response
  • removed: method MultiClusterPipeline.waitReplicas(int, long): Response
  • removed: method MultiClusterTransaction.appendCommand(CommandObject): Response
  • removed: method MultiClusterTransaction.close(): void
  • removed: method MultiClusterTransaction.discard(): String
  • removed: method MultiClusterTransaction.exec(): List
  • removed: method MultiClusterTransaction.multi(): void
  • removed: method MultiClusterTransaction.unwatch(): String
  • removed: method MultiClusterTransaction.watch(String[]): String
  • removed: method MultiClusterTransaction.watch(byte[][]): String
  • added: class ConnectionFailoverException extends JedisException
  • added: class DatabaseSwitchEvent
  • added: class HealthCheckCollection
  • added: class HealthCheckImpl implements HealthCheck
  • added: class HealthStatusChangeEvent
  • added: class HealthStatusManager
  • added: class JedisFailoverException extends JedisConnectionException
  • added: class LagAwareStrategy implements HealthCheckStrategy
  • added: class MultiDbCommandExecutor extends MultiDbFailoverBase implements CommandExecutor
  • added: class MultiDbConnectionProvider implements ConnectionProvider
  • added: class MultiDbConnectionSupplier extends MultiDbFailoverBase
  • added: class MultiDbFailoverBase implements AutoCloseable
  • added: class MultiDbPipeline extends AbstractPipeline implements Closeable
  • added: class MultiDbTransaction extends AbstractTransaction
  • added: class PingStrategy implements HealthCheckStrategy
  • added: class StatusTracker
  • added: class TrackingConnectionPool extends ConnectionPool
  • added: ctor ConnectionFailoverException(String, Exception)
  • added: ctor DatabaseSwitchEvent(SwitchReason, Endpoint, MultiDbConnectionProvider.Database)
  • added: ctor HealthCheckCollection()
  • added: ctor HealthCheckStrategy.Config(int, int, int, int, ProbingPolicy)
  • added: ctor HealthCheckStrategy.Config.Builder()
  • added: ctor HealthStatusChangeEvent(Endpoint, HealthStatus, HealthStatus)
  • added: ctor HealthStatusManager()
  • added: ctor InitializationPolicy.BuiltIn()
  • added: ctor JedisFailoverException()
  • added: ctor JedisFailoverException(String)
  • added: ctor JedisFailoverException.JedisPermanentlyNotAvailableException()
  • added: ctor JedisFailoverException.JedisPermanentlyNotAvailableException(String)
  • added: ctor JedisFailoverException.JedisTemporarilyNotAvailableException()
  • added: ctor JedisFailoverException.JedisTemporarilyNotAvailableException(String)
  • added: ctor LagAwareStrategy(LagAwareStrategy.Config)
  • added: ctor LagAwareStrategy.Config(Endpoint, Supplier)
  • added: ctor MultiDbCommandExecutor(MultiDbConnectionProvider)
  • added: ctor MultiDbConnectionProvider(MultiDbConfig)
  • added: ctor MultiDbConnectionSupplier(MultiDbConnectionProvider)
  • added: ctor MultiDbFailoverBase(MultiDbConnectionProvider)
  • added: ctor MultiDbPipeline(MultiDbConnectionProvider)
  • added: ctor MultiDbPipeline(MultiDbConnectionProvider, CommandObjects)
  • added: ctor MultiDbTransaction(MultiDbConnectionProvider)
  • added: ctor MultiDbTransaction(MultiDbConnectionProvider, boolean)
  • added: ctor MultiDbTransaction(MultiDbConnectionProvider, boolean, CommandObjects)
  • added: ctor PingStrategy(HostAndPort, JedisClientConfig)
  • added: ctor PingStrategy(HostAndPort, JedisClientConfig, HealthCheckStrategy.Config)
  • added: ctor ProbingPolicy.BuiltIn()
  • added: ctor StatusTracker(HealthStatusManager)
  • added: ctor TrackingConnectionPool.Builder()
  • added: enum HealthStatus
  • added: enum InitializationPolicy.Decision
  • added: enum ProbingPolicy.Decision
  • added: enum SwitchReason
  • added: field HealthCheckStrategy.Config.Builder.delayInBetweenProbes: int
  • added: field HealthCheckStrategy.Config.Builder.interval: int
  • added: field HealthCheckStrategy.Config.Builder.numProbes: int
  • added: field HealthCheckStrategy.Config.Builder.policy: ProbingPolicy
  • added: field HealthCheckStrategy.Config.Builder.timeout: int
  • added: field HealthCheckStrategy.Config.delayInBetweenProbes: int
  • added: field HealthCheckStrategy.Config.interval: int
  • added: field HealthCheckStrategy.Config.numProbes: int
  • added: field HealthCheckStrategy.Config.policy: ProbingPolicy
  • added: field HealthCheckStrategy.Config.timeout: int
  • added: field MultiDbFailoverBase.provider: MultiDbConnectionProvider
  • added: interface HealthCheck
  • added: interface HealthCheckStrategy extends Closeable
  • added: interface HealthStatusListener
  • added: interface InitializationPolicy
  • added: interface InitializationPolicy.InitializationContext
  • added: interface ProbingPolicy
  • added: interface ProbingPolicy.ProbeContext
  • added: method DatabaseSwitchEvent.getDatabaseName(): String
  • added: method DatabaseSwitchEvent.getEndpoint(): Endpoint
  • added: method DatabaseSwitchEvent.getReason(): SwitchReason
  • added: method HealthCheck.getEndpoint(): Endpoint
  • added: method HealthCheck.getMaxWaitFor(): long
  • added: method HealthCheck.getStatus(): HealthStatus
  • added: method HealthCheck.start(): void
  • added: method HealthCheck.stop(): void
  • added: method HealthCheckCollection.add(HealthCheck): HealthCheck
  • added: method HealthCheckCollection.addAll(HealthCheck[]): HealthCheck[]
  • added: method HealthCheckCollection.close(): void
  • added: method HealthCheckCollection.get(Endpoint): HealthCheck
  • added: method HealthCheckCollection.remove(Endpoint): HealthCheck
  • added: method HealthCheckCollection.remove(HealthCheck): HealthCheck
  • added: method HealthCheckImpl.getEndpoint(): Endpoint
  • added: method HealthCheckImpl.getMaxWaitFor(): long
  • added: method HealthCheckImpl.getStatus(): HealthStatus
  • added: method HealthCheckImpl.start(): void
  • added: method HealthCheckImpl.stop(): void
  • added: method HealthCheckStrategy.Config.Builder.build(): HealthCheckStrategy.Config
  • added: method HealthCheckStrategy.Config.Builder.delayInBetweenProbes(int): HealthCheckStrategy.Config.Builder
  • added: method HealthCheckStrategy.Config.Builder.interval(int): HealthCheckStrategy.Config.Builder
  • added: method HealthCheckStrategy.Config.Builder.numProbes(int): HealthCheckStrategy.Config.Builder
  • added: method HealthCheckStrategy.Config.Builder.policy(ProbingPolicy): HealthCheckStrategy.Config.Builder
  • added: method HealthCheckStrategy.Config.Builder.timeout(int): HealthCheckStrategy.Config.Builder
  • added: method HealthCheckStrategy.Config.getDelayInBetweenProbes(): int
  • added: method HealthCheckStrategy.Config.getInterval(): int
  • added: method HealthCheckStrategy.Config.getNumProbes(): int
  • added: method HealthCheckStrategy.Config.getPolicy(): ProbingPolicy
  • added: method HealthCheckStrategy.Config.getTimeout(): int
  • added: method HealthCheckStrategy.close(): void
  • added: method HealthCheckStrategy.doHealthCheck(Endpoint): HealthStatus
  • added: method HealthCheckStrategy.getDelayInBetweenProbes(): int
  • added: method HealthCheckStrategy.getInterval(): int
  • added: method HealthCheckStrategy.getNumProbes(): int
  • added: method HealthCheckStrategy.getPolicy(): ProbingPolicy
  • added: method HealthCheckStrategy.getTimeout(): int
  • added: method HealthStatus.isHealthy(): boolean
  • added: method HealthStatusChangeEvent.getEndpoint(): Endpoint
  • added: method HealthStatusChangeEvent.getNewStatus(): HealthStatus
  • added: method HealthStatusChangeEvent.getOldStatus(): HealthStatus
  • added: method HealthStatusListener.onStatusChange(HealthStatusChangeEvent): void
  • added: method HealthStatusManager.add(Endpoint, HealthCheckStrategy): HealthCheck
  • added: method HealthStatusManager.addAll(Endpoint[], HealthCheckStrategy): void
  • added: method HealthStatusManager.close(): void
  • added: method HealthStatusManager.getHealthStatus(Endpoint): HealthStatus
  • added: method HealthStatusManager.getMaxWaitFor(Endpoint): long
  • added: method HealthStatusManager.hasHealthCheck(Endpoint): boolean
  • added: method HealthStatusManager.notifyListeners(HealthStatusChangeEvent): void
  • added: method HealthStatusManager.registerListener(Endpoint, HealthStatusListener): void
  • added: method HealthStatusManager.registerListener(HealthStatusListener): void
  • added: method HealthStatusManager.remove(Endpoint): void
  • added: method HealthStatusManager.removeAll(Endpoint[]): void
  • added: method HealthStatusManager.unregisterListener(Endpoint, HealthStatusListener): void
  • added: method HealthStatusManager.unregisterListener(HealthStatusListener): void
  • added: method InitializationPolicy.InitializationContext.getAvailableConnections(): int
  • added: method InitializationPolicy.InitializationContext.getFailedConnections(): int
  • added: method InitializationPolicy.InitializationContext.getPendingConnections(): int
  • added: method InitializationPolicy.evaluate(InitializationPolicy.InitializationContext): InitializationPolicy.Decision
  • added: method LagAwareStrategy.Config.ConfigBuilder.availabilityLagTolerance(Duration): LagAwareStrategy.Config.ConfigBuilder
  • added: method LagAwareStrategy.Config.ConfigBuilder.build(): LagAwareStrategy.Config
  • added: method LagAwareStrategy.Config.ConfigBuilder.extendedCheckEnabled(boolean): LagAwareStrategy.Config.ConfigBuilder
  • added: method LagAwareStrategy.Config.ConfigBuilder.sslOptions(SslOptions): LagAwareStrategy.Config.ConfigBuilder
  • added: method LagAwareStrategy.Config.getAvailabilityLagTolerance(): Duration
  • added: method LagAwareStrategy.Config.getCredentialsSupplier(): Supplier
  • added: method LagAwareStrategy.Config.getRestEndpoint(): Endpoint
  • added: method LagAwareStrategy.Config.getSslOptions(): SslOptions
  • added: method LagAwareStrategy.Config.isExtendedCheckEnabled(): boolean
  • added: method LagAwareStrategy.doHealthCheck(Endpoint): HealthStatus
  • added: method LagAwareStrategy.getDelayInBetweenProbes(): int
  • added: method LagAwareStrategy.getInterval(): int
  • added: method LagAwareStrategy.getNumProbes(): int
  • added: method LagAwareStrategy.getPolicy(): ProbingPolicy
  • added: method LagAwareStrategy.getTimeout(): int
  • added: method MultiDbCommandExecutor.executeCommand(CommandObject): Object
  • added: method MultiDbConnectionProvider.Database.clearGracePeriod(): void
  • added: method MultiDbConnectionProvider.Database.close(): void
  • added: method MultiDbConnectionProvider.Database.forceDisconnect(): void
  • added: method MultiDbConnectionProvider.Database.getCircuitBreaker(): CircuitBreaker
  • added: method MultiDbConnectionProvider.Database.getCircuitBreakerFailureRateThreshold(): float
  • added: method MultiDbConnectionProvider.Database.getCircuitBreakerMinNumOfFailures(): int
  • added: method MultiDbConnectionProvider.Database.getConnection(): Connection
  • added: method MultiDbConnectionProvider.Database.getConnectionPool(): ConnectionPool
  • added: method MultiDbConnectionProvider.Database.getEndpoint(): Endpoint
  • added: method MultiDbConnectionProvider.Database.getHealthStatus(): HealthStatus
  • added: method MultiDbConnectionProvider.Database.getRetry(): Retry
  • added: method MultiDbConnectionProvider.Database.getWeight(): float
  • added: method MultiDbConnectionProvider.Database.isCBForcedOpen(): boolean
  • added: method MultiDbConnectionProvider.Database.isDisabled(): boolean
  • added: method MultiDbConnectionProvider.Database.isFailbackSupported(): boolean
  • added: method MultiDbConnectionProvider.Database.isHealthy(): boolean
  • added: method MultiDbConnectionProvider.Database.isInGracePeriod(): boolean
  • added: method MultiDbConnectionProvider.Database.retryOnFailover(): boolean
  • added: method MultiDbConnectionProvider.Database.setDisabled(boolean): void
  • added: method MultiDbConnectionProvider.Database.setGracePeriod(): void
  • added: method MultiDbConnectionProvider.Database.setGracePeriod(long): void
  • added: method MultiDbConnectionProvider.Database.setWeight(float): void
  • added: method MultiDbConnectionProvider.Database.toString(): String
  • added: method MultiDbConnectionProvider.add(MultiDbConfig.DatabaseConfig): void
  • added: method MultiDbConnectionProvider.assertOperability(): void
  • added: method MultiDbConnectionProvider.canIterateFrom(MultiDbConnectionProvider.Database): boolean
  • added: method MultiDbConnectionProvider.close(): void
  • added: method MultiDbConnectionProvider.forceActiveDatabase(Endpoint, long): void
  • added: method MultiDbConnectionProvider.getActiveEndpoint(): Endpoint
  • added: method MultiDbConnectionProvider.getConnection(): Connection
  • added: method MultiDbConnectionProvider.getConnection(CommandArguments): Connection
  • added: method MultiDbConnectionProvider.getConnection(Endpoint): Connection
  • added: method MultiDbConnectionProvider.getConnectionMap(): Map
  • added: method MultiDbConnectionProvider.getDatabase(): MultiDbConnectionProvider.Database
  • added: method MultiDbConnectionProvider.getDatabase(Endpoint): MultiDbConnectionProvider.Database
  • added: method MultiDbConnectionProvider.getDatabaseCircuitBreaker(): CircuitBreaker
  • added: method MultiDbConnectionProvider.getEndpoints(): Set
  • added: method MultiDbConnectionProvider.getFallbackExceptionList(): List
  • added: method MultiDbConnectionProvider.isHealthy(Endpoint): boolean
  • added: method MultiDbConnectionProvider.onDatabaseSwitch(SwitchReason, Endpoint, MultiDbConnectionProvider.Database): void
  • added: method MultiDbConnectionProvider.remove(Endpoint): void
  • added: method MultiDbConnectionProvider.setActiveDatabase(Endpoint): void
  • added: method MultiDbConnectionProvider.setDatabaseSwitchListener(Consumer): void
  • added: method MultiDbConnectionProvider.validateTargetConnection(Endpoint): void
  • added: method MultiDbConnectionSupplier.getConnection(): Connection
  • added: method MultiDbFailoverBase.close(): void
  • added: method MultiDbFailoverBase.databaseFailover(MultiDbConnectionProvider.Database): void
  • added: method MultiDbPipeline.appendCommand(CommandObject): Response
  • added: method MultiDbPipeline.close(): void
  • added: method MultiDbPipeline.sync(): void
  • added: method MultiDbPipeline.waitAOF(long, long, long): Response
  • added: method MultiDbPipeline.waitReplicas(int, long): Response
  • added: method MultiDbTransaction.appendCommand(CommandObject): Response
  • added: method MultiDbTransaction.close(): void
  • added: method MultiDbTransaction.discard(): String
  • added: method MultiDbTransaction.exec(): List
  • added: method MultiDbTransaction.multi(): void
  • added: method MultiDbTransaction.unwatch(): String
  • added: method MultiDbTransaction.watch(String[]): String
  • added: method MultiDbTransaction.watch(byte[][]): String
  • added: method PingStrategy.close(): void
  • added: method PingStrategy.doHealthCheck(Endpoint): HealthStatus
  • added: method PingStrategy.getDelayInBetweenProbes(): int
  • added: method PingStrategy.getInterval(): int
  • added: method PingStrategy.getNumProbes(): int
  • added: method PingStrategy.getPolicy(): ProbingPolicy
  • added: method PingStrategy.getTimeout(): int
  • added: method ProbingPolicy.ProbeContext.getFails(): int
  • added: method ProbingPolicy.ProbeContext.getRemainingProbes(): int
  • added: method ProbingPolicy.ProbeContext.getSuccesses(): int
  • added: method ProbingPolicy.evaluate(ProbingPolicy.ProbeContext): ProbingPolicy.Decision
  • added: method StatusTracker.waitForHealthStatus(Endpoint): HealthStatus
  • added: method TrackingConnectionPool.Builder.build(): TrackingConnectionPool
  • added: method TrackingConnectionPool.Builder.clientConfig(JedisClientConfig): TrackingConnectionPool.Builder
  • added: method TrackingConnectionPool.Builder.hostAndPort(HostAndPort): TrackingConnectionPool.Builder
  • added: method TrackingConnectionPool.Builder.poolConfig(GenericObjectPoolConfig): TrackingConnectionPool.Builder
  • added: method TrackingConnectionPool.close(): void
  • added: method TrackingConnectionPool.forceDisconnect(): void
  • added: method TrackingConnectionPool.getResource(): Connection
  • added: method TrackingConnectionPool.returnBrokenResource(Connection): void
  • added: method TrackingConnectionPool.returnResource(Connection): void
  • added: static class HealthCheckStrategy.Config
  • added: static class HealthCheckStrategy.Config.Builder
  • added: static class InitializationPolicy.BuiltIn
  • added: static class JedisFailoverException.JedisPermanentlyNotAvailableException extends JedisFailoverException
  • added: static class JedisFailoverException.JedisTemporarilyNotAvailableException extends JedisFailoverException
  • added: static class LagAwareStrategy.Config extends HealthCheckStrategy.Config
  • added: static class LagAwareStrategy.Config.ConfigBuilder extends HealthCheckStrategy.Config.Builder
  • added: static class MultiDbConnectionProvider.Database
  • added: static class ProbingPolicy.BuiltIn
  • added: static class TrackingConnectionPool.Builder
  • added: static field HealthStatus.HEALTHY: HealthStatus
  • added: static field HealthStatus.UNHEALTHY: HealthStatus
  • added: static field HealthStatus.UNKNOWN: HealthStatus
  • added: static field InitializationPolicy.BuiltIn.ALL_AVAILABLE: InitializationPolicy
  • added: static field InitializationPolicy.BuiltIn.MAJORITY_AVAILABLE: InitializationPolicy
  • added: static field InitializationPolicy.BuiltIn.ONE_AVAILABLE: InitializationPolicy
  • added: static field InitializationPolicy.Decision.CONTINUE: InitializationPolicy.Decision
  • added: static field InitializationPolicy.Decision.FAIL: InitializationPolicy.Decision
  • added: static field InitializationPolicy.Decision.SUCCESS: InitializationPolicy.Decision
  • added: static field LagAwareStrategy.Config.AVAILABILITY_LAG_TOLERANCE_DEFAULT: Duration
  • added: static field LagAwareStrategy.Config.EXTENDED_CHECK_DEFAULT: boolean
  • added: static field PingStrategy.DEFAULT: MultiDbConfig.StrategySupplier
  • added: static field ProbingPolicy.BuiltIn.ALL_SUCCESS: ProbingPolicy
  • added: static field ProbingPolicy.BuiltIn.ANY_SUCCESS: ProbingPolicy
  • added: static field ProbingPolicy.BuiltIn.MAJORITY_SUCCESS: ProbingPolicy
  • added: static field ProbingPolicy.Decision.CONTINUE: ProbingPolicy.Decision
  • added: static field ProbingPolicy.Decision.FAIL: ProbingPolicy.Decision
  • added: static field ProbingPolicy.Decision.SUCCESS: ProbingPolicy.Decision
  • added: static field SwitchReason.CIRCUIT_BREAKER: SwitchReason
  • added: static field SwitchReason.FAILBACK: SwitchReason
  • added: static field SwitchReason.FORCED: SwitchReason
  • added: static field SwitchReason.HEALTH_CHECK: SwitchReason
  • added: static method HealthCheckStrategy.Config.builder(): HealthCheckStrategy.Config.Builder
  • added: static method HealthCheckStrategy.Config.create(): HealthCheckStrategy.Config
  • added: static method HealthStatus.valueOf(String): HealthStatus
  • added: static method HealthStatus.values(): HealthStatus[]
  • added: static method InitializationPolicy.Decision.valueOf(String): InitializationPolicy.Decision
  • added: static method InitializationPolicy.Decision.values(): InitializationPolicy.Decision[]
  • added: static method LagAwareStrategy.Config.builder(): LagAwareStrategy.Config.ConfigBuilder
  • added: static method LagAwareStrategy.Config.builder(Endpoint, Supplier): LagAwareStrategy.Config.ConfigBuilder
  • added: static method LagAwareStrategy.Config.create(Endpoint, Supplier): LagAwareStrategy.Config
  • added: static method LagAwareStrategy.Config.databaseAvailability(Endpoint, Supplier): LagAwareStrategy.Config
  • added: static method LagAwareStrategy.Config.lagAware(Endpoint, Supplier): LagAwareStrategy.Config
  • added: static method LagAwareStrategy.Config.lagAwareWithTolerance(Endpoint, Supplier, Duration): LagAwareStrategy.Config
  • added: static method ProbingPolicy.Decision.valueOf(String): ProbingPolicy.Decision
  • added: static method ProbingPolicy.Decision.values(): ProbingPolicy.Decision[]
  • added: static method SwitchReason.valueOf(String): SwitchReason
  • added: static method SwitchReason.values(): SwitchReason[]
  • added: static method TrackingConnectionPool.builder(): TrackingConnectionPool.Builder
  • added: static method TrackingConnectionPool.from(TrackingConnectionPool): TrackingConnectionPool
  • added: class HotkeysParams implements IParams
  • added: class MSetExParams extends BaseSetExParams
  • added: class XCfgSetParams implements IParams
  • added: ctor HotkeysParams()
  • added: ctor MSetExParams()
  • added: ctor XCfgSetParams()
  • added: ctor ZRangeParams(long, long)
  • added: method HotkeysParams.addParams(CommandArguments): void
  • added: method HotkeysParams.count(int): HotkeysParams
  • added: method HotkeysParams.duration(int): HotkeysParams
  • added: method HotkeysParams.equals(Object): boolean
  • added: method HotkeysParams.hashCode(): int
  • added: method HotkeysParams.metrics(HotkeysMetric[]): HotkeysParams
  • added: method HotkeysParams.sample(int): HotkeysParams
  • added: method HotkeysParams.slots(int[]): HotkeysParams
  • added: method MSetExParams.addParams(CommandArguments): void
  • added: method MSetExParams.equals(Object): boolean
  • added: method MSetExParams.hashCode(): int
  • added: method MSetExParams.nx(): MSetExParams
  • added: method MSetExParams.xx(): MSetExParams
  • added: method SetParams.condition(CompareCondition): SetParams
  • added: method XAddParams.idmp(String, String): XAddParams
  • added: method XAddParams.idmp(byte[], byte[]): XAddParams
  • added: method XAddParams.idmpAuto(String): XAddParams
  • added: method XAddParams.idmpAuto(byte[]): XAddParams
  • added: method XCfgSetParams.addParams(CommandArguments): void
  • added: method XCfgSetParams.equals(Object): boolean
  • added: method XCfgSetParams.hashCode(): int
  • added: method XCfgSetParams.idmpDuration(int): XCfgSetParams
  • added: method XCfgSetParams.idmpMaxsize(int): XCfgSetParams
  • added: method XReadGroupParams.claim(long): XReadGroupParams
  • added: static method HotkeysParams.hotkeysParams(): HotkeysParams
  • added: static method MSetExParams.setParams(): MSetExParams
  • added: static method XCfgSetParams.xCfgSetParams(): XCfgSetParams
  • added: static method ZRangeParams.zrangeParams(long, long): ZRangeParams
  • removed: class MultiClusterPooledConnectionProvider implements ConnectionProvider
  • removed: class ShardedConnectionProvider implements ConnectionProvider
  • removed: ctor MultiClusterPooledConnectionProvider(MultiClusterClientConfig)
  • removed: ctor MultiClusterPooledConnectionProvider.Cluster(ConnectionPool, Retry, CircuitBreaker)
  • removed: ctor ShardedConnectionProvider(List)
  • removed: ctor ShardedConnectionProvider(List, JedisClientConfig)
  • removed: ctor ShardedConnectionProvider(List, JedisClientConfig, GenericObjectPoolConfig)
  • removed: ctor ShardedConnectionProvider(List, JedisClientConfig, GenericObjectPoolConfig, Hashing)
  • removed: ctor ShardedConnectionProvider(List, JedisClientConfig, Hashing)
  • removed: method MultiClusterPooledConnectionProvider.Cluster.getCircuitBreaker(): CircuitBreaker
  • removed: method MultiClusterPooledConnectionProvider.Cluster.getConnection(): Connection
  • removed: method MultiClusterPooledConnectionProvider.Cluster.getConnectionPool(): ConnectionPool
  • removed: method MultiClusterPooledConnectionProvider.Cluster.getRetry(): Retry
  • removed: method MultiClusterPooledConnectionProvider.close(): void
  • removed: method MultiClusterPooledConnectionProvider.getCluster(): MultiClusterPooledConnectionProvider.Cluster
  • removed: method MultiClusterPooledConnectionProvider.getCluster(int): MultiClusterPooledConnectionProvider.Cluster
  • removed: method MultiClusterPooledConnectionProvider.getClusterCircuitBreaker(): CircuitBreaker
  • removed: method MultiClusterPooledConnectionProvider.getClusterCircuitBreaker(int): CircuitBreaker
  • removed: method MultiClusterPooledConnectionProvider.getConnection(): Connection
  • removed: method MultiClusterPooledConnectionProvider.getConnection(CommandArguments): Connection
  • removed: method MultiClusterPooledConnectionProvider.getConnection(int): Connection
  • removed: method MultiClusterPooledConnectionProvider.getConnectionMap(): Map
  • removed: method MultiClusterPooledConnectionProvider.getFallbackExceptionList(): List
  • removed: method MultiClusterPooledConnectionProvider.incrementActiveMultiClusterIndex(): int
  • removed: method MultiClusterPooledConnectionProvider.isLastClusterCircuitBreakerForcedOpen(): boolean
  • removed: method MultiClusterPooledConnectionProvider.runClusterFailoverPostProcessor(Integer): void
  • removed: method MultiClusterPooledConnectionProvider.setActiveMultiClusterIndex(int): void
  • removed: method MultiClusterPooledConnectionProvider.setClusterFailoverPostProcessor(Consumer): void
  • removed: method MultiClusterPooledConnectionProvider.validateTargetConnection(int): void
  • removed: method ShardedConnectionProvider.close(): void
  • removed: method ShardedConnectionProvider.getConnection(): Connection
  • removed: method ShardedConnectionProvider.getConnection(CommandArguments): Connection
  • removed: method ShardedConnectionProvider.getConnection(HostAndPort): Connection
  • removed: method ShardedConnectionProvider.getConnectionMap(): Map
  • removed: method ShardedConnectionProvider.getHashingAlgo(): Hashing
  • removed: method ShardedConnectionProvider.getNode(Long): HostAndPort
  • removed: static class MultiClusterPooledConnectionProvider.Cluster
  • added: ctor SentineledConnectionProvider(String, JedisClientConfig, Cache, GenericObjectPoolConfig, Set, JedisClientConfig, Delay)
  • added: ctor SentineledConnectionProvider(String, JedisClientConfig, GenericObjectPoolConfig, Set, JedisClientConfig, Delay)
  • added: field SentineledConnectionProvider.SentinelListener.subscribeAttempt: long
  • added: interface SentineledConnectionProvider.SentinelConnectionFactory
  • added: method SentineledConnectionProvider.SentinelConnectionFactory.createConnection(HostAndPort, JedisClientConfig): Jedis
  • added: method SentineledConnectionProvider.defaultSentinelConnectionFactory(): SentineledConnectionProvider.SentinelConnectionFactory
  • added: method SentineledConnectionProvider.getConnectionMap(): Map
  • added: method SentineledConnectionProvider.getPrimaryNodesConnectionMap(): Map
  • added: static field SentineledConnectionProvider.DEFAULT_RESUBSCRIBE_DELAY: Delay
  • added: class HotkeysInfo implements Serializable
  • added: ctor HotkeysInfo(boolean, long, List, Long, Long, long, Long, Long, long, long, long, long, long, long, Map, Map)
  • added: ctor StreamEntry(StreamEntryID, Map, Long, Long)
  • added: ctor StreamEntryBinary(StreamEntryID, Map, Long, Long)
  • added: method HotkeysInfo.getAllCommandsAllSlotsUs(): long
  • added: method HotkeysInfo.getAllCommandsSelectedSlotsUs(): Long
  • added: method HotkeysInfo.getByCpuTimeUs(): Map
  • added: method HotkeysInfo.getByNetBytes(): Map
  • added: method HotkeysInfo.getCollectionDurationMs(): long
  • added: method HotkeysInfo.getCollectionStartTimeUnixMs(): long
  • added: method HotkeysInfo.getNetBytesAllCommandsAllSlots(): long
  • added: method HotkeysInfo.getNetBytesAllCommandsSelectedSlots(): Long
  • added: method HotkeysInfo.getNetBytesSampledCommandsSelectedSlots(): Long
  • added: method HotkeysInfo.getSampleRatio(): long
  • added: method HotkeysInfo.getSampledCommandSelectedSlotsUs(): Long
  • added: method HotkeysInfo.getSelectedSlots(): List
  • added: method HotkeysInfo.getTotalCpuTimeSysMs(): long
  • added: method HotkeysInfo.getTotalCpuTimeUserMs(): long
  • added: method HotkeysInfo.getTotalNetBytes(): long
  • added: method HotkeysInfo.isTrackingActive(): boolean
  • added: method StreamEntry.getDeliveredCount(): Long
  • added: method StreamEntry.getMillisElapsedFromDelivery(): Long
  • added: method StreamEntry.isClaimed(): boolean
  • added: method StreamEntryBinary.getDeliveredCount(): Long
  • added: method StreamEntryBinary.getMillisElapsedFromDelivery(): Long
  • added: method StreamEntryBinary.isClaimed(): boolean
  • added: method StreamInfo.getIdmpDuration(): Long
  • added: method StreamInfo.getIdmpMaxsize(): Long
  • added: method StreamInfo.getIidsAdded(): Long
  • added: method StreamInfo.getIidsDuplicates(): Long
  • added: method StreamInfo.getIidsTracked(): Long
  • added: method StreamInfo.getPidsTracked(): Long
  • added: static field HotkeysInfo.ALL_COMMANDS_ALL_SLOTS_US: String
  • added: static field HotkeysInfo.ALL_COMMANDS_SELECTED_SLOTS_US: String
  • added: static field HotkeysInfo.BY_CPU_TIME_US: String
  • added: static field HotkeysInfo.BY_NET_BYTES: String
  • added: static field HotkeysInfo.COLLECTION_DURATION_MS: String
  • added: static field HotkeysInfo.COLLECTION_START_TIME_UNIX_MS: String
  • added: static field HotkeysInfo.HOTKEYS_INFO_BUILDER: Builder
  • added: static field HotkeysInfo.NET_BYTES_ALL_COMMANDS_ALL_SLOTS: String
  • added: static field HotkeysInfo.NET_BYTES_ALL_COMMANDS_SELECTED_SLOTS: String
  • added: static field HotkeysInfo.NET_BYTES_SAMPLED_COMMANDS_SELECTED_SLOTS: String
  • added: static field HotkeysInfo.SAMPLED_COMMANDS_SELECTED_SLOTS_US: String
  • added: static field HotkeysInfo.SAMPLE_RATIO: String
  • added: static field HotkeysInfo.SELECTED_SLOTS: String
  • added: static field HotkeysInfo.TOTAL_CPU_TIME_SYS_MS: String
  • added: static field HotkeysInfo.TOTAL_CPU_TIME_USER_MS: String
  • added: static field HotkeysInfo.TOTAL_NET_BYTES: String
  • added: static field HotkeysInfo.TRACKING_ACTIVE: String
  • added: static field StreamInfo.IDMP_DURATION: String
  • added: static field StreamInfo.IDMP_MAXSIZE: String
  • added: static field StreamInfo.IIDS_ADDED: String
  • added: static field StreamInfo.IIDS_DUPLICATES: String
  • added: static field StreamInfo.IIDS_TRACKED: String
  • added: static field StreamInfo.PIDS_TRACKED: String
  • added: abstract class Combiner implements IParams
  • added: abstract class Scorer implements IParams
  • added: class Apply implements IParams
  • added: class Filter implements IParams
  • added: class Limit implements IParams
  • added: class Scorers
  • added: ctor Combiner(String)
  • added: ctor Scorer(String)
  • added: final class Combiners
  • added: method Apply.addParams(CommandArguments): void
  • added: method Combiner.addParams(CommandArguments): void
  • added: method Combiner.as(String): Combiner
  • added: method Combiner.getName(): String
  • added: method Combiner.getOwnArgs(): List
  • added: method Combiners.Linear.alpha(double): Combiners.Linear
  • added: method Combiners.Linear.beta(double): Combiners.Linear
  • added: method Combiners.Linear.getOwnArgs(): List
  • added: method Combiners.Linear.window(int): Combiners.Linear
  • added: method Combiners.RRF.constant(double): Combiners.RRF
  • added: method Combiners.RRF.getOwnArgs(): List
  • added: method Combiners.RRF.window(int): Combiners.RRF
  • added: method Filter.addParams(CommandArguments): void
  • added: method Limit.addParams(CommandArguments): void
  • added: method RediSearchCommands.ftHybrid(String, FTHybridParams): HybridResult
  • added: method RediSearchPipelineCommands.ftHybrid(String, FTHybridParams): Response
  • added: method Scorer.addParams(CommandArguments): void
  • added: method Scorer.getName(): String
  • added: method Scorer.toString(): String
  • added: static class Combiners.Linear extends Combiner
  • added: static class Combiners.RRF extends Combiner
  • added: static field SearchProtocol.DEFAULT_DIALECT: int
  • added: static field SearchProtocol.SearchCommand.HYBRID: SearchProtocol.SearchCommand
  • added: static field SearchProtocol.SearchKeyword.ALPHA: SearchProtocol.SearchKeyword
  • added: static field SearchProtocol.SearchKeyword.BETA: SearchProtocol.SearchKeyword
  • added: static field SearchProtocol.SearchKeyword.COMBINE: SearchProtocol.SearchKeyword
  • added: static field SearchProtocol.SearchKeyword.CONSTANT: SearchProtocol.SearchKeyword
  • added: static field SearchProtocol.SearchKeyword.EF_RUNTIME: SearchProtocol.SearchKeyword
  • added: static field SearchProtocol.SearchKeyword.EPSILON: SearchProtocol.SearchKeyword
  • added: static field SearchProtocol.SearchKeyword.K: SearchProtocol.SearchKeyword
  • added: static field SearchProtocol.SearchKeyword.KNN: SearchProtocol.SearchKeyword
  • added: static field SearchProtocol.SearchKeyword.LINEAR: SearchProtocol.SearchKeyword
  • added: static field SearchProtocol.SearchKeyword.NOSORT: SearchProtocol.SearchKeyword
  • added: static field SearchProtocol.SearchKeyword.RADIUS: SearchProtocol.SearchKeyword
  • added: static field SearchProtocol.SearchKeyword.RANGE: SearchProtocol.SearchKeyword
  • added: static field SearchProtocol.SearchKeyword.RRF: SearchProtocol.SearchKeyword
  • added: static field SearchProtocol.SearchKeyword.VSIM: SearchProtocol.SearchKeyword
  • added: static field SearchProtocol.SearchKeyword.WINDOW: SearchProtocol.SearchKeyword
  • added: static field SearchProtocol.SearchKeyword.YIELD_SCORE_AS: SearchProtocol.SearchKeyword
  • added: static method Apply.of(String): Apply
  • added: static method Apply.of(String, String): Apply
  • added: static method Combiners.linear(): Combiners.Linear
  • added: static method Combiners.rrf(): Combiners.RRF
  • added: static method Filter.of(String): Filter
  • added: static method Limit.of(int, int): Limit
  • added: static method Scorers.bm25std(): Scorer
  • added: static method Scorers.bm25stdNorm(): Scorer
  • added: static method Scorers.dismax(): Scorer
  • added: static method Scorers.docscore(): Scorer
  • added: static method Scorers.hamming(): Scorer
  • added: static method Scorers.tfidf(): Scorer
  • added: static method Scorers.tfidfDocnorm(): Scorer
  • added: class FTHybridParams implements IParams
  • added: class FTHybridPostProcessingParams implements IParams
  • added: class FTHybridSearchParams implements IParams
  • added: class FTHybridVectorParams implements IParams
  • added: class HybridResult
  • added: ctor FTHybridParams.Builder()
  • added: ctor FTHybridPostProcessingParams.Builder()
  • added: ctor FTHybridSearchParams.Builder()
  • added: ctor FTHybridVectorParams.Builder()
  • added: interface FTHybridVectorParams.VectorMethod extends IParams
  • added: method FTHybridParams.Builder.build(): FTHybridParams
  • added: method FTHybridParams.Builder.combine(Combiner): FTHybridParams.Builder
  • added: method FTHybridParams.Builder.param(String, Object): FTHybridParams.Builder
  • added: method FTHybridParams.Builder.postProcessing(FTHybridPostProcessingParams): FTHybridParams.Builder
  • added: method FTHybridParams.Builder.search(FTHybridSearchParams): FTHybridParams.Builder
  • added: method FTHybridParams.Builder.timeout(long): FTHybridParams.Builder
  • added: method FTHybridParams.Builder.vectorSearch(FTHybridVectorParams): FTHybridParams.Builder
  • added: method FTHybridParams.addParams(CommandArguments): void
  • added: method FTHybridPostProcessingParams.Builder.apply(Apply): FTHybridPostProcessingParams.Builder
  • added: method FTHybridPostProcessingParams.Builder.build(): FTHybridPostProcessingParams
  • added: method FTHybridPostProcessingParams.Builder.filter(Filter): FTHybridPostProcessingParams.Builder
  • added: method FTHybridPostProcessingParams.Builder.groupBy(Group): FTHybridPostProcessingParams.Builder
  • added: method FTHybridPostProcessingParams.Builder.limit(Limit): FTHybridPostProcessingParams.Builder
  • added: method FTHybridPostProcessingParams.Builder.load(String[]): FTHybridPostProcessingParams.Builder
  • added: method FTHybridPostProcessingParams.Builder.loadAll(): FTHybridPostProcessingParams.Builder
  • added: method FTHybridPostProcessingParams.Builder.noSort(): FTHybridPostProcessingParams.Builder
  • added: method FTHybridPostProcessingParams.Builder.sortBy(SortedField[]): FTHybridPostProcessingParams.Builder
  • added: method FTHybridPostProcessingParams.addParams(CommandArguments): void
  • added: method FTHybridPostProcessingParams.equals(Object): boolean
  • added: method FTHybridPostProcessingParams.hashCode(): int
  • added: method FTHybridSearchParams.Builder.build(): FTHybridSearchParams
  • added: method FTHybridSearchParams.Builder.query(String): FTHybridSearchParams.Builder
  • added: method FTHybridSearchParams.Builder.scoreAlias(String): FTHybridSearchParams.Builder
  • added: method FTHybridSearchParams.Builder.scorer(Scorer): FTHybridSearchParams.Builder
  • added: method FTHybridSearchParams.addParams(CommandArguments): void
  • added: method FTHybridVectorParams.Builder.build(): FTHybridVectorParams
  • added: method FTHybridVectorParams.Builder.field(String): FTHybridVectorParams.Builder
  • added: method FTHybridVectorParams.Builder.filter(String): FTHybridVectorParams.Builder
  • added: method FTHybridVectorParams.Builder.method(FTHybridVectorParams.VectorMethod): FTHybridVectorParams.Builder
  • added: method FTHybridVectorParams.Builder.scoreAlias(String): FTHybridVectorParams.Builder
  • added: method FTHybridVectorParams.Builder.vector(String): FTHybridVectorParams.Builder
  • added: method FTHybridVectorParams.Knn.addParams(CommandArguments): void
  • added: method FTHybridVectorParams.Knn.efRuntime(int): FTHybridVectorParams.Knn
  • added: method FTHybridVectorParams.Range.addParams(CommandArguments): void
  • added: method FTHybridVectorParams.Range.epsilon(double): FTHybridVectorParams.Range
  • added: method FTHybridVectorParams.addParams(CommandArguments): void
  • added: method HybridResult.getDocuments(): List
  • added: method HybridResult.getExecutionTime(): double
  • added: method HybridResult.getTotalResults(): long
  • added: method HybridResult.getWarnings(): List
  • added: method HybridResult.toString(): String
  • added: static class FTHybridParams.Builder
  • added: static class FTHybridPostProcessingParams.Builder
  • added: static class FTHybridSearchParams.Builder
  • added: static class FTHybridVectorParams.Builder
  • added: static class FTHybridVectorParams.Knn implements FTHybridVectorParams.VectorMethod
  • added: static class FTHybridVectorParams.Range implements FTHybridVectorParams.VectorMethod
  • added: static field HybridResult.HYBRID_RESULT_BUILDER: Builder
  • added: static method FTHybridParams.builder(): FTHybridParams.Builder
  • added: static method FTHybridPostProcessingParams.builder(): FTHybridPostProcessingParams.Builder
  • added: static method FTHybridSearchParams.builder(): FTHybridSearchParams.Builder
  • added: static method FTHybridVectorParams.Knn.of(int): FTHybridVectorParams.Knn
  • added: static method FTHybridVectorParams.Range.of(double): FTHybridVectorParams.Range
  • added: static method FTHybridVectorParams.builder(): FTHybridVectorParams.Builder
  • added: static field AggregationType.COUNTALL: AggregationType
  • added: static field AggregationType.COUNTNAN: AggregationType
  • added: abstract class Delay
  • added: ctor Delay()
  • added: enum CompareCondition.Condition
  • added: final class CompareCondition
  • added: method CompareCondition.Condition.getKeyword(): Protocol.Keyword
  • added: method CompareCondition.addTo(CommandArguments): void
  • added: method CompareCondition.equals(Object): boolean
  • added: method CompareCondition.getCondition(): CompareCondition.Condition
  • added: method CompareCondition.getPayload(): Object
  • added: method CompareCondition.hashCode(): int
  • added: method CompareCondition.toString(): String
  • added: method Delay.delay(long): Duration
  • added: static field CompareCondition.Condition.DIGEST_EQUAL: CompareCondition.Condition
  • added: static field CompareCondition.Condition.DIGEST_NOT_EQUAL: CompareCondition.Condition
  • added: static field CompareCondition.Condition.VALUE_EQUAL: CompareCondition.Condition
  • added: static field CompareCondition.Condition.VALUE_NOT_EQUAL: CompareCondition.Condition
  • added: static method CompareCondition.Condition.valueOf(String): CompareCondition.Condition
  • added: static method CompareCondition.Condition.values(): CompareCondition.Condition[]
  • added: static method CompareCondition.digestEq(String): CompareCondition
  • added: static method CompareCondition.digestEq(byte[]): CompareCondition
  • added: static method CompareCondition.digestNe(String): CompareCondition
  • added: static method CompareCondition.digestNe(byte[]): CompareCondition
  • added: static method CompareCondition.valueEq(String): CompareCondition
  • added: static method CompareCondition.valueEq(byte[]): CompareCondition
  • added: static method CompareCondition.valueNe(String): CompareCondition
  • added: static method CompareCondition.valueNe(byte[]): CompareCondition
  • added: static method Delay.constant(Duration): Delay
  • added: static method Delay.exponentialWithJitter(Duration, Duration, Duration): Delay
  • added: static method JedisAsserts.isFalse(boolean, String): void
  • added: static method JedisURIHelper.hasDbIndex(URI): boolean
  • added: static method SafeEncoder.toUpperCase(byte[]): byte[]