--- title: Pipelines --- [Skip to content](#_top) [API Reference](https://developers.cloudflare.com/api/go) Copy Markdown Open in **Claude**Open in **ChatGPT**Open in **Cursor** --- **Copy Markdown****View as Markdown** # Pipelines ##### [\[DEPRECATED\] List Pipelines](https://developers.cloudflare.com/api/go/resources/pipelines/methods/list) Deprecated client.Pipelines.List(ctx, params) (\*[PipelineListResponse](), error) GET/accounts/{account\_id}/pipelines ##### [\[DEPRECATED\] Get Pipeline](https://developers.cloudflare.com/api/go/resources/pipelines/methods/get) Deprecated client.Pipelines.Get(ctx, pipelineName, query) (\*[PipelineGetResponse](), error) GET/accounts/{account\_id}/pipelines/{pipeline\_name} ##### [\[DEPRECATED\] Create Pipeline](https://developers.cloudflare.com/api/go/resources/pipelines/methods/create) Deprecated client.Pipelines.New(ctx, params) (\*[PipelineNewResponse](), error) POST/accounts/{account\_id}/pipelines ##### [\[DEPRECATED\] Update Pipeline](https://developers.cloudflare.com/api/go/resources/pipelines/methods/update) Deprecated client.Pipelines.Update(ctx, pipelineName, params) (\*[PipelineUpdateResponse](), error) PUT/accounts/{account\_id}/pipelines/{pipeline\_name} ##### [\[DEPRECATED\] Delete Pipeline](https://developers.cloudflare.com/api/go/resources/pipelines/methods/delete) Deprecated client.Pipelines.Delete(ctx, pipelineName, body) error DELETE/accounts/{account\_id}/pipelines/{pipeline\_name} ##### [List Pipelines](https://developers.cloudflare.com/api/go/resources/pipelines/methods/list_v1) client.Pipelines.ListV1(ctx, params) (\*V4PagePaginationArray\[[PipelineListV1Response]()], error) GET/accounts/{account\_id}/pipelines/v1/pipelines ##### [Get Pipeline Details](https://developers.cloudflare.com/api/go/resources/pipelines/methods/get_v1) client.Pipelines.GetV1(ctx, pipelineID, query) (\*[PipelineGetV1Response](), error) GET/accounts/{account\_id}/pipelines/v1/pipelines/{pipeline\_id} ##### [Create Pipeline](https://developers.cloudflare.com/api/go/resources/pipelines/methods/create_v1) client.Pipelines.NewV1(ctx, params) (\*[PipelineNewV1Response](), error) POST/accounts/{account\_id}/pipelines/v1/pipelines ##### [Delete Pipeline](https://developers.cloudflare.com/api/go/resources/pipelines/methods/delete_v1) client.Pipelines.DeleteV1(ctx, pipelineID, body) (\*[PipelineDeleteV1Response](), error) DELETE/accounts/{account\_id}/pipelines/v1/pipelines/{pipeline\_id} ##### [Validate SQL](https://developers.cloudflare.com/api/go/resources/pipelines/methods/validate_sql) client.Pipelines.ValidateSql(ctx, params) (\*[PipelineValidateSqlResponse](), error) POST/accounts/{account\_id}/pipelines/v1/validate\_sql ##### ModelsExpand Collapse
type FieldType interface{…} One of the following:
FieldTypeInt32 Type FieldTypeInt32Type Link to this property
Link to this property
FieldTypeInt64 Type FieldTypeInt64Type Link to this property
Link to this property
FieldTypeFloat32 Type FieldTypeFloat32Type Link to this property
Link to this property
FieldTypeFloat64 Type FieldTypeFloat64Type Link to this property
Link to this property
FieldTypeBool Type FieldTypeBoolType Link to this property
Link to this property
FieldTypeString Type FieldTypeStringType Link to this property
Link to this property
FieldTypeBinary Type FieldTypeBinaryType Link to this property
Link to this property
FieldTypeTimestamp Type FieldTypeTimestampType Link to this property
Unit FieldTypeTimestampUnitOptional One of the following: const FieldTypeTimestampUnitSecond FieldTypeTimestampUnit = "second" Link to this property const FieldTypeTimestampUnitMillisecond FieldTypeTimestampUnit = "millisecond" Link to this property const FieldTypeTimestampUnitMicrosecond FieldTypeTimestampUnit = "microsecond" Link to this property const FieldTypeTimestampUnitNanosecond FieldTypeTimestampUnit = "nanosecond" Link to this property
Link to this property
Link to this property
FieldTypeJson Type FieldTypeJsonType Link to this property
Link to this property
FieldTypeStruct
Fields \[]SourceField One of the following:
type SourceFieldInt32 struct{…} Type SourceFieldInt32Type Link to this property MetadataKey stringOptional Link to this property Name stringOptional Link to this property Required boolOptional Link to this property SqlName stringOptional Link to this property
Link to this property
type SourceFieldInt64 struct{…} Type SourceFieldInt64Type Link to this property MetadataKey stringOptional Link to this property Name stringOptional Link to this property Required boolOptional Link to this property SqlName stringOptional Link to this property
Link to this property
type SourceFieldFloat32 struct{…} Type SourceFieldFloat32Type Link to this property MetadataKey stringOptional Link to this property Name stringOptional Link to this property Required boolOptional Link to this property SqlName stringOptional Link to this property
Link to this property
type SourceFieldFloat64 struct{…} Type SourceFieldFloat64Type Link to this property MetadataKey stringOptional Link to this property Name stringOptional Link to this property Required boolOptional Link to this property SqlName stringOptional Link to this property
Link to this property
type SourceFieldBool struct{…} Type SourceFieldBoolType Link to this property MetadataKey stringOptional Link to this property Name stringOptional Link to this property Required boolOptional Link to this property SqlName stringOptional Link to this property
Link to this property
type SourceFieldString struct{…} Type SourceFieldStringType Link to this property MetadataKey stringOptional Link to this property Name stringOptional Link to this property Required boolOptional Link to this property SqlName stringOptional Link to this property
Link to this property
type SourceFieldBinary struct{…} Type SourceFieldBinaryType Link to this property MetadataKey stringOptional Link to this property Name stringOptional Link to this property Required boolOptional Link to this property SqlName stringOptional Link to this property
Link to this property
type SourceFieldTimestamp struct{…} Type SourceFieldTimestampType Link to this property MetadataKey stringOptional Link to this property Name stringOptional Link to this property Required boolOptional Link to this property SqlName stringOptional Link to this property
Unit SourceFieldTimestampUnitOptional One of the following: const SourceFieldTimestampUnitSecond SourceFieldTimestampUnit = "second" Link to this property const SourceFieldTimestampUnitMillisecond SourceFieldTimestampUnit = "millisecond" Link to this property const SourceFieldTimestampUnitMicrosecond SourceFieldTimestampUnit = "microsecond" Link to this property const SourceFieldTimestampUnitNanosecond SourceFieldTimestampUnit = "nanosecond" Link to this property
Link to this property
Link to this property
type SourceFieldJson struct{…} Type SourceFieldJsonType Link to this property MetadataKey stringOptional Link to this property Name stringOptional Link to this property Required boolOptional Link to this property SqlName stringOptional Link to this property
Link to this property
type SourceFieldStruct struct{…} Type SourceFieldStructType Link to this property MetadataKey stringOptional Link to this property Name stringOptional Link to this property Required boolOptional Link to this property SqlName stringOptional Link to this property
Link to this property
type SourceFieldList struct{…} Type SourceFieldListType Link to this property MetadataKey stringOptional Link to this property Name stringOptional Link to this property Required boolOptional Link to this property SqlName stringOptional Link to this property
Link to this property
Link to this property Type FieldTypeStructType Link to this property Name stringOptional Link to this property
Link to this property
FieldTypeList Items SourceField Link to this property Type FieldTypeListType Link to this property
Link to this property
[Link to this property](<#(resource)%20pipelines%20%3E%20(model)%20field_type%20%3E%20(schema)>)
type ListField struct{…} Items SourceField Link to this property
[Link to this property](<#(resource)%20pipelines%20%3E%20(model)%20list_field%20%3E%20(schema)>)
type SourceField interface{…} One of the following:
type SourceFieldInt32 struct{…} Type SourceFieldInt32Type Link to this property MetadataKey stringOptional Link to this property Name stringOptional Link to this property Required boolOptional Link to this property SqlName stringOptional Link to this property
Link to this property
type SourceFieldInt64 struct{…} Type SourceFieldInt64Type Link to this property MetadataKey stringOptional Link to this property Name stringOptional Link to this property Required boolOptional Link to this property SqlName stringOptional Link to this property
Link to this property
type SourceFieldFloat32 struct{…} Type SourceFieldFloat32Type Link to this property MetadataKey stringOptional Link to this property Name stringOptional Link to this property Required boolOptional Link to this property SqlName stringOptional Link to this property
Link to this property
type SourceFieldFloat64 struct{…} Type SourceFieldFloat64Type Link to this property MetadataKey stringOptional Link to this property Name stringOptional Link to this property Required boolOptional Link to this property SqlName stringOptional Link to this property
Link to this property
type SourceFieldBool struct{…} Type SourceFieldBoolType Link to this property MetadataKey stringOptional Link to this property Name stringOptional Link to this property Required boolOptional Link to this property SqlName stringOptional Link to this property
Link to this property
type SourceFieldString struct{…} Type SourceFieldStringType Link to this property MetadataKey stringOptional Link to this property Name stringOptional Link to this property Required boolOptional Link to this property SqlName stringOptional Link to this property
Link to this property
type SourceFieldBinary struct{…} Type SourceFieldBinaryType Link to this property MetadataKey stringOptional Link to this property Name stringOptional Link to this property Required boolOptional Link to this property SqlName stringOptional Link to this property
Link to this property
type SourceFieldTimestamp struct{…} Type SourceFieldTimestampType Link to this property MetadataKey stringOptional Link to this property Name stringOptional Link to this property Required boolOptional Link to this property SqlName stringOptional Link to this property
Unit SourceFieldTimestampUnitOptional One of the following: const SourceFieldTimestampUnitSecond SourceFieldTimestampUnit = "second" Link to this property const SourceFieldTimestampUnitMillisecond SourceFieldTimestampUnit = "millisecond" Link to this property const SourceFieldTimestampUnitMicrosecond SourceFieldTimestampUnit = "microsecond" Link to this property const SourceFieldTimestampUnitNanosecond SourceFieldTimestampUnit = "nanosecond" Link to this property
Link to this property
Link to this property
type SourceFieldJson struct{…} Type SourceFieldJsonType Link to this property MetadataKey stringOptional Link to this property Name stringOptional Link to this property Required boolOptional Link to this property SqlName stringOptional Link to this property
Link to this property
type SourceFieldStruct struct{…} Type SourceFieldStructType Link to this property MetadataKey stringOptional Link to this property Name stringOptional Link to this property Required boolOptional Link to this property SqlName stringOptional Link to this property
Link to this property
type SourceFieldList struct{…} Type SourceFieldListType Link to this property MetadataKey stringOptional Link to this property Name stringOptional Link to this property Required boolOptional Link to this property SqlName stringOptional Link to this property
Link to this property
[Link to this property](<#(resource)%20pipelines%20%3E%20(model)%20source_field%20%3E%20(schema)>)
type StructField struct{…} Fields \[]SourceField Link to this property Name stringOptional Link to this property
[Link to this property](<#(resource)%20pipelines%20%3E%20(model)%20struct_field%20%3E%20(schema)>) #### PipelinesSinks ##### [List Sinks](https://developers.cloudflare.com/api/go/resources/pipelines/subresources/sinks/methods/list) client.Pipelines.Sinks.List(ctx, params) (\*V4PagePaginationArray\[[SinkListResponse]()], error) GET/accounts/{account\_id}/pipelines/v1/sinks ##### [Get Sink Details](https://developers.cloudflare.com/api/go/resources/pipelines/subresources/sinks/methods/get) client.Pipelines.Sinks.Get(ctx, sinkID, query) (\*[SinkGetResponse](), error) GET/accounts/{account\_id}/pipelines/v1/sinks/{sink\_id} ##### [Create Sink](https://developers.cloudflare.com/api/go/resources/pipelines/subresources/sinks/methods/create) client.Pipelines.Sinks.New(ctx, params) (\*[SinkNewResponse](), error) POST/accounts/{account\_id}/pipelines/v1/sinks ##### [Delete Sink](https://developers.cloudflare.com/api/go/resources/pipelines/subresources/sinks/methods/delete) client.Pipelines.Sinks.Delete(ctx, sinkID, body) (\*[SinkDeleteResponse](), error) DELETE/accounts/{account\_id}/pipelines/v1/sinks/{sink\_id} #### PipelinesStreams ##### [List Streams](https://developers.cloudflare.com/api/go/resources/pipelines/subresources/streams/methods/list) client.Pipelines.Streams.List(ctx, params) (\*V4PagePaginationArray\[[StreamListResponse]()], error) GET/accounts/{account\_id}/pipelines/v1/streams ##### [Get Stream Details](https://developers.cloudflare.com/api/go/resources/pipelines/subresources/streams/methods/get) client.Pipelines.Streams.Get(ctx, streamID, query) (\*[StreamGetResponse](), error) GET/accounts/{account\_id}/pipelines/v1/streams/{stream\_id} ##### [Create Stream](https://developers.cloudflare.com/api/go/resources/pipelines/subresources/streams/methods/create) client.Pipelines.Streams.New(ctx, params) (\*[StreamNewResponse](), error) POST/accounts/{account\_id}/pipelines/v1/streams ##### [Update Stream](https://developers.cloudflare.com/api/go/resources/pipelines/subresources/streams/methods/update) client.Pipelines.Streams.Update(ctx, streamID, params) (\*[StreamUpdateResponse](), error) PATCH/accounts/{account\_id}/pipelines/v1/streams/{stream\_id} ##### [Delete Stream](https://developers.cloudflare.com/api/go/resources/pipelines/subresources/streams/methods/delete) client.Pipelines.Streams.Delete(ctx, streamID, body) (\*[StreamDeleteResponse](), error) DELETE/accounts/{account\_id}/pipelines/v1/streams/{stream\_id}