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
}) : StateCacheRefresher<S, D, StateDomainEventExchange<S, Any>> , TtlConfiguration
主动刷新缓存.
Constructors
Link copied to clipboard
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
})
Properties
Functions
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
open fun <M : Message<*, Any>, NamedBoundedContext, NamedAggregate> supportMessage(message: M): Boolean