kotka-streams-extensions/dev.adamko.kotka.extensions.state

Package-level declarations

Types

KeyValueIteratorOperation

typealias KeyValueIteratorOperation<K, V, Result> = KeyValueIterator<K, V>.() -> Result

Functions

fun <K, V> KeyValueStore<K, V>.allAsSequence(): Sequence<KeyValue<K, V>>

Generate a Sequence of all records.

prefixScanAsSequence

fun <K, V, Prefix> KeyValueStore<K, V>.prefixScanAsSequence(prefix: Prefix, prefixKeySerializer: Serializer<Prefix>): Sequence<KeyValue<K, V>>

Iterate over keys based on the key prefix.

rangeAsSequence

fun <K, V> KeyValueStore<K, V>.rangeAsSequence(from: K? = null, to: K? = null): Sequence<KeyValue<K, V>>

Generate a Sequence of a range of records.

reverseAllAsSequence

fun <K, V> KeyValueStore<K, V>.reverseAllAsSequence(): Sequence<KeyValue<K, V>>

Generate a Sequence of all records, in reverse

reverseRangeAsSequence

fun <K, V> KeyValueStore<K, V>.reverseRangeAsSequence(from: K? = null, to: K? = null): Sequence<KeyValue<K, V>>

Generate a Sequence of a reverse-range of records.

inline fun <K, V, Result> KeyValueStore<K, V>.useAll(operation: KeyValueIteratorOperation<K, V, Result>): Result

Iterate over all records.

inline fun <K, V, Prefix, Result> KeyValueStore<K, V>.usePrefixScan(prefix: Prefix, prefixKeySerializer: Serializer<Prefix>, operation: KeyValueIteratorOperation<K, V, Result>): Result

Iterate over records based on the key prefix.

inline fun <K, V, Result> KeyValueStore<K, V>.useRange(from: K? = null, to: K? = null, operation: KeyValueIteratorOperation<K, V, Result>): Result

Iterate over a range of records.

inline fun <K, V, Result> KeyValueStore<K, V>.useReverseAll(operation: KeyValueIteratorOperation<K, V, Result>): Result

Reverse-iterate over all records.

useReverseRange

inline fun <K, V, Result> KeyValueStore<K, V>.useReverseRange(from: K? = null, to: K? = null, operation: KeyValueIteratorOperation<K, V, Result>): Result

Reverse-iterate over a range of records.