trait StreamsApi extends ApiSubset
Linear Supertypes
Known Subclasses
Ordering
- Alphabetic
- By Inheritance
Inherited
- StreamsApi
- ApiSubset
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Type Members
-
type
Field = RedisSerialization.Field
- Definition Classes
- ApiSubset
-
type
Key = RedisSerialization.Key
- Definition Classes
- ApiSubset
-
type
Record = RedisSerialization.Record
- Definition Classes
- ApiSubset
-
abstract
type
Result[A]
The type constructor into which a result of each command is wrapped.
-
type
Value = RedisSerialization.Value
- Definition Classes
- ApiSubset
- type XEntry = commands.XEntry[Record]
Abstract Value Members
-
abstract
def
execute[A](command: RedisCommand[A]): Result[A]
- Definition Classes
- ApiSubset
-
abstract
val
serialization: RedisSerialization
- Definition Classes
- ApiSubset
Concrete Value Members
-
def
xack(key: Key, group: XGroup, ids: Iterable[XEntryId]): Result[Int]
Executes XACK
-
def
xack(key: Key, group: XGroup, id: XEntryId, ids: XEntryId*): Result[Int]
Executes XACK
-
def
xack(key: Key, group: XGroup, id: XEntryId): Result[Boolean]
Executes XACK
-
def
xadd(key: Key, data: Record, id: commons.OptArg[XEntryId] = OptArg.Empty, maxlen: commons.OptArg[XMaxlen] = OptArg.Empty): Result[XEntryId]
Executes XADD
-
def
xaddEntry(key: Key, entry: XEntry, maxlen: commons.OptArg[XMaxlen] = OptArg.Empty): Result[XEntryId]
Executes XADD
-
def
xclaim(key: Key, group: XGroup, consumer: XConsumer, minIdleMillis: Long, ids: Iterable[XEntryId], idleMillis: commons.OptArg[Long] = OptArg.Empty, msUnixTime: commons.OptArg[Long] = OptArg.Empty, retrycount: commons.OptArg[Int] = OptArg.Empty, force: Boolean = false): Result[Seq[XEntry]]
Executes XCLAIM
-
def
xclaimJustid(key: Key, group: XGroup, consumer: XConsumer, minIdleMillis: Long, ids: Iterable[XEntryId], idleMillis: commons.OptArg[Long] = OptArg.Empty, msUnixTime: commons.OptArg[Long] = OptArg.Empty, retrycount: commons.OptArg[Int] = OptArg.Empty, force: Boolean = false): Result[Seq[XEntryId]]
Executes XCLAIM
-
def
xclaimSingle(key: Key, group: XGroup, consumer: XConsumer, minIdleMillis: Long, id: XEntryId, idleMillis: commons.OptArg[Long] = OptArg.Empty, msUnixTime: commons.OptArg[Long] = OptArg.Empty, retrycount: commons.OptArg[Int] = OptArg.Empty, force: Boolean = false): Result[commons.Opt[XEntry]]
Executes XCLAIM
-
def
xdel(key: Key, ids: Iterable[XEntryId]): Result[Long]
Executes XDEL
-
def
xdel(key: Key, id: XEntryId, ids: XEntryId*): Result[Long]
Executes XDEL
-
def
xdel(key: Key, id: XEntryId): Result[Boolean]
Executes XDEL
-
def
xgroupCreate(key: Key, group: XGroup, id: commons.OptArg[XEntryId] = OptArg.Empty, mkstream: Boolean = false): Result[Unit]
Executes XGROUP CREATE
-
def
xgroupDelconsumer(key: Key, group: XGroup, consumer: XConsumer): Result[Boolean]
Executes XGROUP DELCONSUMER
-
def
xgroupDestroy(key: Key, group: XGroup): Result[Boolean]
Executes XGROUP DESTROY
-
def
xgroupSetid(key: Key, group: XGroup, id: commons.OptArg[XEntryId] = OptArg.Empty): Result[Unit]
Executes XGROUP SETID
-
def
xinfoConsumers(key: Key, group: XGroup): Result[Seq[XConsumerInfo]]
Executes XINFO CONSUMERS
-
def
xinfoGroups(key: Key): Result[Seq[XGroupInfo]]
Executes XINFO GROUPS
-
def
xinfoStream(key: Key): Result[XStreamInfo[Record]]
Executes XINFO STREAM
-
def
xlen(key: Key): Result[Long]
Executes XLEN
-
def
xpending(key: Key, group: XGroup): Result[XPendingOverview]
Executes XPENDING
-
def
xpendingEntries(key: Key, group: XGroup, count: Int, start: commons.OptArg[XEntryId] = OptArg.Empty, end: commons.OptArg[XEntryId] = OptArg.Empty, consumer: commons.OptArg[XConsumer] = OptArg.Empty): Result[Seq[XPendingEntry]]
Executes XPENDING
-
def
xrange(key: Key, start: commons.OptArg[XEntryId] = OptArg.Empty, end: commons.OptArg[XEntryId] = OptArg.Empty, count: commons.OptArg[Int] = OptArg.Empty): Result[Seq[XEntry]]
Executes XRANGE
-
def
xread(streams: Iterable[(Key, commons.Opt[XEntryId])], blockMillis: commons.OptArg[Int] = OptArg.Empty, count: commons.OptArg[Int] = OptArg.Empty): Result[commons.BMap[Key, Seq[XEntry]]]
Executes XREAD
-
def
xreadSingle(key: Key, id: commons.Opt[XEntryId], blockMillis: commons.OptArg[Int] = OptArg.Empty, count: commons.OptArg[Int] = OptArg.Empty): Result[Seq[XEntry]]
Executes XREAD
-
def
xreadgroup(group: XGroup, consumer: XConsumer, streams: Iterable[(Key, commons.Opt[XEntryId])], blockMillis: commons.OptArg[Int] = OptArg.Empty, count: commons.OptArg[Int] = OptArg.Empty): Result[commons.BMap[Key, Seq[XEntry]]]
Executes XREADGROUP
-
def
xreadgroupSingle(key: Key, group: XGroup, consumer: XConsumer, id: commons.OptArg[XEntryId] = OptArg.Empty, blockMillis: commons.OptArg[Int] = OptArg.Empty, count: commons.OptArg[Int] = OptArg.Empty): Result[Seq[XEntry]]
Executes XREADGROUP
-
def
xrevrange(key: Key, end: commons.OptArg[XEntryId] = OptArg.Empty, start: commons.OptArg[XEntryId] = OptArg.Empty, count: commons.OptArg[Int] = OptArg.Empty): Result[Seq[XEntry]]
Executes XREVRANGE
-
def
xtrim(key: Key, maxlen: XMaxlen): Result[Long]
Executes XTRIM
-
def
xtrim(key: Key, maxlen: Long, approx: Boolean = true): Result[Long]
Executes XTRIM
- object XEntry