ZqliteWatermarkService class

Copy as MarkdownOpen in...

Home > @cbnsndwch/zero-watermark-zqlite > ZqliteWatermarkService

ZqliteWatermarkService class

Signature:

declare class ZqliteWatermarkService implements IWatermarkService

Implements: IWatermarkService

Constructors

Constructor

Modifiers

Description

(constructor)(db)

Constructs a new instance of the ZqliteWatermarkService class

Methods

Method

Modifiers

Description

_nextWatermark(shardId)

Private, exposed for testing purposes only

getOrCreateWatermark(shardId, resumeToken)

Retrieves an existing watermark for the given shard ID and resume token, or creates a new one if it does not exist.

getResumeToken(shardId, watermark)

Retrieves the change stream resume token for a given shard and watermark.