bulk-cdk-core-load/io.airbyte.cdk.load.message/CheckpointMessageQueue

CheckpointMessageQueue

@Singleton
@Secondary
class CheckpointMessageQueue : ChannelMessageQueue<Reserved<CheckpointMessageWrapped>>

A single-channel queue for checkpoint messages. This is so updating the checkpoint manager never blocks reading from stdin.

Constructors

Link copied to clipboard
constructor()

Properties

Link copied to clipboard

Functions

Link copied to clipboard
open suspend override fun close()
Link copied to clipboard
inline suspend fun CloseableCoroutine.closeFinally(cause: Throwable?)
Link copied to clipboard
open override fun consume(): Flow<Reserved<CheckpointMessageWrapped>>
Link copied to clipboard
open override fun isClosedForPublish(): Boolean
Link copied to clipboard
open suspend override fun poll(): Reserved<CheckpointMessageWrapped>?
Link copied to clipboard
open suspend override fun publish(message: Reserved<CheckpointMessageWrapped>)