import type { DatabaseAdapter } from '../db-manager.js';
import type { ConnectorEventIndexCursorRecord, ConnectorEventIndexRecord, ConnectorEventSearchHit, ConnectorEventStalenessStatus, UpsertConnectorEventIndexCursorInput, UpsertConnectorEventIndexInput } from './types.js';
type ConnectorEventIndexAdapter = Pick<DatabaseAdapter, 'prepare' | 'transaction'>;
interface ListConnectorEventsByDatetimeRangeInput {
    fromMs: number;
    toMs: number;
    limit?: number;
    connectors?: string[];
    order?: 'asc' | 'desc';
}
interface SearchConnectorEventsOptions {
    limit?: number;
    connectors?: string[];
}
interface DeleteExpiredConnectorEventsInput {
    nowMs: number;
    retentionMs: number;
    connectorName?: string;
}
interface StalenessOptions {
    nowMs: number;
    staleAfterMs?: number;
    stalenessWarnAfterMs?: number;
    unhealthyAfterMs?: number;
}
export declare function mapConnectorEventIndexRecord(row: Record<string, unknown>): ConnectorEventIndexRecord;
export declare function connectorEventIndexId(sourceConnector: string, sourceId: string): string;
export declare function connectorEventContentHash(input: {
    source_connector: string;
    source_id: string;
    content: string;
    event_datetime?: number | null;
}): Buffer;
export declare function upsertConnectorEventIndex(adapter: ConnectorEventIndexAdapter, input: UpsertConnectorEventIndexInput): ConnectorEventIndexRecord;
export declare function getConnectorEventIndexRecord(adapter: ConnectorEventIndexAdapter, sourceConnector: string, sourceId: string): ConnectorEventIndexRecord | null;
export declare function listConnectorEventsByDatetimeRange(adapter: ConnectorEventIndexAdapter, input: ListConnectorEventsByDatetimeRangeInput): ConnectorEventIndexRecord[];
export declare function searchConnectorEventsByFTS(adapter: ConnectorEventIndexAdapter, query: string, options?: SearchConnectorEventsOptions): ConnectorEventSearchHit[];
export declare function readConnectorCursor(adapter: ConnectorEventIndexAdapter, connectorName: string): ConnectorEventIndexCursorRecord | null;
export declare function upsertConnectorCursor(adapter: ConnectorEventIndexAdapter, input: UpsertConnectorEventIndexCursorInput): ConnectorEventIndexCursorRecord;
export declare function deleteExpiredConnectorEvents(adapter: ConnectorEventIndexAdapter, input: DeleteExpiredConnectorEventsInput): {
    rows_deleted: number;
};
export declare function computeStalenessStatus(cursor: ConnectorEventIndexCursorRecord | null, options: StalenessOptions): ConnectorEventStalenessStatus;
export type { ConnectorEventIndexCursorRecord, ConnectorEventIndexRecord, ConnectorEventSearchHit, ConnectorEventStalenessStatus, UpsertConnectorEventIndexCursorInput, UpsertConnectorEventIndexInput, } from './types.js';
//# sourceMappingURL=event-index.d.ts.map