import type { ConsumerCheckpoint } from "../types/index.js";
export interface ICheckpointStore {
    initialize(): Promise<void>;
    get(group: string, partition: number): ConsumerCheckpoint | undefined;
    commit(checkpoint: ConsumerCheckpoint): Promise<void>;
    reset(group: string, partition: number, timestamp?: number): Promise<void>;
    getForGroup(group: string): ConsumerCheckpoint[];
    initCheckpoints(group: string, partitionCount: number, timestamp?: number): Promise<void>;
}
export declare class CheckpointStore implements ICheckpointStore {
    private filePath;
    private cache;
    private dirty;
    private authorized;
    constructor(filePath?: string, authToken?: symbol);
    /** Create an authorized CheckpointStore instance for the infrastructure layer. */
    static createAuthorized(filePath?: string): CheckpointStore;
    protected ensureAuthorized(): void;
    initialize(): Promise<void>;
    private key;
    loadAll(): Promise<void>;
    save(): Promise<void>;
    get(group: string, partition: number): ConsumerCheckpoint | undefined;
    commit(checkpoint: ConsumerCheckpoint): Promise<void>;
    reset(group: string, partition: number, timestamp?: number): Promise<void>;
    getForGroup(group: string): ConsumerCheckpoint[];
    initCheckpoints(group: string, partitionCount: number, timestamp?: number): Promise<void>;
}
export declare class InMemoryCheckpointStore implements ICheckpointStore {
    initialize(): Promise<void>;
    private checkpoints;
    get(group: string, partition: number): ConsumerCheckpoint | undefined;
    commit(checkpoint: ConsumerCheckpoint): Promise<void>;
    reset(group: string, partition: number, timestamp?: number): Promise<void>;
    getForGroup(group: string): ConsumerCheckpoint[];
    initCheckpoints(group: string, partitionCount: number, timestamp?: number): Promise<void>;
}