ContextNode
The parts of one bounded context on a node: the log it appends through (log, the partition append queue over the backend's log), its kernel and executor, the built-in snapshots and reservations subscriptions when the context has their stores, the subscriptions runtime of its lease group, this node's ownership of the group's partitions, its wait coordinator, and the endpoint that executes the commands other nodes forward to it.
The application's subscriptions read the context's backends, the kernel's codec, and the state views the executor takes of the aggregate types its state consumers read: the snapshot subscription and the readers the application's subscriptions name (SubscriptionFactory.stateReaders), each reading through its stateReader.
Properties
The context's access walks: each type's history stamped with its aggregates' current access attributes.
The client of the other contexts' command gateways the context's sagas call synchronously; null when the host gives none, and a call then fails.
Names the commands the context's sagas schedule: by its models and the service's Manifests.
The ids of the context's creation commands that name no aggregate: a saga's derived command, one its command topic brings, each looked up by its request in the context's log first.
The node's id generators, the ids its sagas take.
The runtime of the context's command topic, driven by ownership: null unless the node takes commands from topics (SourceTopics.intake).
The context's log groups, its default one first: each with the runtime of its subscriptions and its timers. subscriptions and timers are the default group's.
The events of other contexts' published streams, decoded into their api classes; none by default.
The queries the context's handlers read with, by the commit's tenant; none by default.
Sends the commands of the context's sagas to other contexts; null without a producer.
The context's snapshot maintenance, when it keeps snapshots.
The subscription of the default snapshot store when it is a target, else the first target's, if any.
The subscription of each snapshot target store, the default store's first.
The built-in timers subscription and the context's timer runner, when its backends have a timer store: the runner's TimerRunner.retry and TimerRunner.skip serve an operator.
The node's command validators, the gateway's: the commands the context's sagas derive, and those its intake takes from its topic, are checked as admitted ones are.
Functions
The snapshot write checkpoint of type: the progress of the subscription of type's primary snapshot target over the partitions of type's log group (SubscriptionRuntime.progress). It does not move while no snapshot of the group's aggregate types is written, so a count of type's snapshots taken at one value is still the count at that value. Null when type has no snapshots here.
Reads the state after a commit as the state consumer reader of views (SharedStateReader), from the context's snapshots when its views miss: what me.ahoo.wow.runtime.subscription.EntryDecoder.stateEvents decodes with.