import * as _geenius_adapters from '@geenius/adapters';
import { AdapterHealth as AdapterHealth$1, AdapterListOptions as AdapterListOptions$1, QueueAdapter as QueueAdapter$1, QueueContractError as QueueContractError$1, QueueJob as QueueJob$1, QueueJobInput as QueueJobInput$1, QueueJobStatus as QueueJobStatus$1 } from '@geenius/adapters';
import * as zod_v4_core from 'zod/v4/core';
import * as zod from 'zod';

/**
 * Health result returned by queue providers after checking enqueue and worker
 * connectivity.
 *
 * @example
 * ```ts
 * const health: AdapterHealth = await queue.getHealth();
 * ```
 */
type AdapterHealth = AdapterHealth$1;
/**
 * Pagination options accepted by `QueueAdapter.listJobs()`.
 *
 * @example
 * ```ts
 * const options: AdapterListOptions = { limit: 25, prefix: "email" };
 * ```
 */
type AdapterListOptions = AdapterListOptions$1;
/**
 * SDK-free queue and scheduled-work adapter contract implemented by downstream
 * provider packages and app-owned queue modules.
 *
 * @example
 * ```ts
 * const job = await queue.enqueue({ name: "send-email", payload: { userId: "u1" } });
 * ```
 */
type QueueAdapter = QueueAdapter$1;
/**
 * Serializable queue job returned by queue providers.
 *
 * @example
 * ```ts
 * const job: QueueJob = { id: "job_1", name: "send-email", payload: {}, status: "queued", attempts: 0, createdAt: new Date().toISOString(), updatedAt: new Date().toISOString() };
 * ```
 */
type QueueJob = QueueJob$1;
/**
 * Provider-neutral enqueue payload accepted by queue adapters.
 *
 * @example
 * ```ts
 * const input: QueueJobInput = { name: "send-email", payload: { userId: "u1" } };
 * ```
 */
type QueueJobInput = QueueJobInput$1;
/**
 * Provider-neutral scheduled-job payload accepted by `QueueAdapter.schedule()`.
 *
 * @example
 * ```ts
 * const input: QueueScheduledJobInput = { name: "digest", runAt: new Date().toISOString() };
 * ```
 */
type QueueScheduledJobInput = QueueJobInput$1 & {
    runAt: string;
};
/**
 * Queue job lifecycle status.
 *
 * @example
 * ```ts
 * const status: QueueJobStatus = "scheduled";
 * ```
 */
type QueueJobStatus = QueueJobStatus$1;
/**
 * Runtime validator for the common queue adapter health response.
 *
 * @example
 * ```ts
 * const health = AdapterHealthSchema.parse({ ok: true, checkedAt: new Date().toISOString() });
 * ```
 */
declare const AdapterHealthSchema: zod.ZodObject<{
    ok: zod.ZodBoolean;
    checkedAt: zod.ZodString;
    latencyMs: zod.ZodOptional<zod.ZodNumber>;
    message: zod.ZodOptional<zod.ZodString>;
}, zod_v4_core.$strip>;
/**
 * Runtime validator for queue list pagination options.
 *
 * @example
 * ```ts
 * const options = AdapterListOptionsSchema.parse({ limit: 10 });
 * ```
 */
declare const AdapterListOptionsSchema: zod.ZodObject<{
    limit: zod.ZodOptional<zod.ZodNumber>;
    cursor: zod.ZodOptional<zod.ZodString>;
    prefix: zod.ZodOptional<zod.ZodString>;
}, zod_v4_core.$strip>;
/**
 * Contract-layer error for invalid queue payloads or provider-boundary
 * violations before a concrete queue SDK receives the request.
 *
 * @example
 * ```ts
 * throw new QueueContractError("Scheduled queue jobs require runAt");
 * ```
 */
declare const QueueContractError: typeof QueueContractError$1;
/**
 * Runtime validator for provider-neutral queue enqueue payloads.
 *
 * @example
 * ```ts
 * const input = QueueJobInputSchema.parse({ name: "send-email", payload: { userId: "u1" } });
 * ```
 */
declare const QueueJobInputSchema: zod.ZodObject<{
    name: zod.ZodString;
    payload: zod.ZodOptional<zod.ZodType<_geenius_adapters.AdapterJsonValue, unknown, zod_v4_core.$ZodTypeInternals<_geenius_adapters.AdapterJsonValue, unknown>>>;
    runAt: zod.ZodOptional<zod.ZodString>;
}, zod_v4_core.$strip>;
/**
 * Runtime validator for scheduled queue payloads that require a run time.
 *
 * @example
 * ```ts
 * const input = QueueScheduledJobInputSchema.parse({ name: "digest", runAt: new Date().toISOString() });
 * ```
 */
declare const QueueScheduledJobInputSchema: zod.ZodObject<{
    name: zod.ZodString;
    payload: zod.ZodOptional<zod.ZodType<_geenius_adapters.AdapterJsonValue, unknown, zod_v4_core.$ZodTypeInternals<_geenius_adapters.AdapterJsonValue, unknown>>>;
    runAt: zod.ZodNonOptional<zod.ZodOptional<zod.ZodString>>;
}, zod_v4_core.$strip>;
/**
 * Runtime validator for serialized queue jobs returned by providers.
 *
 * @example
 * ```ts
 * const job = QueueJobSchema.parse({ id: "job_1", name: "send-email", payload: {}, status: "queued", attempts: 0, createdAt: new Date().toISOString(), updatedAt: new Date().toISOString() });
 * ```
 */
declare const QueueJobSchema: zod.ZodObject<{
    id: zod.ZodString;
    name: zod.ZodString;
    payload: zod.ZodType<_geenius_adapters.AdapterJsonValue, unknown, zod_v4_core.$ZodTypeInternals<_geenius_adapters.AdapterJsonValue, unknown>>;
    status: zod.ZodEnum<{
        queued: "queued";
        running: "running";
        completed: "completed";
        failed: "failed";
        scheduled: "scheduled";
    }>;
    runAt: zod.ZodOptional<zod.ZodString>;
    attempts: zod.ZodNumber;
    createdAt: zod.ZodString;
    updatedAt: zod.ZodString;
}, zod_v4_core.$strip>;
/**
 * Runtime validator for queue job lifecycle statuses.
 *
 * @example
 * ```ts
 * const status = QueueJobStatusSchema.parse("queued");
 * ```
 */
declare const QueueJobStatusSchema: zod.ZodEnum<{
    queued: "queued";
    running: "running";
    completed: "completed";
    failed: "failed";
    scheduled: "scheduled";
}>;

export { type AdapterHealth, AdapterHealthSchema, type AdapterListOptions, AdapterListOptionsSchema, type QueueAdapter, QueueContractError, type QueueJob, type QueueJobInput, QueueJobInputSchema, QueueJobSchema, type QueueJobStatus, QueueJobStatusSchema, type QueueScheduledJobInput, QueueScheduledJobInputSchema };