//#region src/types.d.ts type All = "*"; type PendingWriteValue = unknown; type PendingWrite = [Channel, PendingWriteValue]; type CheckpointPendingWrite = [TaskId, ...PendingWrite]; /** * Additional details about the checkpoint, including the source, step, writes, and parents. * * @typeParam ExtraProperties - Optional additional properties to include in the metadata. */ type CheckpointMetadata = { /** * The source of the checkpoint. * - "input": The checkpoint was created from an input to invoke/stream/batch. * - "loop": The checkpoint was created from inside the pregel loop. * - "update": The checkpoint was created from a manual state update. * - "fork": The checkpoint was created as a copy of another checkpoint. */ source: "input" | "loop" | "update" | "fork"; /** * The step number of the checkpoint. * -1 for the first "input" checkpoint. * 0 for the first "loop" checkpoint. * ... for the nth checkpoint afterwards. */ step: number; /** * The IDs of the parent checkpoints. * Mapping from checkpoint namespace to checkpoint ID. */ parents: Record; } & ExtraProperties; //#endregion export { All, CheckpointMetadata, CheckpointPendingWrite, PendingWrite, PendingWriteValue }; //# sourceMappingURL=types.d.ts.map