Cloudflare/pipelines
@swamp/cloudflare/pipelinesv2026.05.29.1
01README
Cloudflare pipelines infrastructure models
02Release Notes
- Updated: pipelines_v2
- Updated: pipelines
- Updated: sinks
- Updated: streams
03Models
@swamp/cloudflare/pipelines/pipelinesv2026.05.29.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. |
| apiToken? | string | Cloudflare API token; overrides the CLOUDFLARE_API_TOKEN environment variable. Wire with a vault.get(...) expression to source it from a vault. |
| apiKey? | string | Cloudflare API key for the legacy key+email auth path; overrides the CLOUDFLARE_API_KEY environment variable. Wire with a vault.get(...) expression. Requires email. |
| email? | string | Cloudflare account email for the legacy key+email auth path; overrides the CLOUDFLARE_EMAIL environment variable. Requires apiKey. |
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.29.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 | |
| apiToken? | string | Cloudflare API token; overrides the CLOUDFLARE_API_TOKEN environment variable. Wire with a vault.get(...) expression to source it from a vault. |
| apiKey? | string | Cloudflare API key for the legacy key+email auth path; overrides the CLOUDFLARE_API_KEY environment variable. Wire with a vault.get(...) expression. Requires email. |
| email? | string | Cloudflare account email for the legacy key+email auth path; overrides the CLOUDFLARE_EMAIL environment variable. Requires apiKey. |
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.29.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. |
| apiToken? | string | Cloudflare API token; overrides the CLOUDFLARE_API_TOKEN environment variable. Wire with a vault.get(...) expression to source it from a vault. |
| apiKey? | string | Cloudflare API key for the legacy key+email auth path; overrides the CLOUDFLARE_API_KEY environment variable. Wire with a vault.get(...) expression. Requires email. |
| email? | string | Cloudflare account email for the legacy key+email auth path; overrides the CLOUDFLARE_EMAIL environment variable. Requires apiKey. |
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.29.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 | |
| apiToken? | string | Cloudflare API token; overrides the CLOUDFLARE_API_TOKEN environment variable. Wire with a vault.get(...) expression to source it from a vault. |
| apiKey? | string | Cloudflare API key for the legacy key+email auth path; overrides the CLOUDFLARE_API_KEY environment variable. Wire with a vault.get(...) expression. Requires email. |
| email? | string | Cloudflare account email for the legacy key+email auth path; overrides the CLOUDFLARE_EMAIL environment variable. Requires apiKey. |
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
04Previous Versions
2026.05.22.1May 22, 2026
- Added: pipelines_v2
- Added: pipelines
- Added: sinks
- Added: streams
05Stats
A
100 / 100
Downloads
0
Archive size
15.2 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
06Platforms
07Labels