confluentcloud.getTableflowTopic

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

export = async () => {
    const example = await confluentcloud.getTableflowTopic({
        environment: {
            id: staging.id,
        },
        kafkaCluster: {
            id: stagingConfluentKafkaCluster.id,
        },
        displayName: "tableflow-example",
        credentials: {
            key: env_admin_tableflow_api_key.id,
            secret: env_admin_tableflow_api_key.secret,
        },
    });
    return {
        "retention-ms": example.retentionMs,
    };
}

import pulumi
import pulumi_confluentcloud as confluentcloud

example = confluentcloud.get_tableflow_topic(environment={
        "id": staging["id"],
    },
    kafka_cluster={
        "id": staging_confluent_kafka_cluster["id"],
    },
    display_name="tableflow-example",
    credentials={
        "key": env_admin_tableflow_api_key["id"],
        "secret": env_admin_tableflow_api_key["secret"],
    })
pulumi.export("retention-ms", example.retention_ms)

package main

import (
	"github.com/pulumi/pulumi-confluentcloud/sdk/v2/go/confluentcloud"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		example, err := confluentcloud.LookupTableflowTopic(ctx, &confluentcloud.LookupTableflowTopicArgs{
			Environment: confluentcloud.GetTableflowTopicEnvironment{
				Id: staging.Id,
			},
			KafkaCluster: confluentcloud.GetTableflowTopicKafkaCluster{
				Id: stagingConfluentKafkaCluster.Id,
			},
			DisplayName: "tableflow-example",
			Credentials: confluentcloud.GetTableflowTopicCredentials{
				Key:    env_admin_tableflow_api_key.Id,
				Secret: env_admin_tableflow_api_key.Secret,
			},
		}, nil)
		if err != nil {
			return err
		}
		ctx.Export("retention-ms", example.RetentionMs)
		return nil
	})
}

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

return await Deployment.RunAsync(() => 
{
    var example = ConfluentCloud.GetTableflowTopic.Invoke(new()
    {
        Environment = new ConfluentCloud.Inputs.GetTableflowTopicEnvironmentInputArgs
        {
            Id = staging.Id,
        },
        KafkaCluster = new ConfluentCloud.Inputs.GetTableflowTopicKafkaClusterInputArgs
        {
            Id = stagingConfluentKafkaCluster.Id,
        },
        DisplayName = "tableflow-example",
        Credentials = new ConfluentCloud.Inputs.GetTableflowTopicCredentialsInputArgs
        {
            Key = env_admin_tableflow_api_key.Id,
            Secret = env_admin_tableflow_api_key.Secret,
        },
    });

    return new Dictionary<string, object?>
    {
        ["retention-ms"] = example.Apply(getTableflowTopicResult => getTableflowTopicResult.RetentionMs),
    };
});

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.confluentcloud.ConfluentcloudFunctions;
import com.pulumi.confluentcloud.inputs.GetTableflowTopicArgs;
import com.pulumi.confluentcloud.inputs.GetTableflowTopicEnvironmentArgs;
import com.pulumi.confluentcloud.inputs.GetTableflowTopicKafkaClusterArgs;
import com.pulumi.confluentcloud.inputs.GetTableflowTopicCredentialsArgs;
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 example = ConfluentcloudFunctions.getTableflowTopic(GetTableflowTopicArgs.builder()
            .environment(GetTableflowTopicEnvironmentArgs.builder()
                .id(staging.id())
                .build())
            .kafkaCluster(GetTableflowTopicKafkaClusterArgs.builder()
                .id(stagingConfluentKafkaCluster.id())
                .build())
            .displayName("tableflow-example")
            .credentials(GetTableflowTopicCredentialsArgs.builder()
                .key(env_admin_tableflow_api_key.id())
                .secret(env_admin_tableflow_api_key.secret())
                .build())
            .build());

        ctx.export("retention-ms", example.applyValue(getTableflowTopicResult -> getTableflowTopicResult.retentionMs()));
    }
}

variables:
  example:
    fn::invoke:
      function: confluentcloud:getTableflowTopic
      arguments:
        environment:
          id: ${staging.id}
        kafkaCluster:
          id: ${stagingConfluentKafkaCluster.id}
        displayName: tableflow-example
        credentials:
          key: ${["env-admin-tableflow-api-key"].id}
          secret: ${["env-admin-tableflow-api-key"].secret}
