trait UnsafeCommand extends RawCommand
Linear Supertypes
Known Subclasses
Ordering
- Alphabetic
- By Inheritance
Inherited
- UnsafeCommand
- RawCommand
- ReplyPreprocessor
- RawCommands
- RawCommandPack
- RawCommandPacks
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Type Members
-
type
Encoded = ArrayMsg[BulkStringMsg]
- Definition Classes
- RawCommand
Abstract Value Members
-
abstract
def
encoded: Encoded
- Definition Classes
- RawCommand
Concrete Value Members
-
final
def
checkLevel(minAllowed: Level, clientType: String): Unit
- Definition Classes
- RawCommand → RawCommandPack
-
final
def
computeSize(limit: Int): Int
- Definition Classes
- RawCommandPack → RawCommandPacks
-
final
def
createPreprocessor(replyCount: Int): RawCommand
- Definition Classes
- RawCommand → RawCommandPack
-
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
foreachKey(consumer: (ByteString) ⇒ Unit): Unit
- Definition Classes
- RawCommandPacks
-
final
def
isAsking: Boolean
- Definition Classes
- RawCommand → RawCommandPack
-
final
def
level: Level
- Definition Classes
- UnsafeCommand → RawCommand
-
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
preprocess(message: RedisMsg, state: WatchState): commons.Opt[RedisMsg]
- Definition Classes
- RawCommand → ReplyPreprocessor
-
final
def
rawCommands(inTransaction: Boolean): RawCommand
- Definition Classes
- RawCommand → RawCommandPack
-
final
def
requireLevel(minAllowed: Level, clientType: String): UnsafeCommand.this.type
- Definition Classes
- RawCommandPacks
-
def
updateWatchState(message: RedisMsg, state: WatchState): Unit
- Definition Classes
- RawCommand