object RedisStream extends RedisStream
Exposes only methods from the RedisStream api
- Annotations
- @deprecated
- Deprecated
(Since version 0.6.0) use the pure
monix.connect.redis.client.RedisConnection- Source
- RedisStream.scala
- Alphabetic
- By Inheritance
- RedisStream
- RedisStream
- 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()
- 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()
- 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 xack[K, V](key: K, group: K, messageIds: String*)(implicit connection: StatefulRedisConnection[K, V]): Task[Long]
Acknowledge one or more messages as processed.
Acknowledge one or more messages as processed.
- returns
simple-reply the lenght of acknowledged messages.
- Definition Classes
- RedisStream
- def xadd[K, V](key: K, body: Map[K, V])(implicit connection: StatefulRedisConnection[K, V]): Task[String]
Append a message to the stream key.
- def xclaim[K, V](key: K, consumer: Consumer[K], minIdleTime: Long, messageIds: String*)(implicit connection: StatefulRedisConnection[K, V]): Observable[StreamMessage[K, V]]
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.
- returns
simple-reply the { @link StreamMessage}
- Definition Classes
- RedisStream
- def xdel[K, V](key: K, messageIds: String*)(implicit connection: StatefulRedisConnection[K, V]): Task[String]
Removes the specified entries from the stream.
Removes the specified entries from the stream. Returns the number of items deleted, that may be different from the number of IDs passed in case certain IDs do not exist.
- returns
simple-reply number of removed entries.
- Definition Classes
- RedisStream
- def xgroupCreate[K, V](streamOffset: StreamOffset[K], group: K)(implicit connection: StatefulRedisConnection[K, V]): Task[String]
Create a consumer group.
Create a consumer group.
- returns
simple-reply { @literal true} if successful.
- Definition Classes
- RedisStream
- def xgroupDelconsumer[K, V](key: K, consumer: Consumer[K])(implicit connection: StatefulRedisConnection[K, V]): Task[Long]
Delete a consumer from a consumer group.
Delete a consumer from a consumer group.
- returns
simple-reply { @literal true} if successful.
- Definition Classes
- RedisStream
- def xgroupDestroy[K, V](key: K, group: K)(implicit connection: StatefulRedisConnection[K, V]): Task[Boolean]
Destroy a consumer group.
Destroy a consumer group.
- returns
simple-reply { @literal true} if successful.
- Definition Classes
- RedisStream
- def xgroupSetid[K, V](streamOffset: StreamOffset[K], group: K)(implicit connection: StatefulRedisConnection[K, V]): Task[String]
Set the current group id.
- def xlen[K, V](key: K)(implicit connection: StatefulRedisConnection[K, V]): Task[Long]
Get the length of a steam.
Get the length of a steam.
- returns
simple-reply the lenght of the stream.
- Definition Classes
- RedisStream
- def xpending[K, V](key: K, consumer: Consumer[K], range: Range[String], limit: Limit)(implicit connection: StatefulRedisConnection[K, V]): Observable[Any]
Read pending messages from a stream within a specific Range.
Read pending messages from a stream within a specific Range.
- returns
List<Object> array-reply list with members of the resulting stream.
- Definition Classes
- RedisStream
- def xpending[K, V](key: K, group: K, range: Range[String], limit: Limit)(implicit connection: StatefulRedisConnection[K, V]): Observable[Any]
Read pending messages from a stream within a specific Range.
Read pending messages from a stream within a specific Range.
- returns
List<Object> array-reply list with members of the resulting stream.
- Definition Classes
- RedisStream
- def xpending[K, V](key: K, group: K)(implicit connection: StatefulRedisConnection[K, V]): Observable[Any]
Read pending messages from a stream for a group.
Read pending messages from a stream for a group.
- returns
List<Object> array-reply list pending entries.
- Definition Classes
- RedisStream
- def xrange[K, V](key: K, range: Range[String], limit: Limit)(implicit connection: StatefulRedisConnection[K, V]): Observable[StreamMessage[K, V]]
Read messages from a stream within a specific Range applying a Limit.
Read messages from a stream within a specific Range applying a Limit.
- returns
Members of the resulting stream.
- Definition Classes
- RedisStream
- def xrange[K, V](key: K, range: Range[String])(implicit connection: StatefulRedisConnection[K, V]): Observable[StreamMessage[K, V]]
Read messages from a stream within a specific Range.
Read messages from a stream within a specific Range.
- returns
Members of the resulting stream.
- Definition Classes
- RedisStream
- def xread[K, V](streams: StreamOffset[K]*)(implicit connection: StatefulRedisConnection[K, V]): Observable[StreamMessage[K, V]]
Read messages from one or more StreamOffsets.
Read messages from one or more StreamOffsets.
- returns
Members of the resulting stream.
- Definition Classes
- RedisStream
- def xreadgroup[K, V](consumer: Consumer[K], streams: StreamOffset[K]*)(implicit connection: StatefulRedisConnection[K, V]): Observable[StreamMessage[K, V]]
Read messages from one or more StreamOffsets using a consumer group.
Read messages from one or more StreamOffsets using a consumer group.
- returns
List<StreamMessage> array-reply list with members of the resulting stream.
- Definition Classes
- RedisStream
- def xrevrange[K, V](key: K, range: Range[String], limit: Limit)(implicit connection: StatefulRedisConnection[K, V]): Observable[StreamMessage[K, V]]
Read messages from a stream within a specific Range applying a Limit in reverse order.
Read messages from a stream within a specific Range applying a Limit in reverse order.
- returns
Meembers of the resulting stream.
- Definition Classes
- RedisStream
- def xrevrange[K, V](key: K, range: Range[String])(implicit connection: StatefulRedisConnection[K, V]): Observable[StreamMessage[K, V]]
Read messages from a stream within a specific Range in reverse order.
Read messages from a stream within a specific Range in reverse order.
- returns
Members of the resulting stream.
- Definition Classes
- RedisStream
- def xtrim[K, V](key: K, approximateTrimming: Boolean, count: Long)(implicit connection: StatefulRedisConnection[K, V]): Task[Long]
Trims the stream to count elements.
- def xtrim[K, V](key: K, count: Long)(implicit connection: StatefulRedisConnection[K, V]): Task[Long]
Trims the stream to count elements.