Packages

trait StreamsApi extends ApiSubset

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. StreamsApi
  2. ApiSubset
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. type Field = RedisSerialization.Field
    Definition Classes
    ApiSubset
  2. type Key = RedisSerialization.Key
    Definition Classes
    ApiSubset
  3. type Record = RedisSerialization.Record
    Definition Classes
    ApiSubset
  4. abstract type Result[A]

    The type constructor into which a result of each command is wrapped.

    The type constructor into which a result of each command is wrapped. For example if Result is Future, then incr returns Future[Long].

    Definition Classes
    ApiSubset
  5. type Value = RedisSerialization.Value
    Definition Classes
    ApiSubset
  6. type XEntry = commands.XEntry[Record]

Abstract Value Members

  1. abstract def execute[A](command: RedisCommand[A]): Result[A]
    Definition Classes
    ApiSubset
  2. abstract val serialization: RedisSerialization
    Definition Classes
    ApiSubset

Concrete Value Members

  1. def xack(key: Key, group: XGroup, ids: Iterable[XEntryId]): Result[Int]

    Executes XACK

  2. def xack(key: Key, group: XGroup, id: XEntryId, ids: XEntryId*): Result[Int]

    Executes XACK

  3. def xack(key: Key, group: XGroup, id: XEntryId): Result[Boolean]

    Executes XACK

  4. def xadd(key: Key, data: Record, id: commons.OptArg[XEntryId] = OptArg.Empty, maxlen: commons.OptArg[XMaxlen] = OptArg.Empty): Result[XEntryId]

    Executes XADD

  5. def xaddEntry(key: Key, entry: XEntry, maxlen: commons.OptArg[XMaxlen] = OptArg.Empty): Result[XEntryId]

    Executes XADD

  6. 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

  7. 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

  8. 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

  9. def xdel(key: Key, ids: Iterable[XEntryId]): Result[Long]

    Executes XDEL

  10. def xdel(key: Key, id: XEntryId, ids: XEntryId*): Result[Long]

    Executes XDEL

  11. def xdel(key: Key, id: XEntryId): Result[Boolean]

    Executes XDEL

  12. def xgroupCreate(key: Key, group: XGroup, id: commons.OptArg[XEntryId] = OptArg.Empty, mkstream: Boolean = false): Result[Unit]

    Executes XGROUP CREATE

  13. def xgroupDelconsumer(key: Key, group: XGroup, consumer: XConsumer): Result[Boolean]

    Executes XGROUP DELCONSUMER

  14. def xgroupDestroy(key: Key, group: XGroup): Result[Boolean]

    Executes XGROUP DESTROY

  15. def xgroupSetid(key: Key, group: XGroup, id: commons.OptArg[XEntryId] = OptArg.Empty): Result[Unit]

    Executes XGROUP SETID

  16. def xinfoConsumers(key: Key, group: XGroup): Result[Seq[XConsumerInfo]]

    Executes XINFO CONSUMERS

  17. def xinfoGroups(key: Key): Result[Seq[XGroupInfo]]

    Executes XINFO GROUPS

  18. def xinfoStream(key: Key): Result[XStreamInfo[Record]]

    Executes XINFO STREAM

  19. def xlen(key: Key): Result[Long]

    Executes XLEN

  20. def xpending(key: Key, group: XGroup): Result[XPendingOverview]

    Executes XPENDING

  21. 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

  22. 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

  23. 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

  24. 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

  25. 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

  26. 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

  27. 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

  28. def xtrim(key: Key, maxlen: XMaxlen): Result[Long]

    Executes XTRIM

  29. def xtrim(key: Key, maxlen: Long, approx: Boolean = true): Result[Long]

    Executes XTRIM

  30. object XEntry