Skip to main content
← back to extensions

Cloudflare/queues

@webframp/cloudflare/queuesv2026.07.27.1· 1d agoMODELS
01README

Cloudflare Queues — queue management, consumers, message operations

02Release Notes

2026.07.27.1

Fixed: Regenerated from scripts/cloudflare-codegen after two generator bugs were repaired (webframp/swamp-extensions#284).

  1. Methods referencing an undeclared path parameter did not compile. The generator derived a method's arguments schema and execute signature from the OpenAPI parameters list, but built the request URL from the path template. Where the Cloudflare spec omits a declaration for a {placeholder} — which it does in several places — the result was a method with arguments: z.object({}) and an unused _args parameter whose body still interpolated args.<name>. Those methods failed type checking and were uncallable even if they had compiled, because the argument was never declared. Path-template placeholders are now unioned into the declared parameters, so the schema, the signature, and the body agree.

  2. Generated tests could request a URL the mock server did not serve. Test arguments merged the request-body fixture over the path-parameter values, so a body property sharing a name with a path parameter (commonly id) substituted its own example value into the URL. The request then missed the mock and failed with Cloudflare API error: Not found. Path parameters now take precedence, matching what the generated model already does by excluding path-parameter names from the request body.

Upgrade note: No API surface change and no method was added or removed. If this extension type-checked and tested cleanly before, its behavior is unchanged and only the version moved. Extensions that previously failed deno check or deno task test now pass.

03Models1
@webframp/cloudflare/queuesv2026.07.27.1cloudflare/queues.ts

Global Arguments

ArgumentTypeDescription
apiTokenstringCloudflare API token
accountIdstringCloudflare account ID
fn list()
List Queues
fn create(queue_name: unknown)
Create Queue
ArgumentTypeDescription
queue_nameunknown
fn get(queue_id: string)
Get Queue
ArgumentTypeDescription
queue_idstring
fn update(queue_id: string, consumers?: array, consumers_total_count?: number, created_on?: string, modified_on?: string, producers?: array, producers_total_count?: number, queue_name?: unknown, settings?: unknown)
Update Queue
ArgumentTypeDescription
queue_idstring
consumers?array
consumers_total_count?number
created_on?string
modified_on?string
producers?array
producers_total_count?number
queue_name?unknown
settings?unknown
fn update_partial(queue_id: string, consumers?: array, consumers_total_count?: number, created_on?: string, modified_on?: string, producers?: array, producers_total_count?: number, queue_name?: unknown, settings?: unknown)
Update Queue
ArgumentTypeDescription
queue_idstring
consumers?array
consumers_total_count?number
created_on?string
modified_on?string
producers?array
producers_total_count?number
queue_name?unknown
settings?unknown
fn delete(queue_id: string)
Delete Queue
ArgumentTypeDescription
queue_idstring
fn list_consumers(queue_id: string)
List Queue Consumers
ArgumentTypeDescription
queue_idstring
fn create_consumer(queue_id: string)
Create a Queue Consumer
ArgumentTypeDescription
queue_idstring
fn get_consumer(consumer_id: string, queue_id: string)
Get Queue Consumer
ArgumentTypeDescription
consumer_idstring
queue_idstring
fn update_consumer(consumer_id: string, queue_id: string)
Update Queue Consumer
ArgumentTypeDescription
consumer_idstring
queue_idstring
fn delete_consumer(consumer_id: string, queue_id: string)
Delete Queue Consumer
ArgumentTypeDescription
consumer_idstring
queue_idstring
fn create_queues_push_message(queue_id: string, delay_seconds?: number)
Push Message
ArgumentTypeDescription
queue_idstring
delay_seconds?numberThe number of seconds to wait for attempting to deliver this message to consu...
fn create_queues_ack_messages(queue_id: string, acks?: array, retries?: array)
Acknowledge + Retry Queue Messages
ArgumentTypeDescription
queue_idstring
acks?array
retries?array
fn create_queues_push_messages(queue_id: string, delay_seconds?: number, messages?: array)
Push Message Batch
ArgumentTypeDescription
queue_idstring
delay_seconds?numberThe number of seconds to wait for attempting to deliver this batch to consumers
messages?array
fn create_queues_preview_messages(queue_id: string, batch_size?: unknown)
Preview Queue Messages
ArgumentTypeDescription
queue_idstring
batch_size?unknown
fn create_queues_ack_preview_messages(queue_id: string, acks?: array, retries?: array)
Delete Previewed Queue Messages
ArgumentTypeDescription
queue_idstring
acks?array
retries?array
fn create_queues_pull_messages(queue_id: string, batch_size?: unknown, visibility_timeout_ms?: unknown)
Pull Queue Messages
ArgumentTypeDescription
queue_idstring
batch_size?unknown
visibility_timeout_ms?unknown
fn get_metrics(queue_id: string)
Get Queue Metrics
ArgumentTypeDescription
queue_idstring
fn create_queues_purge(queue_id: string, delete_messages_permanently?: boolean)
Purge Queue
ArgumentTypeDescription
queue_idstring
delete_messages_permanently?booleanConfimation that all messages will be deleted permanently.

Resources

list(infinite)— List Queues
create(infinite)— Create Queue
get(infinite)— Get Queue
update(infinite)— Update Queue
partial(infinite)— Update Queue
consumers(infinite)— List Queue Consumers
consumer(infinite)— Create a Queue Consumer
queues_push_message(infinite)— Push Message
queues_ack_messages(infinite)— Acknowledge + Retry Queue Messages
queues_push_messages(infinite)— Push Message Batch
queues_preview_messages(infinite)— Preview Queue Messages
queues_ack_preview_messages(infinite)— Delete Previewed Queue Messages
queues_pull_messages(infinite)— Pull Queue Messages
metrics(infinite)— Get Queue Metrics
queues_purge(infinite)— Purge Queue
04Previous Versions1
2026.07.19.1

2026.07.19.1

Added: Initial code-generated release of @webframp/cloudflare/queues with 19 methods covering the Cloudflare queues API surface.

05Stats
A
100 / 100
Downloads
0
Archive size
10.2 KB
  • Has README or module doc2/2earned
  • README has a code example1/1earned
  • README is substantive1/1earned
  • Most symbols documented1/1earned
  • No slow types (deprecated)1/1earned
  • Dependencies pass trust audit2/2earned
  • Has description1/1earned
  • Platform support declared (or universal)2/2earned
  • License declared1/1earned
  • Verified public repository2/2earned
Repository
https://github.com/webframp/swamp-extensions
06Platforms
07Labels
#cloudflare#queues#messaging