import { CreateJobRequest, CreateSessionRequest, JobEvent, JobInfo, QueueStats } from "@workerdeck/protocol";
import { Runner, SessionRunnerConfig } from "@workerdeck/core";
//#region src/adapter.d.ts
type JobRecord = {
  info: JobInfo;
  request: CreateJobRequest;
};
interface QueueAdapter {
  add(job: JobRecord): Promise<void>;
  claimNext(): Promise<JobRecord | null>;
  get(id: string): Promise<JobRecord | null>;
  list(): Promise<JobRecord[]>;
  update(id: string, patch: Partial<JobInfo>): Promise<JobRecord | null>;
  prune(olderThanMs: number): Promise<number>;
  addDailyTokens(dayKey: string, tokens: number): Promise<number>;
  dailyTokens(dayKey: string): Promise<number>;
  nextRunAt?(): Promise<number | undefined>;
  onWork?(listener: () => void): () => void;
}
declare class InMemoryQueueAdapter implements QueueAdapter {
  #private;
  add(job: JobRecord): Promise<void>;
  claimNext(): Promise<JobRecord | null>;
  get(id: string): Promise<JobRecord | null>;
  list(): Promise<JobRecord[]>;
  update(id: string, patch: Partial<JobInfo>): Promise<JobRecord | null>;
  prune(olderThanMs: number): Promise<number>;
  addDailyTokens(dayKey: string, tokens: number): Promise<number>;
  dailyTokens(dayKey: string): Promise<number>;
  nextRunAt(): Promise<number | undefined>;
}
//#endregion
//#region src/queue.d.ts
type JobQueueOptions = {
  createRunner: (config: SessionRunnerConfig) => Runner | Promise<Runner>;
  adapter?: QueueAdapter;
  maxConcurrency?: number;
  sessionTokenLimit?: number;
  dailyTokenLimit?: number;
  maxJobDurationMs?: number;
  maxParkedDurationMs?: number;
  killGraceMs?: number;
  retention?: {
    maxAgeMs: number;
    sweepIntervalMs?: number;
  };
  buildRunnerConfig?: (req: CreateSessionRequest) => SessionRunnerConfig;
  discardSession?: (sessionId: string) => void | Promise<void>;
  fetchImpl?: typeof fetch;
  webhookAttempts?: number;
  webhookRetryDelayMs?: number;
  onEvent?: (event: JobEvent) => void;
  onError?: (error: unknown, context: JobQueueErrorContext) => void;
};
type JobQueueErrorPhase = 'pump' | 'start' | 'event' | 'finalize' | 'park' | 'resume';
type JobQueueErrorContext = {
  jobId?: string;
  phase: JobQueueErrorPhase;
};
declare class JobQueue {
  #private;
  constructor(options: JobQueueOptions);
  submit(request: CreateJobRequest): Promise<JobInfo>;
  get(id: string): Promise<JobInfo | null>;
  list(): Promise<JobInfo[]>;
  canParkSession(sessionId: string): boolean;
  onSessionParking(sessionId: string, executionId: string): boolean;
  onSessionResumed(sessionId: string, runner: Runner): void;
  cancel(id: string): Promise<JobInfo | null>;
  pause(): void;
  resume(): void;
  get paused(): boolean;
  stats(): Promise<QueueStats>;
  close(): void;
}
//#endregion
export { InMemoryQueueAdapter, JobQueue, type JobQueueErrorContext, type JobQueueErrorPhase, type JobQueueOptions, type JobRecord, type QueueAdapter };
//# sourceMappingURL=index.d.mts.map