/*! * Copyright (c) Microsoft Corporation and contributors. All rights reserved. * Licensed under the MIT License. */ import { ICheckpointService, IDeliState, IQueuedMessage } from "@fluidframework/server-services-core"; import { CheckpointReason } from "../utils"; /** * @internal */ export interface IDeliCheckpointManager { writeCheckpoint(checkpoint: IDeliState, isLocal: boolean, reason: CheckpointReason): Promise; deleteCheckpoint(checkpointParams: ICheckpointParams, isLocal: boolean): Promise; } /** * @internal */ export interface ICheckpointParams { /** * The reason why this checkpoint was triggered */ reason: CheckpointReason; /** * The deli checkpoint state \@ deliCheckpointMessage */ deliState: IDeliState; /** * The message to checkpoint for deli (mongodb) */ deliCheckpointMessage: IQueuedMessage; /** * The message to checkpoint for kafka */ kafkaCheckpointMessage: IQueuedMessage | undefined; /** * Flag that decides if the deli checkpoint should be deleted */ clear?: boolean; } /** * @internal */ export declare function createDeliCheckpointManagerFromCollection(tenantId: string, documentId: string, checkpointService: ICheckpointService): IDeliCheckpointManager; //# sourceMappingURL=checkpointManager.d.ts.map