object
ReplyDecoders
Value Members
-
final
def
!=(arg0: Any): Boolean
-
final
def
##(): Int
-
final
def
==(arg0: Any): Boolean
-
final
def
asInstanceOf[T0]: T0
-
def
bulk[T](implicit arg0: RedisDataCodec[T]): ReplyDecoder[T]
-
def
bulk[T](fun: (ByteString) ⇒ T): ReplyDecoder[T]
-
val
bulkBinary: ReplyDecoder[ByteString]
-
val
bulkClientInfos: ReplyDecoder[Seq[ClientInfo]]
-
val
bulkCursor: ReplyDecoder[Cursor]
-
val
bulkDouble: ReplyDecoder[Double]
-
val
bulkInt: ReplyDecoder[Long]
-
val
bulkLong: ReplyDecoder[Long]
-
def
bulkNamedEnum[E <: NamedEnum](companion: NamedEnumCompanion[E]): ReplyDecoder[E]
-
val
bulkNodeId: ReplyDecoder[NodeId]
-
val
bulkNodeInfo: ReplyDecoder[NodeInfo]
-
val
bulkNodeInfos: ReplyDecoder[Seq[NodeInfo]]
-
val
bulkSha1: ReplyDecoder[Sha1]
-
val
bulkUTF8: ReplyDecoder[String]
-
val
bulkXConsumer: ReplyDecoder[XConsumer]
-
val
bulkXEntryId: ReplyDecoder[XEntryId]
-
val
bulkXGroup: ReplyDecoder[XGroup]
-
def
clone(): AnyRef
-
final
def
eq(arg0: AnyRef): Boolean
-
def
equals(arg0: Any): Boolean
-
val
failing: ReplyDecoder[Nothing]
-
def
finalize(): Unit
-
def
flatMultiBulkMap[A, B](implicit arg0: RedisDataCodec[A], arg1: RedisDataCodec[B]): ReplyDecoder[commons.BMap[A, B]]
-
def
flatMultiBulkMap[A, B](keyDecoder: ReplyDecoder[A], valueDecoder: ReplyDecoder[B]): ReplyDecoder[commons.BMap[A, B]]
-
def
flatMultiBulkRecord[R](implicit arg0: RedisRecordCodec[R]): ReplyDecoder[R]
-
def
flatMultiBulkRecordOpt[R](implicit arg0: RedisRecordCodec[R]): ReplyDecoder[commons.Opt[R]]
-
def
flatMultiBulkSeq[A, B](implicit arg0: RedisDataCodec[A], arg1: RedisDataCodec[B]): ReplyDecoder[Seq[(A, B)]]
-
def
flatMultiBulkSeq[A, B](firstDecoder: ReplyDecoder[A], secondDecoder: ReplyDecoder[B]): ReplyDecoder[Seq[(A, B)]]
-
def
flatMultiBulkSeqSwapped[A, B](firstDecoder: ReplyDecoder[A], secondDecoder: ReplyDecoder[B]): ReplyDecoder[Seq[(B, A)]]
-
def
flatPairMultiBulkSeq[T](pairDecoder: ReplyPairDecoder[T]): ReplyDecoder[Seq[T]]
-
def
geoAttributed[A](attributes: GeoradiusAttrs, unattributed: ReplyDecoder[A]): ReplyDecoder[Attributed[A]]
-
final
def
getClass(): Class[_]
-
def
hashCode(): Int
-
val
integerBoolean: ReplyDecoder[Boolean]
-
val
integerClientId: ReplyDecoder[ClientId]
-
val
integerInt: ReplyDecoder[Int]
-
val
integerLong: ReplyDecoder[Long]
-
val
integerTtl: ReplyDecoder[commons.Opt[commons.Opt[Long]]]
-
final
def
isInstanceOf[T0]: Boolean
-
val
multiBulkCommandInfo: ReplyDecoder[CommandInfo]
-
val
multiBulkGeoPoint: ReplyDecoder[GeoPoint]
-
def
multiBulkGroupedSeq[T](size: Int, elementDecoder: ReplyDecoder[T]): ReplyDecoder[Seq[Seq[T]]]
-
def
multiBulkMap[A, B](implicit arg0: RedisDataCodec[A], arg1: RedisDataCodec[B]): ReplyDecoder[commons.BMap[A, B]]
-
def
multiBulkMap[A, B](keyDecoder: ReplyDecoder[A], valueDecoder: ReplyDecoder[B]): ReplyDecoder[commons.BMap[A, B]]
-
val
multiBulkNodeInfos: ReplyDecoder[Seq[NodeInfo]]
-
def
multiBulkPair[A, B](firstDecoder: ReplyDecoder[A], secondDecoder: ReplyDecoder[B]): ReplyDecoder[(A, B)]
-
val
multiBulkRedisRole: ReplyDecoder[RedisRole]
-
val
multiBulkRedisTimestamp: ReplyDecoder[RedisTimestamp]
-
def
multiBulkSeq[T](implicit arg0: RedisDataCodec[T]): ReplyDecoder[Seq[T]]
-
def
multiBulkSeq[T](elementDecoder: ReplyDecoder[T]): ReplyDecoder[Seq[T]]
-
def
multiBulkSet[T](implicit arg0: RedisDataCodec[T]): ReplyDecoder[commons.BSet[T]]
-
def
multiBulkSet[T](elementDecoder: ReplyDecoder[T]): ReplyDecoder[commons.BSet[T]]
-
val
multiBulkSlotRangeMapping: ReplyDecoder[SlotRangeMapping]
-
val
multiBulkSlowlogEntry: ReplyDecoder[SlowlogEntry]
-
val
multiBulkXConsumerInfo: ReplyDecoder[XConsumerInfo]
-
def
multiBulkXEntriesMap[K, R](implicit arg0: RedisDataCodec[K], arg1: RedisRecordCodec[R]): ReplyDecoder[commons.BMap[K, Seq[XEntry[R]]]]
-
def
multiBulkXEntry[R](implicit arg0: RedisRecordCodec[R]): ReplyDecoder[XEntry[R]]
-
val
multiBulkXGroupInfo: ReplyDecoder[XGroupInfo]
-
val
multiBulkXPendingEntry: ReplyDecoder[XPendingEntry]
-
val
multiBulkXPendingOverview: ReplyDecoder[XPendingOverview]
-
def
multiBulkXStreamInfo[Record](implicit arg0: RedisRecordCodec[Record]): ReplyDecoder[XStreamInfo[Record]]
-
def
multiBulkZTriple[K, V](implicit arg0: RedisDataCodec[K], arg1: RedisDataCodec[V]): ReplyDecoder[commons.Opt[(K, V, Double)]]
-
final
def
ne(arg0: AnyRef): Boolean
-
final
def
notify(): Unit
-
final
def
notifyAll(): Unit
-
def
nullBulkOr[T](implicit arg0: RedisDataCodec[T]): ReplyDecoder[commons.Opt[T]]
-
def
nullBulkOr[T](decoder: ReplyDecoder[T]): ReplyDecoder[commons.Opt[T]]
-
val
nullBulkOrSimpleOkBoolean: ReplyDecoder[Boolean]
-
def
nullMultiBulkOr[T](implicit arg0: RedisDataCodec[T]): ReplyDecoder[commons.Opt[T]]
-
def
nullMultiBulkOr[T](decoder: ReplyDecoder[T]): ReplyDecoder[commons.Opt[T]]
-
def
nullOrEmptyBulkOr[T](implicit arg0: RedisDataCodec[T]): ReplyDecoder[commons.Opt[T]]
-
def
nullOrEmptyBulkOr[T](fun: (ByteString) ⇒ T): ReplyDecoder[commons.Opt[T]]
-
def
nullOrEmptyBulkOr[T](decoder: ReplyDecoder[T]): ReplyDecoder[commons.Opt[T]]
-
val
positiveIntegerLongOpt: ReplyDecoder[commons.Opt[Long]]
-
def
simple[T](implicit arg0: RedisDataCodec[T]): ReplyDecoder[T]
-
def
simple[T](fun: (ByteString) ⇒ T): ReplyDecoder[T]
-
val
simpleBinary: ReplyDecoder[ByteString]
-
val
simpleOkUnit: ReplyDecoder[Unit]
-
val
simpleUTF8: ReplyDecoder[String]
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
-
def
toString(): String
-
val
undecoded: ReplyDecoder[ValidRedisMsg]
-
final
def
wait(): Unit
-
final
def
wait(arg0: Long, arg1: Int): Unit
-
final
def
wait(arg0: Long): Unit
Inherited from Any
Value Members
-
final
def
asInstanceOf[T0]: T0
-
final
def
isInstanceOf[T0]: Boolean
Ungrouped
-
final
def
!=(arg0: Any): Boolean
-
final
def
##(): Int
-
final
def
==(arg0: Any): Boolean
-
final
def
asInstanceOf[T0]: T0
-
def
bulk[T](implicit arg0: RedisDataCodec[T]): ReplyDecoder[T]
-
def
bulk[T](fun: (ByteString) ⇒ T): ReplyDecoder[T]
-
val
bulkBinary: ReplyDecoder[ByteString]
-
val
bulkClientInfos: ReplyDecoder[Seq[ClientInfo]]
-
val
bulkCursor: ReplyDecoder[Cursor]
-
val
bulkDouble: ReplyDecoder[Double]
-
val
bulkInt: ReplyDecoder[Long]
-
val
bulkLong: ReplyDecoder[Long]
-
def
bulkNamedEnum[E <: NamedEnum](companion: NamedEnumCompanion[E]): ReplyDecoder[E]
-
val
bulkNodeId: ReplyDecoder[NodeId]
-
val
bulkNodeInfo: ReplyDecoder[NodeInfo]
-
val
bulkNodeInfos: ReplyDecoder[Seq[NodeInfo]]
-
val
bulkSha1: ReplyDecoder[Sha1]
-
val
bulkUTF8: ReplyDecoder[String]
-
val
bulkXConsumer: ReplyDecoder[XConsumer]
-
val
bulkXEntryId: ReplyDecoder[XEntryId]
-
val
bulkXGroup: ReplyDecoder[XGroup]
-
def
clone(): AnyRef
-
final
def
eq(arg0: AnyRef): Boolean
-
def
equals(arg0: Any): Boolean
-
val
failing: ReplyDecoder[Nothing]
-
def
finalize(): Unit
-
def
flatMultiBulkMap[A, B](implicit arg0: RedisDataCodec[A], arg1: RedisDataCodec[B]): ReplyDecoder[commons.BMap[A, B]]
-
def
flatMultiBulkMap[A, B](keyDecoder: ReplyDecoder[A], valueDecoder: ReplyDecoder[B]): ReplyDecoder[commons.BMap[A, B]]
-
def
flatMultiBulkRecord[R](implicit arg0: RedisRecordCodec[R]): ReplyDecoder[R]
-
def
flatMultiBulkRecordOpt[R](implicit arg0: RedisRecordCodec[R]): ReplyDecoder[commons.Opt[R]]
-
def
flatMultiBulkSeq[A, B](implicit arg0: RedisDataCodec[A], arg1: RedisDataCodec[B]): ReplyDecoder[Seq[(A, B)]]
-
def
flatMultiBulkSeq[A, B](firstDecoder: ReplyDecoder[A], secondDecoder: ReplyDecoder[B]): ReplyDecoder[Seq[(A, B)]]
-
def
flatMultiBulkSeqSwapped[A, B](firstDecoder: ReplyDecoder[A], secondDecoder: ReplyDecoder[B]): ReplyDecoder[Seq[(B, A)]]
-
def
flatPairMultiBulkSeq[T](pairDecoder: ReplyPairDecoder[T]): ReplyDecoder[Seq[T]]
-
def
geoAttributed[A](attributes: GeoradiusAttrs, unattributed: ReplyDecoder[A]): ReplyDecoder[Attributed[A]]
-
final
def
getClass(): Class[_]
-
def
hashCode(): Int
-
val
integerBoolean: ReplyDecoder[Boolean]
-
val
integerClientId: ReplyDecoder[ClientId]
-
val
integerInt: ReplyDecoder[Int]
-
val
integerLong: ReplyDecoder[Long]
-
val
integerTtl: ReplyDecoder[commons.Opt[commons.Opt[Long]]]
-
final
def
isInstanceOf[T0]: Boolean
-
val
multiBulkCommandInfo: ReplyDecoder[CommandInfo]
-
val
multiBulkGeoPoint: ReplyDecoder[GeoPoint]
-
def
multiBulkGroupedSeq[T](size: Int, elementDecoder: ReplyDecoder[T]): ReplyDecoder[Seq[Seq[T]]]
-
def
multiBulkMap[A, B](implicit arg0: RedisDataCodec[A], arg1: RedisDataCodec[B]): ReplyDecoder[commons.BMap[A, B]]
-
def
multiBulkMap[A, B](keyDecoder: ReplyDecoder[A], valueDecoder: ReplyDecoder[B]): ReplyDecoder[commons.BMap[A, B]]
-
val
multiBulkNodeInfos: ReplyDecoder[Seq[NodeInfo]]
-
def
multiBulkPair[A, B](firstDecoder: ReplyDecoder[A], secondDecoder: ReplyDecoder[B]): ReplyDecoder[(A, B)]
-
val
multiBulkRedisRole: ReplyDecoder[RedisRole]
-
val
multiBulkRedisTimestamp: ReplyDecoder[RedisTimestamp]
-
def
multiBulkSeq[T](implicit arg0: RedisDataCodec[T]): ReplyDecoder[Seq[T]]
-
def
multiBulkSeq[T](elementDecoder: ReplyDecoder[T]): ReplyDecoder[Seq[T]]
-
def
multiBulkSet[T](implicit arg0: RedisDataCodec[T]): ReplyDecoder[commons.BSet[T]]
-
def
multiBulkSet[T](elementDecoder: ReplyDecoder[T]): ReplyDecoder[commons.BSet[T]]
-
val
multiBulkSlotRangeMapping: ReplyDecoder[SlotRangeMapping]
-
val
multiBulkSlowlogEntry: ReplyDecoder[SlowlogEntry]
-
val
multiBulkXConsumerInfo: ReplyDecoder[XConsumerInfo]
-
def
multiBulkXEntriesMap[K, R](implicit arg0: RedisDataCodec[K], arg1: RedisRecordCodec[R]): ReplyDecoder[commons.BMap[K, Seq[XEntry[R]]]]
-
def
multiBulkXEntry[R](implicit arg0: RedisRecordCodec[R]): ReplyDecoder[XEntry[R]]
-
val
multiBulkXGroupInfo: ReplyDecoder[XGroupInfo]
-
val
multiBulkXPendingEntry: ReplyDecoder[XPendingEntry]
-
val
multiBulkXPendingOverview: ReplyDecoder[XPendingOverview]
-
def
multiBulkXStreamInfo[Record](implicit arg0: RedisRecordCodec[Record]): ReplyDecoder[XStreamInfo[Record]]
-
def
multiBulkZTriple[K, V](implicit arg0: RedisDataCodec[K], arg1: RedisDataCodec[V]): ReplyDecoder[commons.Opt[(K, V, Double)]]
-
final
def
ne(arg0: AnyRef): Boolean
-
final
def
notify(): Unit
-
final
def
notifyAll(): Unit
-
def
nullBulkOr[T](implicit arg0: RedisDataCodec[T]): ReplyDecoder[commons.Opt[T]]
-
def
nullBulkOr[T](decoder: ReplyDecoder[T]): ReplyDecoder[commons.Opt[T]]
-
val
nullBulkOrSimpleOkBoolean: ReplyDecoder[Boolean]
-
def
nullMultiBulkOr[T](implicit arg0: RedisDataCodec[T]): ReplyDecoder[commons.Opt[T]]
-
def
nullMultiBulkOr[T](decoder: ReplyDecoder[T]): ReplyDecoder[commons.Opt[T]]
-
def
nullOrEmptyBulkOr[T](implicit arg0: RedisDataCodec[T]): ReplyDecoder[commons.Opt[T]]
-
def
nullOrEmptyBulkOr[T](fun: (ByteString) ⇒ T): ReplyDecoder[commons.Opt[T]]
-
def
nullOrEmptyBulkOr[T](decoder: ReplyDecoder[T]): ReplyDecoder[commons.Opt[T]]
-
val
positiveIntegerLongOpt: ReplyDecoder[commons.Opt[Long]]
-
def
simple[T](implicit arg0: RedisDataCodec[T]): ReplyDecoder[T]
-
def
simple[T](fun: (ByteString) ⇒ T): ReplyDecoder[T]
-
val
simpleBinary: ReplyDecoder[ByteString]
-
val
simpleOkUnit: ReplyDecoder[Unit]
-
val
simpleUTF8: ReplyDecoder[String]
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
-
def
toString(): String
-
val
undecoded: ReplyDecoder[ValidRedisMsg]
-
final
def
wait(): Unit
-
final
def
wait(arg0: Long, arg1: Int): Unit
-
final
def
wait(arg0: Long): Unit