Module io.inverno.mod.redis.lettuce

Package io.inverno.mod.redis.lettuce

Class PoolRedisClusterClient<A,B,C extends io.lettuce.core.cluster.api.StatefulRedisClusterConnection<A,B>>

java.lang.Object

io.inverno.mod.redis.lettuce.internal.AbstractRedisClient<A,B,C>

io.inverno.mod.redis.lettuce.PoolRedisClusterClient<A,B,C>

Type Parameters:

A - key type

B - value type

C - underlying cluster connection type

All Implemented Interfaces:

RedisGeoReactiveOperations<A,B>, RedisHashReactiveOperations<A,B>, RedisHLLReactiveOperations<A,B>, RedisKeyReactiveOperations<A,B>, RedisListReactiveOperations<A,B>, RedisScriptingReactiveOperations<A,B>, RedisSetReactiveOperations<A,B>, RedisSortedSetReactiveOperations<A,B>, RedisStreamReactiveOperations<A,B>, RedisStringReactiveOperations<A,B>, RedisClient<A,B>, RedisOperations<A,B>

public class PoolRedisClusterClient<A,B,C extends io.lettuce.core.cluster.api.StatefulRedisClusterConnection<A,B>>
extends io.inverno.mod.redis.lettuce.internal.AbstractRedisClient<A,B,C>

A Lettuce cluster pool Redis client wrapper.

This Redis client implementation doesn't support transaction.

Since:

1.4

Author:

Jeremy Kuhn

Nested Class Summary

Nested classes/interfaces inherited from interface io.inverno.mod.redis.operations.RedisGeoReactiveOperations

RedisGeoReactiveOperations.AbstractGeoradiusBuilder<A,B,C extends RedisGeoReactiveOperations.AbstractGeoradiusBuilder<A,B,C>>, RedisGeoReactiveOperations.AbstractGeoradiusExtendedBuilder<A,B,C extends RedisGeoReactiveOperations.AbstractGeoradiusExtendedBuilder<A,B,C>>, RedisGeoReactiveOperations.AbstractGeoradiusStoreBuilder<A,B,C extends RedisGeoReactiveOperations.AbstractGeoradiusStoreBuilder<A,B,C>>, RedisGeoReactiveOperations.AbstractGeosearchBuilder<A,B,C extends RedisGeoReactiveOperations.AbstractGeosearchBuilder<A,B,C>>, RedisGeoReactiveOperations.GeoaddBuilder<A,B>, RedisGeoReactiveOperations.GeoCoordinates, RedisGeoReactiveOperations.GeoItems<B>, RedisGeoReactiveOperations.GeoradiusBuilder<A,B>, RedisGeoReactiveOperations.GeoradiusbymemberBuilder<A,B>, RedisGeoReactiveOperations.GeoradiusbymemberExtendedBuilder<A,B>, RedisGeoReactiveOperations.GeoradiusbymemberStoreBuilder<A,B>, RedisGeoReactiveOperations.GeoradiusExtendedBuilder<A,B>, RedisGeoReactiveOperations.GeoradiusStoreBuilder<A,B>, RedisGeoReactiveOperations.GeosearchBuilder<A,B>, RedisGeoReactiveOperations.GeosearchExtendedBuilder<A,B>, RedisGeoReactiveOperations.GeosearchstoreBuilder<A,B>, RedisGeoReactiveOperations.GeoUnit, RedisGeoReactiveOperations.GeoWithin<B>

Nested classes/interfaces inherited from interface io.inverno.mod.redis.operations.RedisHashReactiveOperations

RedisHashReactiveOperations.HashScanBuilder<A,B>, RedisHashReactiveOperations.HashScanResult<A,B>

Nested classes/interfaces inherited from interface io.inverno.mod.redis.operations.RedisKeyReactiveOperations

