import { ApiPromise, ApiRequestOptions, ListQueueOptions, OffsetLimitPagePromise, QueueItem, RetrieveQueueParam } from "@trigger.dev/core/v3"; /** * Lists queues * @param options - The list options * @param options.page - The page number * @param options.perPage - The number of queues per page * @returns The list of queues */ export declare function list(options?: ListQueueOptions, requestOptions?: ApiRequestOptions): OffsetLimitPagePromise; /** * When retrieving a queue you can either use the queue id, * or the type and name. * * @example * * ```ts * // Use a queue id (they start with queue_ * const q1 = await queues.retrieve("queue_12345"); * * // Or use the type and name * // The default queue for your "my-task-id" * const q2 = await queues.retrieve({ type: "task", name: "my-task-id"}); * * // The custom queue you defined in your code * const q3 = await queues.retrieve({ type: "custom", name: "my-custom-queue" }); * ``` * @param queue - The ID of the queue to retrieve, or the type and name * @returns The retrieved queue */ export declare function retrieve(queue: RetrieveQueueParam, requestOptions?: ApiRequestOptions): ApiPromise; /** * Pauses a queue, preventing any new runs from being started. * Runs that are currently running will continue to completion. * * @example * ```ts * // Pause using a queue id * await queues.pause("queue_12345"); * * // Or pause using type and name * await queues.pause({ type: "task", name: "my-task-id"}); * ``` * @param queue - The ID of the queue to pause, or the type and name * @returns The updated queue state */ export declare function pause(queue: RetrieveQueueParam, requestOptions?: ApiRequestOptions): ApiPromise; /** * Overrides the concurrency limit of a queue. * * @param queue - The ID of the queue to override the concurrency limit, or the type and name * @param concurrencyLimit - The concurrency limit to override * @returns The updated queue state */ export declare function overrideConcurrencyLimit(queue: RetrieveQueueParam, concurrencyLimit: number, requestOptions?: ApiRequestOptions): ApiPromise; /** * Resets the concurrency limit of a queue to the base value. * * @param queue - The ID of the queue to reset the concurrency limit, or the type and name * @returns The updated queue state */ export declare function resetConcurrencyLimit(queue: RetrieveQueueParam, requestOptions?: ApiRequestOptions): ApiPromise; /** * Resumes a paused queue, allowing new runs to be started. * * @example * ```ts * // Resume using a queue id * await queues.resume("queue_12345"); * * // Or resume using type and name * await queues.resume({ type: "task", name: "my-task-id"}); * ``` * @param queue - The ID of the queue to resume, or the type and name * @returns The updated queue state */ export declare function resume(queue: RetrieveQueueParam, requestOptions?: ApiRequestOptions): ApiPromise;