kv
Module Contents
alltypes
Module Contents
class EntityManagerKeyValueStore<K, V> : KeyValueStore<K, V>
class InfinispanKeyValueStore<K, V> : KeyValueStore<K, V>
interface KeyValueStore<K, V> : Closeable, CoroutineScope
class LevelDBKeyValueStore<K, V> : KeyValueStore<K, V>
Module Contents
LevelDBKeyValueStore(dbPath: Path, keySerializer: (K) -> Bytes, valueSerializer: (V) -> Bytes, keyDeserializer: (Bytes) -> K, valueDeserializer: (Bytes) -> V, options: Options = Options().createIfMissing(true).cacheSize((100 * 1048576).toLong()), coroutineContext: CoroutineContext = Dispatchers.IO)
suspend fun clear(): Unit
fun close(): Unit
suspend fun containsKey(key: K): Boolean
val coroutineContext: CoroutineContext
suspend fun get(key: K): V?
suspend fun keys(): Iterable<K>
@JvmStatic fun <K, V> open(dbPath: Path, keySerializer: Function<K, Bytes>, valueSerializer: Function<V, Bytes>, keyDeserializer: Function<Bytes, K>, valueDeserializer: Function<Bytes, V>): LevelDBKeyValueStore<K, V>
@JvmStatic fun <K, V> open(dbPath: Path, keySerializer: Function<K, Bytes>, valueSerializer: Function<V, Bytes>, keyDeserializer: Function<Bytes, K>, valueDeserializer: Function<Bytes, V>, options: Options): LevelDBKeyValueStore<K, V>
@JvmStatic fun open(dbPath: Path): LevelDBKeyValueStore<Bytes, Bytes>
suspend fun put(key: K, value: V): Unit
class MapDBKeyValueStore<K, V> : KeyValueStore<K, V>
Module Contents
MapDBKeyValueStore(dbPath: Path, keySerializer: (K) -> Bytes, valueSerializer: (V) -> Bytes, keyDeserializer: (Bytes) -> K, valueDeserializer: (Bytes) -> V, coroutineContext: CoroutineContext = Dispatchers.IO)
suspend fun clear(): Unit
fun close(): Unit
suspend fun containsKey(key: K): Boolean
val coroutineContext: CoroutineContext
suspend fun get(key: K): V?
suspend fun keys(): Iterable<K>
@JvmStatic fun <K, V> open(dbPath: Path, keySerializer: Function<K, Bytes>, valueSerializer: Function<V, Bytes>, keyDeserializer: Function<Bytes, K>, valueDeserializer: Function<Bytes, V>): MapDBKeyValueStore<K, V>
@JvmStatic fun open(dbPath: Path): MapDBKeyValueStore<Bytes, Bytes>
suspend fun put(key: K, value: V): Unit
class MapKeyValueStore<K, V> : KeyValueStore<K, V>
class ProxyKeyValueStore<K, V, E, R> : KeyValueStore<K, V>
Module Contents
ProxyKeyValueStore(store: KeyValueStore<E, R>, unproxyKey: (E) -> K, proxyKey: (K) -> E, unproxyValue: (R) -> V, proxyValue: (K, V) -> R, coroutineContext: CoroutineContext = store.coroutineContext)
suspend fun clear(): Unit
fun close(): Unit
suspend fun containsKey(key: K): Boolean
val coroutineContext: CoroutineContext
suspend fun get(key: K): V?
suspend fun keys(): Iterable<K>
@JvmStatic fun <K, V, E, R> open(store: KeyValueStore<E, R>, unproxyKey: Function<E, K>, proxyKey: Function<K, E>, unproxyValue: Function<R, V>, proxyValue: BiFunction<K, V, R>): ProxyKeyValueStore<K, V, E, R>
suspend fun put(key: K, value: V): Unit
class RedisKeyValueStore<K, V> : KeyValueStore<K, V>
Module Contents
RedisKeyValueStore(port: Int = 6379, address: InetAddress = InetAddress.getLoopbackAddress(), keySerializer: (K) -> Bytes, valueSerializer: (V) -> Bytes, keyDeserializer: (Bytes) -> K, valueDeserializer: (Bytes) -> V)
RedisKeyValueStore(uri: String, keySerializer: (K) -> Bytes, valueSerializer: (V) -> Bytes, keyDeserializer: (Bytes) -> K, valueDeserializer: (Bytes) -> V, coroutineContext: CoroutineContext = Dispatchers.IO)
suspend fun clear(): Unit
fun close(): Unit
@JvmStatic fun codec(): RedisCodec<Bytes, Bytes>
suspend fun containsKey(key: K): Boolean
val coroutineContext: CoroutineContext
suspend fun get(key: K): V?
suspend fun keys(): Iterable<K>
@JvmStatic fun open(uri: String): RedisKeyValueStore<Bytes, Bytes>
@JvmStatic fun <K, V> open(uri: String, keySerializer: Function<K, Bytes>, valueSerializer: Function<V, Bytes>, keyDeserializer: Function<Bytes, K>, valueDeserializer: Function<Bytes, V>): RedisKeyValueStore<K, V>
@JvmStatic fun <K, V> open(port: Int, keySerializer: Function<K, Bytes>, valueSerializer: Function<V, Bytes>, keyDeserializer: Function<Bytes, K>, valueDeserializer: Function<Bytes, V>): RedisKeyValueStore<K, V>
@JvmStatic fun <K, V> open(address: InetAddress, keySerializer: Function<K, Bytes>, valueSerializer: Function<V, Bytes>, keyDeserializer: Function<Bytes, K>, valueDeserializer: Function<Bytes, V>): RedisKeyValueStore<K, V>
@JvmStatic fun <K, V> open(port: Int, address: InetAddress, keySerializer: Function<K, Bytes>, valueSerializer: Function<V, Bytes>, keyDeserializer: Function<Bytes, K>, valueDeserializer: Function<Bytes, V>): RedisKeyValueStore<K, V>
suspend fun put(key: K, value: V): Unit
class RocksDBKeyValueStore<K, V> : KeyValueStore<K, V>
Module Contents
RocksDBKeyValueStore(dbPath: Path, keySerializer: (K) -> Bytes, valueSerializer: (V) -> Bytes, keyDeserializer: (Bytes) -> K, valueDeserializer: (Bytes) -> V, options: Options = Options().setCreateIfMissing(true).setWriteBufferSize(268435456).setMaxOpenFiles(-1), coroutineContext: CoroutineContext = Dispatchers.IO)
suspend fun clear(): Unit
fun close(): Unit
suspend fun containsKey(key: K): Boolean
val coroutineContext: CoroutineContext
suspend fun get(key: K): V?
suspend fun keys(): Iterable<K>
@JvmStatic fun <K, V> open(dbPath: Path, keySerializer: Function<K, Bytes>, valueSerializer: Function<V, Bytes>, keyDeserializer: Function<Bytes, K>, valueDeserializer: Function<Bytes, V>): RocksDBKeyValueStore<K, V>
@JvmStatic fun <K, V> open(dbPath: Path, keySerializer: Function<K, Bytes>, valueSerializer: Function<V, Bytes>, keyDeserializer: Function<Bytes, K>, valueDeserializer: Function<Bytes, V>, options: Options): RocksDBKeyValueStore<K, V>
suspend fun put(key: K, value: V): Unit
class SQLKeyValueStore<K, V> : KeyValueStore<K, V>
Module Contents
SQLKeyValueStore(jdbcurl: String, tableName: String = "store", keyColumn: String = "key", valueColumn: String = "value", keySerializer: (K) -> Bytes, valueSerializer: (V) -> Bytes, keyDeserializer: (Bytes) -> K, valueDeserializer: (Bytes?) -> V?, coroutineContext: CoroutineContext = Dispatchers.IO)
suspend fun clear(): Unit
fun close(): Unit
suspend fun containsKey(key: K): Boolean
val coroutineContext: CoroutineContext
suspend fun get(key: K): V?
val keyColumn: String
suspend fun keys(): Iterable<K>
@JvmStatic fun <K, V> open(jdbcUrl: String, keySerializer: (K) -> Bytes, valueSerializer: (V) -> Bytes, keyDeserializer: (Bytes) -> K, valueDeserializer: (Bytes?) -> V?): SQLKeyValueStore<K, V>
@JvmStatic fun <K, V> open(jdbcUrl: String, tableName: String, keyColumn: String, valueColumn: String, keySerializer: (K) -> Bytes, valueSerializer: (V) -> Bytes, keyDeserializer: (Bytes) -> K, valueDeserializer: (Bytes?) -> V?): SQLKeyValueStore<K, V>
suspend fun put(key: K, value: V): Unit
val tableName: String
val valueColumn: String
package org.apache.tuweni.kv
Module Contents
class EntityManagerKeyValueStore<K, V> : KeyValueStore<K, V>
class InfinispanKeyValueStore<K, V> : KeyValueStore<K, V>
interface KeyValueStore<K, V> : Closeable, CoroutineScope
class LevelDBKeyValueStore<K, V> : KeyValueStore<K, V>
Module Contents
LevelDBKeyValueStore(dbPath: Path, keySerializer: (K) -> Bytes, valueSerializer: (V) -> Bytes, keyDeserializer: (Bytes) -> K, valueDeserializer: (Bytes) -> V, options: Options = Options().createIfMissing(true).cacheSize((100 * 1048576).toLong()), coroutineContext: CoroutineContext = Dispatchers.IO)
suspend fun clear(): Unit
fun close(): Unit
suspend fun containsKey(key: K): Boolean
val coroutineContext: CoroutineContext
suspend fun get(key: K): V?
suspend fun keys(): Iterable<K>
@JvmStatic fun <K, V> open(dbPath: Path, keySerializer: Function<K, Bytes>, valueSerializer: Function<V, Bytes>, keyDeserializer: Function<Bytes, K>, valueDeserializer: Function<Bytes, V>): LevelDBKeyValueStore<K, V>
@JvmStatic fun <K, V> open(dbPath: Path, keySerializer: Function<K, Bytes>, valueSerializer: Function<V, Bytes>, keyDeserializer: Function<Bytes, K>, valueDeserializer: Function<Bytes, V>, options: Options): LevelDBKeyValueStore<K, V>
@JvmStatic fun open(dbPath: Path): LevelDBKeyValueStore<Bytes, Bytes>
suspend fun put(key: K, value: V): Unit
class MapDBKeyValueStore<K, V> : KeyValueStore<K, V>
Module Contents
MapDBKeyValueStore(dbPath: Path, keySerializer: (K) -> Bytes, valueSerializer: (V) -> Bytes, keyDeserializer: (Bytes) -> K, valueDeserializer: (Bytes) -> V, coroutineContext: CoroutineContext = Dispatchers.IO)
suspend fun clear(): Unit
fun close(): Unit
suspend fun containsKey(key: K): Boolean
val coroutineContext: CoroutineContext
suspend fun get(key: K): V?
suspend fun keys(): Iterable<K>
@JvmStatic fun <K, V> open(dbPath: Path, keySerializer: Function<K, Bytes>, valueSerializer: Function<V, Bytes>, keyDeserializer: Function<Bytes, K>, valueDeserializer: Function<Bytes, V>): MapDBKeyValueStore<K, V>
@JvmStatic fun open(dbPath: Path): MapDBKeyValueStore<Bytes, Bytes>
suspend fun put(key: K, value: V): Unit
class MapKeyValueStore<K, V> : KeyValueStore<K, V>
class ProxyKeyValueStore<K, V, E, R> : KeyValueStore<K, V>
Module Contents
ProxyKeyValueStore(store: KeyValueStore<E, R>, unproxyKey: (E) -> K, proxyKey: (K) -> E, unproxyValue: (R) -> V, proxyValue: (K, V) -> R, coroutineContext: CoroutineContext = store.coroutineContext)
suspend fun clear(): Unit
fun close(): Unit
suspend fun containsKey(key: K): Boolean
val coroutineContext: CoroutineContext
suspend fun get(key: K): V?
suspend fun keys(): Iterable<K>
@JvmStatic fun <K, V, E, R> open(store: KeyValueStore<E, R>, unproxyKey: Function<E, K>, proxyKey: Function<K, E>, unproxyValue: Function<R, V>, proxyValue: BiFunction<K, V, R>): ProxyKeyValueStore<K, V, E, R>
suspend fun put(key: K, value: V): Unit
class RedisKeyValueStore<K, V> : KeyValueStore<K, V>
Module Contents
RedisKeyValueStore(port: Int = 6379, address: InetAddress = InetAddress.getLoopbackAddress(), keySerializer: (K) -> Bytes, valueSerializer: (V) -> Bytes, keyDeserializer: (Bytes) -> K, valueDeserializer: (Bytes) -> V)
RedisKeyValueStore(uri: String, keySerializer: (K) -> Bytes, valueSerializer: (V) -> Bytes, keyDeserializer: (Bytes) -> K, valueDeserializer: (Bytes) -> V, coroutineContext: CoroutineContext = Dispatchers.IO)
suspend fun clear(): Unit
fun close(): Unit
@JvmStatic fun codec(): RedisCodec<Bytes, Bytes>
suspend fun containsKey(key: K): Boolean
val coroutineContext: CoroutineContext
suspend fun get(key: K): V?
suspend fun keys(): Iterable<K>
@JvmStatic fun open(uri: String): RedisKeyValueStore<Bytes, Bytes>
@JvmStatic fun <K, V> open(uri: String, keySerializer: Function<K, Bytes>, valueSerializer: Function<V, Bytes>, keyDeserializer: Function<Bytes, K>, valueDeserializer: Function<Bytes, V>): RedisKeyValueStore<K, V>
@JvmStatic fun <K, V> open(port: Int, keySerializer: Function<K, Bytes>, valueSerializer: Function<V, Bytes>, keyDeserializer: Function<Bytes, K>, valueDeserializer: Function<Bytes, V>): RedisKeyValueStore<K, V>
@JvmStatic fun <K, V> open(address: InetAddress, keySerializer: Function<K, Bytes>, valueSerializer: Function<V, Bytes>, keyDeserializer: Function<Bytes, K>, valueDeserializer: Function<Bytes, V>): RedisKeyValueStore<K, V>
@JvmStatic fun <K, V> open(port: Int, address: InetAddress, keySerializer: Function<K, Bytes>, valueSerializer: Function<V, Bytes>, keyDeserializer: Function<Bytes, K>, valueDeserializer: Function<Bytes, V>): RedisKeyValueStore<K, V>
suspend fun put(key: K, value: V): Unit
class RocksDBKeyValueStore<K, V> : KeyValueStore<K, V>
Module Contents
RocksDBKeyValueStore(dbPath: Path, keySerializer: (K) -> Bytes, valueSerializer: (V) -> Bytes, keyDeserializer: (Bytes) -> K, valueDeserializer: (Bytes) -> V, options: Options = Options().setCreateIfMissing(true).setWriteBufferSize(268435456).setMaxOpenFiles(-1), coroutineContext: CoroutineContext = Dispatchers.IO)
suspend fun clear(): Unit
fun close(): Unit
suspend fun containsKey(key: K): Boolean
val coroutineContext: CoroutineContext
suspend fun get(key: K): V?
suspend fun keys(): Iterable<K>
@JvmStatic fun <K, V> open(dbPath: Path, keySerializer: Function<K, Bytes>, valueSerializer: Function<V, Bytes>, keyDeserializer: Function<Bytes, K>, valueDeserializer: Function<Bytes, V>): RocksDBKeyValueStore<K, V>
@JvmStatic fun <K, V> open(dbPath: Path, keySerializer: Function<K, Bytes>, valueSerializer: Function<V, Bytes>, keyDeserializer: Function<Bytes, K>, valueDeserializer: Function<Bytes, V>, options: Options): RocksDBKeyValueStore<K, V>
suspend fun put(key: K, value: V): Unit
class SQLKeyValueStore<K, V> : KeyValueStore<K, V>
Module Contents
SQLKeyValueStore(jdbcurl: String, tableName: String = "store", keyColumn: String = "key", valueColumn: String = "value", keySerializer: (K) -> Bytes, valueSerializer: (V) -> Bytes, keyDeserializer: (Bytes) -> K, valueDeserializer: (Bytes?) -> V?, coroutineContext: CoroutineContext = Dispatchers.IO)
suspend fun clear(): Unit
fun close(): Unit
suspend fun containsKey(key: K): Boolean
val coroutineContext: CoroutineContext
suspend fun get(key: K): V?
val keyColumn: String
suspend fun keys(): Iterable<K>
@JvmStatic fun <K, V> open(jdbcUrl: String, keySerializer: (K) -> Bytes, valueSerializer: (V) -> Bytes, keyDeserializer: (Bytes) -> K, valueDeserializer: (Bytes?) -> V?): SQLKeyValueStore<K, V>
@JvmStatic fun <K, V> open(jdbcUrl: String, tableName: String, keyColumn: String, valueColumn: String, keySerializer: (K) -> Bytes, valueSerializer: (V) -> Bytes, keyDeserializer: (Bytes) -> K, valueDeserializer: (Bytes?) -> V?): SQLKeyValueStore<K, V>
suspend fun put(key: K, value: V): Unit
val tableName: String
val valueColumn: String