import { APIResource } from "../../resource.js";
import * as Core from "../../core.js";
import * as Shared from "../shared.js";
import { SinglePage } from "../../pagination.js";
export declare class Consumers extends APIResource {
    /**
     * Creates a new consumer for a Queue
     *
     * @example
     * ```ts
     * const consumer = await client.queues.consumers.create(
     *   '023e105f4ecef8ad9ca31a8372d0c353',
     *   {
     *     account_id: '023e105f4ecef8ad9ca31a8372d0c353',
     *     script_name: 'my-consumer-worker',
     *     type: 'worker',
     *   },
     * );
     * ```
     */
    create(queueId: string, params: ConsumerCreateParams, options?: Core.RequestOptions): Core.APIPromise<Consumer>;
    /**
     * Updates the consumer for a queue, or creates one if it does not exist.
     *
     * @example
     * ```ts
     * const consumer = await client.queues.consumers.update(
     *   '023e105f4ecef8ad9ca31a8372d0c353',
     *   '023e105f4ecef8ad9ca31a8372d0c353',
     *   {
     *     account_id: '023e105f4ecef8ad9ca31a8372d0c353',
     *     script_name: 'my-consumer-worker',
     *     type: 'worker',
     *   },
     * );
     * ```
     */
    update(queueId: string, consumerId: string, params: ConsumerUpdateParams, options?: Core.RequestOptions): Core.APIPromise<Consumer>;
    /**
     * Returns the consumers for a Queue
     *
     * @example
     * ```ts
     * // Automatically fetches more pages as needed.
     * for await (const consumer of client.queues.consumers.list(
     *   '023e105f4ecef8ad9ca31a8372d0c353',
     *   { account_id: '023e105f4ecef8ad9ca31a8372d0c353' },
     * )) {
     *   // ...
     * }
     * ```
     */
    list(queueId: string, params: ConsumerListParams, options?: Core.RequestOptions): Core.PagePromise<ConsumersSinglePage, Consumer>;
    /**
     * Deletes the consumer for a queue.
     *
     * @example
     * ```ts
     * const consumer = await client.queues.consumers.delete(
     *   '023e105f4ecef8ad9ca31a8372d0c353',
     *   '023e105f4ecef8ad9ca31a8372d0c353',
     *   { account_id: '023e105f4ecef8ad9ca31a8372d0c353' },
     * );
     * ```
     */
    delete(queueId: string, consumerId: string, params: ConsumerDeleteParams, options?: Core.RequestOptions): Core.APIPromise<ConsumerDeleteResponse>;
    /**
     * Fetches the consumer for a queue by consumer id
     *
     * @example
     * ```ts
     * const consumer = await client.queues.consumers.get(
     *   '023e105f4ecef8ad9ca31a8372d0c353',
     *   '023e105f4ecef8ad9ca31a8372d0c353',
     *   { account_id: '023e105f4ecef8ad9ca31a8372d0c353' },
     * );
     * ```
     */
    get(queueId: string, consumerId: string, params: ConsumerGetParams, options?: Core.RequestOptions): Core.APIPromise<Consumer>;
}
export declare class ConsumersSinglePage extends SinglePage<Consumer> {
}
/**
 * Response body representing a consumer
 */
