import * as S from "@distilled.cloud/core/schema"; import * as API from "@distilled.cloud/core/api"; import { type CloudflareOpError, type CloudflareOpContext } from "../protocol.ts"; import { ResultInfo } from "../pagination.ts"; export type { CloudflareOpError, CloudflareOpContext }; declare const ConsumerAlreadyExists_base: S.Class, import("effect/Cause").YieldableError>; export declare class ConsumerAlreadyExists extends /*@__PURE__*/ ConsumerAlreadyExists_base { } declare const ConsumerNotFound_base: S.Class, import("effect/Cause").YieldableError>; export declare class ConsumerNotFound extends /*@__PURE__*/ ConsumerNotFound_base { } declare const Forbidden_base: S.Class, import("effect/Cause").YieldableError>; export declare class Forbidden extends /*@__PURE__*/ Forbidden_base { } declare const InvalidMessageBody_base: S.Class, import("effect/Cause").YieldableError>; export declare class InvalidMessageBody extends /*@__PURE__*/ InvalidMessageBody_base { } declare const InvalidQueueId_base: S.Class, import("effect/Cause").YieldableError>; export declare class InvalidQueueId extends /*@__PURE__*/ InvalidQueueId_base { } declare const InvalidQueueName_base: S.Class, import("effect/Cause").YieldableError>; export declare class InvalidQueueName extends /*@__PURE__*/ InvalidQueueName_base { } declare const InvalidRequestBody_base: S.Class, import("effect/Cause").YieldableError>; export declare class InvalidRequestBody extends /*@__PURE__*/ InvalidRequestBody_base { } declare const InvalidRoute_base: S.Class, import("effect/Cause").YieldableError>; export declare class InvalidRoute extends /*@__PURE__*/ InvalidRoute_base { } declare const QueueAlreadyExists_base: S.Class, import("effect/Cause").YieldableError>; export declare class QueueAlreadyExists extends /*@__PURE__*/ QueueAlreadyExists_base { } declare const QueueHandlerMissing_base: S.Class, import("effect/Cause").YieldableError>; export declare class QueueHandlerMissing extends /*@__PURE__*/ QueueHandlerMissing_base { } declare const QueueInUseByEventNotification_base: S.Class, import("effect/Cause").YieldableError>; export declare class QueueInUseByEventNotification extends /*@__PURE__*/ QueueInUseByEventNotification_base { } declare const QueueInUseByWorkerBinding_base: S.Class, import("effect/Cause").YieldableError>; export declare class QueueInUseByWorkerBinding extends /*@__PURE__*/ QueueInUseByWorkerBinding_base { } declare const QueueNotFound_base: S.Class, import("effect/Cause").YieldableError>; export declare class QueueNotFound extends /*@__PURE__*/ QueueNotFound_base { } declare const SubscriptionAlreadyExists_base: S.Class, import("effect/Cause").YieldableError>; export declare class SubscriptionAlreadyExists extends /*@__PURE__*/ SubscriptionAlreadyExists_base { } declare const SubscriptionNotFound_base: S.Class, import("effect/Cause").YieldableError>; export declare class SubscriptionNotFound extends /*@__PURE__*/ SubscriptionNotFound_base { } declare const UnrecognizedEventType_base: S.Class, import("effect/Cause").YieldableError>; export declare class UnrecognizedEventType extends /*@__PURE__*/ UnrecognizedEventType_base { } declare const WorkerNotFound_base: S.Class, import("effect/Cause").YieldableError>; export declare class WorkerNotFound extends /*@__PURE__*/ WorkerNotFound_base { } export interface MessagesAckRequestAcksItem { /** An ID that represents an "in-flight" message that has been pulled from a Queue. You must hold on to this ID and use it to acknowledge this message. */ leaseId?: string; } export declare const MessagesAckRequestAcksItem: S.Schema; export type MessagesAckRequestAcksList = Array; export declare const MessagesAckRequestAcksList: S.Schema; export interface MessagesAckRequestRetriesItem { /** The number of seconds to delay before making the message available for another attempt. */ delaySeconds?: number; /** An ID that represents an "in-flight" message that has been pulled from a Queue. You must hold on to this ID and use it to acknowledge this message. */ leaseId?: string; } export declare const MessagesAckRequestRetriesItem: S.Schema; export type MessagesAckRequestRetriesList = Array; export declare const MessagesAckRequestRetriesList: S.Schema; export interface AckMessageRequest { /** A Resource identifier. */ accountId: string; /** A Resource identifier. */ queueId: string; acks?: MessagesAckRequestAcksList; retries?: MessagesAckRequestRetriesList; } export declare const AckMessageRequest: S.Schema; export type MessagesAckResponseWarningsMap = { [key: string]: string | undefined; }; export declare const MessagesAckResponseWarningsMap: S.Schema; /** Unwrapped `result` payload of the Cloudflare v4 response envelope. */ export interface AckMessageResponse { /** The number of messages that were succesfully acknowledged. */ ackCount?: number | null; /** The number of messages that were succesfully retried. */ retryCount?: number | null; /** Map of lease IDs to warning messages encountered during acknowledgement. */ warnings?: MessagesAckResponseWarningsMap | null; } export declare const AckMessageResponse: S.Schema; export type MessagesBulkPushRequestMessagesItemMqQueueMessageTextContentType = "text"; export declare const MessagesBulkPushRequestMessagesItemMqQueueMessageTextContentType: any; export interface MessagesBulkPushRequestMessagesItemMqQueueMessageText { body?: string; contentType?: MessagesBulkPushRequestMessagesItemMqQueueMessageTextContentType | (string & {}); /** The number of seconds to wait for attempting to deliver this message to consumers */ delaySeconds?: number; } export declare const MessagesBulkPushRequestMessagesItemMqQueueMessageText: S.Schema; export type MessagesBulkPushRequestMessagesItemMqQueueMessageJsonContentType = "json"; export declare const MessagesBulkPushRequestMessagesItemMqQueueMessageJsonContentType: any; export interface MessagesBulkPushRequestMessagesItemMqQueueMessageJson { body?: unknown; contentType?: MessagesBulkPushRequestMessagesItemMqQueueMessageJsonContentType | (string & {}); /** The number of seconds to wait for attempting to deliver this message to consumers */ delaySeconds?: number; } export declare const MessagesBulkPushRequestMessagesItemMqQueueMessageJson: S.Schema; export type MessagesBulkPushRequestMessagesItem = MessagesBulkPushRequestMessagesItemMqQueueMessageText | MessagesBulkPushRequestMessagesItemMqQueueMessageJson; export declare const MessagesBulkPushRequestMessagesItem: any; export type MessagesBulkPushRequestMessagesList = Array; export declare const MessagesBulkPushRequestMessagesList: S.Schema; export interface BulkPushMessagesRequest { /** A Resource identifier. */ accountId: string; /** A Resource identifier. */ queueId: string; /** The number of seconds to wait for attempting to deliver this batch to consumers */ delaySeconds?: number; messages?: MessagesBulkPushRequestMessagesList; } export declare const BulkPushMessagesRequest: S.Schema; export interface MessagesBulkPushResponseMetadataMetrics { /** The size in bytes of unacknowledged messages in the queue. */ backlogBytes: number; /** The number of unacknowledged messages in the queue. */ backlogCount: number; /** Unix timestamp in milliseconds of the oldest unacknowledged message in the queue. Returns 0 if unknown. */ oldestMessageTimestampMs: number; } export declare const MessagesBulkPushResponseMetadataMetrics: S.Schema; export interface MessagesBulkPushResponseMetadata { /** Best-effort metrics for the queue. Values may be approximate due to the distributed nature of queues. */ metrics?: MessagesBulkPushResponseMetadataMetrics | null; } export declare const MessagesBulkPushResponseMetadata: S.Schema; /** Unwrapped `result` payload of the Cloudflare v4 response envelope. */ export interface BulkPushMessagesResponse { metadata?: MessagesBulkPushResponseMetadata | null; } export declare const BulkPushMessagesResponse: S.Schema; export type ConsumersCreateRequestType = "worker" | "http_pull"; export declare const ConsumersCreateRequestType: any; export interface ConsumersCreateRequestSettingsWorker { /** The maximum number of messages to include in a batch. */ batchSize?: 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). */ maxConcurrency?: number; /** The maximum number of retries */ maxRetries?: number; /** The number of milliseconds to wait for a batch to fill up before attempting to deliver it */ maxWaitTimeMs?: number; /** The number of seconds to delay before making the message available for another attempt. */ retryDelay?: number; } export declare const ConsumersCreateRequestSettingsWorker: S.Schema; export interface ConsumersCreateRequestSettingsHTTPPull { /** The maximum number of messages to include in a batch. */ batchSize?: number; /** The maximum number of retries */ maxRetries?: number; /** The number of seconds to delay before making the message available for another attempt. */ retryDelay?: number; /** The number of milliseconds that a message is exclusively leased. After the timeout, the message becomes available for another attempt. */ visibilityTimeoutMs?: number; } export declare const ConsumersCreateRequestSettingsHTTPPull: S.Schema; export type ConsumersCreateRequestSettings = ConsumersCreateRequestSettingsWorker | ConsumersCreateRequestSettingsHTTPPull; export declare const ConsumersCreateRequestSettings: any; export interface CreateConsumerRequest { /** A Resource identifier. */ accountId: string; /** A Resource identifier. */ queueId: string; /** Name of a Worker */ scriptName?: string; type: ConsumersCreateRequestType | (string & {}); deadLetterQueue?: string; settings?: ConsumersCreateRequestSettings; } export declare const CreateConsumerRequest: S.Schema; export interface ConsumersCreateResultWorkerSettings { /** The maximum number of messages to include in a batch. */ batchSize?: number | null; /** Maximum number of concurrent consumers that may consume from this Queue. Set to `null` to automatically opt in to the platform's maximum (recommended). */ maxConcurrency?: number | null; /** The maximum number of retries */ maxRetries?: number | null; /** The number of milliseconds to wait for a batch to fill up before attempting to deliver it */ maxWaitTimeMs?: number | null; /** The number of seconds to delay before making the message available for another attempt. */ retryDelay?: number | null; } export declare const ConsumersCreateResultWorkerSettings: S.Schema; export type ConsumersCreateResultWorkerType = "worker"; export declare const ConsumersCreateResultWorkerType: any; export interface ConsumersCreateResultWorker { /** A Resource identifier. */ consumerId?: string | null; createdOn?: string | null; /** Name of the dead letter queue, or empty string if not configured */ deadLetterQueue?: string | null; queueName?: string | null; /** Name of a Worker */ scriptName?: string | null; settings?: ConsumersCreateResultWorkerSettings | null; type?: ConsumersCreateResultWorkerType | null; } export declare const ConsumersCreateResultWorker: S.Schema; export interface ConsumersCreateResultHTTPPullSettings { /** The maximum number of messages to include in a batch. */ batchSize?: number | null; /** The maximum number of retries */ maxRetries?: number | null; /** The number of seconds to delay before making the message available for another attempt. */ retryDelay?: number | null; /** The number of milliseconds that a message is exclusively leased. After the timeout, the message becomes available for another attempt. */ visibilityTimeoutMs?: number | null; } export declare const ConsumersCreateResultHTTPPullSettings: S.Schema; export type ConsumersCreateResultHTTPPullType = "http_pull"; export declare const ConsumersCreateResultHTTPPullType: any; export interface ConsumersCreateResultHTTPPull { /** A Resource identifier. */ consumerId?: string | null; createdOn?: string | null; /** Name of the dead letter queue, or empty string if not configured */ deadLetterQueue?: string | null; queueName?: string | null; settings?: ConsumersCreateResultHTTPPullSettings | null; type?: ConsumersCreateResultHTTPPullType | null; } export declare const ConsumersCreateResultHTTPPull: S.Schema; export type ConsumersCreateResult = ConsumersCreateResultWorker | ConsumersCreateResultHTTPPull; export declare const ConsumersCreateResult: any; export type CreateConsumerResponse = ConsumersCreateResult; export declare const CreateConsumerResponse: S.Schema; export interface CreateQueueRequest { /** A Resource identifier. */ accountId: string; queueName: string; } export declare const CreateQueueRequest: S.Schema; export type CreateResponseConsumersItemWorkerSettings = ConsumersCreateResultWorkerSettings; export declare const CreateResponseConsumersItemWorkerSettings: S.Schema; export type CreateResponseConsumersItemWorkerType = "worker"; export declare const CreateResponseConsumersItemWorkerType: any; export interface CreateResponseConsumersItemWorker { /** A Resource identifier. */ consumerId?: string | null; createdOn?: string | null; /** Name of the dead letter queue, or empty string if not configured */ deadLetterQueue?: string | null; queueName?: string | null; /** Name of a Worker */ scriptName?: string | null; settings?: ConsumersCreateResultWorkerSettings | null; type?: CreateResponseConsumersItemWorkerType | null; } export declare const CreateResponseConsumersItemWorker: S.Schema; export type CreateResponseConsumersItemHTTPPullSettings = ConsumersCreateResultHTTPPullSettings; export declare const CreateResponseConsumersItemHTTPPullSettings: S.Schema; export type CreateResponseConsumersItemHTTPPullType = "http_pull"; export declare const CreateResponseConsumersItemHTTPPullType: any; export interface CreateResponseConsumersItemHTTPPull { /** A Resource identifier. */ consumerId?: string | null; createdOn?: string | null; /** Name of the dead letter queue, or empty string if not configured */ deadLetterQueue?: string | null; queueName?: string | null; settings?: ConsumersCreateResultHTTPPullSettings | null; type?: CreateResponseConsumersItemHTTPPullType | null; } export declare const CreateResponseConsumersItemHTTPPull: S.Schema; export type CreateResponseConsumersItem = CreateResponseConsumersItemWorker | CreateResponseConsumersItemHTTPPull; export declare const CreateResponseConsumersItem: any; export type CreateResponseConsumersList = Array; export declare const CreateResponseConsumersList: S.Schema; export type CreateResponseProducersItemMqWorkerProducerType = "worker"; export declare const CreateResponseProducersItemMqWorkerProducerType: any; export interface CreateResponseProducersItemMqWorkerProducer { type?: CreateResponseProducersItemMqWorkerProducerType | null; scriptName?: string | null; } export declare const CreateResponseProducersItemMqWorkerProducer: S.Schema; export type CreateResponseProducersItemMqR2ProducerType = "r2_bucket"; export declare const CreateResponseProducersItemMqR2ProducerType: any; export interface CreateResponseProducersItemMqR2Producer { bucketName?: string | null; type?: CreateResponseProducersItemMqR2ProducerType | null; } export declare const CreateResponseProducersItemMqR2Producer: S.Schema; export type CreateResponseProducersItem = CreateResponseProducersItemMqWorkerProducer | CreateResponseProducersItemMqR2Producer; export declare const CreateResponseProducersItem: any; export type CreateResponseProducersList = Array; export declare const CreateResponseProducersList: S.Schema; export interface CreateResponseSettings { /** Number of seconds to delay delivery of all messages to consumers. */ deliveryDelay?: number | null; /** Indicates if message delivery to consumers is currently paused. */ deliveryPaused?: boolean | null; /** Number of seconds after which an unconsumed message will be delayed. */ messageRetentionPeriod?: number | null; } export declare const CreateResponseSettings: S.Schema; /** Unwrapped `result` payload of the Cloudflare v4 response envelope. */ export interface CreateQueueResponse { consumers?: CreateResponseConsumersList | null; consumersTotalCount?: number | null; createdOn?: string | null; modifiedOn?: string | null; producers?: CreateResponseProducersList | null; producersTotalCount?: number | null; queueId?: string | null; queueName?: string | null; settings?: CreateResponseSettings | null; } export declare const CreateQueueResponse: S.Schema; export type SubscriptionsCreateRequestDestinationType = "queues.queue"; export declare const SubscriptionsCreateRequestDestinationType: any; export interface SubscriptionsCreateRequestDestination { /** ID of the target queue */ queueId: string; /** Type of destination */ type: SubscriptionsCreateRequestDestinationType | (string & {}); } export declare const SubscriptionsCreateRequestDestination: S.Schema; export type SubscriptionsCreateRequestEventsList = Array; export declare const SubscriptionsCreateRequestEventsList: S.Schema; export type SubscriptionsCreateRequestSourceMqEventSourceImagesType = "images"; export declare const SubscriptionsCreateRequestSourceMqEventSourceImagesType: any; export interface SubscriptionsCreateRequestSourceMqEventSourceImages { /** Type of source */ type?: SubscriptionsCreateRequestSourceMqEventSourceImagesType | (string & {}); } export declare const SubscriptionsCreateRequestSourceMqEventSourceImages: S.Schema; export type SubscriptionsCreateRequestSourceMqEventSourceKVType = "kv"; export declare const SubscriptionsCreateRequestSourceMqEventSourceKVType: any; export interface SubscriptionsCreateRequestSourceMqEventSourceKV { /** Type of source */ type?: SubscriptionsCreateRequestSourceMqEventSourceKVType | (string & {}); } export declare const SubscriptionsCreateRequestSourceMqEventSourceKV: S.Schema; export type SubscriptionsCreateRequestSourceMqEventSourceR2Type = "r2"; export declare const SubscriptionsCreateRequestSourceMqEventSourceR2Type: any; export interface SubscriptionsCreateRequestSourceMqEventSourceR2 { /** Type of source */ type?: SubscriptionsCreateRequestSourceMqEventSourceR2Type | (string & {}); } export declare const SubscriptionsCreateRequestSourceMqEventSourceR2: S.Schema; export type SubscriptionsCreateRequestSourceMqEventSourceSuperSlurperType = "superSlurper"; export declare const SubscriptionsCreateRequestSourceMqEventSourceSuperSlurperType: any; export interface SubscriptionsCreateRequestSourceMqEventSourceSuperSlurper { /** Type of source */ type?: SubscriptionsCreateRequestSourceMqEventSourceSuperSlurperType | (string & {}); } export declare const SubscriptionsCreateRequestSourceMqEventSourceSuperSlurper: S.Schema; export type SubscriptionsCreateRequestSourceMqEventSourceVectorizeType = "vectorize"; export declare const SubscriptionsCreateRequestSourceMqEventSourceVectorizeType: any; export interface SubscriptionsCreateRequestSourceMqEventSourceVectorize { /** Type of source */ type?: SubscriptionsCreateRequestSourceMqEventSourceVectorizeType | (string & {}); } export declare const SubscriptionsCreateRequestSourceMqEventSourceVectorize: S.Schema; export type SubscriptionsCreateRequestSourceMqEventSourceWorkersAIModelType = "workersAi.model"; export declare const SubscriptionsCreateRequestSourceMqEventSourceWorkersAIModelType: any; export interface SubscriptionsCreateRequestSourceMqEventSourceWorkersAIModel { /** Name of the Workers AI model */ modelName?: string; /** Type of source */ type?: SubscriptionsCreateRequestSourceMqEventSourceWorkersAIModelType | (string & {}); } export declare const SubscriptionsCreateRequestSourceMqEventSourceWorkersAIModel: S.Schema; export type SubscriptionsCreateRequestSourceMqEventSourceWorkersBuildsWorkerType = "workersBuilds.worker"; export declare const SubscriptionsCreateRequestSourceMqEventSourceWorkersBuildsWorkerType: any; export interface SubscriptionsCreateRequestSourceMqEventSourceWorkersBuildsWorker { /** Type of source */ type?: SubscriptionsCreateRequestSourceMqEventSourceWorkersBuildsWorkerType | (string & {}); /** Name of the worker */ workerName?: string; } export declare const SubscriptionsCreateRequestSourceMqEventSourceWorkersBuildsWorker: S.Schema; export type SubscriptionsCreateRequestSourceMqEventSourceWorkflowsWorkflowType = "workflows.workflow"; export declare const SubscriptionsCreateRequestSourceMqEventSourceWorkflowsWorkflowType: any; export interface SubscriptionsCreateRequestSourceMqEventSourceWorkflowsWorkflow { /** Type of source */ type?: SubscriptionsCreateRequestSourceMqEventSourceWorkflowsWorkflowType | (string & {}); /** Name of the workflow */ workflowName?: string; } export declare const SubscriptionsCreateRequestSourceMqEventSourceWorkflowsWorkflow: S.Schema; export type SubscriptionsCreateRequestSource = SubscriptionsCreateRequestSourceMqEventSourceImages | SubscriptionsCreateRequestSourceMqEventSourceKV | SubscriptionsCreateRequestSourceMqEventSourceR2 | SubscriptionsCreateRequestSourceMqEventSourceSuperSlurper | SubscriptionsCreateRequestSourceMqEventSourceVectorize | SubscriptionsCreateRequestSourceMqEventSourceWorkersAIModel | SubscriptionsCreateRequestSourceMqEventSourceWorkersBuildsWorker | SubscriptionsCreateRequestSourceMqEventSourceWorkflowsWorkflow; export declare const SubscriptionsCreateRequestSource: any; export interface CreateSubscriptionRequest { /** A Resource identifier. */ accountId: string; /** Destination configuration for the subscription */ destination?: SubscriptionsCreateRequestDestination; /** Whether the subscription is active */ enabled?: boolean; /** List of event types this subscription handles */ events?: SubscriptionsCreateRequestEventsList; /** Name of the subscription */ name?: string; /** Source configuration for the subscription */ source?: SubscriptionsCreateRequestSource; } export declare const CreateSubscriptionRequest: S.Schema; export type SubscriptionsCreateResponseDestinationType = "queues.queue"; export declare const SubscriptionsCreateResponseDestinationType: any; export interface SubscriptionsCreateResponseDestination { /** ID of the target queue */ queueId: string; /** Type of destination */ type: SubscriptionsCreateResponseDestinationType; } export declare const SubscriptionsCreateResponseDestination: S.Schema; export type SubscriptionsCreateResponseEventsList = Array; export declare const SubscriptionsCreateResponseEventsList: S.Schema; export type SubscriptionsCreateResponseSourceMqEventSourceImagesType = "images"; export declare const SubscriptionsCreateResponseSourceMqEventSourceImagesType: any; export interface SubscriptionsCreateResponseSourceMqEventSourceImages { /** Type of source */ type?: SubscriptionsCreateResponseSourceMqEventSourceImagesType | null; } export declare const SubscriptionsCreateResponseSourceMqEventSourceImages: S.Schema; export type SubscriptionsCreateResponseSourceMqEventSourceKVType = "kv"; export declare const SubscriptionsCreateResponseSourceMqEventSourceKVType: any; export interface SubscriptionsCreateResponseSourceMqEventSourceKV { /** Type of source */ type?: SubscriptionsCreateResponseSourceMqEventSourceKVType | null; } export declare const SubscriptionsCreateResponseSourceMqEventSourceKV: S.Schema; export type SubscriptionsCreateResponseSourceMqEventSourceR2Type = "r2"; export declare const SubscriptionsCreateResponseSourceMqEventSourceR2Type: any; export interface SubscriptionsCreateResponseSourceMqEventSourceR2 { /** Type of source */ type?: SubscriptionsCreateResponseSourceMqEventSourceR2Type | null; } export declare const SubscriptionsCreateResponseSourceMqEventSourceR2: S.Schema; export type SubscriptionsCreateResponseSourceMqEventSourceSuperSlurperType = "superSlurper"; export declare const SubscriptionsCreateResponseSourceMqEventSourceSuperSlurperType: any; export interface SubscriptionsCreateResponseSourceMqEventSourceSuperSlurper { /** Type of source */ type?: SubscriptionsCreateResponseSourceMqEventSourceSuperSlurperType | null; } export declare const SubscriptionsCreateResponseSourceMqEventSourceSuperSlurper: S.Schema; export type SubscriptionsCreateResponseSourceMqEventSourceVectorizeType = "vectorize"; export declare const SubscriptionsCreateResponseSourceMqEventSourceVectorizeType: any; export interface SubscriptionsCreateResponseSourceMqEventSourceVectorize { /** Type of source */ type?: SubscriptionsCreateResponseSourceMqEventSourceVectorizeType | null; } export declare const SubscriptionsCreateResponseSourceMqEventSourceVectorize: S.Schema; export type SubscriptionsCreateResponseSourceMqEventSourceWorkersAIModelType = "workersAi.model"; export declare const SubscriptionsCreateResponseSourceMqEventSourceWorkersAIModelType: any; export interface SubscriptionsCreateResponseSourceMqEventSourceWorkersAIModel { /** Name of the Workers AI model */ modelName?: string | null; /** Type of source */ type?: SubscriptionsCreateResponseSourceMqEventSourceWorkersAIModelType | null; } export declare const SubscriptionsCreateResponseSourceMqEventSourceWorkersAIModel: S.Schema; export type SubscriptionsCreateResponseSourceMqEventSourceWorkersBuildsWorkerType = "workersBuilds.worker"; export declare const SubscriptionsCreateResponseSourceMqEventSourceWorkersBuildsWorkerType: any; export interface SubscriptionsCreateResponseSourceMqEventSourceWorkersBuildsWorker { /** Type of source */ type?: SubscriptionsCreateResponseSourceMqEventSourceWorkersBuildsWorkerType | null; /** Name of the worker */ workerName?: string | null; } export declare const SubscriptionsCreateResponseSourceMqEventSourceWorkersBuildsWorker: S.Schema; export type SubscriptionsCreateResponseSourceMqEventSourceWorkflowsWorkflowType = "workflows.workflow"; export declare const SubscriptionsCreateResponseSourceMqEventSourceWorkflowsWorkflowType: any; export interface SubscriptionsCreateResponseSourceMqEventSourceWorkflowsWorkflow { /** Type of source */ type?: SubscriptionsCreateResponseSourceMqEventSourceWorkflowsWorkflowType | null; /** Name of the workflow */ workflowName?: string | null; } export declare const SubscriptionsCreateResponseSourceMqEventSourceWorkflowsWorkflow: S.Schema; export type SubscriptionsCreateResponseSource = SubscriptionsCreateResponseSourceMqEventSourceImages | SubscriptionsCreateResponseSourceMqEventSourceKV | SubscriptionsCreateResponseSourceMqEventSourceR2 | SubscriptionsCreateResponseSourceMqEventSourceSuperSlurper | SubscriptionsCreateResponseSourceMqEventSourceVectorize | SubscriptionsCreateResponseSourceMqEventSourceWorkersAIModel | SubscriptionsCreateResponseSourceMqEventSourceWorkersBuildsWorker | SubscriptionsCreateResponseSourceMqEventSourceWorkflowsWorkflow; export declare const SubscriptionsCreateResponseSource: any; /** Unwrapped `result` payload of the Cloudflare v4 response envelope. */ export interface CreateSubscriptionResponse { /** Unique identifier for the subscription */ id: string; /** When the subscription was created */ createdAt: string; /** Destination configuration for the subscription */ destination: SubscriptionsCreateResponseDestination; /** Whether the subscription is active */ enabled: boolean; /** List of event types this subscription handles */ events: SubscriptionsCreateResponseEventsList; /** When the subscription was last modified */ modifiedAt: string; /** Name of the subscription */ name: string; /** Source configuration for the subscription */ source: SubscriptionsCreateResponseSource; } export declare const CreateSubscriptionResponse: S.Schema; export interface DeleteConsumerRequest { /** A Resource identifier. */ accountId: string; /** A Resource identifier. */ queueId: string; /** A Resource identifier. */ consumerId: string; } export declare const DeleteConsumerRequest: S.Schema; export interface DeleteConsumerResponse { } export declare const DeleteConsumerResponse: S.Schema; export interface DeleteQueueRequest { /** A Resource identifier. */ accountId: string; /** A Resource identifier. */ queueId: string; } export declare const DeleteQueueRequest: S.Schema; export interface DeleteQueueResponse { } export declare const DeleteQueueResponse: S.Schema; export interface DeleteSubscriptionRequest { /** A Resource identifier. */ accountId: string; /** A Resource identifier. */ subscriptionId: string; } export declare const DeleteSubscriptionRequest: S.Schema; export type SubscriptionsDeleteResponseDestinationType = "queues.queue"; export declare const SubscriptionsDeleteResponseDestinationType: any; export interface SubscriptionsDeleteResponseDestination { /** ID of the target queue */ queueId: string; /** Type of destination */ type: SubscriptionsDeleteResponseDestinationType; } export declare const SubscriptionsDeleteResponseDestination: S.Schema; export type SubscriptionsDeleteResponseEventsList = Array; export declare const SubscriptionsDeleteResponseEventsList: S.Schema; export type SubscriptionsDeleteResponseSourceMqEventSourceImagesType = "images"; export declare const SubscriptionsDeleteResponseSourceMqEventSourceImagesType: any; export interface SubscriptionsDeleteResponseSourceMqEventSourceImages { /** Type of source */ type?: SubscriptionsDeleteResponseSourceMqEventSourceImagesType | null; } export declare const SubscriptionsDeleteResponseSourceMqEventSourceImages: S.Schema; export type SubscriptionsDeleteResponseSourceMqEventSourceKVType = "kv"; export declare const SubscriptionsDeleteResponseSourceMqEventSourceKVType: any; export interface SubscriptionsDeleteResponseSourceMqEventSourceKV { /** Type of source */ type?: SubscriptionsDeleteResponseSourceMqEventSourceKVType | null; } export declare const SubscriptionsDeleteResponseSourceMqEventSourceKV: S.Schema; export type SubscriptionsDeleteResponseSourceMqEventSourceR2Type = "r2"; export declare const SubscriptionsDeleteResponseSourceMqEventSourceR2Type: any; export interface SubscriptionsDeleteResponseSourceMqEventSourceR2 { /** Type of source */ type?: SubscriptionsDeleteResponseSourceMqEventSourceR2Type | null; } export declare const SubscriptionsDeleteResponseSourceMqEventSourceR2: S.Schema; export type SubscriptionsDeleteResponseSourceMqEventSourceSuperSlurperType = "superSlurper"; export declare const SubscriptionsDeleteResponseSourceMqEventSourceSuperSlurperType: any; export interface SubscriptionsDeleteResponseSourceMqEventSourceSuperSlurper { /** Type of source */ type?: SubscriptionsDeleteResponseSourceMqEventSourceSuperSlurperType | null; } export declare const SubscriptionsDeleteResponseSourceMqEventSourceSuperSlurper: S.Schema; export type SubscriptionsDeleteResponseSourceMqEventSourceVectorizeType = "vectorize"; export declare const SubscriptionsDeleteResponseSourceMqEventSourceVectorizeType: any; export interface SubscriptionsDeleteResponseSourceMqEventSourceVectorize { /** Type of source */ type?: SubscriptionsDeleteResponseSourceMqEventSourceVectorizeType | null; } export declare const SubscriptionsDeleteResponseSourceMqEventSourceVectorize: S.Schema; export type SubscriptionsDeleteResponseSourceMqEventSourceWorkersAIModelType = "workersAi.model"; export declare const SubscriptionsDeleteResponseSourceMqEventSourceWorkersAIModelType: any; export interface SubscriptionsDeleteResponseSourceMqEventSourceWorkersAIModel { /** Name of the Workers AI model */ modelName?: string | null; /** Type of source */ type?: SubscriptionsDeleteResponseSourceMqEventSourceWorkersAIModelType | null; } export declare const SubscriptionsDeleteResponseSourceMqEventSourceWorkersAIModel: S.Schema; export type SubscriptionsDeleteResponseSourceMqEventSourceWorkersBuildsWorkerType = "workersBuilds.worker"; export declare const SubscriptionsDeleteResponseSourceMqEventSourceWorkersBuildsWorkerType: any; export interface SubscriptionsDeleteResponseSourceMqEventSourceWorkersBuildsWorker { /** Type of source */ type?: SubscriptionsDeleteResponseSourceMqEventSourceWorkersBuildsWorkerType | null; /** Name of the worker */ workerName?: string | null; } export declare const SubscriptionsDeleteResponseSourceMqEventSourceWorkersBuildsWorker: S.Schema; export type SubscriptionsDeleteResponseSourceMqEventSourceWorkflowsWorkflowType = "workflows.workflow"; export declare const SubscriptionsDeleteResponseSourceMqEventSourceWorkflowsWorkflowType: any; export interface SubscriptionsDeleteResponseSourceMqEventSourceWorkflowsWorkflow { /** Type of source */ type?: SubscriptionsDeleteResponseSourceMqEventSourceWorkflowsWorkflowType | null; /** Name of the workflow */ workflowName?: string | null; } export declare const SubscriptionsDeleteResponseSourceMqEventSourceWorkflowsWorkflow: S.Schema; export type SubscriptionsDeleteResponseSource = SubscriptionsDeleteResponseSourceMqEventSourceImages | SubscriptionsDeleteResponseSourceMqEventSourceKV | SubscriptionsDeleteResponseSourceMqEventSourceR2 | SubscriptionsDeleteResponseSourceMqEventSourceSuperSlurper | SubscriptionsDeleteResponseSourceMqEventSourceVectorize | SubscriptionsDeleteResponseSourceMqEventSourceWorkersAIModel | SubscriptionsDeleteResponseSourceMqEventSourceWorkersBuildsWorker | SubscriptionsDeleteResponseSourceMqEventSourceWorkflowsWorkflow; export declare const SubscriptionsDeleteResponseSource: any; /** Unwrapped `result` payload of the Cloudflare v4 response envelope. */ export interface DeleteSubscriptionResponse { /** Unique identifier for the subscription */ id: string; /** When the subscription was created */ createdAt: string; /** Destination configuration for the subscription */ destination: SubscriptionsDeleteResponseDestination; /** Whether the subscription is active */ enabled: boolean; /** List of event types this subscription handles */ events: SubscriptionsDeleteResponseEventsList; /** When the subscription was last modified */ modifiedAt: string; /** Name of the subscription */ name: string; /** Source configuration for the subscription */ source: SubscriptionsDeleteResponseSource; } export declare const DeleteSubscriptionResponse: S.Schema; export interface GetConsumerRequest { /** A Resource identifier. */ accountId: string; /** A Resource identifier. */ queueId: string; /** A Resource identifier. */ consumerId: string; } export declare const GetConsumerRequest: S.Schema; export type ConsumersGetResultWorkerSettings = ConsumersCreateResultWorkerSettings; export declare const ConsumersGetResultWorkerSettings: S.Schema; export type ConsumersGetResultWorkerType = "worker"; export declare const ConsumersGetResultWorkerType: any; export interface ConsumersGetResultWorker { /** A Resource identifier. */ consumerId?: string | null; createdOn?: string | null; /** Name of the dead letter queue, or empty string if not configured */ deadLetterQueue?: string | null; queueName?: string | null; /** Name of a Worker */ scriptName?: string | null; settings?: ConsumersCreateResultWorkerSettings | null; type?: ConsumersGetResultWorkerType | null; } export declare const ConsumersGetResultWorker: S.Schema; export type ConsumersGetResultHTTPPullSettings = ConsumersCreateResultHTTPPullSettings; export declare const ConsumersGetResultHTTPPullSettings: S.Schema; export type ConsumersGetResultHTTPPullType = "http_pull"; export declare const ConsumersGetResultHTTPPullType: any; export interface ConsumersGetResultHTTPPull { /** A Resource identifier. */ consumerId?: string | null; createdOn?: string | null; /** Name of the dead letter queue, or empty string if not configured */ deadLetterQueue?: string | null; queueName?: string | null; settings?: ConsumersCreateResultHTTPPullSettings | null; type?: ConsumersGetResultHTTPPullType | null; } export declare const ConsumersGetResultHTTPPull: S.Schema; export type ConsumersGetResult = ConsumersGetResultWorker | ConsumersGetResultHTTPPull; export declare const ConsumersGetResult: any; export type GetConsumerResponse = ConsumersGetResult; export declare const GetConsumerResponse: S.Schema; export interface GetMetricsQueueRequest { /** A Resource identifier. */ accountId: string; /** A Resource identifier. */ queueId: string; } export declare const GetMetricsQueueRequest: S.Schema; /** Unwrapped `result` payload of the Cloudflare v4 response envelope. */ export interface GetMetricsQueueResponse { /** The size in bytes of unacknowledged messages in the queue. */ backlogBytes: number; /** The number of unacknowledged messages in the queue. */ backlogCount: number; /** Unix timestamp in milliseconds of the oldest unacknowledged message in the queue. Returns 0 if unknown. */ oldestMessageTimestampMs: number; } export declare const GetMetricsQueueResponse: S.Schema; export interface GetQueueRequest { /** A Resource identifier. */ accountId: string; /** A Resource identifier. */ queueId: string; } export declare const GetQueueRequest: S.Schema; export type GetResponseConsumersItemWorkerSettings = ConsumersCreateResultWorkerSettings; export declare const GetResponseConsumersItemWorkerSettings: S.Schema; export type GetResponseConsumersItemWorkerType = "worker"; export declare const GetResponseConsumersItemWorkerType: any; export interface GetResponseConsumersItemWorker { /** A Resource identifier. */ consumerId?: string | null; createdOn?: string | null; /** Name of the dead letter queue, or empty string if not configured */ deadLetterQueue?: string | null; queueName?: string | null; /** Name of a Worker */ scriptName?: string | null; settings?: ConsumersCreateResultWorkerSettings | null; type?: GetResponseConsumersItemWorkerType | null; } export declare const GetResponseConsumersItemWorker: S.Schema; export type GetResponseConsumersItemHTTPPullSettings = ConsumersCreateResultHTTPPullSettings; export declare const GetResponseConsumersItemHTTPPullSettings: S.Schema; export type GetResponseConsumersItemHTTPPullType = "http_pull"; export declare const GetResponseConsumersItemHTTPPullType: any; export interface GetResponseConsumersItemHTTPPull { /** A Resource identifier. */ consumerId?: string | null; createdOn?: string | null; /** Name of the dead letter queue, or empty string if not configured */ deadLetterQueue?: string | null; queueName?: string | null; settings?: ConsumersCreateResultHTTPPullSettings | null; type?: GetResponseConsumersItemHTTPPullType | null; } export declare const GetResponseConsumersItemHTTPPull: S.Schema; export type GetResponseConsumersItem = GetResponseConsumersItemWorker | GetResponseConsumersItemHTTPPull; export declare const GetResponseConsumersItem: any; export type GetResponseConsumersList = Array; export declare const GetResponseConsumersList: S.Schema; export type GetResponseProducersItemMqWorkerProducerType = "worker"; export declare const GetResponseProducersItemMqWorkerProducerType: any; export interface GetResponseProducersItemMqWorkerProducer { type?: GetResponseProducersItemMqWorkerProducerType | null; scriptName?: string | null; } export declare const GetResponseProducersItemMqWorkerProducer: S.Schema; export type GetResponseProducersItemMqR2ProducerType = "r2_bucket"; export declare const GetResponseProducersItemMqR2ProducerType: any; export interface GetResponseProducersItemMqR2Producer { bucketName?: string | null; type?: GetResponseProducersItemMqR2ProducerType | null; } export declare const GetResponseProducersItemMqR2Producer: S.Schema; export type GetResponseProducersItem = GetResponseProducersItemMqWorkerProducer | GetResponseProducersItemMqR2Producer; export declare const GetResponseProducersItem: any; export type GetResponseProducersList = Array; export declare const GetResponseProducersList: S.Schema; export type GetResponseSettings = CreateResponseSettings; export declare const GetResponseSettings: S.Schema; /** Unwrapped `result` payload of the Cloudflare v4 response envelope. */ export interface GetQueueResponse { consumers?: GetResponseConsumersList | null; consumersTotalCount?: number | null; createdOn?: string | null; modifiedOn?: string | null; producers?: GetResponseProducersList | null; producersTotalCount?: number | null; queueId?: string | null; queueName?: string | null; settings?: CreateResponseSettings | null; } export declare const GetQueueResponse: S.Schema; export interface GetSubscriptionRequest { /** A Resource identifier. */ accountId: string; /** A Resource identifier. */ subscriptionId: string; } export declare const GetSubscriptionRequest: S.Schema; export type SubscriptionsGetResponseDestinationType = "queues.queue"; export declare const SubscriptionsGetResponseDestinationType: any; export interface SubscriptionsGetResponseDestination { /** ID of the target queue */ queueId: string; /** Type of destination */ type: SubscriptionsGetResponseDestinationType; } export declare const SubscriptionsGetResponseDestination: S.Schema; export type SubscriptionsGetResponseEventsList = Array; export declare const SubscriptionsGetResponseEventsList: S.Schema; export type SubscriptionsGetResponseSourceMqEventSourceImagesType = "images"; export declare const SubscriptionsGetResponseSourceMqEventSourceImagesType: any; export interface SubscriptionsGetResponseSourceMqEventSourceImages { /** Type of source */ type?: SubscriptionsGetResponseSourceMqEventSourceImagesType | null; } export declare const SubscriptionsGetResponseSourceMqEventSourceImages: S.Schema; export type SubscriptionsGetResponseSourceMqEventSourceKVType = "kv"; export declare const SubscriptionsGetResponseSourceMqEventSourceKVType: any; export interface SubscriptionsGetResponseSourceMqEventSourceKV { /** Type of source */ type?: SubscriptionsGetResponseSourceMqEventSourceKVType | null; } export declare const SubscriptionsGetResponseSourceMqEventSourceKV: S.Schema; export type SubscriptionsGetResponseSourceMqEventSourceR2Type = "r2"; export declare const SubscriptionsGetResponseSourceMqEventSourceR2Type: any; export interface SubscriptionsGetResponseSourceMqEventSourceR2 { /** Type of source */ type?: SubscriptionsGetResponseSourceMqEventSourceR2Type | null; } export declare const SubscriptionsGetResponseSourceMqEventSourceR2: S.Schema; export type SubscriptionsGetResponseSourceMqEventSourceSuperSlurperType = "superSlurper"; export declare const SubscriptionsGetResponseSourceMqEventSourceSuperSlurperType: any; export interface SubscriptionsGetResponseSourceMqEventSourceSuperSlurper { /** Type of source */ type?: SubscriptionsGetResponseSourceMqEventSourceSuperSlurperType | null; } export declare const SubscriptionsGetResponseSourceMqEventSourceSuperSlurper: S.Schema; export type SubscriptionsGetResponseSourceMqEventSourceVectorizeType = "vectorize"; export declare const SubscriptionsGetResponseSourceMqEventSourceVectorizeType: any; export interface SubscriptionsGetResponseSourceMqEventSourceVectorize { /** Type of source */ type?: SubscriptionsGetResponseSourceMqEventSourceVectorizeType | null; } export declare const SubscriptionsGetResponseSourceMqEventSourceVectorize: S.Schema; export type SubscriptionsGetResponseSourceMqEventSourceWorkersAIModelType = "workersAi.model"; export declare const SubscriptionsGetResponseSourceMqEventSourceWorkersAIModelType: any; export interface SubscriptionsGetResponseSourceMqEventSourceWorkersAIModel { /** Name of the Workers AI model */ modelName?: string | null; /** Type of source */ type?: SubscriptionsGetResponseSourceMqEventSourceWorkersAIModelType | null; } export declare const SubscriptionsGetResponseSourceMqEventSourceWorkersAIModel: S.Schema; export type SubscriptionsGetResponseSourceMqEventSourceWorkersBuildsWorkerType = "workersBuilds.worker"; export declare const SubscriptionsGetResponseSourceMqEventSourceWorkersBuildsWorkerType: any; export interface SubscriptionsGetResponseSourceMqEventSourceWorkersBuildsWorker { /** Type of source */ type?: SubscriptionsGetResponseSourceMqEventSourceWorkersBuildsWorkerType | null; /** Name of the worker */ workerName?: string | null; } export declare const SubscriptionsGetResponseSourceMqEventSourceWorkersBuildsWorker: S.Schema; export type SubscriptionsGetResponseSourceMqEventSourceWorkflowsWorkflowType = "workflows.workflow"; export declare const SubscriptionsGetResponseSourceMqEventSourceWorkflowsWorkflowType: any; export interface SubscriptionsGetResponseSourceMqEventSourceWorkflowsWorkflow { /** Type of source */ type?: SubscriptionsGetResponseSourceMqEventSourceWorkflowsWorkflowType | null; /** Name of the workflow */ workflowName?: string | null; } export declare const SubscriptionsGetResponseSourceMqEventSourceWorkflowsWorkflow: S.Schema; export type SubscriptionsGetResponseSource = SubscriptionsGetResponseSourceMqEventSourceImages | SubscriptionsGetResponseSourceMqEventSourceKV | SubscriptionsGetResponseSourceMqEventSourceR2 | SubscriptionsGetResponseSourceMqEventSourceSuperSlurper | SubscriptionsGetResponseSourceMqEventSourceVectorize | SubscriptionsGetResponseSourceMqEventSourceWorkersAIModel | SubscriptionsGetResponseSourceMqEventSourceWorkersBuildsWorker | SubscriptionsGetResponseSourceMqEventSourceWorkflowsWorkflow; export declare const SubscriptionsGetResponseSource: any; /** Unwrapped `result` payload of the Cloudflare v4 response envelope. */ export interface GetSubscriptionResponse { /** Unique identifier for the subscription */ id: string; /** When the subscription was created */ createdAt: string; /** Destination configuration for the subscription */ destination: SubscriptionsGetResponseDestination; /** Whether the subscription is active */ enabled: boolean; /** List of event types this subscription handles */ events: SubscriptionsGetResponseEventsList; /** When the subscription was last modified */ modifiedAt: string; /** Name of the subscription */ name: string; /** Source configuration for the subscription */ source: SubscriptionsGetResponseSource; } export declare const GetSubscriptionResponse: S.Schema; export interface ListConsumersRequest { /** A Resource identifier. */ accountId: string; /** A Resource identifier. */ queueId: string; } export declare const ListConsumersRequest: S.Schema; export type ConsumersListResultItemWorkerSettings = ConsumersCreateResultWorkerSettings; export declare const ConsumersListResultItemWorkerSettings: S.Schema; export type ConsumersListResultItemWorkerType = "worker"; export declare const ConsumersListResultItemWorkerType: any; export interface ConsumersListResultItemWorker { /** A Resource identifier. */ consumerId?: string | null; createdOn?: string | null; /** Name of the dead letter queue, or empty string if not configured */ deadLetterQueue?: string | null; queueName?: string | null; /** Name of a Worker */ scriptName?: string | null; settings?: ConsumersCreateResultWorkerSettings | null; type?: ConsumersListResultItemWorkerType | null; } export declare const ConsumersListResultItemWorker: S.Schema; export type ConsumersListResultItemHTTPPullSettings = ConsumersCreateResultHTTPPullSettings; export declare const ConsumersListResultItemHTTPPullSettings: S.Schema; export type ConsumersListResultItemHTTPPullType = "http_pull"; export declare const ConsumersListResultItemHTTPPullType: any; export interface ConsumersListResultItemHTTPPull { /** A Resource identifier. */ consumerId?: string | null; createdOn?: string | null; /** Name of the dead letter queue, or empty string if not configured */ deadLetterQueue?: string | null; queueName?: string | null; settings?: ConsumersCreateResultHTTPPullSettings | null; type?: ConsumersListResultItemHTTPPullType | null; } export declare const ConsumersListResultItemHTTPPull: S.Schema; export type ConsumersListResultItem = ConsumersListResultItemWorker | ConsumersListResultItemHTTPPull; export declare const ConsumersListResultItem: any; export type ConsumersListResultList = Array; export declare const ConsumersListResultList: S.Schema; export interface ListConsumersResponse { /** The unwrapped `result` payload of the v4 response envelope. */ result: ConsumersListResultList; /** Pagination info from the envelope's `result_info`. */ resultInfo?: ResultInfo | null; } export declare const ListConsumersResponse: S.Schema; export interface ListQueuesRequest { /** A Resource identifier. */ accountId: string; } export declare const ListQueuesRequest: S.Schema; export type ListResultItemConsumersItemWorkerSettings = ConsumersCreateResultWorkerSettings; export declare const ListResultItemConsumersItemWorkerSettings: S.Schema; export type ListResultItemConsumersItemWorkerType = "worker"; export declare const ListResultItemConsumersItemWorkerType: any; export interface ListResultItemConsumersItemWorker { /** A Resource identifier. */ consumerId?: string | null; createdOn?: string | null; /** Name of the dead letter queue, or empty string if not configured */ deadLetterQueue?: string | null; queueName?: string | null; /** Name of a Worker */ scriptName?: string | null; settings?: ConsumersCreateResultWorkerSettings | null; type?: ListResultItemConsumersItemWorkerType | null; } export declare const ListResultItemConsumersItemWorker: S.Schema; export type ListResultItemConsumersItemHTTPPullSettings = ConsumersCreateResultHTTPPullSettings; export declare const ListResultItemConsumersItemHTTPPullSettings: S.Schema; export type ListResultItemConsumersItemHTTPPullType = "http_pull"; export declare const ListResultItemConsumersItemHTTPPullType: any; export interface ListResultItemConsumersItemHTTPPull { /** A Resource identifier. */ consumerId?: string | null; createdOn?: string | null; /** Name of the dead letter queue, or empty string if not configured */ deadLetterQueue?: string | null; queueName?: string | null; settings?: ConsumersCreateResultHTTPPullSettings | null; type?: ListResultItemConsumersItemHTTPPullType | null; } export declare const ListResultItemConsumersItemHTTPPull: S.Schema; export type ListResultItemConsumersItem = ListResultItemConsumersItemWorker | ListResultItemConsumersItemHTTPPull; export declare const ListResultItemConsumersItem: any; export type ListResultItemConsumersList = Array; export declare const ListResultItemConsumersList: S.Schema; export type ListResultItemProducersItemMqWorkerProducerType = "worker"; export declare const ListResultItemProducersItemMqWorkerProducerType: any; export interface ListResultItemProducersItemMqWorkerProducer { type?: ListResultItemProducersItemMqWorkerProducerType | null; scriptName?: string | null; } export declare const ListResultItemProducersItemMqWorkerProducer: S.Schema; export type ListResultItemProducersItemMqR2ProducerType = "r2_bucket"; export declare const ListResultItemProducersItemMqR2ProducerType: any; export interface ListResultItemProducersItemMqR2Producer { bucketName?: string | null; type?: ListResultItemProducersItemMqR2ProducerType | null; } export declare const ListResultItemProducersItemMqR2Producer: S.Schema; export type ListResultItemProducersItem = ListResultItemProducersItemMqWorkerProducer | ListResultItemProducersItemMqR2Producer; export declare const ListResultItemProducersItem: any; export type ListResultItemProducersList = Array; export declare const ListResultItemProducersList: S.Schema; export type ListResultItemSettings = CreateResponseSettings; export declare const ListResultItemSettings: S.Schema; export interface ListResultItem { consumers?: ListResultItemConsumersList | null; consumersTotalCount?: number | null; createdOn?: string | null; modifiedOn?: string | null; producers?: ListResultItemProducersList | null; producersTotalCount?: number | null; queueId?: string | null; queueName?: string | null; settings?: CreateResponseSettings | null; } export declare const ListResultItem: S.Schema; export type ListResultList = Array; export declare const ListResultList: S.Schema; export interface ListQueuesResponse { /** The unwrapped `result` payload of the v4 response envelope. */ result: ListResultList; /** Pagination info from the envelope's `result_info`. */ resultInfo?: ResultInfo | null; } export declare const ListQueuesResponse: S.Schema; export type SubscriptionsListRequestDirection = "asc" | "desc"; export declare const SubscriptionsListRequestDirection: any; export type SubscriptionsListRequestOrder = "created_at" | "name" | "enabled" | "source"; export declare const SubscriptionsListRequestOrder: any; export interface ListSubscriptionsRequest { /** A Resource identifier. */ accountId: string; /** Sort direction */ direction?: SubscriptionsListRequestDirection | (string & {}); /** Field to sort by */ order?: SubscriptionsListRequestOrder | (string & {}); /** Page number for pagination */ page?: number; /** Number of items per page */ perPage?: number; } export declare const ListSubscriptionsRequest: S.Schema; export type SubscriptionsListResultItemDestinationType = "queues.queue"; export declare const SubscriptionsListResultItemDestinationType: any; export interface SubscriptionsListResultItemDestination { /** ID of the target queue */ queueId: string; /** Type of destination */ type: SubscriptionsListResultItemDestinationType; } export declare const SubscriptionsListResultItemDestination: S.Schema; export type SubscriptionsListResultItemEventsList = Array; export declare const SubscriptionsListResultItemEventsList: S.Schema; export type SubscriptionsListResultItemSourceMqEventSourceImagesType = "images"; export declare const SubscriptionsListResultItemSourceMqEventSourceImagesType: any; export interface SubscriptionsListResultItemSourceMqEventSourceImages { /** Type of source */ type?: SubscriptionsListResultItemSourceMqEventSourceImagesType | null; } export declare const SubscriptionsListResultItemSourceMqEventSourceImages: S.Schema; export type SubscriptionsListResultItemSourceMqEventSourceKVType = "kv"; export declare const SubscriptionsListResultItemSourceMqEventSourceKVType: any; export interface SubscriptionsListResultItemSourceMqEventSourceKV { /** Type of source */ type?: SubscriptionsListResultItemSourceMqEventSourceKVType | null; } export declare const SubscriptionsListResultItemSourceMqEventSourceKV: S.Schema; export type SubscriptionsListResultItemSourceMqEventSourceR2Type = "r2"; export declare const SubscriptionsListResultItemSourceMqEventSourceR2Type: any; export interface SubscriptionsListResultItemSourceMqEventSourceR2 { /** Type of source */ type?: SubscriptionsListResultItemSourceMqEventSourceR2Type | null; } export declare const SubscriptionsListResultItemSourceMqEventSourceR2: S.Schema; export type SubscriptionsListResultItemSourceMqEventSourceSuperSlurperType = "superSlurper"; export declare const SubscriptionsListResultItemSourceMqEventSourceSuperSlurperType: any; export interface SubscriptionsListResultItemSourceMqEventSourceSuperSlurper { /** Type of source */ type?: SubscriptionsListResultItemSourceMqEventSourceSuperSlurperType | null; } export declare const SubscriptionsListResultItemSourceMqEventSourceSuperSlurper: S.Schema; export type SubscriptionsListResultItemSourceMqEventSourceVectorizeType = "vectorize"; export declare const SubscriptionsListResultItemSourceMqEventSourceVectorizeType: any; export interface SubscriptionsListResultItemSourceMqEventSourceVectorize { /** Type of source */ type?: SubscriptionsListResultItemSourceMqEventSourceVectorizeType | null; } export declare const SubscriptionsListResultItemSourceMqEventSourceVectorize: S.Schema; export type SubscriptionsListResultItemSourceMqEventSourceWorkersAIModelType = "workersAi.model"; export declare const SubscriptionsListResultItemSourceMqEventSourceWorkersAIModelType: any; export interface SubscriptionsListResultItemSourceMqEventSourceWorkersAIModel { /** Name of the Workers AI model */ modelName?: string | null; /** Type of source */ type?: SubscriptionsListResultItemSourceMqEventSourceWorkersAIModelType | null; } export declare const SubscriptionsListResultItemSourceMqEventSourceWorkersAIModel: S.Schema; export type SubscriptionsListResultItemSourceMqEventSourceWorkersBuildsWorkerType = "workersBuilds.worker"; export declare const SubscriptionsListResultItemSourceMqEventSourceWorkersBuildsWorkerType: any; export interface SubscriptionsListResultItemSourceMqEventSourceWorkersBuildsWorker { /** Type of source */ type?: SubscriptionsListResultItemSourceMqEventSourceWorkersBuildsWorkerType | null; /** Name of the worker */ workerName?: string | null; } export declare const SubscriptionsListResultItemSourceMqEventSourceWorkersBuildsWorker: S.Schema; export type SubscriptionsListResultItemSourceMqEventSourceWorkflowsWorkflowType = "workflows.workflow"; export declare const SubscriptionsListResultItemSourceMqEventSourceWorkflowsWorkflowType: any; export interface SubscriptionsListResultItemSourceMqEventSourceWorkflowsWorkflow { /** Type of source */ type?: SubscriptionsListResultItemSourceMqEventSourceWorkflowsWorkflowType | null; /** Name of the workflow */ workflowName?: string | null; } export declare const SubscriptionsListResultItemSourceMqEventSourceWorkflowsWorkflow: S.Schema; export type SubscriptionsListResultItemSource = SubscriptionsListResultItemSourceMqEventSourceImages | SubscriptionsListResultItemSourceMqEventSourceKV | SubscriptionsListResultItemSourceMqEventSourceR2 | SubscriptionsListResultItemSourceMqEventSourceSuperSlurper | SubscriptionsListResultItemSourceMqEventSourceVectorize | SubscriptionsListResultItemSourceMqEventSourceWorkersAIModel | SubscriptionsListResultItemSourceMqEventSourceWorkersBuildsWorker | SubscriptionsListResultItemSourceMqEventSourceWorkflowsWorkflow; export declare const SubscriptionsListResultItemSource: any; export interface SubscriptionsListResultItem { /** Unique identifier for the subscription */ id: string; /** When the subscription was created */ createdAt: string; /** Destination configuration for the subscription */ destination: SubscriptionsListResultItemDestination; /** Whether the subscription is active */ enabled: boolean; /** List of event types this subscription handles */ events: SubscriptionsListResultItemEventsList; /** When the subscription was last modified */ modifiedAt: string; /** Name of the subscription */ name: string; /** Source configuration for the subscription */ source: SubscriptionsListResultItemSource; } export declare const SubscriptionsListResultItem: S.Schema; export type SubscriptionsListResultList = Array; export declare const SubscriptionsListResultList: S.Schema; export interface ListSubscriptionsResponse { /** The unwrapped `result` payload of the v4 response envelope. */ result: SubscriptionsListResultList; /** Pagination info from the envelope's `result_info`. */ resultInfo?: ResultInfo | null; } export declare const ListSubscriptionsResponse: S.Schema; export interface EditRequestSettings { /** Number of seconds to delay delivery of all messages to consumers. */ deliveryDelay?: number; /** Indicates if message delivery to consumers is currently paused. */ deliveryPaused?: boolean; /** Number of seconds after which an unconsumed message will be delayed. */ messageRetentionPeriod?: number; } export declare const EditRequestSettings: S.Schema; export interface PatchQueueRequest { /** A Resource identifier. */ accountId: string; /** A Resource identifier. */ queueId: string; queueName?: string; settings?: EditRequestSettings; } export declare const PatchQueueRequest: S.Schema; export type EditResponseConsumersItemWorkerSettings = ConsumersCreateResultWorkerSettings; export declare const EditResponseConsumersItemWorkerSettings: S.Schema; export type EditResponseConsumersItemWorkerType = "worker"; export declare const EditResponseConsumersItemWorkerType: any; export interface EditResponseConsumersItemWorker { /** A Resource identifier. */ consumerId?: string | null; createdOn?: string | null; /** Name of the dead letter queue, or empty string if not configured */ deadLetterQueue?: string | null; queueName?: string | null; /** Name of a Worker */ scriptName?: string | null; settings?: ConsumersCreateResultWorkerSettings | null; type?: EditResponseConsumersItemWorkerType | null; } export declare const EditResponseConsumersItemWorker: S.Schema; export type EditResponseConsumersItemHTTPPullSettings = ConsumersCreateResultHTTPPullSettings; export declare const EditResponseConsumersItemHTTPPullSettings: S.Schema; export type EditResponseConsumersItemHTTPPullType = "http_pull"; export declare const EditResponseConsumersItemHTTPPullType: any; export interface EditResponseConsumersItemHTTPPull { /** A Resource identifier. */ consumerId?: string | null; createdOn?: string | null; /** Name of the dead letter queue, or empty string if not configured */ deadLetterQueue?: string | null; queueName?: string | null; settings?: ConsumersCreateResultHTTPPullSettings | null; type?: EditResponseConsumersItemHTTPPullType | null; } export declare const EditResponseConsumersItemHTTPPull: S.Schema; export type EditResponseConsumersItem = EditResponseConsumersItemWorker | EditResponseConsumersItemHTTPPull; export declare const EditResponseConsumersItem: any; export type EditResponseConsumersList = Array; export declare const EditResponseConsumersList: S.Schema; export type EditResponseProducersItemMqWorkerProducerType = "worker"; export declare const EditResponseProducersItemMqWorkerProducerType: any; export interface EditResponseProducersItemMqWorkerProducer { type?: EditResponseProducersItemMqWorkerProducerType | null; scriptName?: string | null; } export declare const EditResponseProducersItemMqWorkerProducer: S.Schema; export type EditResponseProducersItemMqR2ProducerType = "r2_bucket"; export declare const EditResponseProducersItemMqR2ProducerType: any; export interface EditResponseProducersItemMqR2Producer { bucketName?: string | null; type?: EditResponseProducersItemMqR2ProducerType | null; } export declare const EditResponseProducersItemMqR2Producer: S.Schema; export type EditResponseProducersItem = EditResponseProducersItemMqWorkerProducer | EditResponseProducersItemMqR2Producer; export declare const EditResponseProducersItem: any; export type EditResponseProducersList = Array; export declare const EditResponseProducersList: S.Schema; export type EditResponseSettings = CreateResponseSettings; export declare const EditResponseSettings: S.Schema; /** Unwrapped `result` payload of the Cloudflare v4 response envelope. */ export interface PatchQueueResponse { consumers?: EditResponseConsumersList | null; consumersTotalCount?: number | null; createdOn?: string | null; modifiedOn?: string | null; producers?: EditResponseProducersList | null; producersTotalCount?: number | null; queueId?: string | null; queueName?: string | null; settings?: CreateResponseSettings | null; } export declare const PatchQueueResponse: S.Schema; export type SubscriptionsUpdateRequestDestinationType = "queues.queue"; export declare const SubscriptionsUpdateRequestDestinationType: any; export interface SubscriptionsUpdateRequestDestination { /** ID of the target queue */ queueId: string; /** Type of destination */ type: SubscriptionsUpdateRequestDestinationType | (string & {}); } export declare const SubscriptionsUpdateRequestDestination: S.Schema; export type SubscriptionsUpdateRequestEventsList = Array; export declare const SubscriptionsUpdateRequestEventsList: S.Schema; export interface PatchSubscriptionRequest { /** A Resource identifier. */ accountId: string; /** A Resource identifier. */ subscriptionId: string; /** Destination configuration for the subscription */ destination?: SubscriptionsUpdateRequestDestination; /** Whether the subscription is active */ enabled?: boolean; /** List of event types this subscription handles */ events?: SubscriptionsUpdateRequestEventsList; /** Name of the subscription */ name?: string; } export declare const PatchSubscriptionRequest: S.Schema; export type SubscriptionsUpdateResponseDestinationType = "queues.queue"; export declare const SubscriptionsUpdateResponseDestinationType: any; export interface SubscriptionsUpdateResponseDestination { /** ID of the target queue */ queueId: string; /** Type of destination */ type: SubscriptionsUpdateResponseDestinationType; } export declare const SubscriptionsUpdateResponseDestination: S.Schema; export type SubscriptionsUpdateResponseEventsList = Array; export declare const SubscriptionsUpdateResponseEventsList: S.Schema; export type SubscriptionsUpdateResponseSourceMqEventSourceImagesType = "images"; export declare const SubscriptionsUpdateResponseSourceMqEventSourceImagesType: any; export interface SubscriptionsUpdateResponseSourceMqEventSourceImages { /** Type of source */ type?: SubscriptionsUpdateResponseSourceMqEventSourceImagesType | null; } export declare const SubscriptionsUpdateResponseSourceMqEventSourceImages: S.Schema; export type SubscriptionsUpdateResponseSourceMqEventSourceKVType = "kv"; export declare const SubscriptionsUpdateResponseSourceMqEventSourceKVType: any; export interface SubscriptionsUpdateResponseSourceMqEventSourceKV { /** Type of source */ type?: SubscriptionsUpdateResponseSourceMqEventSourceKVType | null; } export declare const SubscriptionsUpdateResponseSourceMqEventSourceKV: S.Schema; export type SubscriptionsUpdateResponseSourceMqEventSourceR2Type = "r2"; export declare const SubscriptionsUpdateResponseSourceMqEventSourceR2Type: any; export interface SubscriptionsUpdateResponseSourceMqEventSourceR2 { /** Type of source */ type?: SubscriptionsUpdateResponseSourceMqEventSourceR2Type | null; } export declare const SubscriptionsUpdateResponseSourceMqEventSourceR2: S.Schema; export type SubscriptionsUpdateResponseSourceMqEventSourceSuperSlurperType = "superSlurper"; export declare const SubscriptionsUpdateResponseSourceMqEventSourceSuperSlurperType: any; export interface SubscriptionsUpdateResponseSourceMqEventSourceSuperSlurper { /** Type of source */ type?: SubscriptionsUpdateResponseSourceMqEventSourceSuperSlurperType | null; } export declare const SubscriptionsUpdateResponseSourceMqEventSourceSuperSlurper: S.Schema; export type SubscriptionsUpdateResponseSourceMqEventSourceVectorizeType = "vectorize"; export declare const SubscriptionsUpdateResponseSourceMqEventSourceVectorizeType: any; export interface SubscriptionsUpdateResponseSourceMqEventSourceVectorize { /** Type of source */ type?: SubscriptionsUpdateResponseSourceMqEventSourceVectorizeType | null; } export declare const SubscriptionsUpdateResponseSourceMqEventSourceVectorize: S.Schema; export type SubscriptionsUpdateResponseSourceMqEventSourceWorkersAIModelType = "workersAi.model"; export declare const SubscriptionsUpdateResponseSourceMqEventSourceWorkersAIModelType: any; export interface SubscriptionsUpdateResponseSourceMqEventSourceWorkersAIModel { /** Name of the Workers AI model */ modelName?: string | null; /** Type of source */ type?: SubscriptionsUpdateResponseSourceMqEventSourceWorkersAIModelType | null; } export declare const SubscriptionsUpdateResponseSourceMqEventSourceWorkersAIModel: S.Schema; export type SubscriptionsUpdateResponseSourceMqEventSourceWorkersBuildsWorkerType = "workersBuilds.worker"; export declare const SubscriptionsUpdateResponseSourceMqEventSourceWorkersBuildsWorkerType: any; export interface SubscriptionsUpdateResponseSourceMqEventSourceWorkersBuildsWorker { /** Type of source */ type?: SubscriptionsUpdateResponseSourceMqEventSourceWorkersBuildsWorkerType | null; /** Name of the worker */ workerName?: string | null; } export declare const SubscriptionsUpdateResponseSourceMqEventSourceWorkersBuildsWorker: S.Schema; export type SubscriptionsUpdateResponseSourceMqEventSourceWorkflowsWorkflowType = "workflows.workflow"; export declare const SubscriptionsUpdateResponseSourceMqEventSourceWorkflowsWorkflowType: any; export interface SubscriptionsUpdateResponseSourceMqEventSourceWorkflowsWorkflow { /** Type of source */ type?: SubscriptionsUpdateResponseSourceMqEventSourceWorkflowsWorkflowType | null; /** Name of the workflow */ workflowName?: string | null; } export declare const SubscriptionsUpdateResponseSourceMqEventSourceWorkflowsWorkflow: S.Schema; export type SubscriptionsUpdateResponseSource = SubscriptionsUpdateResponseSourceMqEventSourceImages | SubscriptionsUpdateResponseSourceMqEventSourceKV | SubscriptionsUpdateResponseSourceMqEventSourceR2 | SubscriptionsUpdateResponseSourceMqEventSourceSuperSlurper | SubscriptionsUpdateResponseSourceMqEventSourceVectorize | SubscriptionsUpdateResponseSourceMqEventSourceWorkersAIModel | SubscriptionsUpdateResponseSourceMqEventSourceWorkersBuildsWorker | SubscriptionsUpdateResponseSourceMqEventSourceWorkflowsWorkflow; export declare const SubscriptionsUpdateResponseSource: any; /** Unwrapped `result` payload of the Cloudflare v4 response envelope. */ export interface PatchSubscriptionResponse { /** Unique identifier for the subscription */ id: string; /** When the subscription was created */ createdAt: string; /** Destination configuration for the subscription */ destination: SubscriptionsUpdateResponseDestination; /** Whether the subscription is active */ enabled: boolean; /** List of event types this subscription handles */ events: SubscriptionsUpdateResponseEventsList; /** When the subscription was last modified */ modifiedAt: string; /** Name of the subscription */ name: string; /** Source configuration for the subscription */ source: SubscriptionsUpdateResponseSource; } export declare const PatchSubscriptionResponse: S.Schema; export interface PullMessageRequest { /** A Resource identifier. */ accountId: string; /** A Resource identifier. */ queueId: string; /** The maximum number of messages to include in a batch. */ batchSize?: number; /** The number of milliseconds that a message is exclusively leased. After the timeout, the message becomes available for another attempt. */ visibilityTimeoutMs?: number; } export declare const PullMessageRequest: S.Schema; export interface MessagesPullResponseMessagesItem { id?: string | null; attempts?: number | null; body?: string | null; /** An ID that represents an "in-flight" message that has been pulled from a Queue. You must hold on to this ID and use it to acknowledge this message. */ leaseId?: string | null; metadata?: unknown | null; timestampMs?: number | null; } export declare const MessagesPullResponseMessagesItem: S.Schema; export type MessagesPullResponseMessagesList = Array; export declare const MessagesPullResponseMessagesList: S.Schema; export type MessagesPullResponseMetadataMetrics = MessagesBulkPushResponseMetadataMetrics; export declare const MessagesPullResponseMetadataMetrics: S.Schema; export type MessagesPullResponseMetadata = MessagesBulkPushResponseMetadata; export declare const MessagesPullResponseMetadata: S.Schema; /** Unwrapped `result` payload of the Cloudflare v4 response envelope. */ export interface PullMessageResponse { /** The number of unacknowledged messages in the queue. */ messageBacklogCount?: number | null; messages?: MessagesPullResponseMessagesList | null; metadata?: MessagesBulkPushResponseMetadata | null; } export declare const PullMessageResponse: S.Schema; export type MessagesPushRequestContentType = "text" | "json"; export declare const MessagesPushRequestContentType: any; export interface PushMessageRequest { /** A Resource identifier. */ accountId: string; /** A Resource identifier. */ queueId: string; body?: unknown; contentType?: MessagesPushRequestContentType | (string & {}); /** The number of seconds to wait for attempting to deliver this message to consumers */ delaySeconds?: number; } export declare const PushMessageRequest: S.Schema; export type MessagesPushResponseMetadataMetrics = MessagesBulkPushResponseMetadataMetrics; export declare const MessagesPushResponseMetadataMetrics: S.Schema; export type MessagesPushResponseMetadata = MessagesBulkPushResponseMetadata; export declare const MessagesPushResponseMetadata: S.Schema; /** Unwrapped `result` payload of the Cloudflare v4 response envelope. */ export interface PushMessageResponse { metadata?: MessagesBulkPushResponseMetadata | null; } export declare const PushMessageResponse: S.Schema; export interface StartPurgeRequest { /** A Resource identifier. */ accountId: string; /** A Resource identifier. */ queueId: string; /** Confimation that all messages will be deleted permanently. */ deleteMessagesPermanently?: boolean; } export declare const StartPurgeRequest: S.Schema; export type PurgeStartResponseConsumersItemWorkerSettings = ConsumersCreateResultWorkerSettings; export declare const PurgeStartResponseConsumersItemWorkerSettings: S.Schema; export type PurgeStartResponseConsumersItemWorkerType = "worker"; export declare const PurgeStartResponseConsumersItemWorkerType: any; export interface PurgeStartResponseConsumersItemWorker { /** A Resource identifier. */ consumerId?: string | null; createdOn?: string | null; /** Name of the dead letter queue, or empty string if not configured */ deadLetterQueue?: string | null; queueName?: string | null; /** Name of a Worker */ scriptName?: string | null; settings?: ConsumersCreateResultWorkerSettings | null; type?: PurgeStartResponseConsumersItemWorkerType | null; } export declare const PurgeStartResponseConsumersItemWorker: S.Schema; export type PurgeStartResponseConsumersItemHTTPPullSettings = ConsumersCreateResultHTTPPullSettings; export declare const PurgeStartResponseConsumersItemHTTPPullSettings: S.Schema; export type PurgeStartResponseConsumersItemHTTPPullType = "http_pull"; export declare const PurgeStartResponseConsumersItemHTTPPullType: any; export interface PurgeStartResponseConsumersItemHTTPPull { /** A Resource identifier. */ consumerId?: string | null; createdOn?: string | null; /** Name of the dead letter queue, or empty string if not configured */ deadLetterQueue?: string | null; queueName?: string | null; settings?: ConsumersCreateResultHTTPPullSettings | null; type?: PurgeStartResponseConsumersItemHTTPPullType | null; } export declare const PurgeStartResponseConsumersItemHTTPPull: S.Schema; export type PurgeStartResponseConsumersItem = PurgeStartResponseConsumersItemWorker | PurgeStartResponseConsumersItemHTTPPull; export declare const PurgeStartResponseConsumersItem: any; export type PurgeStartResponseConsumersList = Array; export declare const PurgeStartResponseConsumersList: S.Schema; export type PurgeStartResponseProducersItemMqWorkerProducerType = "worker"; export declare const PurgeStartResponseProducersItemMqWorkerProducerType: any; export interface PurgeStartResponseProducersItemMqWorkerProducer { type?: PurgeStartResponseProducersItemMqWorkerProducerType | null; scriptName?: string | null; } export declare const PurgeStartResponseProducersItemMqWorkerProducer: S.Schema; export type PurgeStartResponseProducersItemMqR2ProducerType = "r2_bucket"; export declare const PurgeStartResponseProducersItemMqR2ProducerType: any; export interface PurgeStartResponseProducersItemMqR2Producer { bucketName?: string | null; type?: PurgeStartResponseProducersItemMqR2ProducerType | null; } export declare const PurgeStartResponseProducersItemMqR2Producer: S.Schema; export type PurgeStartResponseProducersItem = PurgeStartResponseProducersItemMqWorkerProducer | PurgeStartResponseProducersItemMqR2Producer; export declare const PurgeStartResponseProducersItem: any; export type PurgeStartResponseProducersList = Array; export declare const PurgeStartResponseProducersList: S.Schema; export type PurgeStartResponseSettings = CreateResponseSettings; export declare const PurgeStartResponseSettings: S.Schema; /** Unwrapped `result` payload of the Cloudflare v4 response envelope. */ export interface StartPurgeResponse { consumers?: PurgeStartResponseConsumersList | null; consumersTotalCount?: number | null; createdOn?: string | null; modifiedOn?: string | null; producers?: PurgeStartResponseProducersList | null; producersTotalCount?: number | null; queueId?: string | null; queueName?: string | null; settings?: CreateResponseSettings | null; } export declare const StartPurgeResponse: S.Schema; export interface StatusPurgeRequest { /** A Resource identifier. */ accountId: string; /** A Resource identifier. */ queueId: string; } export declare const StatusPurgeRequest: S.Schema; /** Unwrapped `result` payload of the Cloudflare v4 response envelope. */ export interface StatusPurgeResponse { /** Indicates if the last purge operation completed successfully. */ completed?: string | null; /** Timestamp when the last purge operation started. */ startedAt?: string | null; } export declare const StatusPurgeResponse: S.Schema; export type ConsumersUpdateRequestType = "worker" | "http_pull"; export declare const ConsumersUpdateRequestType: any; export type ConsumersUpdateRequestSettingsWorker = ConsumersCreateRequestSettingsWorker; export declare const ConsumersUpdateRequestSettingsWorker: S.Schema; export type ConsumersUpdateRequestSettingsHTTPPull = ConsumersCreateRequestSettingsHTTPPull; export declare const ConsumersUpdateRequestSettingsHTTPPull: S.Schema; export type ConsumersUpdateRequestSettings = ConsumersCreateRequestSettingsWorker | ConsumersCreateRequestSettingsHTTPPull; export declare const ConsumersUpdateRequestSettings: any; export interface UpdateConsumerRequest { /** A Resource identifier. */ accountId: string; /** A Resource identifier. */ queueId: string; /** A Resource identifier. */ consumerId: string; /** Name of a Worker */ scriptName?: string; type: ConsumersUpdateRequestType | (string & {}); deadLetterQueue?: string; settings?: ConsumersUpdateRequestSettings; } export declare const UpdateConsumerRequest: S.Schema; export type ConsumersUpdateResultWorkerSettings = ConsumersCreateResultWorkerSettings; export declare const ConsumersUpdateResultWorkerSettings: S.Schema; export type ConsumersUpdateResultWorkerType = "worker"; export declare const ConsumersUpdateResultWorkerType: any; export interface ConsumersUpdateResultWorker { /** A Resource identifier. */ consumerId?: string | null; createdOn?: string | null; /** Name of the dead letter queue, or empty string if not configured */ deadLetterQueue?: string | null; queueName?: string | null; /** Name of a Worker */ scriptName?: string | null; settings?: ConsumersCreateResultWorkerSettings | null; type?: ConsumersUpdateResultWorkerType | null; } export declare const ConsumersUpdateResultWorker: S.Schema; export type ConsumersUpdateResultHTTPPullSettings = ConsumersCreateResultHTTPPullSettings; export declare const ConsumersUpdateResultHTTPPullSettings: S.Schema; export type ConsumersUpdateResultHTTPPullType = "http_pull"; export declare const ConsumersUpdateResultHTTPPullType: any; export interface ConsumersUpdateResultHTTPPull { /** A Resource identifier. */ consumerId?: string | null; createdOn?: string | null; /** Name of the dead letter queue, or empty string if not configured */ deadLetterQueue?: string | null; queueName?: string | null; settings?: ConsumersCreateResultHTTPPullSettings | null; type?: ConsumersUpdateResultHTTPPullType | null; } export declare const ConsumersUpdateResultHTTPPull: S.Schema; export type ConsumersUpdateResult = ConsumersUpdateResultWorker | ConsumersUpdateResultHTTPPull; export declare const ConsumersUpdateResult: any; export type UpdateConsumerResponse = ConsumersUpdateResult; export declare const UpdateConsumerResponse: S.Schema; export type UpdateRequestSettings = EditRequestSettings; export declare const UpdateRequestSettings: S.Schema; export interface UpdateQueueRequest { /** A Resource identifier. */ accountId: string; /** A Resource identifier. */ queueId: string; queueName?: string; settings?: EditRequestSettings; } export declare const UpdateQueueRequest: S.Schema; export type UpdateResponseConsumersItemWorkerSettings = ConsumersCreateResultWorkerSettings; export declare const UpdateResponseConsumersItemWorkerSettings: S.Schema; export type UpdateResponseConsumersItemWorkerType = "worker"; export declare const UpdateResponseConsumersItemWorkerType: any; export interface UpdateResponseConsumersItemWorker { /** A Resource identifier. */ consumerId?: string | null; createdOn?: string | null; /** Name of the dead letter queue, or empty string if not configured */ deadLetterQueue?: string | null; queueName?: string | null; /** Name of a Worker */ scriptName?: string | null; settings?: ConsumersCreateResultWorkerSettings | null; type?: UpdateResponseConsumersItemWorkerType | null; } export declare const UpdateResponseConsumersItemWorker: S.Schema; export type UpdateResponseConsumersItemHTTPPullSettings = ConsumersCreateResultHTTPPullSettings; export declare const UpdateResponseConsumersItemHTTPPullSettings: S.Schema; export type UpdateResponseConsumersItemHTTPPullType = "http_pull"; export declare const UpdateResponseConsumersItemHTTPPullType: any; export interface UpdateResponseConsumersItemHTTPPull { /** A Resource identifier. */ consumerId?: string | null; createdOn?: string | null; /** Name of the dead letter queue, or empty string if not configured */ deadLetterQueue?: string | null; queueName?: string | null; settings?: ConsumersCreateResultHTTPPullSettings | null; type?: UpdateResponseConsumersItemHTTPPullType | null; } export declare const UpdateResponseConsumersItemHTTPPull: S.Schema; export type UpdateResponseConsumersItem = UpdateResponseConsumersItemWorker | UpdateResponseConsumersItemHTTPPull; export declare const UpdateResponseConsumersItem: any; export type UpdateResponseConsumersList = Array; export declare const UpdateResponseConsumersList: S.Schema; export type UpdateResponseProducersItemMqWorkerProducerType = "worker"; export declare const UpdateResponseProducersItemMqWorkerProducerType: any; export interface UpdateResponseProducersItemMqWorkerProducer { type?: UpdateResponseProducersItemMqWorkerProducerType | null; scriptName?: string | null; } export declare const UpdateResponseProducersItemMqWorkerProducer: S.Schema; export type UpdateResponseProducersItemMqR2ProducerType = "r2_bucket"; export declare const UpdateResponseProducersItemMqR2ProducerType: any; export interface UpdateResponseProducersItemMqR2Producer { bucketName?: string | null; type?: UpdateResponseProducersItemMqR2ProducerType | null; } export declare const UpdateResponseProducersItemMqR2Producer: S.Schema; export type UpdateResponseProducersItem = UpdateResponseProducersItemMqWorkerProducer | UpdateResponseProducersItemMqR2Producer; export declare const UpdateResponseProducersItem: any; export type UpdateResponseProducersList = Array; export declare const UpdateResponseProducersList: S.Schema; export type UpdateResponseSettings = CreateResponseSettings; export declare const UpdateResponseSettings: S.Schema; /** Unwrapped `result` payload of the Cloudflare v4 response envelope. */ export interface UpdateQueueResponse { consumers?: UpdateResponseConsumersList | null; consumersTotalCount?: number | null; createdOn?: string | null; modifiedOn?: string | null; producers?: UpdateResponseProducersList | null; producersTotalCount?: number | null; queueId?: string | null; queueName?: string | null; settings?: CreateResponseSettings | null; } export declare const UpdateQueueResponse: S.Schema; export type AckMessageError = InvalidRequestBody | InvalidQueueId | QueueNotFound | InvalidRoute | CloudflareOpError; /** Acknowledge + Retry messages from a Queue */ export declare const ackMessage: API.OperationMethod; export type BulkPushMessagesError = InvalidMessageBody | InvalidQueueId | InvalidRoute | CloudflareOpError; /** Push a batch of message to a Queue */ export declare const bulkPushMessages: API.OperationMethod; export type CreateConsumerError = InvalidRequestBody | QueueNotFound | QueueHandlerMissing | ConsumerAlreadyExists | WorkerNotFound | InvalidRoute | CloudflareOpError; /** Creates a new consumer for a Queue */ export declare const createConsumer: API.OperationMethod; export type CreateQueueError = QueueAlreadyExists | InvalidQueueName | InvalidRoute | CloudflareOpError; /** Create a new queue */ export declare const createQueue: API.OperationMethod; export type CreateSubscriptionError = UnrecognizedEventType | SubscriptionAlreadyExists | QueueNotFound | CloudflareOpError; /** Create a new event subscription for a queue */ export declare const createSubscription: API.OperationMethod; export type DeleteConsumerError = InvalidRequestBody | QueueNotFound | ConsumerNotFound | InvalidRoute | CloudflareOpError; /** Deletes the consumer for a queue. */ export declare const deleteConsumer: API.OperationMethod; export type DeleteQueueError = QueueNotFound | QueueInUseByEventNotification | InvalidRoute | QueueInUseByWorkerBinding | CloudflareOpError; /** Deletes a queue */ export declare const deleteQueue: API.OperationMethod; export type DeleteSubscriptionError = UnrecognizedEventType | SubscriptionNotFound | CloudflareOpError; /** Delete an existing event subscription */ export declare const deleteSubscription: API.OperationMethod; export type GetConsumerError = InvalidRequestBody | QueueNotFound | ConsumerNotFound | InvalidRoute | CloudflareOpError; /** Fetches the consumer for a queue by consumer id */ export declare const getConsumer: API.OperationMethod; export type GetMetricsQueueError = CloudflareOpError; /** Return best-effort metrics for a queue. Values may be approximate due to the distributed nature of queues. */ export declare const getMetricsQueue: API.OperationMethod; export type GetQueueError = QueueNotFound | InvalidRoute | CloudflareOpError; /** Get details about a specific queue. */ export declare const getQueue: API.OperationMethod; export type GetSubscriptionError = UnrecognizedEventType | SubscriptionNotFound | Forbidden | CloudflareOpError; /** Get details about an existing event subscription */ export declare const getSubscription: API.OperationMethod; export type ListConsumersError = InvalidRequestBody | QueueNotFound | InvalidRoute | CloudflareOpError; /** Returns the consumers for a Queue */ export declare const listConsumers: API.PaginatedOperationMethod; export type ListQueuesError = InvalidRoute | CloudflareOpError; /** Returns the queues owned by an account. */ export declare const listQueues: API.PaginatedOperationMethod; export type ListSubscriptionsError = Forbidden | CloudflareOpError; /** Get a paginated list of event subscriptions with optional sorting and filtering */ export declare const listSubscriptions: API.PaginatedOperationMethod; export type PatchQueueError = QueueNotFound | InvalidRoute | CloudflareOpError; /** Updates a Queue. */ export declare const patchQueue: API.OperationMethod; export type PatchSubscriptionError = UnrecognizedEventType | SubscriptionNotFound | QueueNotFound | CloudflareOpError; /** Update an existing event subscription */ export declare const patchSubscription: API.OperationMethod; export type PullMessageError = InvalidRequestBody | InvalidQueueId | QueueNotFound | InvalidRoute | CloudflareOpError; /** Pull a batch of messages from a Queue */ export declare const pullMessage: API.OperationMethod; export type PushMessageError = InvalidMessageBody | InvalidQueueId | InvalidRoute | CloudflareOpError; /** Push a message to a Queue */ export declare const pushMessage: API.OperationMethod; export type StartPurgeError = InvalidQueueId | InvalidRoute | CloudflareOpError; /** Deletes all messages from the Queue. */ export declare const startPurge: API.OperationMethod; export type StatusPurgeError = InvalidQueueId | InvalidRoute | CloudflareOpError; /** Get details about a Queue's purge status. */ export declare const statusPurge: API.OperationMethod; export type UpdateConsumerError = InvalidRequestBody | QueueNotFound | QueueHandlerMissing | ConsumerNotFound | WorkerNotFound | InvalidRoute | CloudflareOpError; /** Updates the consumer for a queue, or creates one if it does not exist. */ export declare const updateConsumer: API.OperationMethod; export type UpdateQueueError = InvalidQueueName | QueueNotFound | InvalidRoute | CloudflareOpError; /** Updates a Queue. Note that this endpoint does not support partial updates. If successful, the Queue's configuration is overwritten with the supplied configuration. */ export declare const updateQueue: API.OperationMethod; //# sourceMappingURL=queues.d.ts.map