micro_utils.dokka/dev.inmo.micro_utils.repos.mappers/MapperKeyValueRepo

MapperKeyValueRepo

open class MapperKeyValueRepo<FromKey, FromValue, ToKey, ToValue>(to: KeyValueRepo<ToKey, ToValue>, mapper: MapperRepo<FromKey, FromValue, ToKey, ToValue>) : KeyValueRepo<FromKey, FromValue> , MapperRepo<FromKey, FromValue, ToKey, ToValue> , ReadKeyValueRepo<FromKey, FromValue> , WriteKeyValueRepo<FromKey, FromValue>

Constructors

MapperKeyValueRepo

fun <FromKey, FromValue, ToKey, ToValue> MapperKeyValueRepo(to: KeyValueRepo<ToKey, ToValue>, mapper: MapperRepo<FromKey, FromValue, ToKey, ToValue>)

Functions

clear

open suspend fun clear()

By default, will remove all the data of current repo using doAllWithCurrentPaging, keys and unset

contains

open suspend override fun contains(key: FromKey): Boolean

count

open suspend override fun count(): Long

get

open suspend override fun get(k: FromKey): FromValue?

keys

open suspend override fun keys(pagination: Pagination, reversed: Boolean): PaginationResult<FromKey>

This method should use sorted by Keys search and return the PaginationResult. By default, it should use ascending sort for Keys

open suspend override fun keys(v: FromValue, pagination: Pagination, reversed: Boolean): PaginationResult<FromKey>

This method should use sorted by Keys search and return the PaginationResult. By default, it should use ascending sort for Keys.

set

open suspend override fun set(toSet: Map<FromKey, FromValue>)

Will set as batch toSet data in current repo. Must pass the data which were successfully updated in repo to onNewValue

toInnerKey

open suspend override fun ToKey.toInnerKey(): FromKey

toInnerValue

open suspend override fun ToValue.toInnerValue(): FromValue

toOutKey

open suspend override fun FromKey.toOutKey(): ToKey

toOutValue

open suspend override fun FromValue.toOutValue(): ToValue

unset

open suspend override fun unset(toUnset: List<FromKey>)

Will unset as batch data with keys from toUnset. Must pass the Keys which were successfully removed in repo to onValueRemoved

unsetWithValues

open suspend override fun unsetWithValues(toUnset: List<FromValue>)

By default, will walk throw all the keys with Values from toUnset and run doAllWithCurrentPaging with unset of found data Keys

values

open suspend override fun values(pagination: Pagination, reversed: Boolean): PaginationResult<FromValue>

This method should use sorted by Keys search and return the PaginationResult. By default, it should use ascending sort for Keys

Properties

keyMapper

open override val keyMapper: SimpleSuspendableMapper<FromKey, ToKey>

onNewValue

open override val onNewValue: Flow<Pair<FromKey, FromValue>>

onValueRemoved

open override val onValueRemoved: Flow<FromKey>

valueMapper

open override val valueMapper: SimpleSuspendableMapper<FromValue, ToValue>

Extensions

asKeyValuesRepo

fun <K, V, VI : Iterable<V>> KeyValueRepo<K, VI>.asKeyValuesRepo(listToValuesIterable: suspend (List<V>) -> VI): KeyValuesFromKeyValueRepo<K, V, VI>

@JvmName(name = "asListKeyValuesRepo")

fun <K, V> KeyValueRepo<K, List<V>>.asKeyValuesRepo(): KeyValuesFromKeyValueRepo<K, V, List<V>>

@JvmName(name = "asSetKeyValuesRepo")

fun <K, V> KeyValueRepo<K, Set<V>>.asKeyValuesRepo(): KeyValuesFromKeyValueRepo<K, V, Set<V>>

asReadCRUDRepo

fun <K, V> ReadKeyValueRepo<K, V>.asReadCRUDRepo(): ReadCRUDFromKeyValueRepo<V, K>

asReadKeyValuesRepo

fun <K, V, VI : Iterable<V>> ReadKeyValueRepo<K, VI>.asReadKeyValuesRepo(): ReadKeyValuesFromKeyValueRepo<K, V, VI>

cached

