xtdb-core/xtdb.api.log/Watchers

Watchers

class Watchers(latestTxId: TxId, latestSourceMsgId: MessageId, externalSourceToken: ExternalSourceToken? = null)

Constructors

constructor(latestTxId: TxId, latestSourceMsgId: MessageId, externalSourceToken: ExternalSourceToken? = null)

Properties

val exception: IngestionStoppedException?

externalSourceToken

val externalSourceToken: ExternalSourceToken?

latestSourceMsgId

val latestSourceMsgId: MessageId

val latestTxId: TxId

Functions

suspend fun awaitSource(srcMsgId: MessageId)

suspend fun awaitTx(txId: TxId): TransactionResult?

fun notifyError(exception: Throwable)

fun notifyMsg(srcMsgId: MessageId)

fun notifyTx(result: TransactionResult, srcMsgId: MessageId, externalSourceToken: ExternalSourceToken?)

open override fun toString(): String