getPipelineSink

Cloudflare v6.15.0, May 2 26

Viewing docs for Cloudflare v6.15.0
published on Saturday, May 2, 2026 by Pulumi

Schema (JSON)

pulumi/pulumi-cloudflare

Viewing docs for Cloudflare v6.15.0
published on Saturday, May 2, 2026 by Pulumi

Schema (JSON)

pulumi/pulumi-cloudflare

Example Usage

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

const examplePipelineSink = cloudflare.getPipelineSink({
    accountId: "0123105f4ecef8ad9ca31a8372d0c353",
    sinkId: "0223105f4ecef8ad9ca31a8372d0c353",
});

import pulumi
import pulumi_cloudflare as cloudflare

example_pipeline_sink = cloudflare.get_pipeline_sink(account_id="0123105f4ecef8ad9ca31a8372d0c353",
    sink_id="0223105f4ecef8ad9ca31a8372d0c353")

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.GetPipelineSink(ctx, &cloudflare.LookupPipelineSinkArgs{
			AccountId: pulumi.StringRef("0123105f4ecef8ad9ca31a8372d0c353"),
			SinkId:    pulumi.StringRef("0223105f4ecef8ad9ca31a8372d0c353"),
		}, 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 examplePipelineSink = Cloudflare.Index.GetPipelineSink.Invoke(new()
    {
        AccountId = "0123105f4ecef8ad9ca31a8372d0c353",
        SinkId = "0223105f4ecef8ad9ca31a8372d0c353",
    });

});

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.GetPipelineSinkArgs;
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 examplePipelineSink = CloudflareFunctions.getPipelineSink(GetPipelineSinkArgs.builder()
            .accountId("0123105f4ecef8ad9ca31a8372d0c353")
            .sinkId("0223105f4ecef8ad9ca31a8372d0c353")
            .build());

    }
}

variables:
  examplePipelineSink:
    fn::invoke:
      function: cloudflare:getPipelineSink
      arguments:
        accountId: 0123105f4ecef8ad9ca31a8372d0c353
        sinkId: 0223105f4ecef8ad9ca31a8372d0c353

Using getPipelineSink

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 getPipelineSink(args: GetPipelineSinkArgs, opts?: InvokeOptions): Promise<GetPipelineSinkResult>
function getPipelineSinkOutput(args: GetPipelineSinkOutputArgs, opts?: InvokeOptions): Output<GetPipelineSinkResult>

def get_pipeline_sink(account_id: Optional[str] = None,
                      filter: Optional[GetPipelineSinkFilter] = None,
                      sink_id: Optional[str] = None,
                      opts: Optional[InvokeOptions] = None) -> GetPipelineSinkResult
def get_pipeline_sink_output(account_id: Optional[pulumi.Input[str]] = None,
                      filter: Optional[pulumi.Input[GetPipelineSinkFilterArgs]] = None,
                      sink_id: Optional[pulumi.Input[str]] = None,
                      opts: Optional[InvokeOptions] = None) -> Output[GetPipelineSinkResult]

func LookupPipelineSink(ctx *Context, args *LookupPipelineSinkArgs, opts ...InvokeOption) (*LookupPipelineSinkResult, error)
func LookupPipelineSinkOutput(ctx *Context, args *LookupPipelineSinkOutputArgs, opts ...InvokeOption) LookupPipelineSinkResultOutput

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

public static class GetPipelineSink 
{
    public static Task<GetPipelineSinkResult> InvokeAsync(GetPipelineSinkArgs args, InvokeOptions? opts = null)
    public static Output<GetPipelineSinkResult> Invoke(GetPipelineSinkInvokeArgs args, InvokeOptions? opts = null)
}

public static CompletableFuture<GetPipelineSinkResult> getPipelineSink(GetPipelineSinkArgs args, InvokeOptions options)
public static Output<GetPipelineSinkResult> getPipelineSink(GetPipelineSinkArgs args, InvokeOptions options)

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

The following arguments are supported:

AccountId string: Specifies the public ID of the account.
Filter GetPipelineSinkFilter
SinkId string: Specifies the publid ID of the sink.

AccountId string: Specifies the public ID of the account.
Filter GetPipelineSinkFilter
SinkId string: Specifies the publid ID of the sink.

accountId String: Specifies the public ID of the account.
filter GetPipelineSinkFilter
sinkId String: Specifies the publid ID of the sink.

accountId string: Specifies the public ID of the account.
filter GetPipelineSinkFilter
sinkId string: Specifies the publid ID of the sink.

account_id str: Specifies the public ID of the account.
filter GetPipelineSinkFilter
sink_id str: Specifies the publid ID of the sink.

accountId String: Specifies the public ID of the account.
filter Property Map
sinkId String: Specifies the publid ID of the sink.