resolvers += "Sonatype OSS Release Repository" at "https://oss.sonatype.org/content/repositories/releases/" libraryDependencies += "com.github.j5ik2o" %% "reactive-redis-core" % "1.0.21"

resolvers += "Sonatype OSS Snapshot Repository" at "https://oss.sonatype.org/content/repositories/snapshots/" libraryDependencies += "com.github.j5ik2o" %% "reactive-redis-core" % "1.0.22-SNAPSHOT"

import monix.execution.Scheduler.Implicits.global implicit val system = ActorSystem() val peerConfig = PeerConfig(remoteAddress = new InetSocketAddress("127.0.0.1", 6379)) val connection = RedisConnection(peerConfig) val client = RedisClient() val result = (for{ _ <- client.set("foo", "bar") r <- client.get("foo") } yield r).run(connection).runAsync println(result) // bar

import monix.execution.Scheduler.Implicits.global implicit val system = ActorSystem() val peerConfig = PeerConfig(remoteAddress = new InetSocketAddress("127.0.0.1", 6379)) val pool = RedisConnectionPool.ofRoundRobin(sizePerPeer = 5, Seq(peerConfig), RedisConnection(_)) // powered by RoundRobinPool val connection = RedisConnection(connectionConfig) val client = RedisClient() // Fucntion style val result1 = pool.withConnectionF{ con => (for{ _ <- client.set("foo", "bar") r <- client.get("foo") } yield r).run(con) }.runAsync println(result1) // bar // Monadic style val result2 = (for { _ <- ConnectionAutoClose(pool)(client.set("foo", "bar").run) r <- ConnectionAutoClose(pool)(client.get("foo").run) } yield r).run().runAsync println(result2) // bar

import monix.execution.Scheduler.Implicits.global implicit val system = ActorSystem() val masterPeerConfig = PeerConfig(remoteAddress = new InetSocketAddress("127.0.0.1", 6379)) val slavePeerConfigs = Seq( PeerConfig(remoteAddress = new InetSocketAddress("127.0.0.1", 6380)), PeerConfig(remoteAddress = new InetSocketAddress("127.0.0.1", 6381)), PeerConfig(remoteAddress = new InetSocketAddress("127.0.0.1", 6382)) ) val connection = new RedisMasterSlavesConnection( masterConnectionPoolFactory = RedisConnectionPool.ofRoundRobin(sizePerPeer = 2, Seq(masterPeerConfig), RedisConnection(_)), slaveConnectionPoolFactory = RedisConnectionPool.ofRoundRobin(sizePerPeer = 2, slavePeerConfigs, RedisConnection(_)) ) val client = RedisClient() val result = (for{ _ <- client.set("foo", "bar") // write to master r <- client.get("foo") // read from any slave } yield r).run(connection).runAsync println(result) // bar