API Reference

Copy Markdown

Open in Claude

Open in ChatGPT

Open in Cursor

---

Copy Markdown

View as Markdown

Pipelines

[DEPRECATED] List Pipelines

Deprecated

client.Pipelines.List(ctx, params) (*PipelineListResponse, error)

GET/accounts/{account_id}/pipelines

[DEPRECATED] Get Pipeline

Deprecated

client.Pipelines.Get(ctx, pipelineName, query) (*PipelineGetResponse, error)

GET/accounts/{account_id}/pipelines/{pipeline_name}

[DEPRECATED] Create Pipeline

Deprecated

client.Pipelines.New(ctx, params) (*PipelineNewResponse, error)

POST/accounts/{account_id}/pipelines

[DEPRECATED] Update Pipeline

Deprecated

client.Pipelines.Update(ctx, pipelineName, params) (*PipelineUpdateResponse, error)

PUT/accounts/{account_id}/pipelines/{pipeline_name}

[DEPRECATED] Delete Pipeline

Deprecated

client.Pipelines.Delete(ctx, pipelineName, body) error

DELETE/accounts/{account_id}/pipelines/{pipeline_name}

List Pipelines

client.Pipelines.ListV1(ctx, params) (*V4PagePaginationArray[PipelineListV1Response], error)

GET/accounts/{account_id}/pipelines/v1/pipelines

Get Pipeline Details

client.Pipelines.GetV1(ctx, pipelineID, query) (*PipelineGetV1Response, error)

GET/accounts/{account_id}/pipelines/v1/pipelines/{pipeline_id}

Create Pipeline

client.Pipelines.NewV1(ctx, params) (*PipelineNewV1Response, error)

POST/accounts/{account_id}/pipelines/v1/pipelines

Delete Pipelines

client.Pipelines.DeleteV1(ctx, pipelineID, body) error

DELETE/accounts/{account_id}/pipelines/v1/pipelines/{pipeline_id}

Validate SQL

client.Pipelines.ValidateSql(ctx, params) (*PipelineValidateSqlResponse, error)

POST/accounts/{account_id}/pipelines/v1/validate_sql

PipelinesSinks

List Sinks

client.Pipelines.Sinks.List(ctx, params) (*V4PagePaginationArray[SinkListResponse], error)

GET/accounts/{account_id}/pipelines/v1/sinks

Get Sink Details

client.Pipelines.Sinks.Get(ctx, sinkID, query) (*SinkGetResponse, error)

GET/accounts/{account_id}/pipelines/v1/sinks/{sink_id}

Create Sink

client.Pipelines.Sinks.New(ctx, params) (*SinkNewResponse, error)

POST/accounts/{account_id}/pipelines/v1/sinks

Delete Sink

client.Pipelines.Sinks.Delete(ctx, sinkID, params) error

DELETE/accounts/{account_id}/pipelines/v1/sinks/{sink_id}

PipelinesStreams

List Streams

client.Pipelines.Streams.List(ctx, params) (*V4PagePaginationArray[StreamListResponse], error)

GET/accounts/{account_id}/pipelines/v1/streams

Get Stream Details

client.Pipelines.Streams.Get(ctx, streamID, query) (*StreamGetResponse, error)

GET/accounts/{account_id}/pipelines/v1/streams/{stream_id}

Create Stream

client.Pipelines.Streams.New(ctx, params) (*StreamNewResponse, error)

POST/accounts/{account_id}/pipelines/v1/streams

Update Stream

client.Pipelines.Streams.Update(ctx, streamID, params) (*StreamUpdateResponse, error)

PATCH/accounts/{account_id}/pipelines/v1/streams/{stream_id}

Delete Stream

client.Pipelines.Streams.Delete(ctx, streamID, params) error

DELETE/accounts/{account_id}/pipelines/v1/streams/{stream_id}