object RedisPubSub extends RedisPubSub
- Annotations
- @deprecated
- Deprecated
(Since version 0.6.0) use the pure
monix.connect.redis.client.RedisConnection- Source
- RedisPubSub.scala
- Alphabetic
- By Inheritance
- RedisPubSub
- RedisPubSub
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def echo[K, V](msg: V)(implicit connection: StatefulRedisConnection[K, V]): Task[V]
Echo the given string.
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def ping[K, V]()(implicit connection: StatefulRedisConnection[K, V]): Task[String]
Ping the server.
- 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.
- Definition Classes
- RedisPubSub
- 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.
- Definition Classes
- RedisPubSub
- 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.
- Definition Classes
- RedisPubSub
- 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.
- Definition Classes
- RedisPubSub
- 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
- Definition Classes
- RedisPubSub
- 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#closeto close connections and release resources.- returns
String simple string reply always OK.
- Definition Classes
- RedisPubSub
- 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.
- Definition Classes
- RedisPubSub
- 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.
- Definition Classes
- RedisPubSub
- 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.
- Definition Classes
- RedisPubSub
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- def waitForReplication[K, V](replicas: Int, timeout: Long)(implicit connection: StatefulRedisConnection[K, V]): Task[Long]
Wait for replication.