runtime/me.ahoo.wow.runtime.subscription/SubscriptionStart

SubscriptionStart

Where a subscription that has no checkpoint yet in a partition starts: the host's override of its handler's StartFrom (wow.subscriptions."<name>".start, SubscriptionOptions.starts). A subscription that has a checkpoint goes on from it whatever this says.

Inheritors

Beginning

End

Types

@InternalWowApi

data class At(val instant: Instant) : SubscriptionStart

From the first entry of the partition, in log order, committed at or after instant: every entry after it is handled, whatever its commit time; after the head when none is yet, as End.

Beginning

@InternalWowApi

data object Beginning : SubscriptionStart

From the first entry of the partition.

object Companion

data object End : SubscriptionStart

After the entries already committed when the subscription first starts in the partition (its log head).

Functions

checkpointIn

abstract suspend fun checkpointIn(log: EventLog, partition: Int): Long

The checkpoint the subscription starts after in partition of log: every entry after it is handled. 0 is before the first entry.