spi/me.ahoo.wow.spi.subscription/ImportCutover

ImportCutover

Where a context's log ends the history migrate-data imported from 9.x: in each partition, the log's head after the latest import or tail pass, kept as a checkpoint row of the store beside the log (group groupOf, subscription SUBSCRIPTION), which each pass moves forward. A context that was never migrated has none.

An entry at or before it is an imported one: 9.x already acted on it. The log's subscriptions see it so (SubscribedEntry.imported), and the transport sink publishes it marked (me.ahoo.wow.spi.state.StateEventRecord.imported), so a peer's saga or reactor passes over the history while its projections and every sink still take it.

Properties

SUBSCRIPTION

const val SUBSCRIPTION: String

The subscription name of the cut-over's rows in its group.

Functions

groupOf

fun groupOf(context: String): String

The checkpoint group of context's cut-over, apart from every subscription group (<service>/<context>).