1. Packages
  2. Packages
  3. Cloudflare Provider
  4. API Docs
  5. getPipelineStreams
Viewing docs for Cloudflare v6.15.0
published on Saturday, May 2, 2026 by Pulumi
Schema (JSON)
pulumi/pulumi-cloudflare

cloudflare.getPipelineStreams

cloudflare logo
Viewing docs for Cloudflare v6.15.0
published on Saturday, May 2, 2026 by Pulumi
Schema (JSON)
pulumi/pulumi-cloudflare

    Accepted Permissions

    • Pipelines Read
    • Pipelines Write

    Example Usage

    import * as pulumi from "@pulumi/pulumi";
import * as cloudflare from "@pulumi/cloudflare";

const examplePipelineStreams = cloudflare.getPipelineStreams({
    accountId: "0123105f4ecef8ad9ca31a8372d0c353",
    pipelineId: "043e105f4ecef8ad9ca31a8372d0c353",
});

    import pulumi
import pulumi_cloudflare as cloudflare

example_pipeline_streams = cloudflare.get_pipeline_streams(account_id="0123105f4ecef8ad9ca31a8372d0c353",
    pipeline_id="043e105f4ecef8ad9ca31a8372d0c353")

    package main

import (
	"github.com/pulumi/pulumi-cloudflare/sdk/v6/go/cloudflare"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := cloudflare.GetPipelineStreams(ctx, &cloudflare.LookupPipelineStreamsArgs{
			AccountId:  pulumi.StringRef("0123105f4ecef8ad9ca31a8372d0c353"),
			PipelineId: pulumi.StringRef("043e105f4ecef8ad9ca31a8372d0c353"),
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

    using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Cloudflare = Pulumi.Cloudflare;

return await Deployment.RunAsync(() => 
{
    var examplePipelineStreams = Cloudflare.Index.GetPipelineStreams.Invoke(new()
    {
        AccountId = "0123105f4ecef8ad9ca31a8372d0c353",
        PipelineId = "043e105f4ecef8ad9ca31a8372d0c353",
    });

});

    package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.cloudflare.CloudflareFunctions;
import com.pulumi.cloudflare.inputs.GetPipelineStreamsArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        final var examplePipelineStreams = CloudflareFunctions.getPipelineStreams(GetPipelineStreamsArgs.builder()
            .accountId("0123105f4ecef8ad9ca31a8372d0c353")
            .pipelineId("043e105f4ecef8ad9ca31a8372d0c353")
            .build());

    }
}

    variables:
  examplePipelineStreams:
    fn::invoke:
      function: cloudflare:getPipelineStreams
      arguments:
        accountId: 0123105f4ecef8ad9ca31a8372d0c353
        pipelineId: 043e105f4ecef8ad9ca31a8372d0c353

    Using getPipelineStreams

    Two invocation forms are available. The direct form accepts plain arguments and either blocks until the result value is available, or returns a Promise-wrapped result. The output form accepts Input-wrapped arguments and returns an Output-wrapped result.

    function getPipelineStreams(args: GetPipelineStreamsArgs, opts?: InvokeOptions): Promise<GetPipelineStreamsResult>
function getPipelineStreamsOutput(args: GetPipelineStreamsOutputArgs, opts?: InvokeOptions): Output<GetPipelineStreamsResult>
    def get_pipeline_streams(account_id: Optional[str] = None,
                         max_items: Optional[int] = None,
                         pipeline_id: Optional[str] = None,
                         opts: Optional[InvokeOptions] = None) -> GetPipelineStreamsResult
def get_pipeline_streams_output(account_id: Optional[pulumi.Input[str]] = None,
                         max_items: Optional[pulumi.Input[int]] = None,
                         pipeline_id: Optional[pulumi.Input[str]] = None,
                         opts: Optional[InvokeOptions] = None) -> Output[GetPipelineStreamsResult]
    func LookupPipelineStreams(ctx *Context, args *LookupPipelineStreamsArgs, opts ...InvokeOption) (*LookupPipelineStreamsResult, error)
func LookupPipelineStreamsOutput(ctx *Context, args *LookupPipelineStreamsOutputArgs, opts ...InvokeOption) LookupPipelineStreamsResultOutput

    > Note: This function is named LookupPipelineStreams in the Go SDK.

    public static class GetPipelineStreams 
{
    public static Task<GetPipelineStreamsResult> InvokeAsync(GetPipelineStreamsArgs args, InvokeOptions? opts = null)
    public static Output<GetPipelineStreamsResult> Invoke(GetPipelineStreamsInvokeArgs args, InvokeOptions? opts = null)
}
    public static CompletableFuture<GetPipelineStreamsResult> getPipelineStreams(GetPipelineStreamsArgs args, InvokeOptions options)
public static Output<GetPipelineStreamsResult> getPipelineStreams(GetPipelineStreamsArgs args, InvokeOptions options)

    fn::invoke:
  function: cloudflare:index/getPipelineStreams:getPipelineStreams
  arguments:
    # arguments dictionary

    The following arguments are supported:

    AccountId string
    Specifies the public ID of the account.
    MaxItems int
    Max items to fetch, default: 1000
    PipelineId string
    Specifies the public ID of the pipeline.
    AccountId string
    Specifies the public ID of the account.
    MaxItems int
    Max items to fetch, default: 1000
    PipelineId string
    Specifies the public ID of the pipeline.
    accountId String
    Specifies the public ID of the account.
    maxItems Integer
    Max items to fetch, default: 1000
    pipelineId String
    Specifies the public ID of the pipeline.
    accountId string
    Specifies the public ID of the account.
    maxItems number
    Max items to fetch, default: 1000
    pipelineId string
    Specifies the public ID of the pipeline.
    account_id str
    Specifies the public ID of the account.
    max_items int
    Max items to fetch, default: 1000
    pipeline_id str
    Specifies the public ID of the pipeline.
    accountId String
    Specifies the public ID of the account.
    maxItems Number
    Max items to fetch, default: 1000
    pipelineId String
    Specifies the public ID of the pipeline.

    getPipelineStreams Result

    The following output properties are available:

    Id string
    The provider-assigned unique ID for this managed resource.
    Results List<GetPipelineStreamsResult>
    The items returned by the data source
    AccountId string
    Specifies the public ID of the account.
    MaxItems int
    Max items to fetch, default: 1000
    PipelineId string
    Specifies the public ID of the pipeline.
    Id string
    The provider-assigned unique ID for this managed resource.
    Results []GetPipelineStreamsResult
    The items returned by the data source
    AccountId string
    Specifies the public ID of the account.
    MaxItems int
    Max items to fetch, default: 1000
    PipelineId string
    Specifies the public ID of the pipeline.
    id String
    The provider-assigned unique ID for this managed resource.
    results List<GetPipelineStreamsResult>
    The items returned by the data source
    accountId String
    Specifies the public ID of the account.
    maxItems Integer
    Max items to fetch, default: 1000
    pipelineId String
    Specifies the public ID of the pipeline.
    id string
    The provider-assigned unique ID for this managed resource.
    results GetPipelineStreamsResult[]
    The items returned by the data source
    accountId string
    Specifies the public ID of the account.
    maxItems number
    Max items to fetch, default: 1000
    pipelineId string
    Specifies the public ID of the pipeline.
    id str
    The provider-assigned unique ID for this managed resource.
    results Sequence[GetPipelineStreamsResult]
    The items returned by the data source
    account_id str
    Specifies the public ID of the account.
    max_items int
    Max items to fetch, default: 1000
    pipeline_id str
    Specifies the public ID of the pipeline.
    id String
    The provider-assigned unique ID for this managed resource.
    results List<Property Map>
    The items returned by the data source
    accountId String
    Specifies the public ID of the account.
    maxItems Number
    Max items to fetch, default: 1000
    pipelineId String
    Specifies the public ID of the pipeline.

    Supporting Types

    GetPipelineStreamsResult

    CreatedAt string
    Endpoint string
    Indicates the endpoint URL of this stream.
    Format GetPipelineStreamsResultFormat
    Http GetPipelineStreamsResultHttp
    Id string
    Indicates a unique identifier for this stream.
    ModifiedAt string
    Name string
    Indicates the name of the Stream.
    Schema GetPipelineStreamsResultSchema
    Version int
    Indicates the current version of this stream.
    WorkerBinding GetPipelineStreamsResultWorkerBinding
    CreatedAt string
    Endpoint string
    Indicates the endpoint URL of this stream.
    Format GetPipelineStreamsResultFormat
    Http GetPipelineStreamsResultHttp
    Id string
    Indicates a unique identifier for this stream.
    ModifiedAt string
    Name string
    Indicates the name of the Stream.
    Schema GetPipelineStreamsResultSchema
    Version int
    Indicates the current version of this stream.
    WorkerBinding GetPipelineStreamsResultWorkerBinding
    createdAt String
    endpoint String
    Indicates the endpoint URL of this stream.
    format GetPipelineStreamsResultFormat
    http GetPipelineStreamsResultHttp
    id String
    Indicates a unique identifier for this stream.
    modifiedAt String
    name String
    Indicates the name of the Stream.
    schema GetPipelineStreamsResultSchema
    version Integer
    Indicates the current version of this stream.
    workerBinding GetPipelineStreamsResultWorkerBinding
    createdAt string
    endpoint string
    Indicates the endpoint URL of this stream.
    format GetPipelineStreamsResultFormat
    http GetPipelineStreamsResultHttp
    id string
    Indicates a unique identifier for this stream.
    modifiedAt string
    name string
    Indicates the name of the Stream.
    schema GetPipelineStreamsResultSchema
    version number
    Indicates the current version of this stream.
    workerBinding GetPipelineStreamsResultWorkerBinding
    created_at str
    endpoint str
    Indicates the endpoint URL of this stream.
    format GetPipelineStreamsResultFormat
    http GetPipelineStreamsResultHttp
    id str
    Indicates a unique identifier for this stream.
    modified_at str
    name str
    Indicates the name of the Stream.
    schema GetPipelineStreamsResultSchema
    version int
    Indicates the current version of this stream.
    worker_binding GetPipelineStreamsResultWorkerBinding
    createdAt String
    endpoint String
    Indicates the endpoint URL of this stream.
    format Property Map
    http Property Map
    id String
    Indicates a unique identifier for this stream.
    modifiedAt String
    name String
    Indicates the name of the Stream.
    schema Property Map
    version Number
    Indicates the current version of this stream.
    workerBinding Property Map

    GetPipelineStreamsResultFormat

    Compression string
    Available values: "uncompressed", "snappy", "gzip", "zstd", "lz4".
    DecimalEncoding string
    Available values: "number", "string", "bytes".
    RowGroupBytes int
    TimestampFormat string
    Available values: "rfc3339", "unixMillis".
    Type string
    Available values: "json", "parquet".
    Unstructured bool
    Compression string
    Available values: "uncompressed", "snappy", "gzip", "zstd", "lz4".
    DecimalEncoding string
    Available values: "number", "string", "bytes".
    RowGroupBytes int
    TimestampFormat string
    Available values: "rfc3339", "unixMillis".
    Type string
    Available values: "json", "parquet".
    Unstructured bool
    compression String
    Available values: "uncompressed", "snappy", "gzip", "zstd", "lz4".
    decimalEncoding String
    Available values: "number", "string", "bytes".
    rowGroupBytes Integer
    timestampFormat String
    Available values: "rfc3339", "unixMillis".
    type String
    Available values: "json", "parquet".
    unstructured Boolean
    compression string
    Available values: "uncompressed", "snappy", "gzip", "zstd", "lz4".
    decimalEncoding string
    Available values: "number", "string", "bytes".
    rowGroupBytes number
    timestampFormat string
    Available values: "rfc3339", "unixMillis".
    type string
    Available values: "json", "parquet".
    unstructured boolean
    compression str
    Available values: "uncompressed", "snappy", "gzip", "zstd", "lz4".
    decimal_encoding str
    Available values: "number", "string", "bytes".
    row_group_bytes int
    timestamp_format str
    Available values: "rfc3339", "unixMillis".
    type str
    Available values: "json", "parquet".
    unstructured bool
    compression String
    Available values: "uncompressed", "snappy", "gzip", "zstd", "lz4".
    decimalEncoding String
    Available values: "number", "string", "bytes".
    rowGroupBytes Number
    timestampFormat String
    Available values: "rfc3339", "unixMillis".
    type String
    Available values: "json", "parquet".
    unstructured Boolean

    GetPipelineStreamsResultHttp

    Authentication bool
    Indicates that authentication is required for the HTTP endpoint.
    Cors GetPipelineStreamsResultHttpCors
    Specifies the CORS options for the HTTP endpoint.
    Enabled bool
    Indicates that the HTTP endpoint is enabled.
    Authentication bool
    Indicates that authentication is required for the HTTP endpoint.
    Cors GetPipelineStreamsResultHttpCors
    Specifies the CORS options for the HTTP endpoint.
    Enabled bool
    Indicates that the HTTP endpoint is enabled.
    authentication Boolean
    Indicates that authentication is required for the HTTP endpoint.
    cors GetPipelineStreamsResultHttpCors
    Specifies the CORS options for the HTTP endpoint.
    enabled Boolean
    Indicates that the HTTP endpoint is enabled.
    authentication boolean
    Indicates that authentication is required for the HTTP endpoint.
    cors GetPipelineStreamsResultHttpCors
    Specifies the CORS options for the HTTP endpoint.
    enabled boolean
    Indicates that the HTTP endpoint is enabled.
    authentication bool
    Indicates that authentication is required for the HTTP endpoint.
    cors GetPipelineStreamsResultHttpCors
    Specifies the CORS options for the HTTP endpoint.
    enabled bool
    Indicates that the HTTP endpoint is enabled.
    authentication Boolean
    Indicates that authentication is required for the HTTP endpoint.
    cors Property Map
    Specifies the CORS options for the HTTP endpoint.
    enabled Boolean
    Indicates that the HTTP endpoint is enabled.

    GetPipelineStreamsResultHttpCors

    Origins List<string>
    Origins []string
    origins List<String>
    origins string[]
    origins Sequence[str]
    origins List<String>

    GetPipelineStreamsResultSchema

    GetPipelineStreamsResultSchemaField

    MetadataKey string
    Name string
    Required bool
    SqlName string
    Type string
    Available values: "int32", "int64", "float32", "float64", "bool", "string", "binary", "timestamp", "json".
    Unit string
    Available values: "second", "millisecond", "microsecond", "nanosecond".
    MetadataKey string
    Name string
    Required bool
    SqlName string
    Type string
    Available values: "int32", "int64", "float32", "float64", "bool", "string", "binary", "timestamp", "json".
    Unit string
    Available values: "second", "millisecond", "microsecond", "nanosecond".
    metadataKey String
    name String
    required Boolean
    sqlName String
    type String
    Available values: "int32", "int64", "float32", "float64", "bool", "string", "binary", "timestamp", "json".
    unit String
    Available values: "second", "millisecond", "microsecond", "nanosecond".
    metadataKey string
    name string
    required boolean
    sqlName string
    type string
    Available values: "int32", "int64", "float32", "float64", "bool", "string", "binary", "timestamp", "json".
    unit string
    Available values: "second", "millisecond", "microsecond", "nanosecond".
    metadata_key str
    name str
    required bool
    sql_name str
    type str
    Available values: "int32", "int64", "float32", "float64", "bool", "string", "binary", "timestamp", "json".
    unit str
    Available values: "second", "millisecond", "microsecond", "nanosecond".
    metadataKey String
    name String
    required Boolean
    sqlName String
    type String
    Available values: "int32", "int64", "float32", "float64", "bool", "string", "binary", "timestamp", "json".
    unit String
    Available values: "second", "millisecond", "microsecond", "nanosecond".

    GetPipelineStreamsResultSchemaFormat

    Compression string
    Available values: "uncompressed", "snappy", "gzip", "zstd", "lz4".
    DecimalEncoding string
    Available values: "number", "string", "bytes".
    RowGroupBytes int
    TimestampFormat string
    Available values: "rfc3339", "unixMillis".
    Type string
    Available values: "json", "parquet".
    Unstructured bool
    Compression string
    Available values: "uncompressed", "snappy", "gzip", "zstd", "lz4".
    DecimalEncoding string
    Available values: "number", "string", "bytes".
    RowGroupBytes int
    TimestampFormat string
    Available values: "rfc3339", "unixMillis".
    Type string
    Available values: "json", "parquet".
    Unstructured bool
    compression String
    Available values: "uncompressed", "snappy", "gzip", "zstd", "lz4".
    decimalEncoding String
    Available values: "number", "string", "bytes".
    rowGroupBytes Integer
    timestampFormat String
    Available values: "rfc3339", "unixMillis".
    type String
    Available values: "json", "parquet".
    unstructured Boolean
    compression string
    Available values: "uncompressed", "snappy", "gzip", "zstd", "lz4".
    decimalEncoding string
    Available values: "number", "string", "bytes".
    rowGroupBytes number
    timestampFormat string
    Available values: "rfc3339", "unixMillis".
    type string
    Available values: "json", "parquet".
    unstructured boolean
    compression str
    Available values: "uncompressed", "snappy", "gzip", "zstd", "lz4".
    decimal_encoding str
    Available values: "number", "string", "bytes".
    row_group_bytes int
    timestamp_format str
    Available values: "rfc3339", "unixMillis".
    type str
    Available values: "json", "parquet".
    unstructured bool
    compression String
    Available values: "uncompressed", "snappy", "gzip", "zstd", "lz4".
    decimalEncoding String
    Available values: "number", "string", "bytes".
    rowGroupBytes Number
    timestampFormat String
    Available values: "rfc3339", "unixMillis".
    type String
    Available values: "json", "parquet".
    unstructured Boolean

    GetPipelineStreamsResultWorkerBinding

    Enabled bool
    Indicates that the worker binding is enabled.
    Enabled bool
    Indicates that the worker binding is enabled.
    enabled Boolean
    Indicates that the worker binding is enabled.
    enabled boolean
    Indicates that the worker binding is enabled.
    enabled bool
    Indicates that the worker binding is enabled.
    enabled Boolean
    Indicates that the worker binding is enabled.

    Package Details

    Repository
    Cloudflare pulumi/pulumi-cloudflare
    License
    Apache-2.0
    Notes
    This Pulumi package is based on the cloudflare Terraform Provider.
    cloudflare logo
    Viewing docs for Cloudflare v6.15.0
    published on Saturday, May 2, 2026 by Pulumi
    Schema (JSON)
    pulumi/pulumi-cloudflare
      Try Pulumi Cloud free. Your team will thank you.