runtime/me.ahoo.wow.runtime.subscription/SubscriptionPosition

SubscriptionPosition

@InternalWowApi

data class SubscriptionPosition(val subscription: String, val partition: Int, val watermark: Long)

Where subscription stands in partition of its source: every entry up to the sequence watermark is complete.

Constructors

SubscriptionPosition

constructor(subscription: String, partition: Int, watermark: Long)

Properties

val partition: Int

val subscription: String

val watermark: Long