SetStateCacheRefresher

open class SetStateCacheRefresher<K, S : Any, D>(namedAggregate: NamedAggregate, stateToCacheDataConverter: StateToCacheDataConverter<ReadOnlyStateAggregate<S>, D>, val ttl: Long = CoCache.DEFAULT_TTL, val ttlAmplitude: Long = CoCache.DEFAULT_TTL_AMPLITUDE, val cache: Cache<K, D>, val keyConvert: (StateDomainEventExchange<S, Any>) -> K = { exchange -> @Suppress("UNCHECKED_CAST") exchange.message.aggregateId.id as K }) : TtlConfiguration, StateCacheRefresher<S, D, StateDomainEventExchange<S, Any>>

Updates the cache from the latest aggregate state.

Constructors

constructor(namedAggregate: NamedAggregate, stateToCacheDataConverter: StateToCacheDataConverter<ReadOnlyStateAggregate<S>, D>, ttl: Long = CoCache.DEFAULT_TTL, ttlAmplitude: Long = CoCache.DEFAULT_TTL_AMPLITUDE, cache: Cache<K, D>, keyConvert: (StateDomainEventExchange<S, Any>) -> K = { exchange -> @Suppress("UNCHECKED_CAST") exchange.message.aggregateId.id as K })

val cache: Cache<K, D>

open override val ttl: Long

open override val ttlAmplitude: Long