ZqliteWatermarkService.getResumeToken() method

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

Signature:

getResumeToken(shardId: string, watermark: LexiVersion): Promise<string | undefined>;

Parameters

Parameter

Type

Description

shardId

string

The identifier of the shard.

watermark

LexiVersion

The watermark version.

Returns:

Promise<string | undefined>

A promise that resolves to the resume token as a string, or undefined if one is not found.

How was this page?

ZqliteWatermarkService.getOrCreateWatermark() method

ZqliteWatermarkService class