api.md

Pipelines

Types:

• PipelineCreateResponse
• PipelineUpdateResponse
• PipelineListResponse
• PipelineCreateV1Response
• PipelineDeleteV1Response
• PipelineGetResponse
• PipelineGetV1Response
• PipelineListV1Response
• PipelineValidateSqlResponse

Methods:

• client.pipelines.create({ ...params }) -> PipelineCreateResponse
• client.pipelines.update(pipelineName, { ...params }) -> PipelineUpdateResponse
• client.pipelines.list({ ...params }) -> PipelineListResponse
• client.pipelines.delete(pipelineName, { ...params }) -> void
• client.pipelines.createV1({ ...params }) -> PipelineCreateV1Response
• client.pipelines.deleteV1(pipelineId, { ...params }) -> PipelineDeleteV1Response
• client.pipelines.get(pipelineName, { ...params }) -> PipelineGetResponse
• client.pipelines.getV1(pipelineId, { ...params }) -> PipelineGetV1Response
• client.pipelines.listV1({ ...params }) -> PipelineListV1ResponsesV4PagePaginationArray
• client.pipelines.validateSql({ ...params }) -> PipelineValidateSqlResponse

Sinks

Types:

• SinkCreateResponse
• SinkListResponse
• SinkDeleteResponse
• SinkGetResponse

Methods:

• client.pipelines.sinks.create({ ...params }) -> SinkCreateResponse
• client.pipelines.sinks.list({ ...params }) -> SinkListResponsesV4PagePaginationArray
• client.pipelines.sinks.delete(sinkId, { ...params }) -> SinkDeleteResponse
• client.pipelines.sinks.get(sinkId, { ...params }) -> SinkGetResponse

Streams

Types:

• StreamCreateResponse
• StreamUpdateResponse
• StreamListResponse
• StreamDeleteResponse
• StreamGetResponse

Methods:

• client.pipelines.streams.create({ ...params }) -> StreamCreateResponse
• client.pipelines.streams.update(streamId, { ...params }) -> StreamUpdateResponse
• client.pipelines.streams.list({ ...params }) -> StreamListResponsesV4PagePaginationArray
• client.pipelines.streams.delete(streamId, { ...params }) -> StreamDeleteResponse
• client.pipelines.streams.get(streamId, { ...params }) -> StreamGetResponse