StreamBarrierTopic

data class StreamBarrierTopic(var topic: ByteArray, var scopeGeneration: ULong? = null, var target: ULong?, var received: ULong, var processed: ULong, var unresolvedWelcomes: List<ULong>, var inactive: Boolean, var cause: StreamBarrierCause?)

One fixed topic obligation and its stored processing progress.

Constructors

Link copied to clipboard
constructor(topic: ByteArray, scopeGeneration: ULong? = null, target: ULong?, received: ULong, processed: ULong, unresolvedWelcomes: List<ULong>, inactive: Boolean, cause: StreamBarrierCause?)

Types

Link copied to clipboard
object Companion

Properties

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard

Resolved processing cursor P, separate from consumer acknowledgement.

Link copied to clipboard

Stored receipt cursor F.

Link copied to clipboard

Captured owning scope. None precedes admission.

Link copied to clipboard

Target H. None differs from a captured empty target of zero.

Link copied to clipboard

Complete topic bytes.

Link copied to clipboard

Unresolved Welcome sequence IDs at or below H.

Functions

Link copied to clipboard
open operator override fun equals(other: Any?): Boolean
Link copied to clipboard
open override fun hashCode(): Int
Link copied to clipboard
open override fun toString(): String