aerospike-client-kotlin
Aerospike Client for Kotlin wraps the Java client callback-based asynchronous methods and provides an idiomatic Kotlin API using coroutines and Flow.
The AerospikeAsyncClient takes the Java AerospikeClient as a constructor parameter and exposes it via the asJava() method. Make sure to set the ClientPolicy.eventLoops when creating the Java client.
Build from Source
./gradlew build
Examples
@Test
fun `Perform operations on a key`(): Unit = runBlocking {
val record = asyncClient.operate(
null, keys[0],
Operation.put(Bin(intBin, 100)),
Operation.get()
)
assertEquals(100, record?.getInt(intBin))
}
@Test
fun `Scan partitions`(): Unit = runBlocking {
val flow = asyncClient.scanPartitions(null, PartitionFilter.all(), namespace, set)
val recordsNumber = flow.toList().size
assertEquals(keysSize, recordsNumber)
}
License
Licensed under the Apache 2.0 License.
0 Jan 31, 2022
14 Nov 7, 2022
238 Dec 24, 2022
3 Aug 31, 2022
3 Aug 31, 2022
372 Dec 28, 2022
1.5k Dec 30, 2022
0 Jan 20, 2022
98 Dec 15, 2022
14 Nov 5, 2022
19 Sep 8, 2022
118 Oct 3, 2022
39 Nov 4, 2022
3 Jun 24, 2022
1 Feb 11, 2022
6 Sep 26, 2022
76 Nov 30, 2022
0 Jan 21, 2022
4.1k Dec 26, 2022