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
-
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[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
implicit final
def
fieldCodec: RedisDataCodec[Field]
- Attributes
- protected
- Definition Classes
- ApiSubset
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
implicit
def
headOps[T](head: T): HeadOps[T]
- Attributes
- protected
- Definition Classes
- ApiSubset
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
implicit
def
iterableTailOps[T](tail: Iterable[T]): IterableTailOps[T]
- Attributes
- protected
- Definition Classes
- ApiSubset
-
implicit
def
iteratorTailOps[T](tail: Iterator[T]): IteratorTailOps[T]
- Attributes
- protected
- Definition Classes
- ApiSubset
-
implicit final
def
keyCodec: RedisDataCodec[Key]
- Attributes
- protected
- Definition Classes
- ApiSubset
-
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()
-
implicit final
def
recordCodec: RedisRecordCodec[Record]
- Attributes
- protected
- Definition Classes
- ApiSubset
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
implicit final
def
valueCodec: RedisDataCodec[Value]
- Attributes
- protected
- Definition Classes
- ApiSubset
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
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