## List Streams `client.Pipelines.Streams.List(ctx, params) (*V4PagePaginationArray[StreamListResponse], error)` **get** `/accounts/{account_id}/pipelines/v1/streams` List/Filter Streams in Account. ### Parameters - `params StreamListParams` - `AccountID param.Field[string]` Path param: Specifies the public ID of the account. - `Page param.Field[float64]` Query param - `PerPage param.Field[float64]` Query param - `PipelineID param.Field[string]` Query param: Specifies the public ID of the pipeline. ### Returns - `type StreamListResponse struct{…}` - `ID string` Indicates a unique identifier for this stream. - `CreatedAt Time` - `HTTP StreamListResponseHTTP` - `Authentication bool` Indicates that authentication is required for the HTTP endpoint. - `Enabled bool` Indicates that the HTTP endpoint is enabled. - `CORS StreamListResponseHTTPCORS` Specifies the CORS options for the HTTP endpoint. - `Origins []string` - `ModifiedAt Time` - `Name string` Indicates the name of the Stream. - `Version int64` Indicates the current version of this stream. - `WorkerBinding StreamListResponseWorkerBinding` - `Enabled bool` Indicates that the worker binding is enabled. - `Endpoint string` Indicates the endpoint URL of this stream. - `Format StreamListResponseFormat` - `type StreamListResponseFormatJson struct{…}` - `Type StreamListResponseFormatJsonType` - `const StreamListResponseFormatJsonTypeJson StreamListResponseFormatJsonType = "json"` - `DecimalEncoding StreamListResponseFormatJsonDecimalEncoding` - `const StreamListResponseFormatJsonDecimalEncodingNumber StreamListResponseFormatJsonDecimalEncoding = "number"` - `const StreamListResponseFormatJsonDecimalEncodingString StreamListResponseFormatJsonDecimalEncoding = "string"` - `const StreamListResponseFormatJsonDecimalEncodingBytes StreamListResponseFormatJsonDecimalEncoding = "bytes"` - `TimestampFormat StreamListResponseFormatJsonTimestampFormat` - `const StreamListResponseFormatJsonTimestampFormatRfc3339 StreamListResponseFormatJsonTimestampFormat = "rfc3339"` - `const StreamListResponseFormatJsonTimestampFormatUnixMillis StreamListResponseFormatJsonTimestampFormat = "unix_millis"` - `Unstructured bool` - `type StreamListResponseFormatParquet struct{…}` - `Type StreamListResponseFormatParquetType` - `const StreamListResponseFormatParquetTypeParquet StreamListResponseFormatParquetType = "parquet"` - `Compression StreamListResponseFormatParquetCompression` - `const StreamListResponseFormatParquetCompressionUncompressed StreamListResponseFormatParquetCompression = "uncompressed"` - `const StreamListResponseFormatParquetCompressionSnappy StreamListResponseFormatParquetCompression = "snappy"` - `const StreamListResponseFormatParquetCompressionGzip StreamListResponseFormatParquetCompression = "gzip"` - `const StreamListResponseFormatParquetCompressionZstd StreamListResponseFormatParquetCompression = "zstd"` - `const StreamListResponseFormatParquetCompressionLz4 StreamListResponseFormatParquetCompression = "lz4"` - `RowGroupBytes int64` - `Schema StreamListResponseSchema` - `Fields []StreamListResponseSchemaField` - `type StreamListResponseSchemaFieldsInt32 struct{…}` - `Type StreamListResponseSchemaFieldsInt32Type` - `const StreamListResponseSchemaFieldsInt32TypeInt32 StreamListResponseSchemaFieldsInt32Type = "int32"` - `MetadataKey string` - `Name string` - `Required bool` - `SqlName string` - `type StreamListResponseSchemaFieldsInt64 struct{…}` - `Type StreamListResponseSchemaFieldsInt64Type` - `const StreamListResponseSchemaFieldsInt64TypeInt64 StreamListResponseSchemaFieldsInt64Type = "int64"` - `MetadataKey string` - `Name string` - `Required bool` - `SqlName string` - `type StreamListResponseSchemaFieldsFloat32 struct{…}` - `Type StreamListResponseSchemaFieldsFloat32Type` - `const StreamListResponseSchemaFieldsFloat32TypeFloat32 StreamListResponseSchemaFieldsFloat32Type = "float32"` - `MetadataKey string` - `Name string` - `Required bool` - `SqlName string` - `type StreamListResponseSchemaFieldsFloat64 struct{…}` - `Type StreamListResponseSchemaFieldsFloat64Type` - `const StreamListResponseSchemaFieldsFloat64TypeFloat64 StreamListResponseSchemaFieldsFloat64Type = "float64"` - `MetadataKey string` - `Name string` - `Required bool` - `SqlName string` - `type StreamListResponseSchemaFieldsBool struct{…}` - `Type StreamListResponseSchemaFieldsBoolType` - `const StreamListResponseSchemaFieldsBoolTypeBool StreamListResponseSchemaFieldsBoolType = "bool"` - `MetadataKey string` - `Name string` - `Required bool` - `SqlName string` - `type StreamListResponseSchemaFieldsString struct{…}` - `Type StreamListResponseSchemaFieldsStringType` - `const StreamListResponseSchemaFieldsStringTypeString StreamListResponseSchemaFieldsStringType = "string"` - `MetadataKey string` - `Name string` - `Required bool` - `SqlName string` - `type StreamListResponseSchemaFieldsBinary struct{…}` - `Type StreamListResponseSchemaFieldsBinaryType` - `const StreamListResponseSchemaFieldsBinaryTypeBinary StreamListResponseSchemaFieldsBinaryType = "binary"` - `MetadataKey string` - `Name string` - `Required bool` - `SqlName string` - `type StreamListResponseSchemaFieldsTimestamp struct{…}` - `Type StreamListResponseSchemaFieldsTimestampType` - `const StreamListResponseSchemaFieldsTimestampTypeTimestamp StreamListResponseSchemaFieldsTimestampType = "timestamp"` - `MetadataKey string` - `Name string` - `Required bool` - `SqlName string` - `Unit StreamListResponseSchemaFieldsTimestampUnit` - `const StreamListResponseSchemaFieldsTimestampUnitSecond StreamListResponseSchemaFieldsTimestampUnit = "second"` - `const StreamListResponseSchemaFieldsTimestampUnitMillisecond StreamListResponseSchemaFieldsTimestampUnit = "millisecond"` - `const StreamListResponseSchemaFieldsTimestampUnitMicrosecond StreamListResponseSchemaFieldsTimestampUnit = "microsecond"` - `const StreamListResponseSchemaFieldsTimestampUnitNanosecond StreamListResponseSchemaFieldsTimestampUnit = "nanosecond"` - `type StreamListResponseSchemaFieldsJson struct{…}` - `Type StreamListResponseSchemaFieldsJsonType` - `const StreamListResponseSchemaFieldsJsonTypeJson StreamListResponseSchemaFieldsJsonType = "json"` - `MetadataKey string` - `Name string` - `Required bool` - `SqlName string` - `type StreamListResponseSchemaFieldsStruct struct{…}` - `type StreamListResponseSchemaFieldsList struct{…}` - `Format StreamListResponseSchemaFormat` - `type StreamListResponseSchemaFormatJson struct{…}` - `Type StreamListResponseSchemaFormatJsonType` - `const StreamListResponseSchemaFormatJsonTypeJson StreamListResponseSchemaFormatJsonType = "json"` - `DecimalEncoding StreamListResponseSchemaFormatJsonDecimalEncoding` - `const StreamListResponseSchemaFormatJsonDecimalEncodingNumber StreamListResponseSchemaFormatJsonDecimalEncoding = "number"` - `const StreamListResponseSchemaFormatJsonDecimalEncodingString StreamListResponseSchemaFormatJsonDecimalEncoding = "string"` - `const StreamListResponseSchemaFormatJsonDecimalEncodingBytes StreamListResponseSchemaFormatJsonDecimalEncoding = "bytes"` - `TimestampFormat StreamListResponseSchemaFormatJsonTimestampFormat` - `const StreamListResponseSchemaFormatJsonTimestampFormatRfc3339 StreamListResponseSchemaFormatJsonTimestampFormat = "rfc3339"` - `const StreamListResponseSchemaFormatJsonTimestampFormatUnixMillis StreamListResponseSchemaFormatJsonTimestampFormat = "unix_millis"` - `Unstructured bool` - `type StreamListResponseSchemaFormatParquet struct{…}` - `Type StreamListResponseSchemaFormatParquetType` - `const StreamListResponseSchemaFormatParquetTypeParquet StreamListResponseSchemaFormatParquetType = "parquet"` - `Compression StreamListResponseSchemaFormatParquetCompression` - `const StreamListResponseSchemaFormatParquetCompressionUncompressed StreamListResponseSchemaFormatParquetCompression = "uncompressed"` - `const StreamListResponseSchemaFormatParquetCompressionSnappy StreamListResponseSchemaFormatParquetCompression = "snappy"` - `const StreamListResponseSchemaFormatParquetCompressionGzip StreamListResponseSchemaFormatParquetCompression = "gzip"` - `const StreamListResponseSchemaFormatParquetCompressionZstd StreamListResponseSchemaFormatParquetCompression = "zstd"` - `const StreamListResponseSchemaFormatParquetCompressionLz4 StreamListResponseSchemaFormatParquetCompression = "lz4"` - `RowGroupBytes int64` - `Inferred bool` ### Example ```go package main import ( "context" "fmt" "github.com/cloudflare/cloudflare-go" "github.com/cloudflare/cloudflare-go/option" "github.com/cloudflare/cloudflare-go/pipelines" ) func main() { client := cloudflare.NewClient( option.WithAPIToken("Sn3lZJTBX6kkg7OdcBUAxOO963GEIyGQqnFTOFYY"), ) page, err := client.Pipelines.Streams.List(context.TODO(), pipelines.StreamListParams{ AccountID: cloudflare.F("0123105f4ecef8ad9ca31a8372d0c353"), }) if err != nil { panic(err.Error()) } fmt.Printf("%+v\n", page) } ``` #### Response ```json { "result": [ { "id": "01234567890123457689012345678901", "created_at": "2019-12-27T18:11:19.117Z", "http": { "authentication": false, "enabled": true, "cors": { "origins": [ "string" ] } }, "modified_at": "2019-12-27T18:11:19.117Z", "name": "my_stream", "version": 3, "worker_binding": { "enabled": true }, "endpoint": "https://01234567890123457689012345678901.ingest.cloudflare.com/v1", "format": { "type": "json", "decimal_encoding": "number", "timestamp_format": "rfc3339", "unstructured": true }, "schema": { "fields": [ { "type": "int32", "metadata_key": "metadata_key", "name": "name", "required": true, "sql_name": "sql_name" } ], "format": { "type": "json", "decimal_encoding": "number", "timestamp_format": "rfc3339", "unstructured": true }, "inferred": true } } ], "result_info": { "count": 1, "page": 0, "per_page": 10, "total_count": 1 }, "success": true } ```