outputs:
  retention-ms: ${example.retentionMs}

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

export = async () => {
    const example = await confluentcloud.getTableflowTopic({
        displayName: "tableflow-example",
    });
    return {
        "retention-ms": example.retentionMs,
    };
}

import pulumi
import pulumi_confluentcloud as confluentcloud

example = confluentcloud.get_tableflow_topic(display_name="tableflow-example")
pulumi.export("retention-ms", example.retention_ms)

package main

import (
	"github.com/pulumi/pulumi-confluentcloud/sdk/v2/go/confluentcloud"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		example, err := confluentcloud.LookupTableflowTopic(ctx, &confluentcloud.LookupTableflowTopicArgs{
			DisplayName: "tableflow-example",
		}, nil)
		if err != nil {
			return err
		}
		ctx.Export("retention-ms", example.RetentionMs)
		return nil
	})
}

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

return await Deployment.RunAsync(() => 
{
    var example = ConfluentCloud.GetTableflowTopic.Invoke(new()
    {
        DisplayName = "tableflow-example",
    });

    return new Dictionary<string, object?>
    {
        ["retention-ms"] = example.Apply(getTableflowTopicResult => getTableflowTopicResult.RetentionMs),
    };
});

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.confluentcloud.ConfluentcloudFunctions;
import com.pulumi.confluentcloud.inputs.GetTableflowTopicArgs;
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 example = ConfluentcloudFunctions.getTableflowTopic(GetTableflowTopicArgs.builder()
            .displayName("tableflow-example")
            .build());

        ctx.export("retention-ms", example.applyValue(getTableflowTopicResult -> getTableflowTopicResult.retentionMs()));
    }
}

variables:
  example:
    fn::invoke:
      function: confluentcloud:getTableflowTopic
      arguments:
        displayName: tableflow-example
outputs:
  retention-ms: ${example.retentionMs}

function getTableflowTopic(args: GetTableflowTopicArgs, opts?: InvokeOptions): Promise<GetTableflowTopicResult>
function getTableflowTopicOutput(args: GetTableflowTopicOutputArgs, opts?: InvokeOptions): Output<GetTableflowTopicResult>

def get_tableflow_topic(credentials: Optional[GetTableflowTopicCredentials] = None,
                        display_name: Optional[str] = None,
                        environment: Optional[GetTableflowTopicEnvironment] = None,
                        kafka_cluster: Optional[GetTableflowTopicKafkaCluster] = None,
                        opts: Optional[InvokeOptions] = None) -> GetTableflowTopicResult
def get_tableflow_topic_output(credentials: Optional[pulumi.Input[GetTableflowTopicCredentialsArgs]] = None,
                        display_name: Optional[pulumi.Input[str]] = None,
                        environment: Optional[pulumi.Input[GetTableflowTopicEnvironmentArgs]] = None,
                        kafka_cluster: Optional[pulumi.Input[GetTableflowTopicKafkaClusterArgs]] = None,
                        opts: Optional[InvokeOptions] = None) -> Output[GetTableflowTopicResult]

func LookupTableflowTopic(ctx *Context, args *LookupTableflowTopicArgs, opts ...InvokeOption) (*LookupTableflowTopicResult, error)
func LookupTableflowTopicOutput(ctx *Context, args *LookupTableflowTopicOutputArgs, opts ...InvokeOption) LookupTableflowTopicResultOutput

public static class GetTableflowTopic 
{
    public static Task<GetTableflowTopicResult> InvokeAsync(GetTableflowTopicArgs args, InvokeOptions? opts = null)
    public static Output<GetTableflowTopicResult> Invoke(GetTableflowTopicInvokeArgs args, InvokeOptions? opts = null)
}

public static CompletableFuture<GetTableflowTopicResult> getTableflowTopic(GetTableflowTopicArgs args, InvokeOptions options)
public static Output<GetTableflowTopicResult> getTableflowTopic(GetTableflowTopicArgs args, InvokeOptions options)

fn::invoke:
  function: confluentcloud:index/getTableflowTopic:getTableflowTopic
  arguments:
    # arguments dictionary