abstract class RedisUnitCommand extends AbstractRedisCommand[Unit]
- Alphabetic
- By Inheritance
- RedisUnitCommand
- AbstractRedisCommand
- RedisCommand
- RawCommand
- ReplyPreprocessor
- RawCommands
- SinglePackBatch
- RawCommandPack
- RawCommandPacks
- RedisBatch
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
- new RedisUnitCommand()
Type Members
-
type
Encoded = ArrayMsg[BulkStringMsg]
- Definition Classes
- RawCommand
Abstract Value Members
-
abstract
def
encoded: Encoded
- Definition Classes
- RawCommand
-
abstract
def
level: Level
- Definition Classes
- RawCommand
Concrete Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
def
*>[B](other: RedisBatch[B]): RedisBatch[B]
Merges two batches into a single batch where result of the right-hand-side batch is returned while result of left-hand-side is discarded.
Merges two batches into a single batch where result of the right-hand-side batch is returned while result of left-hand-side is discarded. Useful when left-hand-side returns
Unit
. NOTE: errors for left-hand-side are NOT discarded, use ignoreFailures on it if that's your intention.- Definition Classes
- RedisBatch
-
def
<*[B](other: RedisBatch[B]): RedisBatch[Unit]
Merges two batches into a single batch where result of the left-hand-side batch is returned while result of right-hand-side is discarded.
Merges two batches into a single batch where result of the left-hand-side batch is returned while result of right-hand-side is discarded. Useful when right-hand-side returns
Unit
. NOTE: errors for right-hand-side are NOT discarded, use ignoreFailures on it if that's your intention.- Definition Classes
- RedisBatch
-
def
<*>[B, C](other: RedisBatch[B])(f: (Unit, B) ⇒ C): RedisBatch[C]
This is a symbolic alias for map2.
This is a symbolic alias for map2. The symbol (along with *> and <*) is inspired by its Haskell equivalent.
- Definition Classes
- RedisBatch
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
asking: RedisBatch[Unit]
Ensures that every keyed command in this batch is prepended with
ASKING
special command.Ensures that every keyed command in this batch is prepended with
ASKING
special command. This is necessary only when manually handling Redis Cluster redirections.- Definition Classes
- RedisBatch
-
def
atomic: RedisBatch[Unit]
Returns a batch which invokes the same commands as this batch but atomically.
Returns a batch which invokes the same commands as this batch but atomically. If this batch is already atomic then it's returned unchanged. Otherwise, it's wrapped into a Redis transaction (
MULTI
-EXEC
block). Empty batches, single-command batches and transactions are atomic by themselves and therefore are returned unchanged.- Definition Classes
- RedisBatch
-
final
def
batchOrFallback: RedisBatch[Unit]
- Definition Classes
- RedisCommand
-
final
def
checkLevel(minAllowed: Level, clientType: String): Unit
- Definition Classes
- RawCommand → RawCommandPack
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
final
def
computeSize(limit: Int): Int
- Definition Classes
- RawCommandPack → RawCommandPacks
-
final
def
createPreprocessor(replyCount: Int): RawCommand
- Definition Classes
- RawCommand → RawCommandPack
-
final
def
decode(replyMsg: RedisReply): Unit
- Attributes
- protected
- Definition Classes
- RedisCommand
-
val
decodeExpected: ReplyDecoder[Unit]
- Attributes
- protected
- Definition Classes
- AbstractRedisCommand → RedisCommand
-
final
def
decodeReplies(replies: (Int) ⇒ RedisReply, idx: Index, inTransaction: Boolean): Unit
- Definition Classes
- RedisCommand → RedisBatch
-
final
def
emitCommandPacks(consumer: (RawCommandPack) ⇒ Unit): Unit
- Definition Classes
- RawCommandPack → RawCommandPacks
-
final
def
emitCommands(consumer: (RawCommand) ⇒ Unit): Unit
- Definition Classes
- RawCommand → RawCommands
-
final
def
encodedSize: Int
- Definition Classes
- RawCommandPacks
-
final
def
encoder(command: String, subcommand: String): CommandEncoder
- Attributes
- protected
- Definition Classes
- RawCommand
-
final
def
encoder(command: String): CommandEncoder
- Attributes
- protected
- Definition Classes
- RawCommand
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
failed: RedisBatch[Throwable]
- Definition Classes
- RedisBatch
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
foreachKey(consumer: (ByteString) ⇒ Unit): Unit
- Definition Classes
- RawCommandPacks
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
ignoreFailures: RedisBatch[Unit]
- Definition Classes
- RedisBatch
-
def
immediateResult: commons.Opt[Unit]
Returns optional value that may be used as immediate result of this command if it command can be treated as no-op.
Returns optional value that may be used as immediate result of this command if it command can be treated as no-op. For example
DEL
command with no keys may simply return 0 as its immediate result.- Definition Classes
- RedisCommand
-
final
def
isAsking: Boolean
- Definition Classes
- RawCommand → RawCommandPack
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
map[B](fun: (Unit) ⇒ B): RedisCommand[B]
- Definition Classes
- RedisCommand → RedisBatch
-
def
map2[B, C](other: RedisBatch[B])(f: (Unit, B) ⇒ C): RedisBatch[C]
Merges two batches into one.
Merges two batches into one. Provided function is applied on results of the batches being merged to obtain result of the merged batch.
map2
is the fundamental primitive for composing multiple batches into one.- Definition Classes
- RedisBatch
-
def
maxBlockingMillis: Int
Maximum amount of time that these command packs may block on Redis side (like e.g.
Maximum amount of time that these command packs may block on Redis side (like e.g.
BLPOP
). This method is overridden for RawCommand to return 0 and should be further overridden by each blocking command.Int.MaxValue
should be returned for unlimited blocking.- Definition Classes
- RawCommand → RawCommandPacks
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
def
operation: RedisOp[Unit]
Transforms this batch into a RedisOp.
Transforms this batch into a RedisOp.
- Definition Classes
- RedisBatch
-
final
def
preprocess(message: RedisMsg, state: WatchState): commons.Opt[RedisMsg]
- Definition Classes
- RawCommand → ReplyPreprocessor
-
final
def
rawCommandPacks: RawCommandPacks
- Definition Classes
- SinglePackBatch → RedisBatch
-
final
def
rawCommands(inTransaction: Boolean): RawCommand
- Definition Classes
- RawCommand → RawCommandPack
-
def
recover[B >: Unit](f: PartialFunction[Throwable, B]): RedisBatch[B]
- Definition Classes
- RedisBatch
-
final
def
requireLevel(minAllowed: Level, clientType: String): RedisUnitCommand.this.type
- Definition Classes
- RawCommandPacks
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- RedisCommand → AnyRef → Any
-
def
transaction: RedisBatch[Unit]
Wraps this batch into a Redis transaction, i.e.
Wraps this batch into a Redis transaction, i.e. ensures that it's executed inside a
MULTI
-EXEC
block. NOTE: If you simply want to ensure atomicity, use atomic. NOTE: You can safely nest transactions, the driver will make sure that there are no nestedMULTI
-EXEC
blocks on the wire.- Definition Classes
- RedisBatch
-
def
transform[B](fun: (commons.Try[Unit]) ⇒ commons.Try[B]): RedisBatch[B]
- Definition Classes
- RedisBatch
-
def
tried: RedisBatch[commons.Try[Unit]]
- Definition Classes
- RedisBatch
-
def
updateWatchState(message: RedisMsg, state: WatchState): Unit
- Definition Classes
- RawCommand
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
final
def
whenEmpty(args: TraversableOnce[Any], value: Unit): commons.Opt[Unit]
- Attributes
- protected[this]
- Definition Classes
- RedisCommand
-
def
zip[B](other: RedisBatch[B]): RedisBatch[(Unit, B)]
- Definition Classes
- RedisBatch