export type Consumer = Consumer.MqWorkerConsumerResponse | Consumer.MqHTTPConsumerResponse;
export declare namespace Consumer {
    interface MqWorkerConsumerResponse {
        /**
         * A Resource identifier.
         */
        consumer_id?: string;
        created_on?: string;
        /**
         * Name of the dead letter queue, or empty string if not configured
         */
        dead_letter_queue?: string;
        queue_name?: string;
        /**
         * Name of a Worker
         */
        script_name?: string;
        settings?: MqWorkerConsumerResponse.Settings;
        type?: 'worker';
    }
    namespace MqWorkerConsumerResponse {
        interface Settings {
            /**
             * The maximum number of messages to include in a batch.
             */
            batch_size?: number;
            /**
             * Maximum number of concurrent consumers that may consume from this Queue. Set to
             * `null` to automatically opt in to the platform's maximum (recommended).
             */
            max_concurrency?: number;
            /**
             * The maximum number of retries
             */
            max_retries?: number;
            /**
             * The number of milliseconds to wait for a batch to fill up before attempting to
             * deliver it
             */
            max_wait_time_ms?: number;
            /**
             * The number of seconds to delay before making the message available for another
             * attempt.
             */
            retry_delay?: number;
        }
    }
    interface MqHTTPConsumerResponse {
        /**
         * A Resource identifier.
         */
        consumer_id?: string;
        created_on?: string;
        /**
         * Name of the dead letter queue, or empty string if not configured
         */
        dead_letter_queue?: string;
        queue_name?: string;
        settings?: MqHTTPConsumerResponse.Settings;
        type?: 'http_pull';
    }
    namespace MqHTTPConsumerResponse {
        interface Settings {
            /**
             * The maximum number of messages to include in a batch.
             */
            batch_size?: number;
            /**
             * The maximum number of retries
             */
            max_retries?: number;
            /**
             * The number of seconds to delay before making the message available for another
             * attempt.
             */
            retry_delay?: number;
            /**
             * The number of milliseconds that a message is exclusively leased. After the
             * timeout, the message becomes available for another attempt.
             */
            visibility_timeout_ms?: number;
        }
    }
}
export interface ConsumerDeleteResponse {
    errors?: Array<Shared.ResponseInfo>;
    messages?: Array<string>;
    /**
     * Indicates if the API call was successful or not.
     */
    success?: true;
}
export type ConsumerCreateParams = ConsumerCreateParams.MqWorkerConsumerRequest | ConsumerCreateParams.MqHTTPConsumerRequest;
export declare namespace ConsumerCreateParams {
    interface MqWorkerConsumerRequest {
        /**
         * Path param: A Resource identifier.
         */
        account_id: string;
        /**
         * Body param: Name of a Worker
         */
        script_name: string;
        /**
         * Body param
         */
        type: 'worker';
        /**
         * Body param
         */
        dead_letter_queue?: string;
        /**
         * Body param
         */
        settings?: MqWorkerConsumerRequest.Settings;
    }
    namespace MqWorkerConsumerRequest {
        interface Settings {
            /**
             * The maximum number of messages to include in a batch.
             */
            batch_size?: number;
            /**
             * Maximum number of concurrent consumers that may consume from this Queue. Set to
             * `null` to automatically opt in to the platform's maximum (recommended).
             */
            max_concurrency?: number;
            /**
             * The maximum number of retries
             */
            max_retries?: number;
            /**
             * The number of milliseconds to wait for a batch to fill up before attempting to
             * deliver it
             */
            max_wait_time_ms?: number;
            /**
             * The number of seconds to delay before making the message available for another
             * attempt.
             */
            retry_delay?: number;
        }
    }
    interface MqHTTPConsumerRequest {
        /**
         * Path param: A Resource identifier.
         */
        account_id: string;
        /**
         * Body param
         */
        type: 'http_pull';
        /**
         * Body param
         */
        dead_letter_queue?: string;
        /**
         * Body param
         */
        settings?: MqHTTPConsumerRequest.Settings;
    }
    namespace MqHTTPConsumerRequest {
        interface Settings {
            /**
             * The maximum number of messages to include in a batch.
             */
            batch_size?: number;
            /**
             * The maximum number of retries
             */
            max_retries?: number;
            /**
             * The number of seconds to delay before making the message available for another
             * attempt.
             */
            retry_delay?: number;
            /**
             * The number of milliseconds that a message is exclusively leased. After the
             * timeout, the message becomes available for another attempt.
             */
            visibility_timeout_ms?: number;
        }
    }
}
export type ConsumerUpdateParams = ConsumerUpdateParams.MqWorkerConsumerRequest | ConsumerUpdateParams.MqHTTPConsumerRequest;
export declare namespace ConsumerUpdateParams {
    interface MqWorkerConsumerRequest {
        /**
         * Path param: A Resource identifier.
         */
        account_id: string;
        /**
         * Body param: Name of a Worker
         */
        script_name: string;
        /**
         * Body param
         */
        type: 'worker';
        /**
         * Body param
         */
        dead_letter_queue?: string;
        /**
         * Body param
         */
        settings?: MqWorkerConsumerRequest.Settings;
    }
    namespace MqWorkerConsumerRequest {
        interface Settings {
            /**
             * The maximum number of messages to include in a batch.
             */
            batch_size?: number;
            /**
             * Maximum number of concurrent consumers that may consume from this Queue. Set to
             * `null` to automatically opt in to the platform's maximum (recommended).
             */
            max_concurrency?: number;
            /**
             * The maximum number of retries
             */
            max_retries?: number;
            /**
             * The number of milliseconds to wait for a batch to fill up before attempting to
             * deliver it
             */
            max_wait_time_ms?: number;
            /**
             * The number of seconds to delay before making the message available for another
             * attempt.
             */
            retry_delay?: number;
        }
    }
    interface MqHTTPConsumerRequest {
        /**
         * Path param: A Resource identifier.
         */
        account_id: string;
        /**
         * Body param
         */
        type: 'http_pull';
        /**
         * Body param
         */
        dead_letter_queue?: string;
        /**
         * Body param
         */
        settings?: MqHTTPConsumerRequest.Settings;
    }
    namespace MqHTTPConsumerRequest {
        interface Settings {
            /**
             * The maximum number of messages to include in a batch.
             */
            batch_size?: number;
            /**
             * The maximum number of retries
             */
            max_retries?: number;
            /**
             * The number of seconds to delay before making the message available for another
             * attempt.
             */
            retry_delay?: number;
            /**
             * The number of milliseconds that a message is exclusively leased. After the
             * timeout, the message becomes available for another attempt.
             */
            visibility_timeout_ms?: number;
        }
    }
}
export interface ConsumerListParams {
    /**
     * A Resource identifier.
     */
    account_id: string;
}
export interface ConsumerDeleteParams {
    /**
     * A Resource identifier.
     */
    account_id: string;
}
export interface ConsumerGetParams {
    /**
     * A Resource identifier.
     */
    account_id: string;
}
export declare namespace Consumers {
    export { type Consumer as Consumer, type ConsumerDeleteResponse as ConsumerDeleteResponse, ConsumersSinglePage as ConsumersSinglePage, type ConsumerCreateParams as ConsumerCreateParams, type ConsumerUpdateParams as ConsumerUpdateParams, type ConsumerListParams as ConsumerListParams, type ConsumerDeleteParams as ConsumerDeleteParams, type ConsumerGetParams as ConsumerGetParams, };
}
//# sourceMappingURL=consumers.d.ts.map