export type Payload = Record<string, unknown>;
export interface QueueParams {
    key: string;
}
export interface PushRequest<T extends Body = Body> extends APIRequest {
    payload: PushEvent<T>[];
    schema: string;
    type: string;
    jobId: string;
}
export interface APIRequest {
    queueName: string;
    jobId: string;
    time: string;
}
export interface PushEvent<T extends Body = Body> {
    body: T;
    delayInSeconds?: number;
    concurrency?: Concurrency;
}
export type Body = Record<string, unknown>;
export interface Concurrency {
    key: string;
    limit: number;
}
export interface PushResult {
    jobId: string;
}
export interface FailedEvent<T extends Body = Body> {
    errorMessage: string;
    event: PushEvent<T>;
}
export interface AsyncEvent<T extends Body = Body> extends PushEvent<T> {
    queueName: string;
    jobId: string;
    eventId: string;
    retryContext?: RetryContext;
}
export interface RetryContext {
    retryCount: number;
    retryReason: string;
    retryData: any;
    retentionWindow?: RetentionWindow;
}
export interface RetentionWindow {
    startTime: string;
    remainingTimeMs: number;
}
export type GetStatsRequest = APIRequest;
export type CancelJobRequest = APIRequest;
//# sourceMappingURL=types.d.ts.map