Package-level declarations
Types
Link copied to clipboard
open class EvictStateCacheRefresher<K, S : Any, D>(namedAggregate: NamedAggregate, val cache: Cache<K, D>, val keyConvert: (DomainEventExchange<Any>) -> K = { exchange ->
@Suppress("UNCHECKED_CAST")
exchange.message.aggregateId.id as K
}) : StateCacheRefresher<S, D, DomainEventExchange<Any>>
Evicts aggregate state from the cache.
Link copied to clipboard
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.
Link copied to clipboard
abstract class StateCacheRefresher<S : Any, D, M : DomainEventExchange<*>>(val namedAggregate: NamedAggregate) : NamedAggregateDecorator, MessageFunction<StateCacheRefresher<S, D, M>, M, Mono<Void>>
Proactively refreshes aggregate state caches.