A ZIO-based interface to RocksDB.
Add the following dependencies to your build.sbt file:
libraryDependencies ++= Seq(
"dev.zio" %% "zio-rocksdb" % "<version>"
)Use the provided RocksDB wrapper:
import java.nio.charset.StandardCharsets
import zio.rocksdb
import zio.rocksdb.{ RocksDB }
val UTF_8 = StandardCharsets.UTF_8
val key = "key".getBytes(UTF_8)
val value = "value".getBytes(UTF_8)
val database = RocksDB.live("/data/state")
val readWrite = RocksDB.put(key, value) *> RocksDB.get(key)
val result = readWrite.provideCustomLayer(database)zio-rocksdb provides transactional capabilities using RocksDB Transaction API.
import java.nio.charset.StandardCharsets
import zio.rocksdb
import zio.rocksdb.{ TransactionDB, Transaction }
val key0 = "key0".getBytes(UTF_8)
val key1 = "key1".getBytes(UTF_8)
val value0 = "value0".getBytes(UTF_8)
val value1 = "value1".getBytes(UTF_8)
val database = TransactionDB.live("/data/state")
val write0 = Transaction.put(key0, value0)
val write1 = Transaction.put(key1, value1)
val writeTogether = TransactionDB.atomically {
write0 <&> write1
}
val result = readWrite.provideCustomLayer(database)Join us on the ZIO Discord server.
Copyright 2019 Itamar Ravid and the zio-rocksdb contributors. All rights reserved.