import { D as Database, C as ContrailConfig } from '../types-CmjW-xL4.js';
import { B as BackfillRetryOptions } from '../backfill-Bmp9TtLS.js';
import { P as PublicServiceOptions, S as ScheduledIngestOptions, D as DeliveryHandlers, C as CurrentBootstrapRuntimeHandlers, a as DeliveryRuntimeOptions } from '../public-service-DlLFyNXn.js';
import '@atcute/identity-resolver';
import '@atcute/lexicons/syntax';
import '@atcute/client';
import '../service-auth-contract-CER8k0ek.js';

type WorkerEnv = Record<string, unknown>;
interface CreateWorkerOptions<Env extends WorkerEnv = WorkerEnv> {
    /** D1 binding name in wrangler env. Default: `"DB"`. */
    binding?: string;
    /** Exact generated/pinned bundle exposed for type generation and used by
     * collections with `validate: true`. */
    lexicons?: object[];
    /** Enable stable discovery and Lexicon routes for anonymous remote clients. */
    publicService?: PublicServiceOptions;
    /** Record count, identity count, byte, and drain-time limits for each
     * scheduled Jetstream cycle. */
    scheduledIngest?: ScheduledIngestOptions;
    /** Bounded pending-account retry slice after each scheduled ingest. Enabled
     *  by default; pass `false` to disable or options to tune its budget. */
    backfillRetries?: BackfillRetryOptions | false;
    /** Runtime delivery handlers, kept separate from static consumer policy. */
    deliveries?: DeliveryHandlers<Env>;
    /** Snapshot and activation handlers for `initial: "current"` consumers. */
    changeBootstraps?: CurrentBootstrapRuntimeHandlers<Env>;
    /** Bounded scheduled delivery policy. Set false only when another runtime
     * owns all configured consumers. */
    delivery?: DeliveryRuntimeOptions | false;
    /** Runs once per isolate, after schema init, before handling the first
     *  request. Use for app-specific setup that needs a live DB handle. */
    onInit?: (env: Env, db: Database) => void | Promise<void>;
}
declare function createWorker<Env extends WorkerEnv = WorkerEnv>(config: ContrailConfig, options?: CreateWorkerOptions<Env>): {
    fetch(request: Request, env: Env, ctx?: ExecutionContext): Promise<Response>;
    scheduled(_event: ScheduledEvent, env: Env, ctx: ExecutionContext): Promise<void>;
};

export { type CreateWorkerOptions, createWorker };