Packages

class RedisConnection extends ReadStream[Response]

A simple Redis client.

Linear Supertypes
ReadStream[Response], StreamBase, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. RedisConnection
  2. ReadStream
  3. StreamBase
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new RedisConnection(_asJava: AnyRef)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def asJava: AnyRef
    Definition Classes
    RedisConnection → ReadStream → StreamBase
  6. def batch(commands: Buffer[Request], onSend: Handler[AsyncResult[Buffer[Option[Response]]]]): RedisConnection

    Sends a list of commands in a single IO operation, this prevents any inter twinning to happen from other client users.

    Sends a list of commands in a single IO operation, this prevents any inter twinning to happen from other client users. * @param commands list of command to send

    onSend

    the asynchronous result handler.

    returns

    fluent self.

  7. def batchFuture(commands: Buffer[Request]): Future[Buffer[Option[Response]]]

    Like batch but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.

  8. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  9. def close(): Unit

    Closes the connection or returns to the pool.

  10. def endHandler(endHandler: Handler[Unit]): RedisConnection

    Definition Classes
    RedisConnection → ReadStream
  11. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  12. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  13. def exceptionHandler(handler: Handler[Throwable]): RedisConnection

    Definition Classes
    RedisConnection → ReadStream → StreamBase
  14. def fetch(amount: Long): RedisConnection

    Definition Classes
    RedisConnection → ReadStream
  15. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  16. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  17. def handler(handler: Handler[Response]): RedisConnection

    Definition Classes
    RedisConnection → ReadStream
  18. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  19. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  20. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  21. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  22. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  23. def pause(): RedisConnection

    Definition Classes
    RedisConnection → ReadStream
  24. def pendingQueueFull(): Boolean

    Flag to notify if the pending message queue (commands in transit) is full.

    Flag to notify if the pending message queue (commands in transit) is full.

    When the pending message queue is full and a new send command is issued it will result in a exception to be thrown. Checking this flag before sending can allow the application to wait before sending the next message. * @return true is queue is full.

  25. def pipe(): Pipe[Response]
    Definition Classes
    RedisConnection → ReadStream
  26. def pipeTo(dst: WriteStream[Response], handler: Handler[AsyncResult[Unit]]): Unit
    Definition Classes
    RedisConnection → ReadStream
  27. def pipeTo(dst: WriteStream[Response]): Unit
    Definition Classes
    RedisConnection → ReadStream
  28. def pipeToFuture(dst: WriteStream[Response]): Future[Unit]
    Definition Classes
    RedisConnection → ReadStream
  29. def resume(): RedisConnection

    Definition Classes
    RedisConnection → ReadStream
  30. def send(command: Request, onSend: Handler[AsyncResult[Option[Response]]]): RedisConnection

    Send the given command to the redis server or cluster.

    Send the given command to the redis server or cluster. * @param command the command to send

    onSend

    the asynchronous result handler.

    returns

    fluent self.

  31. def sendFuture(command: Request): Future[Option[Response]]

    Like send but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.

  32. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  33. def toString(): String
    Definition Classes
    AnyRef → Any
  34. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  35. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  36. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )

Inherited from ReadStream[Response]

Inherited from StreamBase

Inherited from AnyRef

Inherited from Any

Ungrouped