Packages

c

com.avsystem.commons.redis

AbstractRedisCommand

abstract class AbstractRedisCommand[A] extends RedisCommand[A]

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. AbstractRedisCommand
  2. RedisCommand
  3. RawCommand
  4. ReplyPreprocessor
  5. RawCommands
  6. SinglePackBatch
  7. RawCommandPack
  8. RawCommandPacks
  9. RedisBatch
  10. AnyRef
  11. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new AbstractRedisCommand(decodeExpected: ReplyDecoder[A])

Type Members

  1. type Encoded = ArrayMsg[BulkStringMsg]
    Definition Classes
    RawCommand

Abstract Value Members

  1. abstract def encoded: Encoded
    Definition Classes
    RawCommand
  2. abstract def level: Level
    Definition Classes
    RawCommand

Concrete Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. 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
  4. def <*[B](other: RedisBatch[B]): RedisBatch[A]

    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
  5. def <*>[B, C](other: RedisBatch[B])(f: (A, 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
  6. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  7. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  8. def asking: RedisBatch[A]

    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
  9. def atomic: RedisBatch[A]

    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
  10. final def batchOrFallback: RedisBatch[A]
    Definition Classes
    RedisCommand
  11. final def checkLevel(minAllowed: Level, clientType: String): Unit
    Definition Classes
    RawCommand → RawCommandPack
  12. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  13. final def computeSize(limit: Int): Int
    Definition Classes
    RawCommandPack → RawCommandPacks
  14. final def createPreprocessor(replyCount: Int): RawCommand
    Definition Classes
    RawCommand → RawCommandPack
  15. final def decode(replyMsg: RedisReply): A
    Attributes
    protected
    Definition Classes
    RedisCommand
  16. val decodeExpected: ReplyDecoder[A]
    Attributes
    protected
    Definition Classes
    AbstractRedisCommand → RedisCommand
  17. final def decodeReplies(replies: (Int) ⇒ RedisReply, idx: Index, inTransaction: Boolean): A
    Definition Classes
    RedisCommand → RedisBatch
  18. final def emitCommandPacks(consumer: (RawCommandPack) ⇒ Unit): Unit
    Definition Classes
    RawCommandPack → RawCommandPacks
  19. final def emitCommands(consumer: (RawCommand) ⇒ Unit): Unit
    Definition Classes
    RawCommand → RawCommands
  20. final def encodedSize: Int
    Definition Classes
    RawCommandPacks
  21. final def encoder(command: String, subcommand: String): CommandEncoder
    Attributes
    protected
    Definition Classes
    RawCommand
  22. final def encoder(command: String): CommandEncoder
    Attributes
    protected
    Definition Classes
    RawCommand
  23. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  24. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  25. def failed: RedisBatch[Throwable]
    Definition Classes
    RedisBatch
  26. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  27. final def foreachKey(consumer: (ByteString) ⇒ Unit): Unit
    Definition Classes
    RawCommandPacks
  28. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  29. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  30. def ignoreFailures: RedisBatch[Unit]
    Definition Classes
    RedisBatch
  31. def immediateResult: commons.Opt[A]

    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
  32. final def isAsking: Boolean
    Definition Classes
    RawCommand → RawCommandPack
  33. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  34. def map[B](fun: (A) ⇒ B): RedisCommand[B]
    Definition Classes
    RedisCommand → RedisBatch
  35. def map2[B, C](other: RedisBatch[B])(f: (A, 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
  36. 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
  37. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  38. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  39. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  40. def operation: RedisOp[A]

    Transforms this batch into a RedisOp.

    Transforms this batch into a RedisOp.

    Definition Classes
    RedisBatch
  41. final def preprocess(message: RedisMsg, state: WatchState): commons.Opt[RedisMsg]
    Definition Classes
    RawCommand → ReplyPreprocessor
  42. final def rawCommandPacks: RawCommandPacks
    Definition Classes
    SinglePackBatch → RedisBatch
  43. final def rawCommands(inTransaction: Boolean): RawCommand
    Definition Classes
    RawCommand → RawCommandPack
  44. def recover[B >: A](f: PartialFunction[Throwable, B]): RedisBatch[B]
    Definition Classes
    RedisBatch
  45. final def requireLevel(minAllowed: Level, clientType: String): AbstractRedisCommand.this.type
    Definition Classes
    RawCommandPacks
  46. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  47. def toString(): String
    Definition Classes
    RedisCommand → AnyRef → Any
  48. def transaction: RedisBatch[A]

    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 nested MULTI-EXEC blocks on the wire.

    Definition Classes
    RedisBatch
  49. def transform[B](fun: (commons.Try[A]) ⇒ commons.Try[B]): RedisBatch[B]
    Definition Classes
    RedisBatch
  50. def tried: RedisBatch[commons.Try[A]]
    Definition Classes
    RedisBatch
  51. def updateWatchState(message: RedisMsg, state: WatchState): Unit
    Definition Classes
    RawCommand
  52. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  53. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  54. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  55. final def whenEmpty(args: TraversableOnce[Any], value: A): commons.Opt[A]
    Attributes
    protected[this]
    Definition Classes
    RedisCommand
  56. def zip[B](other: RedisBatch[B]): RedisBatch[(A, B)]
    Definition Classes
    RedisBatch

Inherited from RedisCommand[A]

Inherited from RawCommand

Inherited from ReplyPreprocessor

Inherited from RawCommands

Inherited from SinglePackBatch[A]

Inherited from RawCommandPack

Inherited from RawCommandPacks

Inherited from RedisBatch[A]

Inherited from AnyRef

Inherited from Any

Ungrouped