Packages

trait RedisPubSub extends AnyRef

Annotations
@deprecated
Deprecated

(Since version 0.6.0) use the pure monix.connect.redis.client.RedisConnection

Source
RedisPubSub.scala
See also

The reference Lettuce Api at: io.lettuce.core.api.reactive.BaseRedisReactiveCommands

Linear Supertypes
AnyRef, Any
Known Subclasses
Redis, RedisPubSub
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. RedisPubSub
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

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 clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  6. def echo[K, V](msg: V)(implicit connection: StatefulRedisConnection[K, V]): Task[V]

    Echo the given string.

    Echo the given string.

    returns

    Bulk string reply.

  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  9. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  10. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  11. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  12. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  13. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  14. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  15. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  16. def ping[K, V]()(implicit connection: StatefulRedisConnection[K, V]): Task[String]

    Ping the server.

    Ping the server.

    returns

    Simple string reply.

  17. def publish[K, V](channel: K, message: V)(implicit connection: StatefulRedisConnection[K, V]): Task[Long]

    Post a message to a channel.

    Post a message to a channel.

    returns

    The number of clients that received the message.

  18. def pubsubChannels[K, V](channel: K)(implicit connection: StatefulRedisConnection[K, V]): Observable[K]

    Lists the currently *active channels*.

    Lists the currently *active channels*.

    returns

    The list of active channels, optionally matching the specified pattern.

  19. def pubsubChannels[K, V](implicit connection: StatefulRedisConnection[K, V]): Observable[K]

    Lists the currently *active channels*.

    Lists the currently *active channels*.

    returns

    List of active channels, optionally matching the specified pattern.

  20. def pubsubNumpat[K, V]()(implicit connection: StatefulRedisConnection[K, V]): Task[Long]

    Returns the number of subscriptions to patterns.

    Returns the number of subscriptions to patterns.

    returns

    The number of patterns all the clients are subscribed to.

  21. def pubsubNumsub[K, V](channels: K*)(implicit connection: StatefulRedisConnection[K, V]): Task[Map[K, Long]]

    Returns the number of subscribers (not counting clients subscribed to patterns) for the specified channels.

    Returns the number of subscribers (not counting clients subscribed to patterns) for the specified channels.

    returns

    The list of channels and number of subscribers for every channel. In this case long remains as java.lang.Long and not as as scala.Long, since traversing the map to convert values would imply performance implications

  22. def quit[K, V]()(implicit connection: StatefulRedisConnection[K, V]): Task[String]

    Instructs Redis to disconnect the connection.

    Instructs Redis to disconnect the connection. Note that if auto-reconnect is enabled then Lettuce will auto-reconnect if the connection was disconnected. Use io.lettuce.core.api.StatefulConnection#close to close connections and release resources.

    returns

    String simple string reply always OK.

  23. def readOnly[K, V]()(implicit connection: StatefulRedisConnection[K, V]): Task[String]

    Switch connection to Read-Only mode when connecting to a cluster.

    Switch connection to Read-Only mode when connecting to a cluster.

    returns

    Simple string reply.

  24. def readWrite[K, V]()(implicit connection: StatefulRedisConnection[K, V]): Task[String]

    Switch connection to Read-Write mode (default) when connecting to a cluster.

    Switch connection to Read-Write mode (default) when connecting to a cluster.

    returns

    Simple string reply.

  25. def role[K, V]()(implicit connection: StatefulRedisConnection[K, V]): Observable[Any]

    Return the role of the instance in the context of replication.

    Return the role of the instance in the context of replication.

    returns

    Object array-reply where the first element is one of master, slave, sentinel and the additional elements are role-specific.

  26. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  27. def toString(): String
    Definition Classes
    AnyRef → Any
  28. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  29. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  30. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  31. def waitForReplication[K, V](replicas: Int, timeout: Long)(implicit connection: StatefulRedisConnection[K, V]): Task[Long]

    Wait for replication.

    Wait for replication.

    returns

    Number of replicas

Inherited from AnyRef

Inherited from Any

Ungrouped