fun <Key, Value> KeyValueRepo<Key, Value>.cached(kvCache: FullKVCache<Key, Value>, scope: CoroutineScope = CoroutineScope(Dispatchers.Default)): FullKeyValueCacheRepo<Key, Value>

fun <Key, Value> KeyValueRepo<Key, Value>.cached(kvCache: KVCache<Key, Value>, scope: CoroutineScope = CoroutineScope(Dispatchers.Default)): KeyValueCacheRepo<Key, Value>

fun <Key, Value> ReadKeyValueRepo<Key, Value>.cached(kvCache: FullKVCache<Key, Value>): FullReadKeyValueCacheRepo<Key, Value>

fun <Key, Value> ReadKeyValueRepo<Key, Value>.cached(kvCache: KVCache<Key, Value>): ReadKeyValueCacheRepo<Key, Value>

caching

fun <Key, Value> WriteKeyValueRepo<Key, Value>.caching(kvCache: FullKVCache<Key, Value>, scope: CoroutineScope = CoroutineScope(Dispatchers.Default)): FullWriteKeyValueCacheRepo<Key, Value>

set

inline suspend fun <Key, Value> WriteKeyValueRepo<Key, Value>.set(vararg toSet: Pair<Key, Value>)

inline suspend fun <Key, Value> WriteKeyValueRepo<Key, Value>.set(toSet: List<Pair<Key, Value>>)

inline suspend fun <Key, Value> WriteKeyValueRepo<Key, Value>.set(k: Key, v: Value)

unset

inline suspend fun <Key, Value> WriteKeyValueRepo<Key, Value>.unset(vararg k: Key)

unsetWithValues

inline suspend fun <Key, Value> WriteKeyValueRepo<Key, Value>.unsetWithValues(vararg v: Value)

withMapper

inline fun <FromKey, FromValue, ToKey, ToValue> KeyValueRepo<ToKey, ToValue>.withMapper(mapper: MapperRepo<FromKey, FromValue, ToKey, ToValue>): KeyValueRepo<FromKey, FromValue>

inline fun <FromKey, FromValue, ToKey, ToValue> KeyValueRepo<ToKey, ToValue>.withMapper(noinline keyFromToTo: suspend FromKey.() -> ToKey = { this as ToKey }, noinline valueFromToTo: suspend FromValue.() -> ToValue = { this as ToValue }, noinline keyToToFrom: suspend ToKey.() -> FromKey = { this as FromKey }, noinline valueToToFrom: suspend ToValue.() -> FromValue = { this as FromValue }): KeyValueRepo<FromKey, FromValue>

inline fun <FromKey, FromValue, ToKey, ToValue> ReadKeyValueRepo<ToKey, ToValue>.withMapper(mapper: MapperRepo<FromKey, FromValue, ToKey, ToValue>): ReadKeyValueRepo<FromKey, FromValue>

inline fun <FromKey, FromValue, ToKey, ToValue> ReadKeyValueRepo<ToKey, ToValue>.withMapper(noinline keyFromToTo: suspend FromKey.() -> ToKey = { this as ToKey }, noinline valueFromToTo: suspend FromValue.() -> ToValue = { this as ToValue }, noinline keyToToFrom: suspend ToKey.() -> FromKey = { this as FromKey }, noinline valueToToFrom: suspend ToValue.() -> FromValue = { this as FromValue }): ReadKeyValueRepo<FromKey, FromValue>

inline fun <FromKey, FromValue, ToKey, ToValue> WriteKeyValueRepo<ToKey, ToValue>.withMapper(mapper: MapperRepo<FromKey, FromValue, ToKey, ToValue>): WriteKeyValueRepo<FromKey, FromValue>

inline fun <FromKey, FromValue, ToKey, ToValue> WriteKeyValueRepo<ToKey, ToValue>.withMapper(noinline keyFromToTo: suspend FromKey.() -> ToKey = { this as ToKey }, noinline valueFromToTo: suspend FromValue.() -> ToValue = { this as ToValue }, noinline keyToToFrom: suspend ToKey.() -> FromKey = { this as FromKey }, noinline valueToToFrom: suspend ToValue.() -> FromValue = { this as FromValue }): WriteKeyValueRepo<FromKey, FromValue>