RedisKeyReactiveOperations.AbstractKeySortBuilder<A,C extends RedisKeyReactiveOperations.AbstractKeySortBuilder<A,C>>, RedisKeyReactiveOperations.KeyCopyBuilder<A>, RedisKeyReactiveOperations.KeyExpireatBuilder<A>, RedisKeyReactiveOperations.KeyExpireBuilder<A>, RedisKeyReactiveOperations.KeyMigrateBuilder<A>, RedisKeyReactiveOperations.KeyPexpireatBuilder<A>, RedisKeyReactiveOperations.KeyPexpireBuilder<A>, RedisKeyReactiveOperations.KeyRestoreBuilder<A>, RedisKeyReactiveOperations.KeyScanBuilder<A>, RedisKeyReactiveOperations.KeyScanResult<A>, RedisKeyReactiveOperations.KeySortBuilder<A,B>, RedisKeyReactiveOperations.KeySortStoreBuilder<A>

Nested classes/interfaces inherited from interface io.inverno.mod.redis.operations.RedisListReactiveOperations

RedisListReactiveOperations.AbstractListLmoveBuilder<A,B,C extends RedisListReactiveOperations.AbstractListLmoveBuilder<A,B,C>>, RedisListReactiveOperations.AbstractListLmpopBuilder<A,B,C extends RedisListReactiveOperations.AbstractListLmpopBuilder<A,B,C>>, RedisListReactiveOperations.ListBlmoveBuilder<A,B>, RedisListReactiveOperations.ListBlmpopBuilder<A,B>, RedisListReactiveOperations.ListLmoveBuilder<A,B>, RedisListReactiveOperations.ListLmpopBuilder<A,B>, RedisListReactiveOperations.ListLposBuilder<A,B>

Nested classes/interfaces inherited from interface io.inverno.mod.redis.operations.RedisScriptingReactiveOperations

RedisScriptingReactiveOperations.ScriptFlushMode, RedisScriptingReactiveOperations.ScriptOutput

Nested classes/interfaces inherited from interface io.inverno.mod.redis.operations.RedisSetReactiveOperations

RedisSetReactiveOperations.SetScanBuilder<A,B>, RedisSetReactiveOperations.SetScanResult<B>

Nested classes/interfaces inherited from interface io.inverno.mod.redis.operations.RedisSortedSetReactiveOperations

RedisSortedSetReactiveOperations.AbstractSortedSetZinterBuilder<A,B,C extends RedisSortedSetReactiveOperations.AbstractSortedSetZinterBuilder<A,B,C>>, RedisSortedSetReactiveOperations.AbstractSortedSetZmpopBuilder<A,B,C extends RedisSortedSetReactiveOperations.AbstractSortedSetZmpopBuilder<A,B,C>>, RedisSortedSetReactiveOperations.AbstractSortedSetZrangeBuilder<A,B,C extends RedisSortedSetReactiveOperations.AbstractSortedSetZrangeBuilder<A,B,C>>, RedisSortedSetReactiveOperations.AbstractSortedSetZunionBuilder<A,B,C extends RedisSortedSetReactiveOperations.AbstractSortedSetZunionBuilder<A,B,C>>, RedisSortedSetReactiveOperations.SortedSetBzmpopBuilder<A,B>, RedisSortedSetReactiveOperations.SortedSetScanBuilder<A,B>, RedisSortedSetReactiveOperations.SortedSetScanResult<B>, RedisSortedSetReactiveOperations.SortedSetScoredMember<B>, RedisSortedSetReactiveOperations.SortedSetScoredMembers<B>, RedisSortedSetReactiveOperations.SortedSetZaddBuilder<A,B>, RedisSortedSetReactiveOperations.SortedSetZaddIncrBuilder<A,B>, RedisSortedSetReactiveOperations.SortedSetZinterBuilder<A,B>, RedisSortedSetReactiveOperations.SortedSetZinterstoreBuilder<A,B>, RedisSortedSetReactiveOperations.SortedSetZinterWithScoresBuilder<A,B>, RedisSortedSetReactiveOperations.SortedSetZmpopBuilder<A,B>, RedisSortedSetReactiveOperations.SortedSetZrangeBuilder<A,B,C>, RedisSortedSetReactiveOperations.SortedSetZrangestoreBuilder<A,B,C>, RedisSortedSetReactiveOperations.SortedSetZrangeWithScoresBuilder<A,B,C>, RedisSortedSetReactiveOperations.SortedSetZunionBuilder<A,B>, RedisSortedSetReactiveOperations.SortedSetZunionstoreBuilder<A,B>, RedisSortedSetReactiveOperations.SortedSetZunionWithScoresBuilder<A,B>

