krate-core/com.neutrine.krate.storage.memory/SimpleBucketStateMap

SimpleBucketStateMap

class SimpleBucketStateMap : BucketStateMap

Simple in-memory implementation of BucketStateMap. This implementation is thread-safe and uses ConcurrentHashMap to store the state.

Constructors

constructor()

Functions

getBucketStateReference

open override fun getBucketStateReference(key: String): AtomicReference<BucketState>?

Returns the AtomicReference of the BucketState for the given key. If the key is not present in the map, it returns null.

putIfAbsent

open override fun putIfAbsent(key: String, value: AtomicReference<BucketState>): AtomicReference<BucketState>?

Puts the value in the map if the key is not present. If the key is already present, it returns the AtomicReference of the BucketState for the given key. If the key is not present in the map, it returns null.