Cloudflare/pipelines

@swamp/cloudflare/pipelinesv2026.07.21.1· 5d agoMODELS

01README

Cloudflare pipelines infrastructure models

02Release Notes

Updated: pipelines_v2
Updated: pipelines
Updated: sinks
Updated: streams

03Models4

@swamp/cloudflare/pipelines/pipelinesv2026.07.21.1pipelines.ts

Global Arguments

Argument	Type	Required	Description
account_id	string	yes	Cloudflare account ID
name	string	yes	Specifies the name of the Pipeline.
sql	string	yes	Specifies SQL for the Pipeline processing flow.
apiToken?	string	no	Cloudflare API token; overrides the CLOUDFLARE_API_TOKEN environment variable. Wire with a vault.get(...) expression to source it from a vault.
apiKey?	string	no	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	no	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	Required	Description
id	string	yes	The ID of the Pipelines

fn lookup()

Look up an existing Pipelines by matching global argument values and import it into state

fn adopt(id: string)

Import an existing Pipelines by ID into state for management

Argument	Type	Required	Description
id	string	yes	The ID of the Pipelines to import

fn delete(id: string)

Delete the Pipelines

Argument	Type	Required	Description
id	string	yes	The ID of the Pipelines

fn sync(identifier?: string)

Sync Pipelines state from Cloudflare

Argument	Type	Required	Description
identifier?	string	no	Target a specific Pipelines by id (e.g. one discovered by list)

Resources

state(infinite)— Pipelines resource state

@swamp/cloudflare/pipelines/pipelines-v2v2026.07.21.1pipelines_v2.ts

Global Arguments

Argument	Type	Required	Description
account_id	string	yes	Cloudflare account ID
destination	object	yes
name	string	yes	Defines the name of the pipeline.
source	array	yes
apiToken?	string	no	Cloudflare API token; overrides the CLOUDFLARE_API_TOKEN environment variable. Wire with a vault.get(...) expression to source it from a vault.
apiKey?	string	no	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	no	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	Required	Description
id	string	yes	The ID of the Pipelines

fn lookup()

Look up an existing Pipelines by matching global argument values and import it into state

fn adopt(id: string)

Import an existing Pipelines by ID into state for management

Argument	Type	Required	Description
id	string	yes	The ID of the Pipelines to import

fn update(identifier?: string)

Update Pipelines attributes

Argument	Type	Required	Description
identifier?	string	no	Target a specific Pipelines by id (e.g. one discovered by list)

fn delete(id: string)

Delete the Pipelines

Argument	Type	Required	Description
id	string	yes	The ID of the Pipelines

fn sync(identifier?: string)

Sync Pipelines state from Cloudflare

Argument	Type	Required	Description
identifier?	string	no	Target a specific Pipelines by id (e.g. one discovered by list)

Resources

state(infinite)— Pipelines resource state

@swamp/cloudflare/pipelines/sinksv2026.07.21.1sinks.ts

Global Arguments

Argument	Type	Required	Description
account_id	string	yes	Cloudflare account ID
config?	object	no
format?	object	no
name	string	yes	Defines the name of the Sink.
schema?	object	no
type	enum	yes	Specifies the type of sink.
apiToken?	string	no	Cloudflare API token; overrides the CLOUDFLARE_API_TOKEN environment variable. Wire with a vault.get(...) expression to source it from a vault.
apiKey?	string	no	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	no	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	Required	Description
id	string	yes	The ID of the Sinks

fn lookup()

Look up an existing Sinks by matching global argument values and import it into state

fn adopt(id: string)

Import an existing Sinks by ID into state for management

Argument	Type	Required	Description
id	string	yes	The ID of the Sinks to import

fn delete(id: string)

Delete the Sinks

Argument	Type	Required	Description
id	string	yes	The ID of the Sinks

fn sync(identifier?: string)

Sync Sinks state from Cloudflare

Argument	Type	Required	Description
identifier?	string	no	Target a specific Sinks by id (e.g. one discovered by list)

Resources

state(infinite)— Sinks resource state

@swamp/cloudflare/pipelines/streamsv2026.07.21.1streams.ts

Global Arguments

Argument	Type	Required	Description
account_id	string	yes	Cloudflare account ID
http?	object	no
worker_binding?	object	no
format?	object	no
name	string	yes	Specifies the name of the Stream.
schema?	object	no
apiToken?	string	no	Cloudflare API token; overrides the CLOUDFLARE_API_TOKEN environment variable. Wire with a vault.get(...) expression to source it from a vault.
apiKey?	string	no	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	no	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	Required	Description
id	string	yes	The ID of the Streams

fn lookup()

Look up an existing Streams by matching global argument values and import it into state

fn adopt(id: string)

Import an existing Streams by ID into state for management

Argument	Type	Required	Description
id	string	yes	The ID of the Streams to import

fn update(identifier?: string)

Update Streams attributes

Argument	Type	Required	Description
identifier?	string	no	Target a specific Streams by id (e.g. one discovered by list)

fn delete(id: string)

Delete the Streams

Argument	Type	Required	Description
id	string	yes	The ID of the Streams

fn sync(identifier?: string)

Sync Streams state from Cloudflare

Argument	Type	Required	Description
identifier?	string	no	Target a specific Streams by id (e.g. one discovered by list)

Resources

state(infinite)— Streams resource state

04Previous Versions4

2026.07.18.2Jul 18, 2026

Added 4, removed 1 models

2026.06.08.2Jun 8, 2026

Updated: pipelines_v2
Updated: pipelines
Updated: sinks
Updated: streams

2026.05.29.1May 29, 2026

Updated: pipelines_v2
Updated: pipelines
Updated: sinks
Updated: streams

2026.05.22.1May 22, 2026

Added: pipelines_v2
Added: pipelines
Added: sinks
Added: streams

05Stats

100 / 100

Downloads

Archive size

21.3 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 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/swamp-club/swamp-extensions

06Platforms

linux · x86_64 linux · aarch64 macOS · x86_64 macOS · aarch64

07Labels

#cloudflare #pipelines #cloud #infrastructure