redis

RedisClientPool

case class RedisClientPool(redisServers: Seq[RedisServer], name: String = "RedisClientPool")(implicit _system: ActorSystem) extends RedisClientPoolLike with RedisCommands with Product with Serializable

Source
RedisPool.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. RedisClientPool
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. RedisCommands
  7. Server
  8. Connection
  9. Scripting
  10. Publish
  11. SortedSets
  12. Sets
  13. Lists
  14. Hashes
  15. Strings
  16. Keys
  17. Request
  18. RedisClientPoolLike
  19. RoundRobinPoolRequest
  20. AnyRef
  21. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new RedisClientPool(redisServers: Seq[RedisServer], name: String = "RedisClientPool")(implicit _system: ActorSystem)

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

    Definition Classes
    AnyRef → Any
  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. def append[V](key: String, value: V)(implicit arg0: ByteStringSerializer[V]): Future[Long]

    Definition Classes
    Strings
  7. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  8. def auth[V](value: V)(implicit arg0: ByteStringSerializer[V]): Future[Status]

    Definition Classes
    Connection
  9. def bgrewriteaof(): Future[String]

    Definition Classes
    Server
  10. def bgsave(): Future[String]

    Definition Classes
    Server
  11. def bitcount(key: String, start: Long, end: Long): Future[Long]

    Definition Classes
    Strings
  12. def bitcount(key: String): Future[Long]

    Definition Classes
    Strings
  13. def bitop(operation: BitOperator, destkey: String, keys: String*): Future[Long]

    Definition Classes
    Strings
  14. def bitopAND(destkey: String, keys: String*): Future[Long]

    Definition Classes
    Strings
  15. def bitopNOT(destkey: String, key: String): Future[Long]

    Definition Classes
    Strings
  16. def bitopOR(destkey: String, keys: String*): Future[Long]

    Definition Classes
    Strings
  17. def bitopXOR(destkey: String, keys: String*): Future[Long]

    Definition Classes
    Strings
  18. def broadcast[T](redisCommand: RedisCommand[_ <: RedisReply, T]): Seq[Future[T]]

    T
    redisCommand
    returns

    behave nicely with Future helpers like firstCompletedOf or sequence

    Definition Classes
    RoundRobinPoolRequest
  19. def clientGetname(): Future[Option[String]]

    Definition Classes
    Server
  20. def clientKill(ip: String, port: Int): Future[Boolean]

    Definition Classes
    Server
  21. def clientList(): Future[Seq[Map[String, String]]]

    Definition Classes
    Server
  22. def clientSetname(connectionName: String): Future[Boolean]

    Definition Classes
    Server
  23. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  24. def configGet(parameter: String): Future[Map[String, String]]

    Definition Classes
    Server
  25. def configResetstat(): Future[Boolean]

    Definition Classes
    Server
  26. def configSet(parameter: String, value: String): Future[Boolean]

    Definition Classes
    Server
  27. def dbsize(): Future[Long]

    Definition Classes
    Server
  28. def debugObject(key: String): Future[String]

    Definition Classes
    Server
  29. def debugSegfault(): Future[String]

    Definition Classes
    Server
  30. def decr(key: String): Future[Long]

    Definition Classes
    Strings
  31. def decrby(key: String, decrement: Long): Future[Long]

    Definition Classes
    Strings
  32. def del(keys: String*): Future[Long]

    Definition Classes
    Keys
  33. def dump[R](key: String)(implicit arg0: ByteStringDeserializer[R]): Future[Option[R]]

    Definition Classes
    Keys
  34. def echo[V, R](value: V)(implicit arg0: ByteStringSerializer[V], arg1: ByteStringDeserializer[R]): Future[Option[R]]

    Definition Classes
    Connection
  35. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  36. def eval(script: String, keys: Seq[String] = Seq.empty[String], args: Seq[String] = Seq.empty[String]): Future[RedisReply]

    Definition Classes
    Scripting
  37. def evalsha(sha1: String, keys: Seq[String] = Seq.empty[String], args: Seq[String] = Seq.empty[String]): Future[RedisReply]

    Definition Classes
    Scripting
  38. def evalshaOrEval(redisScript: RedisScript, keys: Seq[String] = Seq.empty[String], args: Seq[String] = Seq.empty[String]): Future[RedisReply]

    Try EVALSHA, if NOSCRIPT returned, fallback to EVAL

    Try EVALSHA, if NOSCRIPT returned, fallback to EVAL

    Definition Classes
    Scripting
  39. implicit val executionContext: ExecutionContext

  40. def exists(key: String): Future[Boolean]

    Definition Classes
    Keys
  41. def expire(key: String, seconds: Long): Future[Boolean]

    Definition Classes
    Keys
  42. def expireat(key: String, seconds: Long): Future[Boolean]

    Definition Classes
    Keys
  43. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  44. def flushall(): Future[Boolean]

    Definition Classes
    Server
  45. def flushdb(): Future[Boolean]

    Definition Classes
    Server
  46. def get[R](key: String)(implicit arg0: ByteStringDeserializer[R]): Future[Option[R]]

    Definition Classes
    Strings
  47. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  48. def getConnectOperations(server: RedisServer): () ⇒ Seq[Operation[_, _]]

    Definition Classes
    RedisClientPoolLike
  49. def getNextConnection: ActorRef

    Definition Classes
    RoundRobinPoolRequest
  50. def getbit(key: String, offset: Long): Future[Boolean]

    Definition Classes
    Strings
  51. def getrange[R](key: String, start: Long, end: Long)(implicit arg0: ByteStringDeserializer[R]): Future[Option[R]]

    Definition Classes
    Strings
  52. def getset[V, R](key: String, value: V)(implicit arg0: ByteStringSerializer[V], arg1: ByteStringDeserializer[R]): Future[Option[R]]

    Definition Classes
    Strings
  53. def hdel(key: String, fields: String*): Future[Long]

    Definition Classes
    Hashes
  54. def hexists(key: String, field: String): Future[Boolean]

    Definition Classes
    Hashes
  55. def hget[R](key: String, field: String)(implicit arg0: ByteStringDeserializer[R]): Future[Option[R]]

    Definition Classes
    Hashes
  56. def hgetall[R](key: String)(implicit arg0: ByteStringDeserializer[R]): Future[Map[String, R]]

    Definition Classes
    Hashes
  57. def hincrby(key: String, fields: String, increment: Long): Future[Long]

    Definition Classes
    Hashes
  58. def hincrbyfloat(key: String, fields: String, increment: Double): Future[Double]

    Definition Classes
    Hashes
  59. def hkeys(key: String): Future[Seq[String]]

    Definition Classes
    Hashes
  60. def hlen(key: String): Future[Long]

    Definition Classes
    Hashes
  61. def hmget[R](key: String, fields: String*)(implicit arg0: ByteStringDeserializer[R]): Future[Seq[Option[R]]]

    Definition Classes
    Hashes
  62. def hmset[V](key: String, keysValues: Map[String, V])(implicit arg0: ByteStringSerializer[V]): Future[Boolean]

    Definition Classes
    Hashes
  63. def hset[V](key: String, field: String, value: V)(implicit arg0: ByteStringSerializer[V]): Future[Boolean]

    Definition Classes
    Hashes
  64. def hsetnx[V](key: String, field: String, value: V)(implicit arg0: ByteStringSerializer[V]): Future[Boolean]

    Definition Classes
    Hashes
  65. def hvals[R](key: String)(implicit arg0: ByteStringDeserializer[R]): Future[Seq[R]]

    Definition Classes
    Hashes
  66. def incr(key: String): Future[Long]

    Definition Classes
    Strings
  67. def incrby(key: String, increment: Long): Future[Long]

    Definition Classes
    Strings
  68. def incrbyfloat(key: String, increment: Double): Future[Option[Double]]

    Definition Classes
    Strings
  69. def info(section: String): Future[String]

    Definition Classes
    Server
  70. def info(): Future[String]

    Definition Classes
    Server
  71. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  72. def keys(pattern: String): Future[Seq[String]]

    Definition Classes
    Keys
  73. def lastsave(): Future[Long]

    Definition Classes
    Server
  74. def lindex[R](key: String, index: Long)(implicit arg0: ByteStringDeserializer[R]): Future[Option[R]]

    Definition Classes
    Lists
  75. def linsert[V](key: String, beforeAfter: ListPivot, pivot: String, value: V)(implicit arg0: ByteStringSerializer[V]): Future[Long]

    Definition Classes
    Lists
  76. def linsertAfter[V](key: String, pivot: String, value: V)(implicit arg0: ByteStringSerializer[V]): Future[Long]

    Definition Classes
    Lists
  77. def linsertBefore[V](key: String, pivot: String, value: V)(implicit arg0: ByteStringSerializer[V]): Future[Long]

    Definition Classes
    Lists
  78. def llen(key: String): Future[Long]

    Definition Classes
    Lists
  79. def lpop[R](key: String)(implicit arg0: ByteStringDeserializer[R]): Future[Option[R]]

    Definition Classes
    Lists
  80. def lpush[V](key: String, values: V*)(implicit arg0: ByteStringSerializer[V]): Future[Long]

    Definition Classes
    Lists
  81. def lpushx[V](key: String, value: V)(implicit arg0: ByteStringSerializer[V]): Future[Long]

    Definition Classes
    Lists
  82. def lrange[R](key: String, start: Long, stop: Long)(implicit arg0: ByteStringDeserializer[R]): Future[Seq[R]]

    Definition Classes
    Lists
  83. def lrem[V](key: String, count: Long, value: V)(implicit arg0: ByteStringSerializer[V]): Future[Long]

    Definition Classes
    Lists
  84. def lset[V](key: String, index: Long, value: V)(implicit arg0: ByteStringSerializer[V]): Future[Boolean]

    Definition Classes
    Lists
  85. def ltrim(key: String, start: Long, stop: Long): Future[Boolean]

    Definition Classes
    Lists
  86. def mget[R](keys: String*)(implicit arg0: ByteStringDeserializer[R]): Future[Seq[Option[R]]]

    Definition Classes
    Strings
  87. def migrate(host: String, port: Int, key: String, destinationDB: Int, timeout: FiniteDuration): Future[Boolean]

    Definition Classes
    Keys
  88. def move(key: String, db: Int): Future[Boolean]

    Definition Classes
    Keys
  89. def mset[V](keysValues: Map[String, V])(implicit arg0: ByteStringSerializer[V]): Future[Boolean]

    Definition Classes
    Strings
  90. def msetnx[V](keysValues: Map[String, V])(implicit arg0: ByteStringSerializer[V]): Future[Boolean]

    Definition Classes
    Strings
  91. val name: String

    Definition Classes
    RedisClientPoolRedisClientPoolLike
  92. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  93. val next: AtomicInteger

    Definition Classes
    RoundRobinPoolRequest
  94. final def notify(): Unit

    Definition Classes
    AnyRef
  95. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  96. def objectEncoding(key: String): Future[Option[String]]

    Definition Classes
    Keys
  97. def objectIdletime(key: String): Future[Option[Long]]

    Definition Classes
    Keys
  98. def objectRefcount(key: String): Future[Option[Long]]

    Definition Classes
    Keys
  99. def onConnect(redis: RedisCommands, server: RedisServer): Unit

    Definition Classes
    RedisClientPoolLike
  100. def persist(key: String): Future[Boolean]

    Definition Classes
    Keys
  101. def pexpire(key: String, milliseconds: Long): Future[Boolean]

    Definition Classes
    Keys
  102. def pexpireat(key: String, millisecondsTimestamp: Long): Future[Boolean]

    Definition Classes
    Keys
  103. def ping(): Future[String]

    Definition Classes
    Connection
  104. def psetex[V](key: String, milliseconds: Long, value: V)(implicit arg0: ByteStringSerializer[V]): Future[Boolean]

    Definition Classes
    Strings
  105. def pttl(key: String): Future[Long]

    Definition Classes
    Keys
  106. def publish[V](channel: String, value: V)(implicit arg0: ByteStringSerializer[V]): Future[Long]

    Definition Classes
    Publish
  107. def quit(): Future[Boolean]

    Definition Classes
    Connection
  108. def randomkey[R]()(implicit arg0: ByteStringDeserializer[R]): Future[Option[R]]

    Definition Classes
    Keys
  109. val redisConnectionPool: Seq[ActorRef]

  110. val redisServers: Seq[RedisServer]

    Definition Classes
    RedisClientPoolRedisClientPoolLike
  111. def rename(key: String, newkey: String): Future[Boolean]

    Definition Classes
    Keys
  112. def renamenx(key: String, newkey: String): Future[Boolean]

    Definition Classes
    Keys
  113. def restore[V](key: String, ttl: Long = 0, serializedValue: V)(implicit arg0: ByteStringSerializer[V]): Future[Boolean]

    Definition Classes
    Keys
  114. def rpop[R](key: String)(implicit arg0: ByteStringDeserializer[R]): Future[Option[R]]

    Definition Classes
    Lists
  115. def rpoplpush[R](source: String, destination: String)(implicit arg0: ByteStringDeserializer[R]): Future[Option[R]]

    Definition Classes
    Lists
  116. def rpush[V](key: String, values: V*)(implicit arg0: ByteStringSerializer[V]): Future[Long]

    Definition Classes
    Lists
  117. def rpushx[V](key: String, value: V)(implicit arg0: ByteStringSerializer[V]): Future[Long]

    Definition Classes
    Lists
  118. def sadd[V](key: String, members: V*)(implicit arg0: ByteStringSerializer[V]): Future[Long]

    Definition Classes
    Sets
  119. def save(): Future[Boolean]

    Definition Classes
    Server
  120. def scard(key: String): Future[Long]

    Definition Classes
    Sets
  121. def scriptExists(sha1: String*): Future[Seq[Boolean]]

    Definition Classes
    Scripting
  122. def scriptFlush(): Future[Boolean]

    Definition Classes
    Scripting
  123. def scriptKill(): Future[Boolean]

    Definition Classes
    Scripting
  124. def scriptLoad(script: String): Future[String]

    Definition Classes
    Scripting
  125. def sdiff[R](key: String, keys: String*)(implicit arg0: ByteStringDeserializer[R]): Future[Seq[R]]

    Definition Classes
    Sets
  126. def sdiffstore(destination: String, key: String, keys: String*): Future[Long]

    Definition Classes
    Sets
  127. def select(index: Int): Future[Boolean]

    Definition Classes
    Connection
  128. def send[T](redisCommand: RedisCommand[_ <: RedisReply, T]): Future[T]

    Definition Classes
    RoundRobinPoolRequest
  129. def set[V](key: String, value: V, exSeconds: Option[Long] = None, pxMilliseconds: Option[Long] = None, NX: Boolean = false, XX: Boolean = false)(implicit arg0: ByteStringSerializer[V]): Future[Boolean]

    Definition Classes
    Strings
  130. def setbit(key: String, offset: Long, value: Boolean): Future[Boolean]

    Definition Classes
    Strings
  131. def setex[V](key: String, seconds: Long, value: V)(implicit arg0: ByteStringSerializer[V]): Future[Boolean]

    Definition Classes
    Strings
  132. def setnx[V](key: String, value: V)(implicit arg0: ByteStringSerializer[V]): Future[Boolean]

    Definition Classes
    Strings
  133. def setrange[V](key: String, offset: Long, value: V)(implicit arg0: ByteStringSerializer[V]): Future[Long]

    Definition Classes
    Strings
  134. def shutdown(modifier: ShutdownModifier): Future[Boolean]

    Definition Classes
    Server
  135. def shutdown(): Future[Boolean]

    Definition Classes
    Server
  136. def sinter[R](key: String, keys: String*)(implicit arg0: ByteStringDeserializer[R]): Future[Seq[R]]

    Definition Classes
    Sets
  137. def sinterstore(destination: String, key: String, keys: String*): Future[Long]

    Definition Classes
    Sets
  138. def sismember[V](key: String, member: V)(implicit arg0: ByteStringSerializer[V]): Future[Boolean]

    Definition Classes
    Sets
  139. def slaveof(host: String, port: Int): Future[Boolean]

    Definition Classes
    Server
  140. def slaveofNoOne(): Future[Boolean]

    Definition Classes
    Server
  141. def smembers[R](key: String)(implicit arg0: ByteStringDeserializer[R]): Future[Seq[R]]

    Definition Classes
    Sets
  142. def smove[V](source: String, destination: String, member: V)(implicit arg0: ByteStringSerializer[V]): Future[Boolean]

    Definition Classes
    Sets
  143. def sort[R](key: String, byPattern: Option[String] = None, limit: Option[LimitOffsetCount] = None, getPatterns: Seq[String] = Seq(), order: Option[Order] = None, alpha: Boolean = false)(implicit arg0: ByteStringDeserializer[R]): Future[Seq[R]]

    Definition Classes
    Keys
  144. def sortStore(key: String, byPattern: Option[String] = None, limit: Option[LimitOffsetCount] = None, getPatterns: Seq[String] = Seq(), order: Option[Order] = None, alpha: Boolean = false, store: String): Future[Long]

    Definition Classes
    Keys
  145. def spop[R](key: String)(implicit arg0: ByteStringDeserializer[R]): Future[Option[R]]

    Definition Classes
    Sets
  146. def srandmember[R](key: String, count: Long)(implicit arg0: ByteStringDeserializer[R]): Future[Seq[R]]

    Definition Classes
    Sets
  147. def srandmember[R](key: String)(implicit arg0: ByteStringDeserializer[R]): Future[Option[R]]

    Definition Classes
    Sets
  148. def srem[V](key: String, members: V*)(implicit arg0: ByteStringSerializer[V]): Future[Long]

    Definition Classes
    Sets
  149. def stop(): Unit

    Disconnect from the server (stop the actor)

    Disconnect from the server (stop the actor)

    Definition Classes
    RedisClientPoolLike
  150. def strlen(key: String): Future[Long]

    Definition Classes
    Strings
  151. def sunion[R](key: String, keys: String*)(implicit arg0: ByteStringDeserializer[R]): Future[Seq[R]]

    Definition Classes
    Sets
  152. def sunionstore(destination: String, key: String, keys: String*): Future[Long]

    Definition Classes
    Sets
  153. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  154. def time(): Future[(Long, Long)]

    Definition Classes
    Server
  155. def ttl(key: String): Future[Long]

    Definition Classes
    Keys
  156. def type(key: String): Future[String]

    Definition Classes
    Keys
  157. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  158. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  159. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  160. def zadd[V](key: String, scoreMembers: (Double, V)*)(implicit arg0: ByteStringSerializer[V]): Future[Long]

    Definition Classes
    SortedSets
  161. def zcard(key: String): Future[Long]

    Definition Classes
    SortedSets
  162. def zcount(key: String, min: Limit = Limit(Double.NegativeInfinity), max: Limit = Limit(Double.PositiveInfinity)): Future[Long]

    Definition Classes
    SortedSets
  163. def zincrby[V](key: String, increment: Double, member: V)(implicit arg0: ByteStringSerializer[V]): Future[Double]

    Definition Classes
    SortedSets
  164. def zinterstore(destination: String, key: String, keys: Seq[String], aggregate: Aggregate = SUM): Future[Long]

    Definition Classes
    SortedSets
  165. def zinterstoreWeighted(destination: String, keys: Map[String, Double], aggregate: Aggregate = SUM): Future[Long]

    Definition Classes
    SortedSets
  166. def zrange[R](key: String, start: Long, stop: Long)(implicit arg0: ByteStringDeserializer[R]): Future[Seq[R]]

    Definition Classes
    SortedSets
  167. def zrangeWithscores[R](key: String, start: Long, stop: Long)(implicit arg0: ByteStringDeserializer[R]): Future[Seq[(R, Double)]]

    Definition Classes
    SortedSets
  168. def zrangebyscore[R](key: String, min: Limit, max: Limit, limit: Option[(Long, Long)] = None)(implicit arg0: ByteStringDeserializer[R]): Future[Seq[R]]

    Definition Classes
    SortedSets
  169. def zrangebyscoreWithscores[R](key: String, min: Limit, max: Limit, limit: Option[(Long, Long)] = None)(implicit arg0: ByteStringDeserializer[R]): Future[Seq[(R, Double)]]

    Definition Classes
    SortedSets
  170. def zrank[V](key: String, member: V)(implicit arg0: ByteStringSerializer[V]): Future[Option[Long]]

    Definition Classes
    SortedSets
  171. def zrem[V](key: String, members: V*)(implicit arg0: ByteStringSerializer[V]): Future[Long]

    Definition Classes
    SortedSets
  172. def zremrangebyrank(key: String, start: Long, stop: Long): Future[Long]

    Definition Classes
    SortedSets
  173. def zremrangebyscore(key: String, min: Limit, max: Limit): Future[Long]

    Definition Classes
    SortedSets
  174. def zrevrange[R](key: String, start: Long, stop: Long)(implicit arg0: ByteStringDeserializer[R]): Future[Seq[R]]

    Definition Classes
    SortedSets
  175. def zrevrangeWithscores[R](key: String, start: Long, stop: Long)(implicit arg0: ByteStringDeserializer[R]): Future[Seq[(R, Double)]]

    Definition Classes
    SortedSets
  176. def zrevrangebyscore[R](key: String, min: Limit, max: Limit, limit: Option[(Long, Long)] = None)(implicit arg0: ByteStringDeserializer[R]): Future[Seq[R]]

    Definition Classes
    SortedSets
  177. def zrevrangebyscoreWithscores[R](key: String, min: Limit, max: Limit, limit: Option[(Long, Long)] = None)(implicit arg0: ByteStringDeserializer[R]): Future[Seq[(R, Double)]]

    Definition Classes
    SortedSets
  178. def zrevrank[V](key: String, member: V)(implicit arg0: ByteStringSerializer[V]): Future[Option[Long]]

    Definition Classes
    SortedSets
  179. def zscore[V](key: String, member: V)(implicit arg0: ByteStringSerializer[V]): Future[Option[Double]]

    Definition Classes
    SortedSets
  180. def zunionstore(destination: String, key: String, keys: Seq[String], aggregate: Aggregate = SUM): Future[Long]

    Definition Classes
    SortedSets
  181. def zunionstoreWeighted(destination: String, keys: Map[String, Double], aggregate: Aggregate = SUM): Future[Long]

    Definition Classes
    SortedSets

Inherited from Serializable

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from RedisCommands

Inherited from Server

Inherited from Connection

Inherited from Scripting

Inherited from Publish

Inherited from SortedSets

Inherited from Sets

Inherited from Lists

Inherited from Hashes

Inherited from Strings

Inherited from Keys

Inherited from Request

Inherited from RedisClientPoolLike

Inherited from RoundRobinPoolRequest

Inherited from AnyRef

Inherited from Any

Ungrouped