--- title: Queues --- [Skip to content](#_top) [API Reference](https://developers.cloudflare.com/api/go) Copy Markdown Open in **Claude**Open in **ChatGPT**Open in **Cursor** --- **Copy Markdown****View as Markdown** # Queues ##### [List Queues](https://developers.cloudflare.com/api/go/resources/queues/methods/list) client.Queues.List(ctx, query) (\*SinglePage\[[Queue]()], error) GET/accounts/{account\_id}/queues ##### [Get Queue](https://developers.cloudflare.com/api/go/resources/queues/methods/get) client.Queues.Get(ctx, queueID, query) (\*[Queue](), error) GET/accounts/{account\_id}/queues/{queue\_id} ##### [Get Queue Metrics](https://developers.cloudflare.com/api/go/resources/queues/methods/get_metrics) client.Queues.GetMetrics(ctx, queueID, query) (\*[QueueGetMetricsResponse](), error) GET/accounts/{account\_id}/queues/{queue\_id}/metrics ##### [Create Queue](https://developers.cloudflare.com/api/go/resources/queues/methods/create) client.Queues.New(ctx, params) (\*[Queue](), error) POST/accounts/{account\_id}/queues ##### [Update Queue](https://developers.cloudflare.com/api/go/resources/queues/methods/update) client.Queues.Update(ctx, queueID, params) (\*[Queue](), error) PUT/accounts/{account\_id}/queues/{queue\_id} ##### [Update Queue](https://developers.cloudflare.com/api/go/resources/queues/methods/edit) client.Queues.Edit(ctx, queueID, params) (\*[Queue](), error) PATCH/accounts/{account\_id}/queues/{queue\_id} ##### [Delete Queue](https://developers.cloudflare.com/api/go/resources/queues/methods/delete) client.Queues.Delete(ctx, queueID, body) (\*[QueueDeleteResponse](), error) DELETE/accounts/{account\_id}/queues/{queue\_id} ##### ModelsExpand Collapse
type Queue struct{…}
Consumers \[]ConsumerOptional One of the following:
type ConsumerMqWorkerConsumerResponse struct{…} ConsumerID stringOptional A Resource identifier. maxLength32 Link to this property CreatedOn TimeOptional formatdate-time Link to this property DeadLetterQueue stringOptional Name of the dead letter queue, or empty string if not configured Link to this property QueueName stringOptional Link to this property ScriptName stringOptional Name of a Worker Link to this property
Settings ConsumerMqWorkerConsumerResponseSettingsOptional BatchSize float64Optional The maximum number of messages to include in a batch. Link to this property MaxConcurrency float64Optional Maximum number of concurrent consumers that may consume from this Queue. Set to null to automatically opt in to the platform’s maximum (recommended). Link to this property MaxRetries float64Optional The maximum number of retries Link to this property MaxWaitTimeMs float64Optional The number of milliseconds to wait for a batch to fill up before attempting to deliver it Link to this property RetryDelay float64Optional The number of seconds to delay before making the message available for another attempt. Link to this property
Link to this property Type ConsumerMqWorkerConsumerResponseTypeOptional Link to this property
Link to this property
type ConsumerMqHTTPConsumerResponse struct{…} ConsumerID stringOptional A Resource identifier. maxLength32 Link to this property CreatedOn TimeOptional formatdate-time Link to this property DeadLetterQueue stringOptional Name of the dead letter queue, or empty string if not configured Link to this property QueueName stringOptional Link to this property
Settings ConsumerMqHTTPConsumerResponseSettingsOptional BatchSize float64Optional The maximum number of messages to include in a batch. Link to this property MaxRetries float64Optional The maximum number of retries Link to this property RetryDelay float64Optional The number of seconds to delay before making the message available for another attempt. Link to this property VisibilityTimeoutMs float64Optional The number of milliseconds that a message is exclusively leased. After the timeout, the message becomes available for another attempt. Link to this property
Link to this property Type ConsumerMqHTTPConsumerResponseTypeOptional Link to this property
Link to this property
Link to this property ConsumersTotalCount float64Optional Link to this property CreatedOn stringOptional Link to this property
Jurisdiction QueueJurisdictionOptional One of the following: const QueueJurisdictionEu QueueJurisdiction = "eu" Link to this property const QueueJurisdictionUs QueueJurisdiction = "us" Link to this property const QueueJurisdictionFedramp QueueJurisdiction = "fedramp" Link to this property
Link to this property ModifiedOn stringOptional Link to this property
Producers \[]QueueProducerOptional One of the following:
type QueueProducersMqWorkerProducer struct{…} Script stringOptional Link to this property Type QueueProducersMqWorkerProducerTypeOptional Link to this property
Link to this property
type QueueProducersMqR2Producer struct{…} BucketName stringOptional Link to this property Type QueueProducersMqR2ProducerTypeOptional Link to this property
Link to this property
Link to this property ProducersTotalCount float64Optional Link to this property QueueID stringOptional Link to this property QueueName stringOptional Link to this property
Settings QueueSettingsOptional DeliveryDelay float64Optional Number of seconds to delay delivery of all messages to consumers. Link to this property DeliveryPaused boolOptional Indicates if message delivery to consumers is currently paused. Link to this property MessageRetentionPeriod float64Optional Number of seconds after which an unconsumed message will be delayed. Link to this property
Link to this property
[Link to this property](<#(resource)%20queues%20%3E%20(model)%20queue%20%3E%20(schema)>) #### QueuesMessages ##### [Push Message](https://developers.cloudflare.com/api/go/resources/queues/subresources/messages/methods/push) client.Queues.Messages.Push(ctx, queueID, params) (\*[MessagePushResponse](), error) POST/accounts/{account\_id}/queues/{queue\_id}/messages ##### [Acknowledge + Retry Queue Messages](https://developers.cloudflare.com/api/go/resources/queues/subresources/messages/methods/ack) client.Queues.Messages.Ack(ctx, queueID, params) (\*[MessageAckResponse](), error) POST/accounts/{account\_id}/queues/{queue\_id}/messages/ack ##### [Pull Queue Messages](https://developers.cloudflare.com/api/go/resources/queues/subresources/messages/methods/pull) client.Queues.Messages.Pull(ctx, queueID, params) (\*[MessagePullResponse](), error) POST/accounts/{account\_id}/queues/{queue\_id}/messages/pull ##### [Push Message Batch](https://developers.cloudflare.com/api/go/resources/queues/subresources/messages/methods/bulk_push) client.Queues.Messages.BulkPush(ctx, queueID, params) (\*[MessageBulkPushResponse](), error) POST/accounts/{account\_id}/queues/{queue\_id}/messages/batch ##### [Peek Queue Messages](https://developers.cloudflare.com/api/go/resources/queues/subresources/messages/methods/peek) client.Queues.Messages.Peek(ctx, queueID, params) (\*[MessagePeekResponse](), error) POST/accounts/{account\_id}/queues/{queue\_id}/messages/peek ##### [Purge Peeked Queue Messages](https://developers.cloudflare.com/api/go/resources/queues/subresources/messages/methods/purge) client.Queues.Messages.Purge(ctx, queueID, params) (\*[MessagePurgeResponse](), error) POST/accounts/{account\_id}/queues/{queue\_id}/messages/purge #### QueuesPurge ##### [Get Queue Purge Status](https://developers.cloudflare.com/api/go/resources/queues/subresources/purge/methods/status) client.Queues.Purge.Status(ctx, queueID, query) (\*[PurgeStatusResponse](), error) GET/accounts/{account\_id}/queues/{queue\_id}/purge ##### [Purge Queue](https://developers.cloudflare.com/api/go/resources/queues/subresources/purge/methods/start) client.Queues.Purge.Start(ctx, queueID, params) (\*[Queue](), error) POST/accounts/{account\_id}/queues/{queue\_id}/purge #### QueuesConsumers ##### [List Queue Consumers](https://developers.cloudflare.com/api/go/resources/queues/subresources/consumers/methods/list) client.Queues.Consumers.List(ctx, queueID, query) (\*SinglePage\[[Consumer]()], error) GET/accounts/{account\_id}/queues/{queue\_id}/consumers ##### [Get Queue Consumer](https://developers.cloudflare.com/api/go/resources/queues/subresources/consumers/methods/get) client.Queues.Consumers.Get(ctx, queueID, consumerID, query) (\*[Consumer](), error) GET/accounts/{account\_id}/queues/{queue\_id}/consumers/{consumer\_id} ##### [Create a Queue Consumer](https://developers.cloudflare.com/api/go/resources/queues/subresources/consumers/methods/create) client.Queues.Consumers.New(ctx, queueID, params) (\*[Consumer](), error) POST/accounts/{account\_id}/queues/{queue\_id}/consumers ##### [Update Queue Consumer](https://developers.cloudflare.com/api/go/resources/queues/subresources/consumers/methods/update) client.Queues.Consumers.Update(ctx, queueID, consumerID, params) (\*[Consumer](), error) PUT/accounts/{account\_id}/queues/{queue\_id}/consumers/{consumer\_id} ##### [Delete Queue Consumer](https://developers.cloudflare.com/api/go/resources/queues/subresources/consumers/methods/delete) client.Queues.Consumers.Delete(ctx, queueID, consumerID, body) (\*[ConsumerDeleteResponse](), error) DELETE/accounts/{account\_id}/queues/{queue\_id}/consumers/{consumer\_id} ##### ModelsExpand Collapse
type Consumer interface{…} Response body representing a consumer One of the following:
type ConsumerMqWorkerConsumerResponse struct{…} ConsumerID stringOptional A Resource identifier. maxLength32 Link to this property CreatedOn TimeOptional formatdate-time Link to this property DeadLetterQueue stringOptional Name of the dead letter queue, or empty string if not configured Link to this property QueueName stringOptional Link to this property ScriptName stringOptional Name of a Worker Link to this property
Settings ConsumerMqWorkerConsumerResponseSettingsOptional BatchSize float64Optional The maximum number of messages to include in a batch. Link to this property MaxConcurrency float64Optional Maximum number of concurrent consumers that may consume from this Queue. Set to null to automatically opt in to the platform’s maximum (recommended). Link to this property MaxRetries float64Optional The maximum number of retries Link to this property MaxWaitTimeMs float64Optional The number of milliseconds to wait for a batch to fill up before attempting to deliver it Link to this property RetryDelay float64Optional The number of seconds to delay before making the message available for another attempt. Link to this property
Link to this property Type ConsumerMqWorkerConsumerResponseTypeOptional Link to this property
Link to this property
type ConsumerMqHTTPConsumerResponse struct{…} ConsumerID stringOptional A Resource identifier. maxLength32 Link to this property CreatedOn TimeOptional formatdate-time Link to this property DeadLetterQueue stringOptional Name of the dead letter queue, or empty string if not configured Link to this property QueueName stringOptional Link to this property
Settings ConsumerMqHTTPConsumerResponseSettingsOptional BatchSize float64Optional The maximum number of messages to include in a batch. Link to this property MaxRetries float64Optional The maximum number of retries Link to this property RetryDelay float64Optional The number of seconds to delay before making the message available for another attempt. Link to this property VisibilityTimeoutMs float64Optional The number of milliseconds that a message is exclusively leased. After the timeout, the message becomes available for another attempt. Link to this property
Link to this property Type ConsumerMqHTTPConsumerResponseTypeOptional Link to this property
Link to this property
[Link to this property](<#(resource)%20queues.consumers%20%3E%20(model)%20consumer%20%3E%20(schema)>) #### QueuesSubscriptions ##### [List Event Subscriptions](https://developers.cloudflare.com/api/go/resources/queues/subresources/subscriptions/methods/list) client.Queues.Subscriptions.List(ctx, params) (\*V4PagePaginationArray\[[SubscriptionListResponse]()], error) GET/accounts/{account\_id}/event\_subscriptions/subscriptions ##### [Get Event Subscription](https://developers.cloudflare.com/api/go/resources/queues/subresources/subscriptions/methods/get) client.Queues.Subscriptions.Get(ctx, subscriptionID, query) (\*[SubscriptionGetResponse](), error) GET/accounts/{account\_id}/event\_subscriptions/subscriptions/{subscription\_id} ##### [Create Event Subscription](https://developers.cloudflare.com/api/go/resources/queues/subresources/subscriptions/methods/create) client.Queues.Subscriptions.New(ctx, params) (\*[SubscriptionNewResponse](), error) POST/accounts/{account\_id}/event\_subscriptions/subscriptions ##### [Update Event Subscription](https://developers.cloudflare.com/api/go/resources/queues/subresources/subscriptions/methods/update) client.Queues.Subscriptions.Update(ctx, subscriptionID, params) (\*[SubscriptionUpdateResponse](), error) PATCH/accounts/{account\_id}/event\_subscriptions/subscriptions/{subscription\_id} ##### [Delete Event Subscription](https://developers.cloudflare.com/api/go/resources/queues/subresources/subscriptions/methods/delete) client.Queues.Subscriptions.Delete(ctx, subscriptionID, body) (\*[SubscriptionDeleteResponse](), error) DELETE/accounts/{account\_id}/event\_subscriptions/subscriptions/{subscription\_id}