/**
 * Timer Store implementations for workflow timers
 *
 * Features:
 * - In-memory and file-based storage
 * - Timer persistence across restarts
 * - Efficient lookup by due time
 * - Cancellation support
 * - Fire event callbacks
 */
import type { TimerEntry, TimerStore } from '@cogitator-ai/types';
/**
 * Timer query options
 */
export interface TimerQueryOptions {
    workflowId?: string;
    runId?: string;
    nodeId?: string;
    status?: 'pending' | 'fired' | 'cancelled';
    firesBefore?: number;
    firesAfter?: number;
    limit?: number;
    offset?: number;
}
type FireCallback = (entry: TimerEntry) => void;
/**
 * In-memory timer store
 */
export declare class InMemoryTimerStore implements TimerStore {
    private timers;
    private fireCallbacks;
    schedule(entry: Omit<TimerEntry, 'id' | 'cancelled' | 'fired' | 'createdAt'>): Promise<string>;
    get(id: string): Promise<TimerEntry | null>;
    cancel(id: string): Promise<void>;
    getByWorkflow(workflowId: string): Promise<TimerEntry[]>;
    getByRun(runId: string): Promise<TimerEntry[]>;
    getPending(): Promise<TimerEntry[]>;
    getOverdue(): Promise<TimerEntry[]>;
    markFired(id: string): Promise<void>;
    cleanup(olderThan: number): Promise<number>;
    onFire(callback: FireCallback): () => void;
    /**
     * List timers with filtering
     */
    update(id: string, patch: Partial<TimerEntry>): Promise<void>;
    list(filter?: {
        enabled?: boolean;
        type?: string;
    }): Promise<TimerEntry[]>;
    query(options?: TimerQueryOptions): Promise<TimerEntry[]>;
    count(options?: TimerQueryOptions): Promise<number>;
    clear(): Promise<void>;
}
/**
 * File-based timer store for persistence
 */
export declare class FileTimerStore implements TimerStore {
    private directory;
    private indexFile;
    private initialized;
    private cache;
    private fireCallbacks;
    constructor(directory: string);
    private ensureInitialized;
    private persist;
    schedule(entry: Omit<TimerEntry, 'id' | 'cancelled' | 'fired' | 'createdAt'>): Promise<string>;
    get(id: string): Promise<TimerEntry | null>;
    cancel(id: string): Promise<void>;
    getByWorkflow(workflowId: string): Promise<TimerEntry[]>;
    getByRun(runId: string): Promise<TimerEntry[]>;
    getPending(): Promise<TimerEntry[]>;
    getOverdue(): Promise<TimerEntry[]>;
    markFired(id: string): Promise<void>;
    cleanup(olderThan: number): Promise<number>;
    onFire(callback: FireCallback): () => void;
    update(id: string, patch: Partial<TimerEntry>): Promise<void>;
    list(filter?: {
        enabled?: boolean;
        type?: string;
    }): Promise<TimerEntry[]>;
    query(options?: TimerQueryOptions): Promise<TimerEntry[]>;
    count(options?: TimerQueryOptions): Promise<number>;
    clear(): Promise<void>;
}
/**
 * Create an in-memory timer store
 */
export declare function createInMemoryTimerStore(): InMemoryTimerStore;
/**
 * Create a file-based timer store
 */
export declare function createFileTimerStore(directory: string): FileTimerStore;
export {};
//# sourceMappingURL=timer-store.d.ts.map