Nested classes/interfaces inherited from interface io.inverno.mod.redis.operations.RedisStreamReactiveOperations

RedisStreamReactiveOperations.StreamClaimedMessages<A,B>, RedisStreamReactiveOperations.StreamEntries<A,B>, RedisStreamReactiveOperations.StreamMessage<A,B>, RedisStreamReactiveOperations.StreamMessageIds, RedisStreamReactiveOperations.StreamPendingMessage, RedisStreamReactiveOperations.StreamPendingMessages, RedisStreamReactiveOperations.StreamStreams<A>, RedisStreamReactiveOperations.StreamXaddBuilder<A,B>, RedisStreamReactiveOperations.StreamXautoclaimBuilder<A,B>, RedisStreamReactiveOperations.StreamXclaimBuilder<A,B>, RedisStreamReactiveOperations.StreamXgroupCreateBuilder<A>, RedisStreamReactiveOperations.StreamXpendingExtendedBuilder<A>, RedisStreamReactiveOperations.StreamXreadBuilder<A,B>, RedisStreamReactiveOperations.StreamXreadgroupBuilder<A,B>, RedisStreamReactiveOperations.StreamXtrimBuilder<A>

Nested classes/interfaces inherited from interface io.inverno.mod.redis.operations.RedisStringReactiveOperations

RedisStringReactiveOperations.AbstractStringSetBuilder<A,B,C extends RedisStringReactiveOperations.AbstractStringSetBuilder<A,B,C>>, RedisStringReactiveOperations.StringBitfieldBuilder<A,B>, RedisStringReactiveOperations.StringGetexBuilder<A,B>, RedisStringReactiveOperations.StringSetBuilder<A,B>, RedisStringReactiveOperations.StringSetGetBuilder<A,B>

Field Summary

Fields inherited from class io.inverno.mod.redis.lettuce.internal.AbstractRedisClient

keyType, pool, valueType

Constructor Summary

Constructors

Constructor	Description
PoolRedisClusterClient(io.lettuce.core.support.AsyncPool<C> pool, Class<A> keyType, Class<B> valueType)	Creates a Redis client with the specified Lettuce cluster pool.

Method Summary

Modifier and Type	Method	Description
protected Mono<io.inverno.mod.redis.lettuce.internal.operations.StatefulRedisConnectionOperations<A,B,C,?>>	operations()	Returns Redis Operations.

Methods inherited from class io.inverno.mod.redis.lettuce.internal.AbstractRedisClient

