wow-cocache/me.ahoo.wow.cache.refresh/SetStateCacheRefresher

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

SetStateCacheRefresher

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

open override val aggregateName: String

val cache: Cache<K, D>

open override val contextName: String

open override val functionKind: FunctionKind

val keyConvert: (StateDomainEventExchange<S, Any>) -> K

open override val name: String

override val namedAggregate: NamedAggregate

open override val processor: StateCacheRefresher<S, D, StateDomainEventExchange<S, Any>>

open override val processorName: String

open override val qualifiedName: String

supportedTopics

override val supportedTopics: Set<NamedAggregate>

open override val supportedType: Class<*>

open override val ttl: Long

open override val ttlAmplitude: Long

Functions

open fun evict(exchange: StateDomainEventExchange<S, Any>)

open override fun <A : Annotation> getAnnotation(annotationClass: Class<A>): A?

open fun handle(exchange: StateDomainEventExchange<S, Any>): Mono<Void>

open operator override fun invoke(exchange: StateDomainEventExchange<S, Any>): Mono<Void>

open fun isEmpty(): Boolean

isSameAggregateName

open fun isSameAggregateName(other: NamedAggregate): Boolean

isSameBoundedContext

open fun isSameBoundedContext(other: NamedBoundedContext): Boolean

open fun isSameFunction(functionInfo: FunctionInfo): Boolean

open override fun refresh(exchange: StateDomainEventExchange<S, Any>)

open fun <M : Message<*, Any>, NamedBoundedContext, NamedAggregate> supportMessage(message: M): Boolean