runtime/me.ahoo.wow.runtime.subscription/SubscriptionFilter

SubscriptionFilter

data class SubscriptionFilter(val context: String, val aggregates: Set<String> = emptySet(), val events: Set<String> = emptySet(), val ids: Set<String> = emptySet())

The streams a subscription handles: those of one bounded context, of the aggregates named (every aggregate of the context when empty), of the aggregates whose id is in ids (any id when empty: a job's subscription reads its job's instances alone), holding at least one event whose stored name is in events (any event when empty). Event names are the names the log stores (context.aggregate.Event). Without models a renamed event must be listed under its former names too; resolve adds them from the models. An entry outside the filter still moves the checkpoint, its state never read.

Constructors

SubscriptionFilter

constructor(context: String, aggregates: Set<String> = emptySet(), events: Set<String> = emptySet(), ids: Set<String> = emptySet())

Properties

aggregates

val aggregates: Set<String>

context

val context: String

events

val events: Set<String>

ids

val ids: Set<String>

Functions

matches

fun matches(stream: EventStreamRecord): Boolean

resolve

fun resolve(models: Collection<AggregateModel<*>>): SubscriptionFilter

This filter with each listed event name widened to every name its event type has among models of the filter's context: the current name and the former ones (aliases), so a rename on either side keeps matching. A name no model knows stays as it is.