Module io.inverno.mod.redis

Package io.inverno.mod.redis

Interface RedisTransactionalOperations<A,B>

Type Parameters:

A - key type

B - value type

All Superinterfaces:

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

public interface RedisTransactionalOperations<A,B>
extends RedisOperations<A,B>

Redis reactive commands with transaction support.

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>

Method Summary

Modifier and Type	Method	Description
Mono<String>	discard()	Discards all commands issued in the transaction.
Mono<RedisTransactionResult>	exec()	Executes all commands issued in the transaction.

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

geoadd, geoadd, geoadd, geodist, geohash, geohash, geopos, geopos, georadius, georadius, georadiusbymember, georadiusbymember, georadiusbymemberExtended, georadiusbymemberStore, georadiusExtended, georadiusStore, geosearch, geosearchExtended, geosearchstore

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

hdel, hdel, hexists, hget, hgetall, hincrby, hincrbyfloat, hkeys, hlen, hmget, hmset, hrandfield, hrandfield, hrandfieldWithvalues, hscan, hscan, hset, hset, hsetnx, hstrlen, hvals

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

pfadd, pfadd, pfcount, pfcount, pfmerge, pfmerge

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

copy, copy, del, del, dump, exists, exists, expire, expire, expire, expireat, expireat, expireat, expireat, expiretime, keys, migrate, migrate, move, objectEncoding, objectFreq, objectIdletime, objectRefcount, persist, pexpire, pexpire, pexpire, pexpireat, pexpireat, pexpireat, pexpireat, pexpiretime, pttl, randomkey, rename, renamenx, restore, restore, scan, scan, sort, sort, sortStore, sortStore, touch, touch, ttl, type, unlink, unlink, waitForReplication

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

blmove, blmpop, blpop, blpop, brpop, brpop, brpoplpush, lindex, linsert, llen, lmove, lmpop, lpop, lpop, lpos, lpos, lpos, lpush, lpush, lpushx, lpushx, lrange, lrem, lset, ltrim, rpop, rpop, rpoplpush, rpush, rpush, rpushx, rpushx

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

digest, digest, 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, scriptExists, scriptFlush, scriptFlush, scriptKill, scriptLoad, scriptLoad

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

sadd, sadd, scard, sdiff, sdiff, sdiffstore, sdiffstore, sinter, sinter, sintercard, sintercard, sintercard, sintercard, sinterstore, sinterstore, sismember, smembers, smismember, smove, spop, spop, srandmember, srandmember, srem, srem, sscan, sscan, sunion, sunion, sunionstore, sunionstore

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

bzmpop, bzpopmax, bzpopmax, bzpopmin, bzpopmin, 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 interface io.inverno.mod.redis.operations.RedisStreamReactiveOperations

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

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

append, bitcount, bitcount, bitfield, bitfield, bitopAnd, bitopAnd, bitopNot, bitopNot, bitopOr, bitopOr, bitopXor, bitopXor, bitpos, bitpos, bitpos, decr, decrby, get, getbit, getdel, getex, getex, getrange, getset, incr, incrby, incrbyfloat, mget, mset, msetnx, psetex, set, set, setbit, setex, setGet, setGet, setnx, setrange, strlen

Method Details

discard

Mono<String> discard()

Discards all commands issued in the transaction.

• DISCARD

Returns:

discard command result (always OK).

exec

Mono<RedisTransactionResult> exec()

Executes all commands issued in the transaction.

• EXEC

Returns:

a mono emitting transaction result