import type { ConnectorProxy } from './connector-proxy.js';
import type { JsonValue, TriggerKeySnapshot, TriggerSchedule } from '../browser/project-change.js';
export declare const maximumPollCheckpointBytes: number;
export declare const maximumPollDedupeKeyBytes = 1024;
export declare const maximumPollEventsPerPage = 100;
export interface PollEvent {
    readonly dedupeKey: string;
    readonly payload: Readonly<Record<string, JsonValue>>;
}
export interface PollResult {
    readonly checkpoint: JsonValue;
    readonly events: readonly PollEvent[];
    readonly filtered?: number;
    readonly hasMore?: boolean;
}
export interface PollContext {
    readonly checkpoint: JsonValue;
    readonly config: Readonly<Record<string, JsonValue>>;
    readonly connector: ConnectorProxy;
    readonly now: Date;
    readonly signal?: AbortSignal;
}
export interface PollDefinition {
    readonly poll: (context: PollContext) => Promise<PollResult>;
    readonly snapshot: TriggerKeySnapshot & {
        readonly type: 'poll';
    };
}
export declare class PollConnectionError extends Error {
    readonly name = "PollConnectionError";
}
export declare class PermanentPollError extends Error {
    readonly name = "PermanentPollError";
}
export declare class TransientPollError extends Error {
    readonly name = "TransientPollError";
}
export declare function pollPageClaimId(bindingId: string, runtimeVersion: number, rootOccurrenceId: string, page: number): Promise<string>;
export declare function providerEventId(bindingId: string, triggerKey: string, dedupeKey: string): Promise<string>;
export interface PollConformanceFixture {
    readonly config: Readonly<Record<string, JsonValue>>;
    readonly connectionId: string;
    readonly publishedAt: string;
    readonly rules: readonly TriggerSchedule[];
}
export interface PollConformanceState {
    readonly calls: number;
    readonly checkpoint: JsonValue;
    readonly health: 'healthy' | 'initializing';
    readonly payloads: readonly JsonValue[];
}
export interface PollConformanceHarness {
    dispose(): Promise<void>;
    replayLast(): Promise<void>;
    republish(at: string, change?: {
        readonly config?: Readonly<Record<string, JsonValue>>;
        readonly connectionId?: string;
    }): Promise<void>;
    restart(): Promise<void>;
    retire(at: string): Promise<void>;
    state(): Promise<PollConformanceState>;
    tick(at: string, pages: readonly PollResult[]): Promise<void>;
}
export interface PollConformanceCase {
    readonly fixture: PollConformanceFixture;
    readonly name: string;
    verify(harness: PollConformanceHarness): Promise<void>;
}
export declare const pollConformanceCases: readonly PollConformanceCase[];