CachedFeatureStore

class CachedFeatureStore(delegate: FeatureStore, ttl: Duration, timeSource: TimeSource = TimeSource.Monotonic) : FeatureStore(source)

Constructors

constructor(delegate: FeatureStore, ttl: Duration, timeSource: TimeSource = TimeSource.Monotonic)

fun FeatureStore.cached(ttl: Duration = 30.seconds, timeSource: TimeSource = TimeSource.Monotonic): FeatureStore

Serves reads from a snapshot of delegate refreshed every ttl; writes go through and drop the snapshot.

open suspend override fun delete(id: String)

Removes the feature; a no-op when it does not exist.

open suspend override fun get(id: String): Feature?

open suspend override fun getAll(): List<Feature>

open suspend override fun put(feature: Feature)

Inserts or replaces the feature.

open suspend override fun update(id: String, transform: (Feature) -> Feature): Feature

Atomically replaces the stored feature with the result of transform.