Cloudflare/pipelines
@swamp/cloudflare/pipelinesv2026.05.22.1
01README
Cloudflare pipelines infrastructure models
02Release Notes
- Added: pipelines_v2
- Added: pipelines
- Added: sinks
- Added: streams
03Models
@swamp/cloudflare/pipelines/pipelinesv2026.05.22.1pipelines.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| account_id | string | Cloudflare account ID |
| name | string | Specifies the name of the Pipeline. |
| sql | string | Specifies SQL for the Pipeline processing flow. |
fn create()
Create a Pipelines
fn get(id: string)
Get a Pipelines
| Argument | Type | Description |
|---|---|---|
| id | string | The ID of the Pipelines |
fn delete(id: string)
Delete the Pipelines
| Argument | Type | Description |
|---|---|---|
| id | string | The ID of the Pipelines |
fn sync()
Sync Pipelines state from Cloudflare
Resources
state(infinite)— Pipelines resource state
@swamp/cloudflare/pipelines/pipelines-v2v2026.05.22.1pipelines_v2.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| account_id | string | Cloudflare account ID |
| destination | object | |
| name | string | Defines the name of the pipeline. |
| source | array |
fn create()
Create a Pipelines
fn get(id: string)
Get a Pipelines
| Argument | Type | Description |
|---|---|---|
| id | string | The ID of the Pipelines |
fn update()
Update Pipelines attributes
fn delete(id: string)
Delete the Pipelines
| Argument | Type | Description |
|---|---|---|
| id | string | The ID of the Pipelines |
fn sync()
Sync Pipelines state from Cloudflare
Resources
state(infinite)— Pipelines resource state
@swamp/cloudflare/pipelines/sinksv2026.05.22.1sinks.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| account_id | string | Cloudflare account ID |
| config? | object | |
| format? | object | |
| name | string | Defines the name of the Sink. |
| schema? | object | |
| type | enum | Specifies the type of sink. |
fn create()
Create a Sinks
fn get(id: string)
Get a Sinks
| Argument | Type | Description |
|---|---|---|
| id | string | The ID of the Sinks |
fn delete(id: string)
Delete the Sinks
| Argument | Type | Description |
|---|---|---|
| id | string | The ID of the Sinks |
fn sync()
Sync Sinks state from Cloudflare
Resources
state(infinite)— Sinks resource state
@swamp/cloudflare/pipelines/streamsv2026.05.22.1streams.ts
Global Arguments
| Argument | Type | Description |
|---|---|---|
| account_id | string | Cloudflare account ID |
| http? | object | |
| worker_binding? | object | |
| format? | object | |
| name | string | Specifies the name of the Stream. |
| schema? | object |
fn create()
Create a Streams
fn get(id: string)
Get a Streams
| Argument | Type | Description |
|---|---|---|
| id | string | The ID of the Streams |
fn update()
Update Streams attributes
fn delete(id: string)
Delete the Streams
| Argument | Type | Description |
|---|---|---|
| id | string | The ID of the Streams |
fn sync()
Sync Streams state from Cloudflare
Resources
state(infinite)— Streams resource state
04Stats
A
100 / 100
Downloads
0
Archive size
13.1 KB
Verified by Swamp
- Has README or module doc2/2earned
- README has a code example1/1earned
- README is substantive1/1earned
- Most symbols documented1/1earned
- No slow types1/1earned
- Dependencies pass trust audit2/2earned
- Has description1/1earned
- Platform support declared (or universal)2/2earned
- License declared1/1earned
- Verified public repository2/2earned
05Platforms
06Labels