object effects
- Source
- effects.scala
- Alphabetic
- By Inheritance
- effects
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- sealed trait AclCategory extends AnyRef
A Redis ACL command category (the closed set understood by the driver).
- sealed abstract class AclError extends RuntimeException
Failure raised while encoding ACL arguments or decoding ACL replies.
- final case class AclSelector(commands: String, keys: String, channels: String) extends Product with Serializable
A command/key/channel selector attached to an ACL user (Redis 7+), as returned by
ACL GETUSER. - sealed trait AclSetUserRule extends AnyRef
A single rule passed to
ACL SETUSER, applied in the order given.A single rule passed to
ACL SETUSER, applied in the order given. Mirrors Lettuce'sAclSetuserArgs. - final case class AclUser(flags: List[String], passwords: List[String], commands: String, keys: String, channels: String, selectors: List[AclSelector]) extends Product with Serializable
An ACL user as returned by
ACL GETUSER.An ACL user as returned by
ACL GETUSER. Thecommands,keysandchannelsfields hold the rule strings exactly as Redis reports them (e.g."-@all +get","~app:*","&*"). - final case class CopyArgs(destinationDb: Option[Long], replace: Option[Boolean]) extends Product with Serializable
- final case class Distance(value: Double) extends AnyVal with Product with Serializable
- sealed trait ExpireExistenceArg extends AnyRef
- sealed trait FlushMode extends AnyRef
- sealed trait FunctionRestoreMode extends AnyRef
- final case class GeoCoordinate(x: Double, y: Double) extends Product with Serializable
- final case class GeoHash(value: Long) extends AnyVal with Product with Serializable
- final case class GeoLocation[V](lon: Longitude, lat: Latitude, value: V) extends Product with Serializable
- final case class GeoRadius(lon: Longitude, lat: Latitude, dist: Distance) extends Product with Serializable
- final case class GeoRadiusDistStorage[K](key: K, count: Long, sort: Sort) extends Product with Serializable
- final case class GeoRadiusKeyStorage[K](key: K, count: Long, sort: Sort) extends Product with Serializable
- final case class GeoRadiusResult[V](value: V, dist: Distance, hash: GeoHash, coordinate: GeoCoordinate) extends Product with Serializable
- sealed trait GetExArg extends AnyRef
- sealed trait HGetExArgs extends AnyRef
- sealed abstract class KeyScanArgs extends AnyRef
- final case class Latitude(value: Double) extends AnyVal with Product with Serializable
- final case class Longitude(value: Double) extends AnyVal with Product with Serializable
- final case class MessageId(value: String) extends AnyVal with Product with Serializable
- final case class RangeLimit(offset: Long, count: Long) extends Product with Serializable
- final case class RawCommand(value: String) extends AnyVal with Product with Serializable
A raw Redis command name for use in
ACL SETUSERrules (e.g.A raw Redis command name for use in
ACL SETUSERrules (e.g.RawCommand("get")).The set of Redis commands is open (modules and new versions add commands), so it is modelled as an explicit string rather than a closed enum. Names unknown to the driver surface as AclError.UnknownCommand when the rule is applied, rather than throwing.
- sealed abstract class RedisType extends AnyRef
- final case class RestoreArgs(ttl: Option[Long] = None, replace: Option[Boolean] = None, absttl: Option[Boolean] = None, idleTime: Option[Long] = None) extends Product with Serializable
- case class ScanArgs(match: Option[String], count: Option[Long]) extends Product with Serializable
- final case class Score(value: Double) extends AnyVal with Product with Serializable
- final case class ScoreWithValue[V](score: Score, value: V) extends Product with Serializable
- sealed trait ScriptOutputType[V] extends AnyRef
- sealed trait SetArg extends AnyRef
- case class SetArgs(existence: Option[Existence], ttl: Option[Ttl]) extends Product with Serializable
- final case class StreamConsumer[K](group: K, consumer: K) extends Product with Serializable
Identifies a consumer within a consumer group (the
<group> <consumer>pair shared byXREADGROUP,XCLAIM,XAUTOCLAIMand theXGROUP *CONSUMERcommands). - final case class StreamMessage[K, V](id: MessageId, key: K, body: Map[K, V]) extends Product with Serializable
- implicit final class TimePrecisionOps extends AnyVal
- final case class XAddArgs(nomkstream: Boolean = false, id: Option[String] = None, xTrimArgs: Option[XTrimArgs] = None) extends Product with Serializable
- final case class XAutoClaimArgs[K](consumer: StreamConsumer[K], minIdleTime: FiniteDuration, start: String = "0", count: Option[Long] = None, justId: Boolean = false) extends Product with Serializable
Options for
XAUTOCLAIM.Options for
XAUTOCLAIM.startis the message id to start scanning the PEL from (defaults to0). - final case class XAutoClaimResult[K, V](nextId: MessageId, messages: List[StreamMessage[K, V]]) extends Product with Serializable
Result of
XAUTOCLAIM: the cursor to resume from plus the claimed messages. - final case class XClaimArgs(minIdleTime: FiniteDuration, idle: Option[XClaimIdle] = None, retryCount: Option[Long] = None, force: Boolean = false, justId: Boolean = false) extends Product with Serializable
Options for
XCLAIM. - sealed trait XClaimIdle extends Product with Serializable
The idle time to set on entries claimed by
XCLAIM(theIDLE/TIMEoptions).The idle time to set on entries claimed by
XCLAIM(theIDLE/TIMEoptions). Both express the same thing — the time since the entry was last delivered — so they are modelled as alternatives rather than a pair that could be set together. - final case class XGroupCreateArgs(mkStream: Boolean = false, entriesRead: Option[Long] = None) extends Product with Serializable
Options for
XGROUP CREATE. - final case class XPendingMessage(id: MessageId, consumer: String, sinceLastDelivery: FiniteDuration, redeliveryCount: Long) extends Product with Serializable
A single entry from the extended form of
XPENDING. - final case class XPendingSummary(count: Long, minId: Option[MessageId], maxId: Option[MessageId], consumers: Map[String, Long]) extends Product with Serializable
Summary form of
XPENDING <key> <group>. - sealed abstract class XRangePoint extends Product with Serializable
- final case class XReadGroupArgs(count: Option[Long] = None, block: Option[Duration] = None, noack: Boolean = false) extends Product with Serializable
Options for
XREADGROUP.Options for
XREADGROUP.noackskips adding the messages to the Pending Entries List. - sealed trait XReadOffsets[K] extends Product with Serializable
- final case class XTrimArgs(strategy: Strategy, precision: Precision = XTrimArgs.Precision.Exact) extends Product with Serializable
- final case class ZRange[V](start: V, end: V) extends Product with Serializable
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[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- object AclCategory
- object AclError extends Serializable
- object AclSetUserRule
- object CopyArgs extends Serializable
- object ExpireExistenceArg
- object FlushMode
- object FunctionRestoreMode
- object GetExArg
- object HGetExArgs
- object KeyScanArgs
- object MessageId extends Serializable
- object RedisType
- object ScanArgs extends Serializable
- object ScriptOutputType
- object SetArg
- object SetArgs extends Serializable
- object StreamMessage extends Serializable
- object XClaimIdle extends Serializable
- object XRangePoint extends Serializable
- object XReadOffsets extends Serializable
- object XTrimArgs extends Serializable
This is the API documentation for the Redis4Cats library.