append, batch, bitcount, bitcount, bitfield, bitfield, bitopAnd, bitopAnd, bitopNot, bitopNot, bitopOr, bitopOr, bitopXor, bitopXor, bitpos, bitpos, bitpos, blmove, blmpop, blpop, blpop, brpop, brpop, brpoplpush, bzmpop, bzpopmax, bzpopmax, bzpopmin, bzpopmin, close, connection, copy, copy, decr, decrby, del, del, digest, digest, dump, eval, eval, eval, eval, eval, eval, eval_ro, eval_ro, eval_ro, eval_ro, eval_ro, eval_ro, evalsha, evalsha, evalsha, evalsha_ro, evalsha_ro, evalsha_ro, exists, exists, expire, expire, expire, expireat, expireat, expireat, expireat, expiretime, geoadd, geoadd, geoadd, geodist, geohash, geohash, geopos, geopos, georadius, georadiusbymember, georadiusbymemberExtended, georadiusbymemberStore, georadiusExtended, georadiusStore, geosearch, geosearchExtended, geosearchstore, get, getbit, getdel, getex, getex, getrange, getset, hdel, hdel, hexists, hget, hgetall, hincrby, hincrbyfloat, hkeys, hlen, hmget, hmset, hrandfield, hrandfield, hrandfieldWithvalues, hscan, hscan, hset, hset, hsetnx, hstrlen, hvals, incr, incrby, incrbyfloat, keys, lindex, linsert, llen, lmove, lmpop, lpop, lpop, lpos, lpos, lpos, lpush, lpush, lpushx, lpushx, lrange, lrem, lset, ltrim, mget, migrate, migrate, move, mset, msetnx, objectEncoding, objectFreq, objectIdletime, objectRefcount, persist, pexpire, pexpire, pexpire, pexpireat, pexpireat, pexpireat, pexpireat, pexpiretime, pfadd, pfadd, pfcount, pfcount, pfmerge, pfmerge, psetex, pttl, randomkey, rename, renamenx, restore, restore, rpop, rpop, rpoplpush, rpush, rpush, rpushx, rpushx, sadd, sadd, scan, scan, scard, scriptExists, scriptFlush, scriptFlush, scriptKill, scriptLoad, scriptLoad, sdiff, sdiff, sdiffstore, sdiffstore, set, set, setbit, setex, setGet, setGet, setnx, setrange, sinter, sinter, sintercard, sintercard, sintercard, sintercard, sinterstore, sinterstore, sismember, smembers, smismember, smove, sort, sort, sortStore, sortStore, spop, spop, srandmember, srandmember, srem, srem, sscan, sscan, strlen, sunion, sunion, sunionstore, sunionstore, touch, touch, ttl, type, unlink, unlink, waitForReplication, xack, xack, xadd, xadd, xadd, xautoclaim, xautoclaim, xclaim, xclaim, xclaim, xdel, xdel, xgroupCreate, xgroupCreate, xgroupCreateconsumer, xgroupDelconsumer, xgroupDestroy, xgroupSetid, xinfoConsumers, xinfoGroups, xinfoStream, xinfoStreamFull, xinfoStreamFull, xlen, xpending, xpendingExtended, xpendingExtended, xrange, xrange, xread, xread, xread, xreadgroup, xreadgroup, xreadgroup, xrevrange, xrevrange, xtrim, xtrimMaxLen, xtrimMaxLen, xtrimMinId, xtrimMinId, zadd, zadd, zadd, zaddIncr, zaddIncr, zcard, zcount, zdiff, zdiff, zdiffstore, zdiffstore, zdiffWithScores, zdiffWithScores, zincrby, zinter, zinter, zinter, zintercard, zintercard, zintercard, zintercard, zinterstore, zinterstore, zinterstore, zinterWithScores, zinterWithScores, zinterWithScores, zlexcount, zmpop, zmscore, zmscore, zpopmax, zpopmax, zpopmin, zpopmin, zrandmember, zrandmember, zrandmemberWithScores, zrange, zrange, zrangestore, zrangestore, zrangeWithScores, zrangeWithScores, zrank, zrem, zrem, zremrangebylex, zremrangebyrank, zremrangebyscore, zrevrank, zscan, zscan, zscore, zunion, zunion, zunion, zunionstore, zunionstore, zunionstore, zunionWithScores, zunionWithScores, zunionWithScores

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.inverno.mod.redis.operations.RedisGeoReactiveOperations

georadius, georadiusbymember

Constructor Details

PoolRedisClusterClient

public PoolRedisClusterClient(io.lettuce.core.support.AsyncPool<C> pool,
 Class<A> keyType,
 Class<B> valueType)

Creates a Redis client with the specified Lettuce cluster pool.

Parameters:

pool - an async pool

keyType - the key type

valueType - the value type

Method Details

operations

protected Mono<io.inverno.mod.redis.lettuce.internal.operations.StatefulRedisConnectionOperations<A,B,C,?>> operations()

Description copied from class: io.inverno.mod.redis.lettuce.internal.AbstractRedisClient

Returns Redis Operations.

Specified by:

operations in class io.inverno.mod.redis.lettuce.internal.AbstractRedisClient<A,B,C extends io.lettuce.core.cluster.api.StatefulRedisClusterConnection<A,B>>

Returns:

a mono emitting RedisOperations object