trait RedisConnection extends AnyRef
Trait that defines the generic set of methods to connect with Redis.
It supports encoding and decoding in Utf and ByteArray with custom codecs.
It currently supports ClusterConnection and StandaloneConnection for cluster and single connections to Redis.
- Source
- RedisConnection.scala
- Alphabetic
- By Inheritance
- RedisConnection
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def connectByteArray[K, V](implicit keyCodec: BytesCodec[K], valueCodec: BytesCodec[V]): Resource[Task, RedisCmd[K, V]]
Connect asynchronously to Redis.
Connect asynchronously to Redis. It requires a codec for keys and values that will encode/decode respectively as K and V to/from Charset.
- K
the connection's key type.
- V
the connection's value type.
- keyCodec
a BytesCodec to encode/decode the key to .
- valueCodec
a BytesCodec to encode/decode the value to .
- returns
A
Resourcethat acquires a redis connection and exposes the usage of the V] .
- See also
connectByteArray and connectByteArray for respective examples.
- abstract def connectByteArray: Resource[Task, RedisCmd[Array[Byte], Array[Byte]]]
Connect asynchronously to a Redis Cluster.
Connect asynchronously to a Redis Cluster. Encodes and decodes keys and values.
- returns
A
Resourcethat acquires a redis connection and exposes the usage of the RedisCmd commands that will be released afterwards.
- abstract def connectUtf[K, V](implicit keyCodec: UtfCodec[K], valueCodec: UtfCodec[V]): Resource[Task, RedisCmd[K, V]]
Connect asynchronously to a Redis Cluster.
Connect asynchronously to a Redis Cluster. It requires a codec for keys and values that will encode/decode respectively as K and V to/from
UTFCharset.- K
the connection's key type.
- V
the connection's value type.
- keyCodec
a UtfCodec to encode/decode the key to
UTF.- valueCodec
a UtfCodec to encode/decode the value to
UTF.- returns
A
Resourcethat acquires a redis connection and exposes the usage of the V] .
- See also
connectUtf and connectUtf for respective examples.
- abstract def connectUtf: Resource[Task, RedisCmd[String, String]]
Connect asynchronously to a Redis Cluster.
Connect asynchronously to a Redis Cluster. Encodes and decodes String keys and values in
UTFCharset.- returns
A
Resourcethat acquires a redis connection and exposes the usage of the RedisCmd String commands that will be released afterwards.
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[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @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
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- 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]) @native()