Type Members

1.  sealed case class Group[G, C](group: G, consumer: C) extends Product with Serializable
2.  type MkStream = MkStream.type
3.  type NoAck = NoAck.type
4.  sealed case class PendingInfo(total: Long, first: Option[String], last: Option[String], consumers: Map[String, Long]) extends Product with Serializable
5.  sealed case class PendingMessage(id: String, owner: String, lastDelivered: zio.Duration, counter: Long) extends Product with Serializable
6.  sealed case class StreamChunk[N, I, K, V](name: N, entries: Chunk[StreamEntry[I, K, V]]) extends Product with Serializable
7.  type StreamChunks[N, I, K, V] = Chunk[StreamChunk[N, I, K, V]]
8.  sealed case class StreamConsumersInfo(name: String, pending: Long, idle: zio.Duration) extends Product with Serializable
9.  type StreamEntries[I, K, V] = Chunk[StreamEntry[I, K, V]]
10.  sealed case class StreamEntry[I, K, V](id: I, fields: Map[K, V]) extends Product with Serializable
11.  sealed case class StreamGroupsInfo(name: String, consumers: Long, pending: Long, lastDeliveredId: String) extends Product with Serializable
12.  sealed case class StreamInfo[I, K, V](length: Long, radixTreeKeys: Long, radixTreeNodes: Long, groups: Long, lastGeneratedId: String, firstEntry: Option[StreamEntry[I, K, V]], lastEntry: Option[StreamEntry[I, K, V]]) extends Product with Serializable
13.  sealed case class StreamMaxLen(approximate: Boolean, count: Long) extends Product with Serializable
14.  type WithForce = WithForce.type
15.  type WithJustId = WithJustId.type
16.  sealed trait XGroupCommand extends AnyRef