upstash

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 24, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Overview

A Pulumi package for creating and managing upstash cloud resources.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func PkgVersion 

func PkgVersion() (semver.Version, error)

PkgVersion uses reflection to determine the version of the current package. If a version cannot be determined, v1 will be assumed. The second return value is always nil.

Types

type KafkaCluster 

type KafkaCluster struct {
	pulumi.CustomResourceState

	// Unique Cluster ID for created cluster
	ClusterId pulumi.StringOutput `pulumi:"clusterId"`
	// Name of the cluster
	ClusterName pulumi.StringOutput `pulumi:"clusterName"`
	// Creation time of the cluster
	CreationTime pulumi.IntOutput `pulumi:"creationTime"`
	// Max Message Size for the cluster
	MaxMessageSize pulumi.IntOutput `pulumi:"maxMessageSize"`
	// Max Messages Per Second for the cluster
	MaxMessagesPerSecond pulumi.IntOutput `pulumi:"maxMessagesPerSecond"`
	// Max Partitions for the cluster
	MaxPartitions pulumi.IntOutput `pulumi:"maxPartitions"`
	// Max Retention Size of the cluster
	MaxRetentionSize pulumi.IntOutput `pulumi:"maxRetentionSize"`
	// Max Retention Time of the cluster
	MaxRetentionTime pulumi.IntOutput `pulumi:"maxRetentionTime"`
	// Whether cluster has multizone attribute
	Multizone pulumi.BoolPtrOutput `pulumi:"multizone"`
	// Password for the cluster
	Password pulumi.StringOutput `pulumi:"password"`
	// region of the cluster. Possible values (may change) are: "eu-west-1", "us-east-1"
	Region pulumi.StringOutput `pulumi:"region"`
	// REST Endpoint of the cluster
	RestEndpoint pulumi.StringOutput `pulumi:"restEndpoint"`
	// State, where the cluster is originated
	State pulumi.StringOutput `pulumi:"state"`
	// TCP Endpoint of the cluster
	TcpEndpoint pulumi.StringOutput `pulumi:"tcpEndpoint"`
	// Type of the cluster
	Type pulumi.StringOutput `pulumi:"type"`
	// Base64 encoded username for the cluster
	Username pulumi.StringOutput `pulumi:"username"`
}

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/upstash/pulumi-upstash/sdk/go/upstash"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := upstash.NewKafkaCluster(ctx, "exampleCluster", &upstash.KafkaClusterArgs{
			ClusterName: pulumi.String("TerraformCluster"),
			Multizone:   pulumi.Bool(false),
			Region:      pulumi.String("eu-west-1"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

func GetKafkaCluster 

func GetKafkaCluster(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *KafkaClusterState, opts ...pulumi.ResourceOption) (*KafkaCluster, error)

GetKafkaCluster gets an existing KafkaCluster resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewKafkaCluster 

func NewKafkaCluster(ctx *pulumi.Context,
	name string, args *KafkaClusterArgs, opts ...pulumi.ResourceOption) (*KafkaCluster, error)

NewKafkaCluster registers a new resource with the given unique name, arguments, and options.

func (*KafkaCluster) ElementType 

func (*KafkaCluster) ElementType() reflect.Type

func (*KafkaCluster) ToKafkaClusterOutput 

func (i *KafkaCluster) ToKafkaClusterOutput() KafkaClusterOutput

func (*KafkaCluster) ToKafkaClusterOutputWithContext 

func (i *KafkaCluster) ToKafkaClusterOutputWithContext(ctx context.Context) KafkaClusterOutput

type KafkaClusterArgs 

type KafkaClusterArgs struct {
	// Name of the cluster
	ClusterName pulumi.StringInput
	// Whether cluster has multizone attribute
	Multizone pulumi.BoolPtrInput
	// region of the cluster. Possible values (may change) are: "eu-west-1", "us-east-1"
	Region pulumi.StringInput
}

The set of arguments for constructing a KafkaCluster resource.

func (KafkaClusterArgs) ElementType 

func (KafkaClusterArgs) ElementType() reflect.Type

type KafkaClusterArray 

type KafkaClusterArray []KafkaClusterInput

func (KafkaClusterArray) ElementType 

func (KafkaClusterArray) ElementType() reflect.Type

func (KafkaClusterArray) ToKafkaClusterArrayOutput 

func (i KafkaClusterArray) ToKafkaClusterArrayOutput() KafkaClusterArrayOutput

func (KafkaClusterArray) ToKafkaClusterArrayOutputWithContext 

func (i KafkaClusterArray) ToKafkaClusterArrayOutputWithContext(ctx context.Context) KafkaClusterArrayOutput

type KafkaClusterArrayInput 

type KafkaClusterArrayInput interface {
	pulumi.Input

	ToKafkaClusterArrayOutput() KafkaClusterArrayOutput
	ToKafkaClusterArrayOutputWithContext(context.Context) KafkaClusterArrayOutput
}

KafkaClusterArrayInput is an input type that accepts KafkaClusterArray and KafkaClusterArrayOutput values. You can construct a concrete instance of `KafkaClusterArrayInput` via: 

KafkaClusterArray{ KafkaClusterArgs{...} }

type KafkaClusterArrayOutput 

type KafkaClusterArrayOutput struct{ *pulumi.OutputState }

func (KafkaClusterArrayOutput) ElementType 

func (KafkaClusterArrayOutput) ElementType() reflect.Type

func (KafkaClusterArrayOutput) Index 

func (o KafkaClusterArrayOutput) Index(i pulumi.IntInput) KafkaClusterOutput

func (KafkaClusterArrayOutput) ToKafkaClusterArrayOutput 

func (o KafkaClusterArrayOutput) ToKafkaClusterArrayOutput() KafkaClusterArrayOutput

func (KafkaClusterArrayOutput) ToKafkaClusterArrayOutputWithContext 

func (o KafkaClusterArrayOutput) ToKafkaClusterArrayOutputWithContext(ctx context.Context) KafkaClusterArrayOutput

type KafkaClusterInput 

type KafkaClusterInput interface {
	pulumi.Input

	ToKafkaClusterOutput() KafkaClusterOutput
	ToKafkaClusterOutputWithContext(ctx context.Context) KafkaClusterOutput
}

type KafkaClusterMap 

type KafkaClusterMap map[string]KafkaClusterInput

func (KafkaClusterMap) ElementType 

func (KafkaClusterMap) ElementType() reflect.Type

func (KafkaClusterMap) ToKafkaClusterMapOutput 

func (i KafkaClusterMap) ToKafkaClusterMapOutput() KafkaClusterMapOutput

func (KafkaClusterMap) ToKafkaClusterMapOutputWithContext 

func (i KafkaClusterMap) ToKafkaClusterMapOutputWithContext(ctx context.Context) KafkaClusterMapOutput

type KafkaClusterMapInput 

type KafkaClusterMapInput interface {
	pulumi.Input

	ToKafkaClusterMapOutput() KafkaClusterMapOutput
	ToKafkaClusterMapOutputWithContext(context.Context) KafkaClusterMapOutput
}

KafkaClusterMapInput is an input type that accepts KafkaClusterMap and KafkaClusterMapOutput values. You can construct a concrete instance of `KafkaClusterMapInput` via: 

KafkaClusterMap{ "key": KafkaClusterArgs{...} }

type KafkaClusterMapOutput 

type KafkaClusterMapOutput struct{ *pulumi.OutputState }

func (KafkaClusterMapOutput) ElementType 

func (KafkaClusterMapOutput) ElementType() reflect.Type

func (KafkaClusterMapOutput) MapIndex 

func (o KafkaClusterMapOutput) MapIndex(k pulumi.StringInput) KafkaClusterOutput

func (KafkaClusterMapOutput) ToKafkaClusterMapOutput 

func (o KafkaClusterMapOutput) ToKafkaClusterMapOutput() KafkaClusterMapOutput

func (KafkaClusterMapOutput) ToKafkaClusterMapOutputWithContext 

func (o KafkaClusterMapOutput) ToKafkaClusterMapOutputWithContext(ctx context.Context) KafkaClusterMapOutput

type KafkaClusterOutput 

type KafkaClusterOutput struct{ *pulumi.OutputState }

func (KafkaClusterOutput) ClusterId 

func (o KafkaClusterOutput) ClusterId() pulumi.StringOutput

Unique Cluster ID for created cluster

func (KafkaClusterOutput) ClusterName 

func (o KafkaClusterOutput) ClusterName() pulumi.StringOutput

Name of the cluster

func (KafkaClusterOutput) CreationTime 

func (o KafkaClusterOutput) CreationTime() pulumi.IntOutput

Creation time of the cluster

func (KafkaClusterOutput) ElementType 

func (KafkaClusterOutput) ElementType() reflect.Type

func (KafkaClusterOutput) MaxMessageSize 

func (o KafkaClusterOutput) MaxMessageSize() pulumi.IntOutput

Max Message Size for the cluster

func (KafkaClusterOutput) MaxMessagesPerSecond 

func (o KafkaClusterOutput) MaxMessagesPerSecond() pulumi.IntOutput

Max Messages Per Second for the cluster

func (KafkaClusterOutput) MaxPartitions 

func (o KafkaClusterOutput) MaxPartitions() pulumi.IntOutput

Max Partitions for the cluster

func (KafkaClusterOutput) MaxRetentionSize 

func (o KafkaClusterOutput) MaxRetentionSize() pulumi.IntOutput

Max Retention Size of the cluster

func (KafkaClusterOutput) MaxRetentionTime 

func (o KafkaClusterOutput) MaxRetentionTime() pulumi.IntOutput

Max Retention Time of the cluster

func (KafkaClusterOutput) Multizone 

func (o KafkaClusterOutput) Multizone() pulumi.BoolPtrOutput

Whether cluster has multizone attribute

func (KafkaClusterOutput) Password 

func (o KafkaClusterOutput) Password() pulumi.StringOutput

Password for the cluster

func (KafkaClusterOutput) Region 

func (o KafkaClusterOutput) Region() pulumi.StringOutput

region of the cluster. Possible values (may change) are: "eu-west-1", "us-east-1"

func (KafkaClusterOutput) RestEndpoint 

func (o KafkaClusterOutput) RestEndpoint() pulumi.StringOutput

REST Endpoint of the cluster

func (KafkaClusterOutput) State 

func (o KafkaClusterOutput) State() pulumi.StringOutput

State, where the cluster is originated

func (KafkaClusterOutput) TcpEndpoint 

func (o KafkaClusterOutput) TcpEndpoint() pulumi.StringOutput

TCP Endpoint of the cluster

func (KafkaClusterOutput) ToKafkaClusterOutput 

func (o KafkaClusterOutput) ToKafkaClusterOutput() KafkaClusterOutput

func (KafkaClusterOutput) ToKafkaClusterOutputWithContext 

func (o KafkaClusterOutput) ToKafkaClusterOutputWithContext(ctx context.Context) KafkaClusterOutput

func (KafkaClusterOutput) Type 

func (o KafkaClusterOutput) Type() pulumi.StringOutput

Type of the cluster

func (KafkaClusterOutput) Username 

func (o KafkaClusterOutput) Username() pulumi.StringOutput

Base64 encoded username for the cluster

type KafkaClusterState 

type KafkaClusterState struct {
	// Unique Cluster ID for created cluster
	ClusterId pulumi.StringPtrInput
	// Name of the cluster
	ClusterName pulumi.StringPtrInput
	// Creation time of the cluster
	CreationTime pulumi.IntPtrInput
	// Max Message Size for the cluster
	MaxMessageSize pulumi.IntPtrInput
	// Max Messages Per Second for the cluster
	MaxMessagesPerSecond pulumi.IntPtrInput
	// Max Partitions for the cluster
	MaxPartitions pulumi.IntPtrInput
	// Max Retention Size of the cluster
	MaxRetentionSize pulumi.IntPtrInput
	// Max Retention Time of the cluster
	MaxRetentionTime pulumi.IntPtrInput
	// Whether cluster has multizone attribute
	Multizone pulumi.BoolPtrInput
	// Password for the cluster
	Password pulumi.StringPtrInput
	// region of the cluster. Possible values (may change) are: "eu-west-1", "us-east-1"
	Region pulumi.StringPtrInput
	// REST Endpoint of the cluster
	RestEndpoint pulumi.StringPtrInput
	// State, where the cluster is originated
	State pulumi.StringPtrInput
	// TCP Endpoint of the cluster
	TcpEndpoint pulumi.StringPtrInput
	// Type of the cluster
	Type pulumi.StringPtrInput
	// Base64 encoded username for the cluster
	Username pulumi.StringPtrInput
}

func (KafkaClusterState) ElementType 

func (KafkaClusterState) ElementType() reflect.Type

type KafkaConnector added in v0.2.0 

type KafkaConnector struct {
	pulumi.CustomResourceState

	// Name of the connector
	ClusterId pulumi.StringOutput `pulumi:"clusterId"`
	// Unique Connector ID for created connector
	ConnectorId pulumi.StringOutput `pulumi:"connectorId"`
	// Creation of the connector
	CreationTime pulumi.IntOutput `pulumi:"creationTime"`
	// Name of the connector
	Name pulumi.StringOutput `pulumi:"name"`
	// Properties that the connector will have
	Properties pulumi.MapOutput `pulumi:"properties"`
	// Running state of the connector. Can be either 'paused', 'running' or 'restart'
	RunningState pulumi.StringPtrOutput `pulumi:"runningState"`
}

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/upstash/pulumi-upstash/sdk/go/upstash"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		exampleKafkaCluster, err := upstash.NewKafkaCluster(ctx, "exampleKafkaCluster", &upstash.KafkaClusterArgs{
			ClusterName: pulumi.String("Terraform_Upstash_Cluster"),
			Region:      pulumi.String("eu-west-1"),
			Multizone:   pulumi.Bool(false),
		})
		if err != nil {
			return err
		}
		exampleKafkaTopic, err := upstash.NewKafkaTopic(ctx, "exampleKafkaTopic", &upstash.KafkaTopicArgs{
			TopicName:      pulumi.String("TerraformTopic"),
			Partitions:     pulumi.Int(1),
			RetentionTime:  pulumi.Int(625135),
			RetentionSize:  pulumi.Int(725124),
			MaxMessageSize: pulumi.Int(829213),
			CleanupPolicy:  pulumi.String("delete"),
			ClusterId:      pulumi.Any(resource.Upstash_kafka_cluster.ExampleKafkaCluster.Cluster_id),
		})
		if err != nil {
			return err
		}
		_, err = upstash.NewKafkaConnector(ctx, "exampleKafkaConnector", &upstash.KafkaConnectorArgs{
			ClusterId: exampleKafkaCluster.ClusterId,
			Properties: pulumi.AnyMap{
				"collection":      pulumi.Any("user123"),
				"connection.uri":  pulumi.Any("mongodb+srv://test:test@cluster0.fohyg7p.mongodb.net/?retryWrites=true&w=majority"),
				"connector.class": pulumi.Any("com.mongodb.kafka.connect.MongoSourceConnector"),
				"database":        pulumi.Any("myshinynewdb2"),
				"topics":          exampleKafkaTopic.TopicName,
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

func GetKafkaConnector added in v0.2.0 

func GetKafkaConnector(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *KafkaConnectorState, opts ...pulumi.ResourceOption) (*KafkaConnector, error)

GetKafkaConnector gets an existing KafkaConnector resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewKafkaConnector added in v0.2.0 

func NewKafkaConnector(ctx *pulumi.Context,
	name string, args *KafkaConnectorArgs, opts ...pulumi.ResourceOption) (*KafkaConnector, error)

NewKafkaConnector registers a new resource with the given unique name, arguments, and options.

func (*KafkaConnector) ElementType added in v0.2.0 

func (*KafkaConnector) ElementType() reflect.Type

func (*KafkaConnector) ToKafkaConnectorOutput added in v0.2.0 

func (i *KafkaConnector) ToKafkaConnectorOutput() KafkaConnectorOutput

func (*KafkaConnector) ToKafkaConnectorOutputWithContext added in v0.2.0 

func (i *KafkaConnector) ToKafkaConnectorOutputWithContext(ctx context.Context) KafkaConnectorOutput

type KafkaConnectorArgs added in v0.2.0 

type KafkaConnectorArgs struct {
	// Name of the connector
	ClusterId pulumi.StringInput
	// Name of the connector
	Name pulumi.StringPtrInput
	// Properties that the connector will have
	Properties pulumi.MapInput
	// Running state of the connector. Can be either 'paused', 'running' or 'restart'
	RunningState pulumi.StringPtrInput
}

The set of arguments for constructing a KafkaConnector resource.

func (KafkaConnectorArgs) ElementType added in v0.2.0 

func (KafkaConnectorArgs) ElementType() reflect.Type

type KafkaConnectorArray added in v0.2.0 

type KafkaConnectorArray []KafkaConnectorInput

func (KafkaConnectorArray) ElementType added in v0.2.0 

func (KafkaConnectorArray) ElementType() reflect.Type

func (KafkaConnectorArray) ToKafkaConnectorArrayOutput added in v0.2.0 

func (i KafkaConnectorArray) ToKafkaConnectorArrayOutput() KafkaConnectorArrayOutput

func (KafkaConnectorArray) ToKafkaConnectorArrayOutputWithContext added in v0.2.0 

func (i KafkaConnectorArray) ToKafkaConnectorArrayOutputWithContext(ctx context.Context) KafkaConnectorArrayOutput

type KafkaConnectorArrayInput added in v0.2.0 

type KafkaConnectorArrayInput interface {
	pulumi.Input

	ToKafkaConnectorArrayOutput() KafkaConnectorArrayOutput
	ToKafkaConnectorArrayOutputWithContext(context.Context) KafkaConnectorArrayOutput
}

KafkaConnectorArrayInput is an input type that accepts KafkaConnectorArray and KafkaConnectorArrayOutput values. You can construct a concrete instance of `KafkaConnectorArrayInput` via: 

KafkaConnectorArray{ KafkaConnectorArgs{...} }

type KafkaConnectorArrayOutput added in v0.2.0 

type KafkaConnectorArrayOutput struct{ *pulumi.OutputState }

func (KafkaConnectorArrayOutput) ElementType added in v0.2.0 

func (KafkaConnectorArrayOutput) ElementType() reflect.Type

func (KafkaConnectorArrayOutput) Index added in v0.2.0 

func (o KafkaConnectorArrayOutput) Index(i pulumi.IntInput) KafkaConnectorOutput

func (KafkaConnectorArrayOutput) ToKafkaConnectorArrayOutput added in v0.2.0 

func (o KafkaConnectorArrayOutput) ToKafkaConnectorArrayOutput() KafkaConnectorArrayOutput

func (KafkaConnectorArrayOutput) ToKafkaConnectorArrayOutputWithContext added in v0.2.0 

func (o KafkaConnectorArrayOutput) ToKafkaConnectorArrayOutputWithContext(ctx context.Context) KafkaConnectorArrayOutput

type KafkaConnectorInput added in v0.2.0 

type KafkaConnectorInput interface {
	pulumi.Input

	ToKafkaConnectorOutput() KafkaConnectorOutput
	ToKafkaConnectorOutputWithContext(ctx context.Context) KafkaConnectorOutput
}

type KafkaConnectorMap added in v0.2.0 

type KafkaConnectorMap map[string]KafkaConnectorInput

func (KafkaConnectorMap) ElementType added in v0.2.0 

func (KafkaConnectorMap) ElementType() reflect.Type

func (KafkaConnectorMap) ToKafkaConnectorMapOutput added in v0.2.0 

func (i KafkaConnectorMap) ToKafkaConnectorMapOutput() KafkaConnectorMapOutput

func (KafkaConnectorMap) ToKafkaConnectorMapOutputWithContext added in v0.2.0 

func (i KafkaConnectorMap) ToKafkaConnectorMapOutputWithContext(ctx context.Context) KafkaConnectorMapOutput

type KafkaConnectorMapInput added in v0.2.0 

type KafkaConnectorMapInput interface {
	pulumi.Input

	ToKafkaConnectorMapOutput() KafkaConnectorMapOutput
	ToKafkaConnectorMapOutputWithContext(context.Context) KafkaConnectorMapOutput
}

KafkaConnectorMapInput is an input type that accepts KafkaConnectorMap and KafkaConnectorMapOutput values. You can construct a concrete instance of `KafkaConnectorMapInput` via: 

KafkaConnectorMap{ "key": KafkaConnectorArgs{...} }

type KafkaConnectorMapOutput added in v0.2.0 

type KafkaConnectorMapOutput struct{ *pulumi.OutputState }

func (KafkaConnectorMapOutput) ElementType added in v0.2.0 

func (KafkaConnectorMapOutput) ElementType() reflect.Type

func (KafkaConnectorMapOutput) MapIndex added in v0.2.0 

func (o KafkaConnectorMapOutput) MapIndex(k pulumi.StringInput) KafkaConnectorOutput

func (KafkaConnectorMapOutput) ToKafkaConnectorMapOutput added in v0.2.0 

func (o KafkaConnectorMapOutput) ToKafkaConnectorMapOutput() KafkaConnectorMapOutput

func (KafkaConnectorMapOutput) ToKafkaConnectorMapOutputWithContext added in v0.2.0 

func (o KafkaConnectorMapOutput) ToKafkaConnectorMapOutputWithContext(ctx context.Context) KafkaConnectorMapOutput

type KafkaConnectorOutput added in v0.2.0 

type KafkaConnectorOutput struct{ *pulumi.OutputState }

func (KafkaConnectorOutput) ClusterId added in v0.2.0 

func (o KafkaConnectorOutput) ClusterId() pulumi.StringOutput

Name of the connector

func (KafkaConnectorOutput) ConnectorId added in v0.2.0 

func (o KafkaConnectorOutput) ConnectorId() pulumi.StringOutput

Unique Connector ID for created connector

func (KafkaConnectorOutput) CreationTime added in v0.2.0 

func (o KafkaConnectorOutput) CreationTime() pulumi.IntOutput

Creation of the connector

func (KafkaConnectorOutput) ElementType added in v0.2.0 

func (KafkaConnectorOutput) ElementType() reflect.Type

func (KafkaConnectorOutput) Name added in v0.2.0 

func (o KafkaConnectorOutput) Name() pulumi.StringOutput

Name of the connector

func (KafkaConnectorOutput) Properties added in v0.2.0 

func (o KafkaConnectorOutput) Properties() pulumi.MapOutput

Properties that the connector will have

func (KafkaConnectorOutput) RunningState added in v0.2.0 

func (o KafkaConnectorOutput) RunningState() pulumi.StringPtrOutput

Running state of the connector. Can be either 'paused', 'running' or 'restart'

func (KafkaConnectorOutput) ToKafkaConnectorOutput added in v0.2.0 

func (o KafkaConnectorOutput) ToKafkaConnectorOutput() KafkaConnectorOutput

func (KafkaConnectorOutput) ToKafkaConnectorOutputWithContext added in v0.2.0 

func (o KafkaConnectorOutput) ToKafkaConnectorOutputWithContext(ctx context.Context) KafkaConnectorOutput

type KafkaConnectorState added in v0.2.0 

type KafkaConnectorState struct {
	// Name of the connector
	ClusterId pulumi.StringPtrInput
	// Unique Connector ID for created connector
	ConnectorId pulumi.StringPtrInput
	// Creation of the connector
	CreationTime pulumi.IntPtrInput
	// Name of the connector
	Name pulumi.StringPtrInput
	// Properties that the connector will have
	Properties pulumi.MapInput
	// Running state of the connector. Can be either 'paused', 'running' or 'restart'
	RunningState pulumi.StringPtrInput
}

func (KafkaConnectorState) ElementType added in v0.2.0 

func (KafkaConnectorState) ElementType() reflect.Type

type KafkaCredential 

type KafkaCredential struct {
	pulumi.CustomResourceState

	// ID of the kafka cluster
	ClusterId pulumi.StringOutput `pulumi:"clusterId"`
	// Creation time of the credential
	CreationTime pulumi.IntOutput `pulumi:"creationTime"`
	// Unique ID of the kafka credential
	CredentialId pulumi.StringOutput `pulumi:"credentialId"`
	// Name of the kafka credential
	CredentialName pulumi.StringOutput `pulumi:"credentialName"`
	// Password to be used in authenticating to the cluster
	Password pulumi.StringOutput `pulumi:"password"`
	// Permission scope given to the kafka credential
	Permissions pulumi.StringOutput `pulumi:"permissions"`
	// State of the credential(active or deleted)
	State pulumi.StringOutput `pulumi:"state"`
	// Name of the kafka topic
	Topic pulumi.StringOutput `pulumi:"topic"`
	// Username to be used for the kafka credential
	Username pulumi.StringOutput `pulumi:"username"`
}

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/upstash/pulumi-upstash/sdk/go/upstash"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		exampleKafkaCluster, err := upstash.NewKafkaCluster(ctx, "exampleKafkaCluster", &upstash.KafkaClusterArgs{
			ClusterName: pulumi.Any(_var.Cluster_name),
			Region:      pulumi.Any(_var.Region),
			Multizone:   pulumi.Any(_var.Multizone),
		})
		if err != nil {
			return err
		}
		exampleKafkaTopic, err := upstash.NewKafkaTopic(ctx, "exampleKafkaTopic", &upstash.KafkaTopicArgs{
			TopicName:      pulumi.Any(_var.Topic_name),
			Partitions:     pulumi.Any(_var.Partitions),
			RetentionTime:  pulumi.Any(_var.Retention_time),
			RetentionSize:  pulumi.Any(_var.Retention_size),
			MaxMessageSize: pulumi.Any(_var.Max_message_size),
			CleanupPolicy:  pulumi.Any(_var.Cleanup_policy),
			ClusterId:      pulumi.Any(resource.Upstash_kafka_cluster.ExampleKafkaCluster.Cluster_id),
		})
		if err != nil {
			return err
		}
		_, err = upstash.NewKafkaCredential(ctx, "exampleKafkaCredential", &upstash.KafkaCredentialArgs{
			ClusterId:      exampleKafkaCluster.ClusterId,
			CredentialName: pulumi.String("credentialFromTerraform"),
			Topic:          exampleKafkaTopic.TopicName,
			Permissions:    pulumi.String("ALL"),
		})
		if err != nil {
			return err
		}
		_, err = upstash.NewKafkaCredential(ctx, "exampleKafkaCredentialAllTopics", &upstash.KafkaCredentialArgs{
			ClusterId:      exampleKafkaCluster.ClusterId,
			CredentialName: pulumi.String("credentialFromTerraform"),
			Topic:          pulumi.String("*"),
			Permissions:    pulumi.String("ALL"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

func GetKafkaCredential 

func GetKafkaCredential(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *KafkaCredentialState, opts ...pulumi.ResourceOption) (*KafkaCredential, error)

GetKafkaCredential gets an existing KafkaCredential resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewKafkaCredential 

func NewKafkaCredential(ctx *pulumi.Context,
	name string, args *KafkaCredentialArgs, opts ...pulumi.ResourceOption) (*KafkaCredential, error)

NewKafkaCredential registers a new resource with the given unique name, arguments, and options.

func (*KafkaCredential) ElementType 

func (*KafkaCredential) ElementType() reflect.Type

func (*KafkaCredential) ToKafkaCredentialOutput 

func (i *KafkaCredential) ToKafkaCredentialOutput() KafkaCredentialOutput

func (*KafkaCredential) ToKafkaCredentialOutputWithContext 

func (i *KafkaCredential) ToKafkaCredentialOutputWithContext(ctx context.Context) KafkaCredentialOutput

type KafkaCredentialArgs 

type KafkaCredentialArgs struct {
	// ID of the kafka cluster
	ClusterId pulumi.StringInput
	// Name of the kafka credential
	CredentialName pulumi.StringInput
	// Permission scope given to the kafka credential
	Permissions pulumi.StringInput
	// Name of the kafka topic
	Topic pulumi.StringInput
}

The set of arguments for constructing a KafkaCredential resource.

func (KafkaCredentialArgs) ElementType 

func (KafkaCredentialArgs) ElementType() reflect.Type

type KafkaCredentialArray 

type KafkaCredentialArray []KafkaCredentialInput

func (KafkaCredentialArray) ElementType 

func (KafkaCredentialArray) ElementType() reflect.Type

func (KafkaCredentialArray) ToKafkaCredentialArrayOutput 

func (i KafkaCredentialArray) ToKafkaCredentialArrayOutput() KafkaCredentialArrayOutput

func (KafkaCredentialArray) ToKafkaCredentialArrayOutputWithContext 

func (i KafkaCredentialArray) ToKafkaCredentialArrayOutputWithContext(ctx context.Context) KafkaCredentialArrayOutput

type KafkaCredentialArrayInput 

type KafkaCredentialArrayInput interface {
	pulumi.Input

	ToKafkaCredentialArrayOutput() KafkaCredentialArrayOutput
	ToKafkaCredentialArrayOutputWithContext(context.Context) KafkaCredentialArrayOutput
}

KafkaCredentialArrayInput is an input type that accepts KafkaCredentialArray and KafkaCredentialArrayOutput values. You can construct a concrete instance of `KafkaCredentialArrayInput` via: 

KafkaCredentialArray{ KafkaCredentialArgs{...} }

type KafkaCredentialArrayOutput 

type KafkaCredentialArrayOutput struct{ *pulumi.OutputState }

func (KafkaCredentialArrayOutput) ElementType 

func (KafkaCredentialArrayOutput) ElementType() reflect.Type

func (KafkaCredentialArrayOutput) Index 

func (o KafkaCredentialArrayOutput) Index(i pulumi.IntInput) KafkaCredentialOutput

func (KafkaCredentialArrayOutput) ToKafkaCredentialArrayOutput 

func (o KafkaCredentialArrayOutput) ToKafkaCredentialArrayOutput() KafkaCredentialArrayOutput

func (KafkaCredentialArrayOutput) ToKafkaCredentialArrayOutputWithContext 

func (o KafkaCredentialArrayOutput) ToKafkaCredentialArrayOutputWithContext(ctx context.Context) KafkaCredentialArrayOutput

type KafkaCredentialInput 

type KafkaCredentialInput interface {
	pulumi.Input

	ToKafkaCredentialOutput() KafkaCredentialOutput
	ToKafkaCredentialOutputWithContext(ctx context.Context) KafkaCredentialOutput
}

type KafkaCredentialMap 

type KafkaCredentialMap map[string]KafkaCredentialInput

func (KafkaCredentialMap) ElementType 

func (KafkaCredentialMap) ElementType() reflect.Type

func (KafkaCredentialMap) ToKafkaCredentialMapOutput 

func (i KafkaCredentialMap) ToKafkaCredentialMapOutput() KafkaCredentialMapOutput

func (KafkaCredentialMap) ToKafkaCredentialMapOutputWithContext 

func (i KafkaCredentialMap) ToKafkaCredentialMapOutputWithContext(ctx context.Context) KafkaCredentialMapOutput

type KafkaCredentialMapInput 

type KafkaCredentialMapInput interface {
	pulumi.Input

	ToKafkaCredentialMapOutput() KafkaCredentialMapOutput
	ToKafkaCredentialMapOutputWithContext(context.Context) KafkaCredentialMapOutput
}

KafkaCredentialMapInput is an input type that accepts KafkaCredentialMap and KafkaCredentialMapOutput values. You can construct a concrete instance of `KafkaCredentialMapInput` via: 

KafkaCredentialMap{ "key": KafkaCredentialArgs{...} }

type KafkaCredentialMapOutput 

type KafkaCredentialMapOutput struct{ *pulumi.OutputState }

func (KafkaCredentialMapOutput) ElementType 

func (KafkaCredentialMapOutput) ElementType() reflect.Type

func (KafkaCredentialMapOutput) MapIndex 

func (o KafkaCredentialMapOutput) MapIndex(k pulumi.StringInput) KafkaCredentialOutput

func (KafkaCredentialMapOutput) ToKafkaCredentialMapOutput 

func (o KafkaCredentialMapOutput) ToKafkaCredentialMapOutput() KafkaCredentialMapOutput

func (KafkaCredentialMapOutput) ToKafkaCredentialMapOutputWithContext 

func (o KafkaCredentialMapOutput) ToKafkaCredentialMapOutputWithContext(ctx context.Context) KafkaCredentialMapOutput

type KafkaCredentialOutput 

type KafkaCredentialOutput struct{ *pulumi.OutputState }

func (KafkaCredentialOutput) ClusterId 

func (o KafkaCredentialOutput) ClusterId() pulumi.StringOutput

ID of the kafka cluster

func (KafkaCredentialOutput) CreationTime 

func (o KafkaCredentialOutput) CreationTime() pulumi.IntOutput

Creation time of the credential

func (KafkaCredentialOutput) CredentialId 

func (o KafkaCredentialOutput) CredentialId() pulumi.StringOutput

Unique ID of the kafka credential

func (KafkaCredentialOutput) CredentialName 

func (o KafkaCredentialOutput) CredentialName() pulumi.StringOutput

Name of the kafka credential

func (KafkaCredentialOutput) ElementType 

func (KafkaCredentialOutput) ElementType() reflect.Type

func (KafkaCredentialOutput) Password 

func (o KafkaCredentialOutput) Password() pulumi.StringOutput

Password to be used in authenticating to the cluster

func (KafkaCredentialOutput) Permissions 

func (o KafkaCredentialOutput) Permissions() pulumi.StringOutput

Permission scope given to the kafka credential

func (KafkaCredentialOutput) State 

func (o KafkaCredentialOutput) State() pulumi.StringOutput

State of the credential(active or deleted)

func (KafkaCredentialOutput) ToKafkaCredentialOutput 

func (o KafkaCredentialOutput) ToKafkaCredentialOutput() KafkaCredentialOutput

func (KafkaCredentialOutput) ToKafkaCredentialOutputWithContext 

func (o KafkaCredentialOutput) ToKafkaCredentialOutputWithContext(ctx context.Context) KafkaCredentialOutput

func (KafkaCredentialOutput) Topic 

func (o KafkaCredentialOutput) Topic() pulumi.StringOutput

Name of the kafka topic

func (KafkaCredentialOutput) Username 

func (o KafkaCredentialOutput) Username() pulumi.StringOutput

Username to be used for the kafka credential

type KafkaCredentialState 

type KafkaCredentialState struct {
	// ID of the kafka cluster
	ClusterId pulumi.StringPtrInput
	// Creation time of the credential
	CreationTime pulumi.IntPtrInput
	// Unique ID of the kafka credential
	CredentialId pulumi.StringPtrInput
	// Name of the kafka credential
	CredentialName pulumi.StringPtrInput
	// Password to be used in authenticating to the cluster
	Password pulumi.StringPtrInput
	// Permission scope given to the kafka credential
	Permissions pulumi.StringPtrInput
	// State of the credential(active or deleted)
	State pulumi.StringPtrInput
	// Name of the kafka topic
	Topic pulumi.StringPtrInput
	// Username to be used for the kafka credential
	Username pulumi.StringPtrInput
}

func (KafkaCredentialState) ElementType 

func (KafkaCredentialState) ElementType() reflect.Type

type KafkaTopic 

type KafkaTopic struct {
	pulumi.CustomResourceState

	// Cleanup policy will be used in the topic(compact or delete)
	CleanupPolicy pulumi.StringOutput `pulumi:"cleanupPolicy"`
	// ID of the cluster the topic will be deployed in
	ClusterId pulumi.StringOutput `pulumi:"clusterId"`
	// Creation time of the topic
	CreationTime pulumi.IntOutput `pulumi:"creationTime"`
	// Max message size in the topic
	MaxMessageSize pulumi.IntOutput `pulumi:"maxMessageSize"`
	// Whether multizone replication is enabled
	Multizone pulumi.BoolOutput `pulumi:"multizone"`
	// The number of partitions the topic will have
	Partitions pulumi.IntOutput `pulumi:"partitions"`
	// Password to be used in authenticating to the cluster
	Password pulumi.StringOutput `pulumi:"password"`
	// Region of the kafka topic
	Region pulumi.StringOutput `pulumi:"region"`
	// REST Endpoint of the kafka topic
	RestEndpoint pulumi.StringOutput `pulumi:"restEndpoint"`
	// Retention size of the messages in the topic
	RetentionSize pulumi.IntOutput `pulumi:"retentionSize"`
	// Retention time of messages in the topic
	RetentionTime pulumi.IntOutput `pulumi:"retentionTime"`
	// State of the kafka topic (active or deleted)
	State pulumi.StringOutput `pulumi:"state"`
	// TCP Endpoint of the kafka topic
	TcpEndpoint pulumi.StringOutput `pulumi:"tcpEndpoint"`
	// Unique Cluster ID for created topic
	TopicId pulumi.StringOutput `pulumi:"topicId"`
	// Name of the topic
	TopicName pulumi.StringOutput `pulumi:"topicName"`
	// Base64 encoded username to be used in authenticating to the cluster
	Username pulumi.StringOutput `pulumi:"username"`
}

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/upstash/pulumi-upstash/sdk/go/upstash"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := upstash.NewKafkaCluster(ctx, "exampleKafkaCluster", &upstash.KafkaClusterArgs{
			ClusterName: pulumi.String("Terraform_Upstash_Cluster"),
			Region:      pulumi.String("eu-west-1"),
			Multizone:   pulumi.Bool(false),
		})
		if err != nil {
			return err
		}
		_, err = upstash.NewKafkaTopic(ctx, "exampleKafkaTopic", &upstash.KafkaTopicArgs{
			TopicName:      pulumi.String("TerraformTopic"),
			Partitions:     pulumi.Int(1),
			RetentionTime:  pulumi.Int(625135),
			RetentionSize:  pulumi.Int(725124),
			MaxMessageSize: pulumi.Int(829213),
			CleanupPolicy:  pulumi.String("delete"),
			ClusterId:      pulumi.Any(resource.Upstash_kafka_cluster.ExampleKafkaCluster.Cluster_id),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

func GetKafkaTopic 

func GetKafkaTopic(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *KafkaTopicState, opts ...pulumi.ResourceOption) (*KafkaTopic, error)

GetKafkaTopic gets an existing KafkaTopic resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewKafkaTopic 

func NewKafkaTopic(ctx *pulumi.Context,
	name string, args *KafkaTopicArgs, opts ...pulumi.ResourceOption) (*KafkaTopic, error)

NewKafkaTopic registers a new resource with the given unique name, arguments, and options.

func (*KafkaTopic) ElementType 

func (*KafkaTopic) ElementType() reflect.Type

func (*KafkaTopic) ToKafkaTopicOutput 

func (i *KafkaTopic) ToKafkaTopicOutput() KafkaTopicOutput

func (*KafkaTopic) ToKafkaTopicOutputWithContext 

func (i *KafkaTopic) ToKafkaTopicOutputWithContext(ctx context.Context) KafkaTopicOutput

type KafkaTopicArgs 

type KafkaTopicArgs struct {
	// Cleanup policy will be used in the topic(compact or delete)
	CleanupPolicy pulumi.StringInput
	// ID of the cluster the topic will be deployed in
	ClusterId pulumi.StringInput
	// Max message size in the topic
	MaxMessageSize pulumi.IntInput
	// The number of partitions the topic will have
	Partitions pulumi.IntInput
	// Retention size of the messages in the topic
	RetentionSize pulumi.IntInput
	// Retention time of messages in the topic
	RetentionTime pulumi.IntInput
	// Name of the topic
	TopicName pulumi.StringInput
}

The set of arguments for constructing a KafkaTopic resource.

func (KafkaTopicArgs) ElementType 

func (KafkaTopicArgs) ElementType() reflect.Type

type KafkaTopicArray 

type KafkaTopicArray []KafkaTopicInput

func (KafkaTopicArray) ElementType 

func (KafkaTopicArray) ElementType() reflect.Type

func (KafkaTopicArray) ToKafkaTopicArrayOutput 

func (i KafkaTopicArray) ToKafkaTopicArrayOutput() KafkaTopicArrayOutput

func (KafkaTopicArray) ToKafkaTopicArrayOutputWithContext 

func (i KafkaTopicArray) ToKafkaTopicArrayOutputWithContext(ctx context.Context) KafkaTopicArrayOutput

type KafkaTopicArrayInput 

type KafkaTopicArrayInput interface {
	pulumi.Input

	ToKafkaTopicArrayOutput() KafkaTopicArrayOutput
	ToKafkaTopicArrayOutputWithContext(context.Context) KafkaTopicArrayOutput
}

KafkaTopicArrayInput is an input type that accepts KafkaTopicArray and KafkaTopicArrayOutput values. You can construct a concrete instance of `KafkaTopicArrayInput` via: 

KafkaTopicArray{ KafkaTopicArgs{...} }

type KafkaTopicArrayOutput 

type KafkaTopicArrayOutput struct{ *pulumi.OutputState }

func (KafkaTopicArrayOutput) ElementType 

func (KafkaTopicArrayOutput) ElementType() reflect.Type

func (KafkaTopicArrayOutput) Index 

func (o KafkaTopicArrayOutput) Index(i pulumi.IntInput) KafkaTopicOutput

func (KafkaTopicArrayOutput) ToKafkaTopicArrayOutput 

func (o KafkaTopicArrayOutput) ToKafkaTopicArrayOutput() KafkaTopicArrayOutput

func (KafkaTopicArrayOutput) ToKafkaTopicArrayOutputWithContext 

func (o KafkaTopicArrayOutput) ToKafkaTopicArrayOutputWithContext(ctx context.Context) KafkaTopicArrayOutput

type KafkaTopicInput 

type KafkaTopicInput interface {
	pulumi.Input

	ToKafkaTopicOutput() KafkaTopicOutput
	ToKafkaTopicOutputWithContext(ctx context.Context) KafkaTopicOutput
}

type KafkaTopicMap 

type KafkaTopicMap map[string]KafkaTopicInput

func (KafkaTopicMap) ElementType 

func (KafkaTopicMap) ElementType() reflect.Type

func (KafkaTopicMap) ToKafkaTopicMapOutput 

func (i KafkaTopicMap) ToKafkaTopicMapOutput() KafkaTopicMapOutput

func (KafkaTopicMap) ToKafkaTopicMapOutputWithContext 

func (i KafkaTopicMap) ToKafkaTopicMapOutputWithContext(ctx context.Context) KafkaTopicMapOutput

type KafkaTopicMapInput 

type KafkaTopicMapInput interface {
	pulumi.Input

	ToKafkaTopicMapOutput() KafkaTopicMapOutput
	ToKafkaTopicMapOutputWithContext(context.Context) KafkaTopicMapOutput
}

KafkaTopicMapInput is an input type that accepts KafkaTopicMap and KafkaTopicMapOutput values. You can construct a concrete instance of `KafkaTopicMapInput` via: 

KafkaTopicMap{ "key": KafkaTopicArgs{...} }

type KafkaTopicMapOutput 

type KafkaTopicMapOutput struct{ *pulumi.OutputState }

func (KafkaTopicMapOutput) ElementType 

func (KafkaTopicMapOutput) ElementType() reflect.Type

func (KafkaTopicMapOutput) MapIndex 

func (o KafkaTopicMapOutput) MapIndex(k pulumi.StringInput) KafkaTopicOutput

func (KafkaTopicMapOutput) ToKafkaTopicMapOutput 

func (o KafkaTopicMapOutput) ToKafkaTopicMapOutput() KafkaTopicMapOutput

func (KafkaTopicMapOutput) ToKafkaTopicMapOutputWithContext 

func (o KafkaTopicMapOutput) ToKafkaTopicMapOutputWithContext(ctx context.Context) KafkaTopicMapOutput

type KafkaTopicOutput 

type KafkaTopicOutput struct{ *pulumi.OutputState }

func (KafkaTopicOutput) CleanupPolicy 

func (o KafkaTopicOutput) CleanupPolicy() pulumi.StringOutput

Cleanup policy will be used in the topic(compact or delete)

func (KafkaTopicOutput) ClusterId 

func (o KafkaTopicOutput) ClusterId() pulumi.StringOutput

ID of the cluster the topic will be deployed in

func (KafkaTopicOutput) CreationTime 

func (o KafkaTopicOutput) CreationTime() pulumi.IntOutput

Creation time of the topic

func (KafkaTopicOutput) ElementType 

func (KafkaTopicOutput) ElementType() reflect.Type

func (KafkaTopicOutput) MaxMessageSize 

func (o KafkaTopicOutput) MaxMessageSize() pulumi.IntOutput

Max message size in the topic

func (KafkaTopicOutput) Multizone 

func (o KafkaTopicOutput) Multizone() pulumi.BoolOutput

Whether multizone replication is enabled

func (KafkaTopicOutput) Partitions 

func (o KafkaTopicOutput) Partitions() pulumi.IntOutput

The number of partitions the topic will have

func (KafkaTopicOutput) Password 

func (o KafkaTopicOutput) Password() pulumi.StringOutput

Password to be used in authenticating to the cluster

func (KafkaTopicOutput) Region 

func (o KafkaTopicOutput) Region() pulumi.StringOutput

Region of the kafka topic

func (KafkaTopicOutput) RestEndpoint 

func (o KafkaTopicOutput) RestEndpoint() pulumi.StringOutput

REST Endpoint of the kafka topic

func (KafkaTopicOutput) RetentionSize 

func (o KafkaTopicOutput) RetentionSize() pulumi.IntOutput

Retention size of the messages in the topic

func (KafkaTopicOutput) RetentionTime 

func (o KafkaTopicOutput) RetentionTime() pulumi.IntOutput

Retention time of messages in the topic

func (KafkaTopicOutput) State 

func (o KafkaTopicOutput) State() pulumi.StringOutput

State of the kafka topic (active or deleted)

func (KafkaTopicOutput) TcpEndpoint 

func (o KafkaTopicOutput) TcpEndpoint() pulumi.StringOutput

TCP Endpoint of the kafka topic

func (KafkaTopicOutput) ToKafkaTopicOutput 

func (o KafkaTopicOutput) ToKafkaTopicOutput() KafkaTopicOutput

func (KafkaTopicOutput) ToKafkaTopicOutputWithContext 

func (o KafkaTopicOutput) ToKafkaTopicOutputWithContext(ctx context.Context) KafkaTopicOutput

func (KafkaTopicOutput) TopicId 

func (o KafkaTopicOutput) TopicId() pulumi.StringOutput

Unique Cluster ID for created topic

func (KafkaTopicOutput) TopicName 

func (o KafkaTopicOutput) TopicName() pulumi.StringOutput

Name of the topic

func (KafkaTopicOutput) Username 

func (o KafkaTopicOutput) Username() pulumi.StringOutput

Base64 encoded username to be used in authenticating to the cluster

type KafkaTopicState 

type KafkaTopicState struct {
	// Cleanup policy will be used in the topic(compact or delete)
	CleanupPolicy pulumi.StringPtrInput
	// ID of the cluster the topic will be deployed in
	ClusterId pulumi.StringPtrInput
	// Creation time of the topic
	CreationTime pulumi.IntPtrInput
	// Max message size in the topic
	MaxMessageSize pulumi.IntPtrInput
	// Whether multizone replication is enabled
	Multizone pulumi.BoolPtrInput
	// The number of partitions the topic will have
	Partitions pulumi.IntPtrInput
	// Password to be used in authenticating to the cluster
	Password pulumi.StringPtrInput
	// Region of the kafka topic
	Region pulumi.StringPtrInput
	// REST Endpoint of the kafka topic
	RestEndpoint pulumi.StringPtrInput
	// Retention size of the messages in the topic
	RetentionSize pulumi.IntPtrInput
	// Retention time of messages in the topic
	RetentionTime pulumi.IntPtrInput
	// State of the kafka topic (active or deleted)
	State pulumi.StringPtrInput
	// TCP Endpoint of the kafka topic
	TcpEndpoint pulumi.StringPtrInput
	// Unique Cluster ID for created topic
	TopicId pulumi.StringPtrInput
	// Name of the topic
	TopicName pulumi.StringPtrInput
	// Base64 encoded username to be used in authenticating to the cluster
	Username pulumi.StringPtrInput
}

func (KafkaTopicState) ElementType 

func (KafkaTopicState) ElementType() reflect.Type

type LookupKafkaClusterArgs 

type LookupKafkaClusterArgs struct {
	ClusterId string `pulumi:"clusterId"`
}

A collection of arguments for invoking getKafkaCluster.

type LookupKafkaClusterOutputArgs 

type LookupKafkaClusterOutputArgs struct {
	ClusterId pulumi.StringInput `pulumi:"clusterId"`
}

A collection of arguments for invoking getKafkaCluster.

func (LookupKafkaClusterOutputArgs) ElementType 

func (LookupKafkaClusterOutputArgs) ElementType() reflect.Type

type LookupKafkaClusterResult 

type LookupKafkaClusterResult struct {
	ClusterId    string `pulumi:"clusterId"`
	ClusterName  string `pulumi:"clusterName"`
	CreationTime int    `pulumi:"creationTime"`
	// The provider-assigned unique ID for this managed resource.
	Id                   string `pulumi:"id"`
	MaxMessageSize       int    `pulumi:"maxMessageSize"`
	MaxMessagesPerSecond int    `pulumi:"maxMessagesPerSecond"`
	MaxPartitions        int    `pulumi:"maxPartitions"`
	MaxRetentionSize     int    `pulumi:"maxRetentionSize"`
	MaxRetentionTime     int    `pulumi:"maxRetentionTime"`
	Multizone            bool   `pulumi:"multizone"`
	Password             string `pulumi:"password"`
	Region               string `pulumi:"region"`
	RestEndpoint         string `pulumi:"restEndpoint"`
	State                string `pulumi:"state"`
	TcpEndpoint          string `pulumi:"tcpEndpoint"`
	Type                 string `pulumi:"type"`
	Username             string `pulumi:"username"`
}

A collection of values returned by getKafkaCluster.

func LookupKafkaCluster 

func LookupKafkaCluster(ctx *pulumi.Context, args *LookupKafkaClusterArgs, opts ...pulumi.InvokeOption) (*LookupKafkaClusterResult, error)

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-upstash/sdk/go/upstash"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/upstash/pulumi-upstash/sdk/go/upstash"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := upstash.LookupKafkaCluster(ctx, &GetKafkaClusterArgs{
			ClusterId: resource.Upstash_kafka_cluster.ExampleCluster.Cluster_id,
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type LookupKafkaClusterResultOutput 

type LookupKafkaClusterResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getKafkaCluster.

func LookupKafkaClusterOutput 

func LookupKafkaClusterOutput(ctx *pulumi.Context, args LookupKafkaClusterOutputArgs, opts ...pulumi.InvokeOption) LookupKafkaClusterResultOutput

func (LookupKafkaClusterResultOutput) ClusterId 

func (o LookupKafkaClusterResultOutput) ClusterId() pulumi.StringOutput

func (LookupKafkaClusterResultOutput) ClusterName 

func (o LookupKafkaClusterResultOutput) ClusterName() pulumi.StringOutput

func (LookupKafkaClusterResultOutput) CreationTime 

func (o LookupKafkaClusterResultOutput) CreationTime() pulumi.IntOutput

func (LookupKafkaClusterResultOutput) ElementType 

func (LookupKafkaClusterResultOutput) ElementType() reflect.Type

func (LookupKafkaClusterResultOutput) Id 

func (o LookupKafkaClusterResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (LookupKafkaClusterResultOutput) MaxMessageSize 

func (o LookupKafkaClusterResultOutput) MaxMessageSize() pulumi.IntOutput

func (LookupKafkaClusterResultOutput) MaxMessagesPerSecond 

func (o LookupKafkaClusterResultOutput) MaxMessagesPerSecond() pulumi.IntOutput

func (LookupKafkaClusterResultOutput) MaxPartitions 

func (o LookupKafkaClusterResultOutput) MaxPartitions() pulumi.IntOutput

func (LookupKafkaClusterResultOutput) MaxRetentionSize 

func (o LookupKafkaClusterResultOutput) MaxRetentionSize() pulumi.IntOutput

func (LookupKafkaClusterResultOutput) MaxRetentionTime 

func (o LookupKafkaClusterResultOutput) MaxRetentionTime() pulumi.IntOutput

func (LookupKafkaClusterResultOutput) Multizone 

func (o LookupKafkaClusterResultOutput) Multizone() pulumi.BoolOutput

func (LookupKafkaClusterResultOutput) Password 

func (o LookupKafkaClusterResultOutput) Password() pulumi.StringOutput

func (LookupKafkaClusterResultOutput) Region 

func (o LookupKafkaClusterResultOutput) Region() pulumi.StringOutput

func (LookupKafkaClusterResultOutput) RestEndpoint 

func (o LookupKafkaClusterResultOutput) RestEndpoint() pulumi.StringOutput

func (LookupKafkaClusterResultOutput) State 

func (o LookupKafkaClusterResultOutput) State() pulumi.StringOutput

func (LookupKafkaClusterResultOutput) TcpEndpoint 

func (o LookupKafkaClusterResultOutput) TcpEndpoint() pulumi.StringOutput

func (LookupKafkaClusterResultOutput) ToLookupKafkaClusterResultOutput 

func (o LookupKafkaClusterResultOutput) ToLookupKafkaClusterResultOutput() LookupKafkaClusterResultOutput

func (LookupKafkaClusterResultOutput) ToLookupKafkaClusterResultOutputWithContext 

func (o LookupKafkaClusterResultOutput) ToLookupKafkaClusterResultOutputWithContext(ctx context.Context) LookupKafkaClusterResultOutput

func (LookupKafkaClusterResultOutput) Type 

func (o LookupKafkaClusterResultOutput) Type() pulumi.StringOutput

func (LookupKafkaClusterResultOutput) Username 

func (o LookupKafkaClusterResultOutput) Username() pulumi.StringOutput

type LookupKafkaConnectorArgs added in v0.2.0 

type LookupKafkaConnectorArgs struct {
	ConnectorId string `pulumi:"connectorId"`
}

A collection of arguments for invoking getKafkaConnector.

type LookupKafkaConnectorOutputArgs added in v0.2.0 

type LookupKafkaConnectorOutputArgs struct {
	ConnectorId pulumi.StringInput `pulumi:"connectorId"`
}

A collection of arguments for invoking getKafkaConnector.

func (LookupKafkaConnectorOutputArgs) ElementType added in v0.2.0 

func (LookupKafkaConnectorOutputArgs) ElementType() reflect.Type

type LookupKafkaConnectorResult added in v0.2.0 

type LookupKafkaConnectorResult struct {
	ClusterId       string `pulumi:"clusterId"`
	ConnectorClass  string `pulumi:"connectorClass"`
	ConnectorId     string `pulumi:"connectorId"`
	ConnectorState  string `pulumi:"connectorState"`
	CreationTime    int    `pulumi:"creationTime"`
	EncodedUsername string `pulumi:"encodedUsername"`
	// The provider-assigned unique ID for this managed resource.
	Id                  string                   `pulumi:"id"`
	Name                string                   `pulumi:"name"`
	Properties          map[string]interface{}   `pulumi:"properties"`
	PropertiesEncrypted string                   `pulumi:"propertiesEncrypted"`
	State               string                   `pulumi:"state"`
	StateErrorMessage   string                   `pulumi:"stateErrorMessage"`
	Tasks               []map[string]interface{} `pulumi:"tasks"`
	Topics              []string                 `pulumi:"topics"`
	Ttl                 int                      `pulumi:"ttl"`
	UserPassword        string                   `pulumi:"userPassword"`
}

A collection of values returned by getKafkaConnector.

func LookupKafkaConnector added in v0.2.0 

func LookupKafkaConnector(ctx *pulumi.Context, args *LookupKafkaConnectorArgs, opts ...pulumi.InvokeOption) (*LookupKafkaConnectorResult, error)

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-upstash/sdk/go/upstash"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/upstash/pulumi-upstash/sdk/go/upstash"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := upstash.LookupKafkaConnector(ctx, &GetKafkaConnectorArgs{
			TopicId: resource.Upstash_kafka_connector.ExampleKafkaConnector.Connector_id,
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type LookupKafkaConnectorResultOutput added in v0.2.0 

type LookupKafkaConnectorResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getKafkaConnector.

func LookupKafkaConnectorOutput added in v0.2.0 

func LookupKafkaConnectorOutput(ctx *pulumi.Context, args LookupKafkaConnectorOutputArgs, opts ...pulumi.InvokeOption) LookupKafkaConnectorResultOutput

func (LookupKafkaConnectorResultOutput) ClusterId added in v0.2.0 

func (o LookupKafkaConnectorResultOutput) ClusterId() pulumi.StringOutput

func (LookupKafkaConnectorResultOutput) ConnectorClass added in v0.2.0 

func (o LookupKafkaConnectorResultOutput) ConnectorClass() pulumi.StringOutput

func (LookupKafkaConnectorResultOutput) ConnectorId added in v0.2.0 

func (o LookupKafkaConnectorResultOutput) ConnectorId() pulumi.StringOutput

func (LookupKafkaConnectorResultOutput) ConnectorState added in v0.2.0 

func (o LookupKafkaConnectorResultOutput) ConnectorState() pulumi.StringOutput

func (LookupKafkaConnectorResultOutput) CreationTime added in v0.2.0 

func (o LookupKafkaConnectorResultOutput) CreationTime() pulumi.IntOutput

func (LookupKafkaConnectorResultOutput) ElementType added in v0.2.0 

func (LookupKafkaConnectorResultOutput) ElementType() reflect.Type

func (LookupKafkaConnectorResultOutput) EncodedUsername added in v0.2.0 

func (o LookupKafkaConnectorResultOutput) EncodedUsername() pulumi.StringOutput

func (LookupKafkaConnectorResultOutput) Id added in v0.2.0 

func (o LookupKafkaConnectorResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (LookupKafkaConnectorResultOutput) Name added in v0.2.0 

func (o LookupKafkaConnectorResultOutput) Name() pulumi.StringOutput

func (LookupKafkaConnectorResultOutput) Properties added in v0.2.0 

func (o LookupKafkaConnectorResultOutput) Properties() pulumi.MapOutput

func (LookupKafkaConnectorResultOutput) PropertiesEncrypted added in v0.2.0 

func (o LookupKafkaConnectorResultOutput) PropertiesEncrypted() pulumi.StringOutput

func (LookupKafkaConnectorResultOutput) State added in v0.2.0 

func (o LookupKafkaConnectorResultOutput) State() pulumi.StringOutput

func (LookupKafkaConnectorResultOutput) StateErrorMessage added in v0.2.0 

func (o LookupKafkaConnectorResultOutput) StateErrorMessage() pulumi.StringOutput

func (LookupKafkaConnectorResultOutput) Tasks added in v0.2.0 

func (o LookupKafkaConnectorResultOutput) Tasks() pulumi.MapArrayOutput

func (LookupKafkaConnectorResultOutput) ToLookupKafkaConnectorResultOutput added in v0.2.0 

func (o LookupKafkaConnectorResultOutput) ToLookupKafkaConnectorResultOutput() LookupKafkaConnectorResultOutput

func (LookupKafkaConnectorResultOutput) ToLookupKafkaConnectorResultOutputWithContext added in v0.2.0 

func (o LookupKafkaConnectorResultOutput) ToLookupKafkaConnectorResultOutputWithContext(ctx context.Context) LookupKafkaConnectorResultOutput

func (LookupKafkaConnectorResultOutput) Topics added in v0.2.0 

func (o LookupKafkaConnectorResultOutput) Topics() pulumi.StringArrayOutput

func (LookupKafkaConnectorResultOutput) Ttl added in v0.2.0 

func (o LookupKafkaConnectorResultOutput) Ttl() pulumi.IntOutput

func (LookupKafkaConnectorResultOutput) UserPassword added in v0.2.0 

func (o LookupKafkaConnectorResultOutput) UserPassword() pulumi.StringOutput

type LookupKafkaCredentialArgs 

type LookupKafkaCredentialArgs struct {
	CredentialId string `pulumi:"credentialId"`
}

A collection of arguments for invoking getKafkaCredential.

type LookupKafkaCredentialOutputArgs 

type LookupKafkaCredentialOutputArgs struct {
	CredentialId pulumi.StringInput `pulumi:"credentialId"`
}

A collection of arguments for invoking getKafkaCredential.

func (LookupKafkaCredentialOutputArgs) ElementType 

func (LookupKafkaCredentialOutputArgs) ElementType() reflect.Type

type LookupKafkaCredentialResult 

type LookupKafkaCredentialResult struct {
	ClusterId      string `pulumi:"clusterId"`
	CreationTime   int    `pulumi:"creationTime"`
	CredentialId   string `pulumi:"credentialId"`
	CredentialName string `pulumi:"credentialName"`
	// The provider-assigned unique ID for this managed resource.
	Id          string `pulumi:"id"`
	Password    string `pulumi:"password"`
	Permissions string `pulumi:"permissions"`
	State       string `pulumi:"state"`
	Topic       string `pulumi:"topic"`
	Username    string `pulumi:"username"`
}

A collection of values returned by getKafkaCredential.

func LookupKafkaCredential 

func LookupKafkaCredential(ctx *pulumi.Context, args *LookupKafkaCredentialArgs, opts ...pulumi.InvokeOption) (*LookupKafkaCredentialResult, error)

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-upstash/sdk/go/upstash"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/upstash/pulumi-upstash/sdk/go/upstash"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := upstash.LookupKafkaCredential(ctx, &GetKafkaCredentialArgs{
			CredentialId: upstash_kafka_credential.ExampleKafkaCredential.Credential_id,
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type LookupKafkaCredentialResultOutput 

type LookupKafkaCredentialResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getKafkaCredential.

func LookupKafkaCredentialOutput 

func LookupKafkaCredentialOutput(ctx *pulumi.Context, args LookupKafkaCredentialOutputArgs, opts ...pulumi.InvokeOption) LookupKafkaCredentialResultOutput

func (LookupKafkaCredentialResultOutput) ClusterId 

func (o LookupKafkaCredentialResultOutput) ClusterId() pulumi.StringOutput

func (LookupKafkaCredentialResultOutput) CreationTime 

func (o LookupKafkaCredentialResultOutput) CreationTime() pulumi.IntOutput

func (LookupKafkaCredentialResultOutput) CredentialId 

func (o LookupKafkaCredentialResultOutput) CredentialId() pulumi.StringOutput

func (LookupKafkaCredentialResultOutput) CredentialName 

func (o LookupKafkaCredentialResultOutput) CredentialName() pulumi.StringOutput

func (LookupKafkaCredentialResultOutput) ElementType 

func (LookupKafkaCredentialResultOutput) ElementType() reflect.Type

func (LookupKafkaCredentialResultOutput) Id 

func (o LookupKafkaCredentialResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (LookupKafkaCredentialResultOutput) Password 

func (o LookupKafkaCredentialResultOutput) Password() pulumi.StringOutput

func (LookupKafkaCredentialResultOutput) Permissions 

func (o LookupKafkaCredentialResultOutput) Permissions() pulumi.StringOutput

func (LookupKafkaCredentialResultOutput) State 

func (o LookupKafkaCredentialResultOutput) State() pulumi.StringOutput

func (LookupKafkaCredentialResultOutput) ToLookupKafkaCredentialResultOutput 

func (o LookupKafkaCredentialResultOutput) ToLookupKafkaCredentialResultOutput() LookupKafkaCredentialResultOutput

func (LookupKafkaCredentialResultOutput) ToLookupKafkaCredentialResultOutputWithContext 

func (o LookupKafkaCredentialResultOutput) ToLookupKafkaCredentialResultOutputWithContext(ctx context.Context) LookupKafkaCredentialResultOutput

func (LookupKafkaCredentialResultOutput) Topic 

func (o LookupKafkaCredentialResultOutput) Topic() pulumi.StringOutput

func (LookupKafkaCredentialResultOutput) Username 

func (o LookupKafkaCredentialResultOutput) Username() pulumi.StringOutput

type LookupKafkaTopicArgs 

type LookupKafkaTopicArgs struct {
	TopicId string `pulumi:"topicId"`
}

A collection of arguments for invoking getKafkaTopic.

type LookupKafkaTopicOutputArgs 

type LookupKafkaTopicOutputArgs struct {
	TopicId pulumi.StringInput `pulumi:"topicId"`
}

A collection of arguments for invoking getKafkaTopic.

func (LookupKafkaTopicOutputArgs) ElementType 

func (LookupKafkaTopicOutputArgs) ElementType() reflect.Type

type LookupKafkaTopicResult 

type LookupKafkaTopicResult struct {
	CleanupPolicy string `pulumi:"cleanupPolicy"`
	ClusterId     string `pulumi:"clusterId"`
	CreationTime  int    `pulumi:"creationTime"`
	// The provider-assigned unique ID for this managed resource.
	Id             string `pulumi:"id"`
	MaxMessageSize int    `pulumi:"maxMessageSize"`
	Multizone      bool   `pulumi:"multizone"`
	Partitions     int    `pulumi:"partitions"`
	Password       string `pulumi:"password"`
	Region         string `pulumi:"region"`
	RestEndpoint   string `pulumi:"restEndpoint"`
	RetentionSize  int    `pulumi:"retentionSize"`
	RetentionTime  int    `pulumi:"retentionTime"`
	State          string `pulumi:"state"`
	TcpEndpoint    string `pulumi:"tcpEndpoint"`
	TopicId        string `pulumi:"topicId"`
	TopicName      string `pulumi:"topicName"`
	Username       string `pulumi:"username"`
}

A collection of values returned by getKafkaTopic.

func LookupKafkaTopic 

func LookupKafkaTopic(ctx *pulumi.Context, args *LookupKafkaTopicArgs, opts ...pulumi.InvokeOption) (*LookupKafkaTopicResult, error)

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-upstash/sdk/go/upstash"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/upstash/pulumi-upstash/sdk/go/upstash"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := upstash.LookupKafkaTopic(ctx, &GetKafkaTopicArgs{
			TopicId: resource.Upstash_kafka_topic.ExampleKafkaTopic.Topic_id,
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type LookupKafkaTopicResultOutput 

type LookupKafkaTopicResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getKafkaTopic.

func LookupKafkaTopicOutput 

func LookupKafkaTopicOutput(ctx *pulumi.Context, args LookupKafkaTopicOutputArgs, opts ...pulumi.InvokeOption) LookupKafkaTopicResultOutput

func (LookupKafkaTopicResultOutput) CleanupPolicy 

func (o LookupKafkaTopicResultOutput) CleanupPolicy() pulumi.StringOutput

func (LookupKafkaTopicResultOutput) ClusterId 

func (o LookupKafkaTopicResultOutput) ClusterId() pulumi.StringOutput

func (LookupKafkaTopicResultOutput) CreationTime 

func (o LookupKafkaTopicResultOutput) CreationTime() pulumi.IntOutput

func (LookupKafkaTopicResultOutput) ElementType 

func (LookupKafkaTopicResultOutput) ElementType() reflect.Type

func (LookupKafkaTopicResultOutput) Id 

func (o LookupKafkaTopicResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (LookupKafkaTopicResultOutput) MaxMessageSize 

func (o LookupKafkaTopicResultOutput) MaxMessageSize() pulumi.IntOutput

func (LookupKafkaTopicResultOutput) Multizone 

func (o LookupKafkaTopicResultOutput) Multizone() pulumi.BoolOutput

func (LookupKafkaTopicResultOutput) Partitions 

func (o LookupKafkaTopicResultOutput) Partitions() pulumi.IntOutput

func (LookupKafkaTopicResultOutput) Password 

func (o LookupKafkaTopicResultOutput) Password() pulumi.StringOutput

func (LookupKafkaTopicResultOutput) Region 

func (o LookupKafkaTopicResultOutput) Region() pulumi.StringOutput

func (LookupKafkaTopicResultOutput) RestEndpoint 

func (o LookupKafkaTopicResultOutput) RestEndpoint() pulumi.StringOutput

func (LookupKafkaTopicResultOutput) RetentionSize 

func (o LookupKafkaTopicResultOutput) RetentionSize() pulumi.IntOutput

func (LookupKafkaTopicResultOutput) RetentionTime 

func (o LookupKafkaTopicResultOutput) RetentionTime() pulumi.IntOutput

func (LookupKafkaTopicResultOutput) State 

func (o LookupKafkaTopicResultOutput) State() pulumi.StringOutput

func (LookupKafkaTopicResultOutput) TcpEndpoint 

func (o LookupKafkaTopicResultOutput) TcpEndpoint() pulumi.StringOutput

func (LookupKafkaTopicResultOutput) ToLookupKafkaTopicResultOutput 

func (o LookupKafkaTopicResultOutput) ToLookupKafkaTopicResultOutput() LookupKafkaTopicResultOutput

func (LookupKafkaTopicResultOutput) ToLookupKafkaTopicResultOutputWithContext 

func (o LookupKafkaTopicResultOutput) ToLookupKafkaTopicResultOutputWithContext(ctx context.Context) LookupKafkaTopicResultOutput

func (LookupKafkaTopicResultOutput) TopicId 

func (o LookupKafkaTopicResultOutput) TopicId() pulumi.StringOutput

func (LookupKafkaTopicResultOutput) TopicName 

func (o LookupKafkaTopicResultOutput) TopicName() pulumi.StringOutput

func (LookupKafkaTopicResultOutput) Username 

func (o LookupKafkaTopicResultOutput) Username() pulumi.StringOutput

type LookupQStashEndpointArgs 

type LookupQStashEndpointArgs struct {
	TopicId string `pulumi:"topicId"`
}

A collection of arguments for invoking getQStashEndpoint.

type LookupQStashEndpointOutputArgs 

type LookupQStashEndpointOutputArgs struct {
	TopicId pulumi.StringInput `pulumi:"topicId"`
}

A collection of arguments for invoking getQStashEndpoint.

func (LookupQStashEndpointOutputArgs) ElementType 

func (LookupQStashEndpointOutputArgs) ElementType() reflect.Type

type LookupQStashEndpointResult 

type LookupQStashEndpointResult struct {
	EndpointId string `pulumi:"endpointId"`
	// The provider-assigned unique ID for this managed resource.
	Id      string `pulumi:"id"`
	TopicId string `pulumi:"topicId"`
	Url     string `pulumi:"url"`
}

A collection of values returned by getQStashEndpoint.

func LookupQStashEndpoint 

func LookupQStashEndpoint(ctx *pulumi.Context, args *LookupQStashEndpointArgs, opts ...pulumi.InvokeOption) (*LookupQStashEndpointResult, error)

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-upstash/sdk/go/upstash"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/upstash/pulumi-upstash/sdk/go/upstash"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := upstash.LookupQStashEndpoint(ctx, &GetQStashEndpointArgs{
			EndpointId: resource.Upstash_qstash_endpoint.ExampleQstashEndpoint.Endpoint_id,
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type LookupQStashEndpointResultOutput 

type LookupQStashEndpointResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getQStashEndpoint.

func LookupQStashEndpointOutput 

func LookupQStashEndpointOutput(ctx *pulumi.Context, args LookupQStashEndpointOutputArgs, opts ...pulumi.InvokeOption) LookupQStashEndpointResultOutput

func (LookupQStashEndpointResultOutput) ElementType 

func (LookupQStashEndpointResultOutput) ElementType() reflect.Type

func (LookupQStashEndpointResultOutput) EndpointId 

func (o LookupQStashEndpointResultOutput) EndpointId() pulumi.StringOutput

func (LookupQStashEndpointResultOutput) Id 

func (o LookupQStashEndpointResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (LookupQStashEndpointResultOutput) ToLookupQStashEndpointResultOutput 

func (o LookupQStashEndpointResultOutput) ToLookupQStashEndpointResultOutput() LookupQStashEndpointResultOutput

func (LookupQStashEndpointResultOutput) ToLookupQStashEndpointResultOutputWithContext 

func (o LookupQStashEndpointResultOutput) ToLookupQStashEndpointResultOutputWithContext(ctx context.Context) LookupQStashEndpointResultOutput

func (LookupQStashEndpointResultOutput) TopicId 

func (o LookupQStashEndpointResultOutput) TopicId() pulumi.StringOutput

func (LookupQStashEndpointResultOutput) Url 

func (o LookupQStashEndpointResultOutput) Url() pulumi.StringOutput

type LookupQStashScheduleArgs 

type LookupQStashScheduleArgs struct {
	ScheduleId string `pulumi:"scheduleId"`
}

A collection of arguments for invoking getQStashSchedule.

type LookupQStashScheduleOutputArgs 

type LookupQStashScheduleOutputArgs struct {
	ScheduleId pulumi.StringInput `pulumi:"scheduleId"`
}

A collection of arguments for invoking getQStashSchedule.

func (LookupQStashScheduleOutputArgs) ElementType 

func (LookupQStashScheduleOutputArgs) ElementType() reflect.Type

type LookupQStashScheduleResult 

type LookupQStashScheduleResult struct {
	Body           string            `pulumi:"body"`
	CreatedAt      int               `pulumi:"createdAt"`
	Cron           string            `pulumi:"cron"`
	Destination    string            `pulumi:"destination"`
	ForwardHeaders map[string]string `pulumi:"forwardHeaders"`
	// The provider-assigned unique ID for this managed resource.
	Id         string `pulumi:"id"`
	NotBefore  int    `pulumi:"notBefore"`
	Retries    int    `pulumi:"retries"`
	ScheduleId string `pulumi:"scheduleId"`
}

A collection of values returned by getQStashSchedule.

func LookupQStashSchedule 

func LookupQStashSchedule(ctx *pulumi.Context, args *LookupQStashScheduleArgs, opts ...pulumi.InvokeOption) (*LookupQStashScheduleResult, error)

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-upstash/sdk/go/upstash"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/upstash/pulumi-upstash/sdk/go/upstash"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := upstash.LookupQStashSchedule(ctx, &GetQStashScheduleArgs{
			ScheduleId: resource.Upstash_qstash_schedule.ExampleQstashSchedule.Schedule_id,
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type LookupQStashScheduleResultOutput 

type LookupQStashScheduleResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getQStashSchedule.

func LookupQStashScheduleOutput 

func LookupQStashScheduleOutput(ctx *pulumi.Context, args LookupQStashScheduleOutputArgs, opts ...pulumi.InvokeOption) LookupQStashScheduleResultOutput

func (LookupQStashScheduleResultOutput) Body 

func (o LookupQStashScheduleResultOutput) Body() pulumi.StringOutput

func (LookupQStashScheduleResultOutput) CreatedAt 

func (o LookupQStashScheduleResultOutput) CreatedAt() pulumi.IntOutput

func (LookupQStashScheduleResultOutput) Cron 

func (o LookupQStashScheduleResultOutput) Cron() pulumi.StringOutput

func (LookupQStashScheduleResultOutput) Destination 

func (o LookupQStashScheduleResultOutput) Destination() pulumi.StringOutput

func (LookupQStashScheduleResultOutput) ElementType 

func (LookupQStashScheduleResultOutput) ElementType() reflect.Type

func (LookupQStashScheduleResultOutput) ForwardHeaders 

func (o LookupQStashScheduleResultOutput) ForwardHeaders() pulumi.StringMapOutput

func (LookupQStashScheduleResultOutput) Id 

func (o LookupQStashScheduleResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (LookupQStashScheduleResultOutput) NotBefore 

func (o LookupQStashScheduleResultOutput) NotBefore() pulumi.IntOutput

func (LookupQStashScheduleResultOutput) Retries 

func (o LookupQStashScheduleResultOutput) Retries() pulumi.IntOutput

func (LookupQStashScheduleResultOutput) ScheduleId 

func (o LookupQStashScheduleResultOutput) ScheduleId() pulumi.StringOutput

func (LookupQStashScheduleResultOutput) ToLookupQStashScheduleResultOutput 

func (o LookupQStashScheduleResultOutput) ToLookupQStashScheduleResultOutput() LookupQStashScheduleResultOutput

func (LookupQStashScheduleResultOutput) ToLookupQStashScheduleResultOutputWithContext 

func (o LookupQStashScheduleResultOutput) ToLookupQStashScheduleResultOutputWithContext(ctx context.Context) LookupQStashScheduleResultOutput

type LookupQStashTopicArgs 

type LookupQStashTopicArgs struct {
	TopicId string `pulumi:"topicId"`
}

A collection of arguments for invoking getQStashTopic.

type LookupQStashTopicOutputArgs 

type LookupQStashTopicOutputArgs struct {
	TopicId pulumi.StringInput `pulumi:"topicId"`
}

A collection of arguments for invoking getQStashTopic.

func (LookupQStashTopicOutputArgs) ElementType 

func (LookupQStashTopicOutputArgs) ElementType() reflect.Type

type LookupQStashTopicResult 

type LookupQStashTopicResult struct {
	Endpoints []map[string]string `pulumi:"endpoints"`
	// The provider-assigned unique ID for this managed resource.
	Id      string `pulumi:"id"`
	Name    string `pulumi:"name"`
	TopicId string `pulumi:"topicId"`
}

A collection of values returned by getQStashTopic.

func LookupQStashTopic 

func LookupQStashTopic(ctx *pulumi.Context, args *LookupQStashTopicArgs, opts ...pulumi.InvokeOption) (*LookupQStashTopicResult, error)

type LookupQStashTopicResultOutput 

type LookupQStashTopicResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getQStashTopic.

func LookupQStashTopicOutput 

func LookupQStashTopicOutput(ctx *pulumi.Context, args LookupQStashTopicOutputArgs, opts ...pulumi.InvokeOption) LookupQStashTopicResultOutput

func (LookupQStashTopicResultOutput) ElementType 

func (LookupQStashTopicResultOutput) ElementType() reflect.Type

func (LookupQStashTopicResultOutput) Endpoints 

func (o LookupQStashTopicResultOutput) Endpoints() pulumi.StringMapArrayOutput

func (LookupQStashTopicResultOutput) Id 

func (o LookupQStashTopicResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (LookupQStashTopicResultOutput) Name 

func (o LookupQStashTopicResultOutput) Name() pulumi.StringOutput

func (LookupQStashTopicResultOutput) ToLookupQStashTopicResultOutput 

func (o LookupQStashTopicResultOutput) ToLookupQStashTopicResultOutput() LookupQStashTopicResultOutput

func (LookupQStashTopicResultOutput) ToLookupQStashTopicResultOutputWithContext 

func (o LookupQStashTopicResultOutput) ToLookupQStashTopicResultOutputWithContext(ctx context.Context) LookupQStashTopicResultOutput

func (LookupQStashTopicResultOutput) TopicId 

func (o LookupQStashTopicResultOutput) TopicId() pulumi.StringOutput

type LookupRedisDatabaseArgs 

type LookupRedisDatabaseArgs struct {
	DatabaseId string `pulumi:"databaseId"`
}

A collection of arguments for invoking getRedisDatabase.

type LookupRedisDatabaseOutputArgs 

type LookupRedisDatabaseOutputArgs struct {
	DatabaseId pulumi.StringInput `pulumi:"databaseId"`
}

A collection of arguments for invoking getRedisDatabase.

func (LookupRedisDatabaseOutputArgs) ElementType 

func (LookupRedisDatabaseOutputArgs) ElementType() reflect.Type

type LookupRedisDatabaseResult 

type LookupRedisDatabaseResult struct {
	AutoScale bool `pulumi:"autoScale"`
	// Deprecated: Consistent option is deprecated.
	Consistent             bool   `pulumi:"consistent"`
	CreationTime           int    `pulumi:"creationTime"`
	DatabaseId             string `pulumi:"databaseId"`
	DatabaseName           string `pulumi:"databaseName"`
	DatabaseType           string `pulumi:"databaseType"`
	DbDailyBandwidthLimit  int    `pulumi:"dbDailyBandwidthLimit"`
	DbDiskThreshold        int    `pulumi:"dbDiskThreshold"`
	DbMaxClients           int    `pulumi:"dbMaxClients"`
	DbMaxCommandsPerSecond int    `pulumi:"dbMaxCommandsPerSecond"`
	DbMaxEntrySize         int    `pulumi:"dbMaxEntrySize"`
	DbMaxRequestSize       int    `pulumi:"dbMaxRequestSize"`
	DbMemoryThreshold      int    `pulumi:"dbMemoryThreshold"`
	Endpoint               string `pulumi:"endpoint"`
	Eviction               bool   `pulumi:"eviction"`
	// The provider-assigned unique ID for this managed resource.
	Id string `pulumi:"id"`
	// Deprecated: Multizone option is deprecated. It is enabled by default for paid databases.
	Multizone         bool     `pulumi:"multizone"`
	Password          string   `pulumi:"password"`
	Port              int      `pulumi:"port"`
	PrimaryRegion     string   `pulumi:"primaryRegion"`
	ReadOnlyRestToken string   `pulumi:"readOnlyRestToken"`
	ReadRegions       []string `pulumi:"readRegions"`
	Region            string   `pulumi:"region"`
	RestToken         string   `pulumi:"restToken"`
	State             string   `pulumi:"state"`
	Tls               bool     `pulumi:"tls"`
	UserEmail         string   `pulumi:"userEmail"`
}

A collection of values returned by getRedisDatabase.

func LookupRedisDatabase 

func LookupRedisDatabase(ctx *pulumi.Context, args *LookupRedisDatabaseArgs, opts ...pulumi.InvokeOption) (*LookupRedisDatabaseResult, error)

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-upstash/sdk/go/upstash"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/upstash/pulumi-upstash/sdk/go/upstash"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := upstash.LookupRedisDatabase(ctx, &GetRedisDatabaseArgs{
			DatabaseId: resource.Upstash_redis_database.ExampleDB.Database_id,
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type LookupRedisDatabaseResultOutput 

type LookupRedisDatabaseResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getRedisDatabase.

func LookupRedisDatabaseOutput 

func LookupRedisDatabaseOutput(ctx *pulumi.Context, args LookupRedisDatabaseOutputArgs, opts ...pulumi.InvokeOption) LookupRedisDatabaseResultOutput

func (LookupRedisDatabaseResultOutput) AutoScale added in v0.2.0 

func (o LookupRedisDatabaseResultOutput) AutoScale() pulumi.BoolOutput

func (LookupRedisDatabaseResultOutput) Consistent deprecated 

func (o LookupRedisDatabaseResultOutput) Consistent() pulumi.BoolOutput

Deprecated: Consistent option is deprecated.

func (LookupRedisDatabaseResultOutput) CreationTime 

func (o LookupRedisDatabaseResultOutput) CreationTime() pulumi.IntOutput

func (LookupRedisDatabaseResultOutput) DatabaseId 

func (o LookupRedisDatabaseResultOutput) DatabaseId() pulumi.StringOutput

func (LookupRedisDatabaseResultOutput) DatabaseName 

func (o LookupRedisDatabaseResultOutput) DatabaseName() pulumi.StringOutput

func (LookupRedisDatabaseResultOutput) DatabaseType 

func (o LookupRedisDatabaseResultOutput) DatabaseType() pulumi.StringOutput

func (LookupRedisDatabaseResultOutput) DbDailyBandwidthLimit 

func (o LookupRedisDatabaseResultOutput) DbDailyBandwidthLimit() pulumi.IntOutput

func (LookupRedisDatabaseResultOutput) DbDiskThreshold 

func (o LookupRedisDatabaseResultOutput) DbDiskThreshold() pulumi.IntOutput

func (LookupRedisDatabaseResultOutput) DbMaxClients 

func (o LookupRedisDatabaseResultOutput) DbMaxClients() pulumi.IntOutput

func (LookupRedisDatabaseResultOutput) DbMaxCommandsPerSecond 

func (o LookupRedisDatabaseResultOutput) DbMaxCommandsPerSecond() pulumi.IntOutput

func (LookupRedisDatabaseResultOutput) DbMaxEntrySize 

func (o LookupRedisDatabaseResultOutput) DbMaxEntrySize() pulumi.IntOutput

func (LookupRedisDatabaseResultOutput) DbMaxRequestSize 

func (o LookupRedisDatabaseResultOutput) DbMaxRequestSize() pulumi.IntOutput

func (LookupRedisDatabaseResultOutput) DbMemoryThreshold 

func (o LookupRedisDatabaseResultOutput) DbMemoryThreshold() pulumi.IntOutput

func (LookupRedisDatabaseResultOutput) ElementType 

func (LookupRedisDatabaseResultOutput) ElementType() reflect.Type

func (LookupRedisDatabaseResultOutput) Endpoint 

func (o LookupRedisDatabaseResultOutput) Endpoint() pulumi.StringOutput

func (LookupRedisDatabaseResultOutput) Eviction added in v0.2.0 

func (o LookupRedisDatabaseResultOutput) Eviction() pulumi.BoolOutput

func (LookupRedisDatabaseResultOutput) Id 

func (o LookupRedisDatabaseResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (LookupRedisDatabaseResultOutput) Multizone deprecated 

func (o LookupRedisDatabaseResultOutput) Multizone() pulumi.BoolOutput

Deprecated: Multizone option is deprecated. It is enabled by default for paid databases.

func (LookupRedisDatabaseResultOutput) Password 

func (o LookupRedisDatabaseResultOutput) Password() pulumi.StringOutput

func (LookupRedisDatabaseResultOutput) Port 

func (o LookupRedisDatabaseResultOutput) Port() pulumi.IntOutput

func (LookupRedisDatabaseResultOutput) PrimaryRegion added in v0.2.0 

func (o LookupRedisDatabaseResultOutput) PrimaryRegion() pulumi.StringOutput

func (LookupRedisDatabaseResultOutput) ReadOnlyRestToken 

func (o LookupRedisDatabaseResultOutput) ReadOnlyRestToken() pulumi.StringOutput

func (LookupRedisDatabaseResultOutput) ReadRegions added in v0.2.0 

func (o LookupRedisDatabaseResultOutput) ReadRegions() pulumi.StringArrayOutput

func (LookupRedisDatabaseResultOutput) Region 

func (o LookupRedisDatabaseResultOutput) Region() pulumi.StringOutput

func (LookupRedisDatabaseResultOutput) RestToken 

func (o LookupRedisDatabaseResultOutput) RestToken() pulumi.StringOutput

func (LookupRedisDatabaseResultOutput) State 

func (o LookupRedisDatabaseResultOutput) State() pulumi.StringOutput

func (LookupRedisDatabaseResultOutput) Tls 

func (o LookupRedisDatabaseResultOutput) Tls() pulumi.BoolOutput

func (LookupRedisDatabaseResultOutput) ToLookupRedisDatabaseResultOutput 

func (o LookupRedisDatabaseResultOutput) ToLookupRedisDatabaseResultOutput() LookupRedisDatabaseResultOutput

func (LookupRedisDatabaseResultOutput) ToLookupRedisDatabaseResultOutputWithContext 

func (o LookupRedisDatabaseResultOutput) ToLookupRedisDatabaseResultOutputWithContext(ctx context.Context) LookupRedisDatabaseResultOutput

func (LookupRedisDatabaseResultOutput) UserEmail 

func (o LookupRedisDatabaseResultOutput) UserEmail() pulumi.StringOutput

type LookupTeamArgs 

type LookupTeamArgs struct {
	TeamId string `pulumi:"teamId"`
}

A collection of arguments for invoking getTeam.

type LookupTeamOutputArgs 

type LookupTeamOutputArgs struct {
	TeamId pulumi.StringInput `pulumi:"teamId"`
}

A collection of arguments for invoking getTeam.

func (LookupTeamOutputArgs) ElementType 

func (LookupTeamOutputArgs) ElementType() reflect.Type

type LookupTeamResult 

type LookupTeamResult struct {
	CopyCc bool `pulumi:"copyCc"`
	// The provider-assigned unique ID for this managed resource.
	Id          string            `pulumi:"id"`
	TeamId      string            `pulumi:"teamId"`
	TeamMembers map[string]string `pulumi:"teamMembers"`
	TeamName    string            `pulumi:"teamName"`
}

A collection of values returned by getTeam.

func LookupTeam 

func LookupTeam(ctx *pulumi.Context, args *LookupTeamArgs, opts ...pulumi.InvokeOption) (*LookupTeamResult, error)

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-upstash/sdk/go/upstash"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/upstash/pulumi-upstash/sdk/go/upstash"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := upstash.LookupTeam(ctx, &GetTeamArgs{
			TeamId: resource.Upstash_team.ExampleTeam.Team_id,
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type LookupTeamResultOutput 

type LookupTeamResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getTeam.

func LookupTeamOutput 

func LookupTeamOutput(ctx *pulumi.Context, args LookupTeamOutputArgs, opts ...pulumi.InvokeOption) LookupTeamResultOutput

func (LookupTeamResultOutput) CopyCc 

func (o LookupTeamResultOutput) CopyCc() pulumi.BoolOutput

func (LookupTeamResultOutput) ElementType 

func (LookupTeamResultOutput) ElementType() reflect.Type

func (LookupTeamResultOutput) Id 

func (o LookupTeamResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (LookupTeamResultOutput) TeamId 

func (o LookupTeamResultOutput) TeamId() pulumi.StringOutput

func (LookupTeamResultOutput) TeamMembers 

func (o LookupTeamResultOutput) TeamMembers() pulumi.StringMapOutput

func (LookupTeamResultOutput) TeamName 

func (o LookupTeamResultOutput) TeamName() pulumi.StringOutput

func (LookupTeamResultOutput) ToLookupTeamResultOutput 

func (o LookupTeamResultOutput) ToLookupTeamResultOutput() LookupTeamResultOutput

func (LookupTeamResultOutput) ToLookupTeamResultOutputWithContext 

func (o LookupTeamResultOutput) ToLookupTeamResultOutputWithContext(ctx context.Context) LookupTeamResultOutput

type Provider 

type Provider struct {
	pulumi.ProviderResourceState

	ApiKey pulumi.StringOutput `pulumi:"apiKey"`
	Email  pulumi.StringOutput `pulumi:"email"`
}

The provider type for the upstash package. By default, resources use package-wide configuration settings, however an explicit `Provider` instance may be created and passed during resource construction to achieve fine-grained programmatic control over provider settings. See the [documentation](https://www.pulumi.com/docs/reference/programming-model/#providers) for more information.

func NewProvider 

func NewProvider(ctx *pulumi.Context,
	name string, args *ProviderArgs, opts ...pulumi.ResourceOption) (*Provider, error)

NewProvider registers a new resource with the given unique name, arguments, and options.

func (*Provider) ElementType 

func (*Provider) ElementType() reflect.Type

func (*Provider) ToProviderOutput 

func (i *Provider) ToProviderOutput() ProviderOutput

func (*Provider) ToProviderOutputWithContext 

func (i *Provider) ToProviderOutputWithContext(ctx context.Context) ProviderOutput

type ProviderArgs 

type ProviderArgs struct {
	ApiKey pulumi.StringInput
	Email  pulumi.StringInput
}

The set of arguments for constructing a Provider resource.

func (ProviderArgs) ElementType 

func (ProviderArgs) ElementType() reflect.Type

type ProviderInput 

type ProviderInput interface {
	pulumi.Input

	ToProviderOutput() ProviderOutput
	ToProviderOutputWithContext(ctx context.Context) ProviderOutput
}

type ProviderOutput 

type ProviderOutput struct{ *pulumi.OutputState }

func (ProviderOutput) ApiKey 

func (o ProviderOutput) ApiKey() pulumi.StringOutput

func (ProviderOutput) ElementType 

func (ProviderOutput) ElementType() reflect.Type

func (ProviderOutput) Email 

func (o ProviderOutput) Email() pulumi.StringOutput

func (ProviderOutput) ToProviderOutput 

func (o ProviderOutput) ToProviderOutput() ProviderOutput

func (ProviderOutput) ToProviderOutputWithContext 

func (o ProviderOutput) ToProviderOutputWithContext(ctx context.Context) ProviderOutput

type QStashEndpoint 

type QStashEndpoint struct {
	pulumi.CustomResourceState

	// Unique Qstash Endpoint ID
	EndpointId pulumi.StringOutput `pulumi:"endpointId"`
	// Topic Id that the endpoint is added to
	TopicId pulumi.StringOutput `pulumi:"topicId"`
	// Unique Qstash Topic Name for Endpoint
	TopicName pulumi.StringOutput `pulumi:"topicName"`
	// URL of the endpoint
	Url pulumi.StringOutput `pulumi:"url"`
}

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/upstash/pulumi-upstash/sdk/go/upstash"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := upstash.NewQStashEndpoint(ctx, "exampleQstashEndpoint", &upstash.QStashEndpointArgs{
			Url:     pulumi.String("https://***.***"),
			TopicId: pulumi.Any(resource.Upstash_qstash_topic.ExampleQstashTopic.Topic_id),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

func GetQStashEndpoint 

func GetQStashEndpoint(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *QStashEndpointState, opts ...pulumi.ResourceOption) (*QStashEndpoint, error)

GetQStashEndpoint gets an existing QStashEndpoint resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewQStashEndpoint 

func NewQStashEndpoint(ctx *pulumi.Context,
	name string, args *QStashEndpointArgs, opts ...pulumi.ResourceOption) (*QStashEndpoint, error)

NewQStashEndpoint registers a new resource with the given unique name, arguments, and options.

func (*QStashEndpoint) ElementType 

func (*QStashEndpoint) ElementType() reflect.Type

func (*QStashEndpoint) ToQStashEndpointOutput 

func (i *QStashEndpoint) ToQStashEndpointOutput() QStashEndpointOutput

func (*QStashEndpoint) ToQStashEndpointOutputWithContext 

func (i *QStashEndpoint) ToQStashEndpointOutputWithContext(ctx context.Context) QStashEndpointOutput

type QStashEndpointArgs 

type QStashEndpointArgs struct {
	// Topic Id that the endpoint is added to
	TopicId pulumi.StringInput
	// URL of the endpoint
	Url pulumi.StringInput
}

The set of arguments for constructing a QStashEndpoint resource.

func (QStashEndpointArgs) ElementType 

func (QStashEndpointArgs) ElementType() reflect.Type

type QStashEndpointArray 

type QStashEndpointArray []QStashEndpointInput

func (QStashEndpointArray) ElementType 

func (QStashEndpointArray) ElementType() reflect.Type

func (QStashEndpointArray) ToQStashEndpointArrayOutput 

func (i QStashEndpointArray) ToQStashEndpointArrayOutput() QStashEndpointArrayOutput

func (QStashEndpointArray) ToQStashEndpointArrayOutputWithContext 

func (i QStashEndpointArray) ToQStashEndpointArrayOutputWithContext(ctx context.Context) QStashEndpointArrayOutput

type QStashEndpointArrayInput 

type QStashEndpointArrayInput interface {
	pulumi.Input

	ToQStashEndpointArrayOutput() QStashEndpointArrayOutput
	ToQStashEndpointArrayOutputWithContext(context.Context) QStashEndpointArrayOutput
}

QStashEndpointArrayInput is an input type that accepts QStashEndpointArray and QStashEndpointArrayOutput values. You can construct a concrete instance of `QStashEndpointArrayInput` via: 

QStashEndpointArray{ QStashEndpointArgs{...} }

type QStashEndpointArrayOutput 

type QStashEndpointArrayOutput struct{ *pulumi.OutputState }

func (QStashEndpointArrayOutput) ElementType 

func (QStashEndpointArrayOutput) ElementType() reflect.Type

func (QStashEndpointArrayOutput) Index 

func (o QStashEndpointArrayOutput) Index(i pulumi.IntInput) QStashEndpointOutput

func (QStashEndpointArrayOutput) ToQStashEndpointArrayOutput 

func (o QStashEndpointArrayOutput) ToQStashEndpointArrayOutput() QStashEndpointArrayOutput

func (QStashEndpointArrayOutput) ToQStashEndpointArrayOutputWithContext 

func (o QStashEndpointArrayOutput) ToQStashEndpointArrayOutputWithContext(ctx context.Context) QStashEndpointArrayOutput

type QStashEndpointInput 

type QStashEndpointInput interface {
	pulumi.Input

	ToQStashEndpointOutput() QStashEndpointOutput
	ToQStashEndpointOutputWithContext(ctx context.Context) QStashEndpointOutput
}

type QStashEndpointMap 

type QStashEndpointMap map[string]QStashEndpointInput

func (QStashEndpointMap) ElementType 

func (QStashEndpointMap) ElementType() reflect.Type

func (QStashEndpointMap) ToQStashEndpointMapOutput 

func (i QStashEndpointMap) ToQStashEndpointMapOutput() QStashEndpointMapOutput

func (QStashEndpointMap) ToQStashEndpointMapOutputWithContext 

func (i QStashEndpointMap) ToQStashEndpointMapOutputWithContext(ctx context.Context) QStashEndpointMapOutput

type QStashEndpointMapInput 

type QStashEndpointMapInput interface {
	pulumi.Input

	ToQStashEndpointMapOutput() QStashEndpointMapOutput
	ToQStashEndpointMapOutputWithContext(context.Context) QStashEndpointMapOutput
}

QStashEndpointMapInput is an input type that accepts QStashEndpointMap and QStashEndpointMapOutput values. You can construct a concrete instance of `QStashEndpointMapInput` via: 

QStashEndpointMap{ "key": QStashEndpointArgs{...} }

type QStashEndpointMapOutput 

type QStashEndpointMapOutput struct{ *pulumi.OutputState }

func (QStashEndpointMapOutput) ElementType 

func (QStashEndpointMapOutput) ElementType() reflect.Type

func (QStashEndpointMapOutput) MapIndex 

func (o QStashEndpointMapOutput) MapIndex(k pulumi.StringInput) QStashEndpointOutput

func (QStashEndpointMapOutput) ToQStashEndpointMapOutput 

func (o QStashEndpointMapOutput) ToQStashEndpointMapOutput() QStashEndpointMapOutput

func (QStashEndpointMapOutput) ToQStashEndpointMapOutputWithContext 

func (o QStashEndpointMapOutput) ToQStashEndpointMapOutputWithContext(ctx context.Context) QStashEndpointMapOutput

type QStashEndpointOutput 

type QStashEndpointOutput struct{ *pulumi.OutputState }

func (QStashEndpointOutput) ElementType 

func (QStashEndpointOutput) ElementType() reflect.Type

func (QStashEndpointOutput) EndpointId 

func (o QStashEndpointOutput) EndpointId() pulumi.StringOutput

Unique Qstash Endpoint ID

func (QStashEndpointOutput) ToQStashEndpointOutput 

func (o QStashEndpointOutput) ToQStashEndpointOutput() QStashEndpointOutput

func (QStashEndpointOutput) ToQStashEndpointOutputWithContext 

func (o QStashEndpointOutput) ToQStashEndpointOutputWithContext(ctx context.Context) QStashEndpointOutput

func (QStashEndpointOutput) TopicId 

func (o QStashEndpointOutput) TopicId() pulumi.StringOutput

Topic Id that the endpoint is added to

func (QStashEndpointOutput) TopicName 

func (o QStashEndpointOutput) TopicName() pulumi.StringOutput

Unique Qstash Topic Name for Endpoint

func (QStashEndpointOutput) Url 

func (o QStashEndpointOutput) Url() pulumi.StringOutput

URL of the endpoint

type QStashEndpointState 

type QStashEndpointState struct {
	// Unique Qstash Endpoint ID
	EndpointId pulumi.StringPtrInput
	// Topic Id that the endpoint is added to
	TopicId pulumi.StringPtrInput
	// Unique Qstash Topic Name for Endpoint
	TopicName pulumi.StringPtrInput
	// URL of the endpoint
	Url pulumi.StringPtrInput
}

func (QStashEndpointState) ElementType 

func (QStashEndpointState) ElementType() reflect.Type

type QStashSchedule 

type QStashSchedule struct {
	pulumi.CustomResourceState

	// Body to send for the POST request in string format. Needs escaping (\) double quotes.
	Body pulumi.StringPtrOutput `pulumi:"body"`
	// Callback URL for Qstash Schedule.
	Callback pulumi.StringPtrOutput `pulumi:"callback"`
	// Content Based Deduplication (bool) for Qstash Scheduling.
	ContentBasedDeduplication pulumi.BoolPtrOutput `pulumi:"contentBasedDeduplication"`
	// Content type for Qstash Scheduling.
	ContentType pulumi.StringPtrOutput `pulumi:"contentType"`
	// Creation time for Qstash Schedule.
	CreatedAt pulumi.IntOutput `pulumi:"createdAt"`
	// Cron string for Qstash Schedule
	Cron pulumi.StringOutput `pulumi:"cron"`
	// Deduplication ID for Qstash Scheduling.
	DeduplicationId pulumi.StringPtrOutput `pulumi:"deduplicationId"`
	// Delay for Qstash Schedule.
	Delay pulumi.StringPtrOutput `pulumi:"delay"`
	// Destination for Qstash Schedule. Either Topic ID or valid URL
	Destination pulumi.StringOutput `pulumi:"destination"`
	// Forward headers to your API
	ForwardHeaders pulumi.StringMapOutput `pulumi:"forwardHeaders"`
	// Start time for Qstash Scheduling.
	NotBefore pulumi.IntPtrOutput `pulumi:"notBefore"`
	// Retries for Qstash Schedule requests.
	Retries pulumi.IntPtrOutput `pulumi:"retries"`
	// Unique Qstash Schedule ID for requested schedule
	ScheduleId pulumi.StringOutput `pulumi:"scheduleId"`
}

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/upstash/pulumi-upstash/sdk/go/upstash"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := upstash.NewQStashSchedule(ctx, "exampleQstashSchedule", &upstash.QStashScheduleArgs{
			Destination: pulumi.Any(resource.Upstash_qstash_topic.ExampleQstashTopic.Topic_id),
			Cron:        pulumi.String("* * * * */2"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

func GetQStashSchedule 

func GetQStashSchedule(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *QStashScheduleState, opts ...pulumi.ResourceOption) (*QStashSchedule, error)

GetQStashSchedule gets an existing QStashSchedule resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewQStashSchedule 

func NewQStashSchedule(ctx *pulumi.Context,
	name string, args *QStashScheduleArgs, opts ...pulumi.ResourceOption) (*QStashSchedule, error)

NewQStashSchedule registers a new resource with the given unique name, arguments, and options.

func (*QStashSchedule) ElementType 

func (*QStashSchedule) ElementType() reflect.Type

func (*QStashSchedule) ToQStashScheduleOutput 

func (i *QStashSchedule) ToQStashScheduleOutput() QStashScheduleOutput

func (*QStashSchedule) ToQStashScheduleOutputWithContext 

func (i *QStashSchedule) ToQStashScheduleOutputWithContext(ctx context.Context) QStashScheduleOutput

type QStashScheduleArgs 

type QStashScheduleArgs struct {
	// Body to send for the POST request in string format. Needs escaping (\) double quotes.
	Body pulumi.StringPtrInput
	// Callback URL for Qstash Schedule.
	Callback pulumi.StringPtrInput
	// Content Based Deduplication (bool) for Qstash Scheduling.
	ContentBasedDeduplication pulumi.BoolPtrInput
	// Content type for Qstash Scheduling.
	ContentType pulumi.StringPtrInput
	// Cron string for Qstash Schedule
	Cron pulumi.StringInput
	// Deduplication ID for Qstash Scheduling.
	DeduplicationId pulumi.StringPtrInput
	// Delay for Qstash Schedule.
	Delay pulumi.StringPtrInput
	// Destination for Qstash Schedule. Either Topic ID or valid URL
	Destination pulumi.StringInput
	// Forward headers to your API
	ForwardHeaders pulumi.StringMapInput
	// Start time for Qstash Scheduling.
	NotBefore pulumi.IntPtrInput
	// Retries for Qstash Schedule requests.
	Retries pulumi.IntPtrInput
}

The set of arguments for constructing a QStashSchedule resource.

func (QStashScheduleArgs) ElementType 

func (QStashScheduleArgs) ElementType() reflect.Type

type QStashScheduleArray 

type QStashScheduleArray []QStashScheduleInput

func (QStashScheduleArray) ElementType 

func (QStashScheduleArray) ElementType() reflect.Type

func (QStashScheduleArray) ToQStashScheduleArrayOutput 

func (i QStashScheduleArray) ToQStashScheduleArrayOutput() QStashScheduleArrayOutput

func (QStashScheduleArray) ToQStashScheduleArrayOutputWithContext 

func (i QStashScheduleArray) ToQStashScheduleArrayOutputWithContext(ctx context.Context) QStashScheduleArrayOutput

type QStashScheduleArrayInput 

type QStashScheduleArrayInput interface {
	pulumi.Input

	ToQStashScheduleArrayOutput() QStashScheduleArrayOutput
	ToQStashScheduleArrayOutputWithContext(context.Context) QStashScheduleArrayOutput
}

QStashScheduleArrayInput is an input type that accepts QStashScheduleArray and QStashScheduleArrayOutput values. You can construct a concrete instance of `QStashScheduleArrayInput` via: 

QStashScheduleArray{ QStashScheduleArgs{...} }

type QStashScheduleArrayOutput 

type QStashScheduleArrayOutput struct{ *pulumi.OutputState }

func (QStashScheduleArrayOutput) ElementType 

func (QStashScheduleArrayOutput) ElementType() reflect.Type

func (QStashScheduleArrayOutput) Index 

func (o QStashScheduleArrayOutput) Index(i pulumi.IntInput) QStashScheduleOutput

func (QStashScheduleArrayOutput) ToQStashScheduleArrayOutput 

func (o QStashScheduleArrayOutput) ToQStashScheduleArrayOutput() QStashScheduleArrayOutput

func (QStashScheduleArrayOutput) ToQStashScheduleArrayOutputWithContext 

func (o QStashScheduleArrayOutput) ToQStashScheduleArrayOutputWithContext(ctx context.Context) QStashScheduleArrayOutput

type QStashScheduleInput 

type QStashScheduleInput interface {
	pulumi.Input

	ToQStashScheduleOutput() QStashScheduleOutput
	ToQStashScheduleOutputWithContext(ctx context.Context) QStashScheduleOutput
}

type QStashScheduleMap 

type QStashScheduleMap map[string]QStashScheduleInput

func (QStashScheduleMap) ElementType 

func (QStashScheduleMap) ElementType() reflect.Type

func (QStashScheduleMap) ToQStashScheduleMapOutput 

func (i QStashScheduleMap) ToQStashScheduleMapOutput() QStashScheduleMapOutput

func (QStashScheduleMap) ToQStashScheduleMapOutputWithContext 

func (i QStashScheduleMap) ToQStashScheduleMapOutputWithContext(ctx context.Context) QStashScheduleMapOutput

type QStashScheduleMapInput 

type QStashScheduleMapInput interface {
	pulumi.Input

	ToQStashScheduleMapOutput() QStashScheduleMapOutput
	ToQStashScheduleMapOutputWithContext(context.Context) QStashScheduleMapOutput
}

QStashScheduleMapInput is an input type that accepts QStashScheduleMap and QStashScheduleMapOutput values. You can construct a concrete instance of `QStashScheduleMapInput` via: 

QStashScheduleMap{ "key": QStashScheduleArgs{...} }

type QStashScheduleMapOutput 

type QStashScheduleMapOutput struct{ *pulumi.OutputState }

func (QStashScheduleMapOutput) ElementType 

func (QStashScheduleMapOutput) ElementType() reflect.Type

func (QStashScheduleMapOutput) MapIndex 

func (o QStashScheduleMapOutput) MapIndex(k pulumi.StringInput) QStashScheduleOutput

func (QStashScheduleMapOutput) ToQStashScheduleMapOutput 

func (o QStashScheduleMapOutput) ToQStashScheduleMapOutput() QStashScheduleMapOutput

func (QStashScheduleMapOutput) ToQStashScheduleMapOutputWithContext 

func (o QStashScheduleMapOutput) ToQStashScheduleMapOutputWithContext(ctx context.Context) QStashScheduleMapOutput

type QStashScheduleOutput 

type QStashScheduleOutput struct{ *pulumi.OutputState }

func (QStashScheduleOutput) Body 

func (o QStashScheduleOutput) Body() pulumi.StringPtrOutput

Body to send for the POST request in string format. Needs escaping (\) double quotes.

func (QStashScheduleOutput) Callback 

func (o QStashScheduleOutput) Callback() pulumi.StringPtrOutput

Callback URL for Qstash Schedule.

func (QStashScheduleOutput) ContentBasedDeduplication 

func (o QStashScheduleOutput) ContentBasedDeduplication() pulumi.BoolPtrOutput

Content Based Deduplication (bool) for Qstash Scheduling.

func (QStashScheduleOutput) ContentType 

func (o QStashScheduleOutput) ContentType() pulumi.StringPtrOutput

Content type for Qstash Scheduling.

func (QStashScheduleOutput) CreatedAt 

func (o QStashScheduleOutput) CreatedAt() pulumi.IntOutput

Creation time for Qstash Schedule.

func (QStashScheduleOutput) Cron 

func (o QStashScheduleOutput) Cron() pulumi.StringOutput

Cron string for Qstash Schedule

func (QStashScheduleOutput) DeduplicationId 

func (o QStashScheduleOutput) DeduplicationId() pulumi.StringPtrOutput

Deduplication ID for Qstash Scheduling.

func (QStashScheduleOutput) Delay 

func (o QStashScheduleOutput) Delay() pulumi.StringPtrOutput

Delay for Qstash Schedule.

func (QStashScheduleOutput) Destination 

func (o QStashScheduleOutput) Destination() pulumi.StringOutput

Destination for Qstash Schedule. Either Topic ID or valid URL

func (QStashScheduleOutput) ElementType 

func (QStashScheduleOutput) ElementType() reflect.Type

func (QStashScheduleOutput) ForwardHeaders 

func (o QStashScheduleOutput) ForwardHeaders() pulumi.StringMapOutput

Forward headers to your API

func (QStashScheduleOutput) NotBefore 

func (o QStashScheduleOutput) NotBefore() pulumi.IntPtrOutput

Start time for Qstash Scheduling.

func (QStashScheduleOutput) Retries 

func (o QStashScheduleOutput) Retries() pulumi.IntPtrOutput

Retries for Qstash Schedule requests.

func (QStashScheduleOutput) ScheduleId 

func (o QStashScheduleOutput) ScheduleId() pulumi.StringOutput

Unique Qstash Schedule ID for requested schedule

func (QStashScheduleOutput) ToQStashScheduleOutput 

func (o QStashScheduleOutput) ToQStashScheduleOutput() QStashScheduleOutput

func (QStashScheduleOutput) ToQStashScheduleOutputWithContext 

func (o QStashScheduleOutput) ToQStashScheduleOutputWithContext(ctx context.Context) QStashScheduleOutput

type QStashScheduleState 

type QStashScheduleState struct {
	// Body to send for the POST request in string format. Needs escaping (\) double quotes.
	Body pulumi.StringPtrInput
	// Callback URL for Qstash Schedule.
	Callback pulumi.StringPtrInput
	// Content Based Deduplication (bool) for Qstash Scheduling.
	ContentBasedDeduplication pulumi.BoolPtrInput
	// Content type for Qstash Scheduling.
	ContentType pulumi.StringPtrInput
	// Creation time for Qstash Schedule.
	CreatedAt pulumi.IntPtrInput
	// Cron string for Qstash Schedule
	Cron pulumi.StringPtrInput
	// Deduplication ID for Qstash Scheduling.
	DeduplicationId pulumi.StringPtrInput
	// Delay for Qstash Schedule.
	Delay pulumi.StringPtrInput
	// Destination for Qstash Schedule. Either Topic ID or valid URL
	Destination pulumi.StringPtrInput
	// Forward headers to your API
	ForwardHeaders pulumi.StringMapInput
	// Start time for Qstash Scheduling.
	NotBefore pulumi.IntPtrInput
	// Retries for Qstash Schedule requests.
	Retries pulumi.IntPtrInput
	// Unique Qstash Schedule ID for requested schedule
	ScheduleId pulumi.StringPtrInput
}

func (QStashScheduleState) ElementType 

func (QStashScheduleState) ElementType() reflect.Type

type QStashTopic 

type QStashTopic struct {
	pulumi.CustomResourceState

	// Endpoints for the Qstash Topic
	Endpoints pulumi.StringMapArrayOutput `pulumi:"endpoints"`
	// Name of the Qstash Topic
	Name pulumi.StringOutput `pulumi:"name"`
	// Unique Qstash Topic ID for requested topic
	TopicId pulumi.StringOutput `pulumi:"topicId"`
}

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/upstash/pulumi-upstash/sdk/go/upstash"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := upstash.NewQStashTopic(ctx, "exampleQstashTopic", nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

func GetQStashTopic 

func GetQStashTopic(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *QStashTopicState, opts ...pulumi.ResourceOption) (*QStashTopic, error)

GetQStashTopic gets an existing QStashTopic resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewQStashTopic 

func NewQStashTopic(ctx *pulumi.Context,
	name string, args *QStashTopicArgs, opts ...pulumi.ResourceOption) (*QStashTopic, error)

NewQStashTopic registers a new resource with the given unique name, arguments, and options.

func (*QStashTopic) ElementType 

func (*QStashTopic) ElementType() reflect.Type

func (*QStashTopic) ToQStashTopicOutput 

func (i *QStashTopic) ToQStashTopicOutput() QStashTopicOutput

func (*QStashTopic) ToQStashTopicOutputWithContext 

func (i *QStashTopic) ToQStashTopicOutputWithContext(ctx context.Context) QStashTopicOutput

type QStashTopicArgs 

type QStashTopicArgs struct {
	// Name of the Qstash Topic
	Name pulumi.StringPtrInput
}

The set of arguments for constructing a QStashTopic resource.

func (QStashTopicArgs) ElementType 

func (QStashTopicArgs) ElementType() reflect.Type

type QStashTopicArray 

type QStashTopicArray []QStashTopicInput

func (QStashTopicArray) ElementType 

func (QStashTopicArray) ElementType() reflect.Type

func (QStashTopicArray) ToQStashTopicArrayOutput 

func (i QStashTopicArray) ToQStashTopicArrayOutput() QStashTopicArrayOutput

func (QStashTopicArray) ToQStashTopicArrayOutputWithContext 

func (i QStashTopicArray) ToQStashTopicArrayOutputWithContext(ctx context.Context) QStashTopicArrayOutput

type QStashTopicArrayInput 

type QStashTopicArrayInput interface {
	pulumi.Input

	ToQStashTopicArrayOutput() QStashTopicArrayOutput
	ToQStashTopicArrayOutputWithContext(context.Context) QStashTopicArrayOutput
}

QStashTopicArrayInput is an input type that accepts QStashTopicArray and QStashTopicArrayOutput values. You can construct a concrete instance of `QStashTopicArrayInput` via: 

QStashTopicArray{ QStashTopicArgs{...} }

type QStashTopicArrayOutput 

type QStashTopicArrayOutput struct{ *pulumi.OutputState }

func (QStashTopicArrayOutput) ElementType 

func (QStashTopicArrayOutput) ElementType() reflect.Type

func (QStashTopicArrayOutput) Index 

func (o QStashTopicArrayOutput) Index(i pulumi.IntInput) QStashTopicOutput

func (QStashTopicArrayOutput) ToQStashTopicArrayOutput 

func (o QStashTopicArrayOutput) ToQStashTopicArrayOutput() QStashTopicArrayOutput

func (QStashTopicArrayOutput) ToQStashTopicArrayOutputWithContext 

func (o QStashTopicArrayOutput) ToQStashTopicArrayOutputWithContext(ctx context.Context) QStashTopicArrayOutput

type QStashTopicInput 

type QStashTopicInput interface {
	pulumi.Input

	ToQStashTopicOutput() QStashTopicOutput
	ToQStashTopicOutputWithContext(ctx context.Context) QStashTopicOutput
}

type QStashTopicMap 

type QStashTopicMap map[string]QStashTopicInput

func (QStashTopicMap) ElementType 

func (QStashTopicMap) ElementType() reflect.Type

func (QStashTopicMap) ToQStashTopicMapOutput 

func (i QStashTopicMap) ToQStashTopicMapOutput() QStashTopicMapOutput

func (QStashTopicMap) ToQStashTopicMapOutputWithContext 

func (i QStashTopicMap) ToQStashTopicMapOutputWithContext(ctx context.Context) QStashTopicMapOutput

type QStashTopicMapInput 

type QStashTopicMapInput interface {
	pulumi.Input

	ToQStashTopicMapOutput() QStashTopicMapOutput
	ToQStashTopicMapOutputWithContext(context.Context) QStashTopicMapOutput
}

QStashTopicMapInput is an input type that accepts QStashTopicMap and QStashTopicMapOutput values. You can construct a concrete instance of `QStashTopicMapInput` via: 

QStashTopicMap{ "key": QStashTopicArgs{...} }

type QStashTopicMapOutput 

type QStashTopicMapOutput struct{ *pulumi.OutputState }

func (QStashTopicMapOutput) ElementType 

func (QStashTopicMapOutput) ElementType() reflect.Type

func (QStashTopicMapOutput) MapIndex 

func (o QStashTopicMapOutput) MapIndex(k pulumi.StringInput) QStashTopicOutput

func (QStashTopicMapOutput) ToQStashTopicMapOutput 

func (o QStashTopicMapOutput) ToQStashTopicMapOutput() QStashTopicMapOutput

func (QStashTopicMapOutput) ToQStashTopicMapOutputWithContext 

func (o QStashTopicMapOutput) ToQStashTopicMapOutputWithContext(ctx context.Context) QStashTopicMapOutput

type QStashTopicOutput 

type QStashTopicOutput struct{ *pulumi.OutputState }

func (QStashTopicOutput) ElementType 

func (QStashTopicOutput) ElementType() reflect.Type

func (QStashTopicOutput) Endpoints 

func (o QStashTopicOutput) Endpoints() pulumi.StringMapArrayOutput

Endpoints for the Qstash Topic

func (QStashTopicOutput) Name 

func (o QStashTopicOutput) Name() pulumi.StringOutput

Name of the Qstash Topic

func (QStashTopicOutput) ToQStashTopicOutput 

func (o QStashTopicOutput) ToQStashTopicOutput() QStashTopicOutput

func (QStashTopicOutput) ToQStashTopicOutputWithContext 

func (o QStashTopicOutput) ToQStashTopicOutputWithContext(ctx context.Context) QStashTopicOutput

func (QStashTopicOutput) TopicId 

func (o QStashTopicOutput) TopicId() pulumi.StringOutput

Unique Qstash Topic ID for requested topic

type QStashTopicState 

type QStashTopicState struct {
	// Endpoints for the Qstash Topic
	Endpoints pulumi.StringMapArrayInput
	// Name of the Qstash Topic
	Name pulumi.StringPtrInput
	// Unique Qstash Topic ID for requested topic
	TopicId pulumi.StringPtrInput
}

func (QStashTopicState) ElementType 

func (QStashTopicState) ElementType() reflect.Type

type RedisDatabase 

type RedisDatabase struct {
	pulumi.CustomResourceState

	// Upgrade to higher plans automatically when it hits quotas
	AutoScale pulumi.BoolPtrOutput `pulumi:"autoScale"`
	// When enabled, all writes are synchronously persisted to the disk.
	//
	// Deprecated: Consistent option is deprecated.
	Consistent pulumi.BoolPtrOutput `pulumi:"consistent"`
	// Creation time of the database
	CreationTime pulumi.IntOutput `pulumi:"creationTime"`
	// Unique Database ID for created database
	DatabaseId pulumi.StringOutput `pulumi:"databaseId"`
	// Name of the database
	DatabaseName pulumi.StringOutput `pulumi:"databaseName"`
	// Type of the database
	DatabaseType pulumi.StringOutput `pulumi:"databaseType"`
	// Daily bandwidth limit for the database
	DbDailyBandwidthLimit pulumi.IntOutput `pulumi:"dbDailyBandwidthLimit"`
	// Disk threshold for the database
	DbDiskThreshold pulumi.IntOutput `pulumi:"dbDiskThreshold"`
	// Max clients for the database
	DbMaxClients pulumi.IntOutput `pulumi:"dbMaxClients"`
	// Max commands per second for the database
	DbMaxCommandsPerSecond pulumi.IntOutput `pulumi:"dbMaxCommandsPerSecond"`
	// Max entry size for the database
	DbMaxEntrySize pulumi.IntOutput `pulumi:"dbMaxEntrySize"`
	// Max request size for the database
	DbMaxRequestSize pulumi.IntOutput `pulumi:"dbMaxRequestSize"`
	// Memory threshold for the database
	DbMemoryThreshold pulumi.IntOutput `pulumi:"dbMemoryThreshold"`
	// Database URL for connection
	Endpoint pulumi.StringOutput `pulumi:"endpoint"`
	// Enable eviction, to evict keys when your database reaches the max size
	Eviction pulumi.BoolPtrOutput `pulumi:"eviction"`
	// When enabled, database becomes highly available and is deployed in multiple zones. (If changed to false from true,
	// results in deletion and recreation of the resource)
	//
	// Deprecated: Multizone option is deprecated. It is enabled by default for paid databases.
	Multizone pulumi.BoolPtrOutput `pulumi:"multizone"`
	// Password of the database
	Password pulumi.StringOutput `pulumi:"password"`
	// Port of the endpoint
	Port pulumi.IntOutput `pulumi:"port"`
	// Primary region for the database (Only works if region='global'. Can be one of [us-east-1, us-west-1, us-west-2,
	// eu-central-1, eu-west-1, sa-east-1, ap-southeast-1, ap-southeast-2])
	PrimaryRegion pulumi.StringPtrOutput `pulumi:"primaryRegion"`
	// Rest Token for the database.
	ReadOnlyRestToken pulumi.StringOutput `pulumi:"readOnlyRestToken"`
	// Read regions for the database (Only works if region='global' and primary_region is set. Can be any combination of
	// [us-east-1, us-west-1, us-west-2, eu-central-1, eu-west-1, sa-east-1, ap-southeast-1, ap-southeast-2], excluding the one
	// given as primary.)
	ReadRegions pulumi.StringArrayOutput `pulumi:"readRegions"`
	// region of the database. Possible values are: "global", "eu-west-1", "us-east-1", "us-west-1", "ap-northeast-1" ,
	// "eu-central1"
	Region pulumi.StringOutput `pulumi:"region"`
	// Rest Token for the database.
	RestToken pulumi.StringOutput `pulumi:"restToken"`
	// State of the database
	State pulumi.StringOutput `pulumi:"state"`
	// When enabled, data is encrypted in transit. (If changed to false from true, results in deletion and recreation of the
	// resource)
	Tls pulumi.BoolPtrOutput `pulumi:"tls"`
	// User email for the database
	UserEmail pulumi.StringOutput `pulumi:"userEmail"`
}

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/upstash/pulumi-upstash/sdk/go/upstash"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := upstash.NewRedisDatabase(ctx, "exampleDB", &upstash.RedisDatabaseArgs{
			DatabaseName: pulumi.String("Terraform DB6"),
			Multizone:    pulumi.Bool(true),
			Region:       pulumi.String("eu-west-1"),
			Tls:          pulumi.Bool(true),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

func GetRedisDatabase 

func GetRedisDatabase(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *RedisDatabaseState, opts ...pulumi.ResourceOption) (*RedisDatabase, error)

GetRedisDatabase gets an existing RedisDatabase resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewRedisDatabase 

func NewRedisDatabase(ctx *pulumi.Context,
	name string, args *RedisDatabaseArgs, opts ...pulumi.ResourceOption) (*RedisDatabase, error)

NewRedisDatabase registers a new resource with the given unique name, arguments, and options.

func (*RedisDatabase) ElementType 

func (*RedisDatabase) ElementType() reflect.Type

func (*RedisDatabase) ToRedisDatabaseOutput 

func (i *RedisDatabase) ToRedisDatabaseOutput() RedisDatabaseOutput

func (*RedisDatabase) ToRedisDatabaseOutputWithContext 

func (i *RedisDatabase) ToRedisDatabaseOutputWithContext(ctx context.Context) RedisDatabaseOutput

type RedisDatabaseArgs 

type RedisDatabaseArgs struct {
	// Upgrade to higher plans automatically when it hits quotas
	AutoScale pulumi.BoolPtrInput
	// When enabled, all writes are synchronously persisted to the disk.
	//
	// Deprecated: Consistent option is deprecated.
	Consistent pulumi.BoolPtrInput
	// Name of the database
	DatabaseName pulumi.StringInput
	// Enable eviction, to evict keys when your database reaches the max size
	Eviction pulumi.BoolPtrInput
	// When enabled, database becomes highly available and is deployed in multiple zones. (If changed to false from true,
	// results in deletion and recreation of the resource)
	//
	// Deprecated: Multizone option is deprecated. It is enabled by default for paid databases.
	Multizone pulumi.BoolPtrInput
	// Primary region for the database (Only works if region='global'. Can be one of [us-east-1, us-west-1, us-west-2,
	// eu-central-1, eu-west-1, sa-east-1, ap-southeast-1, ap-southeast-2])
	PrimaryRegion pulumi.StringPtrInput
	// Read regions for the database (Only works if region='global' and primary_region is set. Can be any combination of
	// [us-east-1, us-west-1, us-west-2, eu-central-1, eu-west-1, sa-east-1, ap-southeast-1, ap-southeast-2], excluding the one
	// given as primary.)
	ReadRegions pulumi.StringArrayInput
	// region of the database. Possible values are: "global", "eu-west-1", "us-east-1", "us-west-1", "ap-northeast-1" ,
	// "eu-central1"
	Region pulumi.StringInput
	// When enabled, data is encrypted in transit. (If changed to false from true, results in deletion and recreation of the
	// resource)
	Tls pulumi.BoolPtrInput
}

The set of arguments for constructing a RedisDatabase resource.

func (RedisDatabaseArgs) ElementType 

func (RedisDatabaseArgs) ElementType() reflect.Type

type RedisDatabaseArray 

type RedisDatabaseArray []RedisDatabaseInput

func (RedisDatabaseArray) ElementType 

func (RedisDatabaseArray) ElementType() reflect.Type

func (RedisDatabaseArray) ToRedisDatabaseArrayOutput 

func (i RedisDatabaseArray) ToRedisDatabaseArrayOutput() RedisDatabaseArrayOutput

func (RedisDatabaseArray) ToRedisDatabaseArrayOutputWithContext 

func (i RedisDatabaseArray) ToRedisDatabaseArrayOutputWithContext(ctx context.Context) RedisDatabaseArrayOutput

type RedisDatabaseArrayInput 

type RedisDatabaseArrayInput interface {
	pulumi.Input

	ToRedisDatabaseArrayOutput() RedisDatabaseArrayOutput
	ToRedisDatabaseArrayOutputWithContext(context.Context) RedisDatabaseArrayOutput
}

RedisDatabaseArrayInput is an input type that accepts RedisDatabaseArray and RedisDatabaseArrayOutput values. You can construct a concrete instance of `RedisDatabaseArrayInput` via: 

RedisDatabaseArray{ RedisDatabaseArgs{...} }

type RedisDatabaseArrayOutput 

type RedisDatabaseArrayOutput struct{ *pulumi.OutputState }

func (RedisDatabaseArrayOutput) ElementType 

func (RedisDatabaseArrayOutput) ElementType() reflect.Type

func (RedisDatabaseArrayOutput) Index 

func (o RedisDatabaseArrayOutput) Index(i pulumi.IntInput) RedisDatabaseOutput

func (RedisDatabaseArrayOutput) ToRedisDatabaseArrayOutput 

func (o RedisDatabaseArrayOutput) ToRedisDatabaseArrayOutput() RedisDatabaseArrayOutput

func (RedisDatabaseArrayOutput) ToRedisDatabaseArrayOutputWithContext 

func (o RedisDatabaseArrayOutput) ToRedisDatabaseArrayOutputWithContext(ctx context.Context) RedisDatabaseArrayOutput

type RedisDatabaseInput 

type RedisDatabaseInput interface {
	pulumi.Input

	ToRedisDatabaseOutput() RedisDatabaseOutput
	ToRedisDatabaseOutputWithContext(ctx context.Context) RedisDatabaseOutput
}

type RedisDatabaseMap 

type RedisDatabaseMap map[string]RedisDatabaseInput

func (RedisDatabaseMap) ElementType 

func (RedisDatabaseMap) ElementType() reflect.Type

func (RedisDatabaseMap) ToRedisDatabaseMapOutput 

func (i RedisDatabaseMap) ToRedisDatabaseMapOutput() RedisDatabaseMapOutput

func (RedisDatabaseMap) ToRedisDatabaseMapOutputWithContext 

func (i RedisDatabaseMap) ToRedisDatabaseMapOutputWithContext(ctx context.Context) RedisDatabaseMapOutput

type RedisDatabaseMapInput 

type RedisDatabaseMapInput interface {
	pulumi.Input

	ToRedisDatabaseMapOutput() RedisDatabaseMapOutput
	ToRedisDatabaseMapOutputWithContext(context.Context) RedisDatabaseMapOutput
}

RedisDatabaseMapInput is an input type that accepts RedisDatabaseMap and RedisDatabaseMapOutput values. You can construct a concrete instance of `RedisDatabaseMapInput` via: 

RedisDatabaseMap{ "key": RedisDatabaseArgs{...} }

type RedisDatabaseMapOutput 

type RedisDatabaseMapOutput struct{ *pulumi.OutputState }

func (RedisDatabaseMapOutput) ElementType 

func (RedisDatabaseMapOutput) ElementType() reflect.Type

func (RedisDatabaseMapOutput) MapIndex 

func (o RedisDatabaseMapOutput) MapIndex(k pulumi.StringInput) RedisDatabaseOutput

func (RedisDatabaseMapOutput) ToRedisDatabaseMapOutput 

func (o RedisDatabaseMapOutput) ToRedisDatabaseMapOutput() RedisDatabaseMapOutput

func (RedisDatabaseMapOutput) ToRedisDatabaseMapOutputWithContext 

func (o RedisDatabaseMapOutput) ToRedisDatabaseMapOutputWithContext(ctx context.Context) RedisDatabaseMapOutput

type RedisDatabaseOutput 

type RedisDatabaseOutput struct{ *pulumi.OutputState }

func (RedisDatabaseOutput) AutoScale added in v0.2.0 

func (o RedisDatabaseOutput) AutoScale() pulumi.BoolPtrOutput

Upgrade to higher plans automatically when it hits quotas

func (RedisDatabaseOutput) Consistent deprecated 

func (o RedisDatabaseOutput) Consistent() pulumi.BoolPtrOutput

When enabled, all writes are synchronously persisted to the disk.

Deprecated: Consistent option is deprecated.

func (RedisDatabaseOutput) CreationTime 

func (o RedisDatabaseOutput) CreationTime() pulumi.IntOutput

Creation time of the database

func (RedisDatabaseOutput) DatabaseId 

func (o RedisDatabaseOutput) DatabaseId() pulumi.StringOutput

Unique Database ID for created database

func (RedisDatabaseOutput) DatabaseName 

func (o RedisDatabaseOutput) DatabaseName() pulumi.StringOutput

Name of the database

func (RedisDatabaseOutput) DatabaseType 

func (o RedisDatabaseOutput) DatabaseType() pulumi.StringOutput

Type of the database

func (RedisDatabaseOutput) DbDailyBandwidthLimit 

func (o RedisDatabaseOutput) DbDailyBandwidthLimit() pulumi.IntOutput

Daily bandwidth limit for the database

func (RedisDatabaseOutput) DbDiskThreshold 

func (o RedisDatabaseOutput) DbDiskThreshold() pulumi.IntOutput

Disk threshold for the database

func (RedisDatabaseOutput) DbMaxClients 

func (o RedisDatabaseOutput) DbMaxClients() pulumi.IntOutput

Max clients for the database

func (RedisDatabaseOutput) DbMaxCommandsPerSecond 

func (o RedisDatabaseOutput) DbMaxCommandsPerSecond() pulumi.IntOutput

Max commands per second for the database

func (RedisDatabaseOutput) DbMaxEntrySize 

func (o RedisDatabaseOutput) DbMaxEntrySize() pulumi.IntOutput

Max entry size for the database

func (RedisDatabaseOutput) DbMaxRequestSize 

func (o RedisDatabaseOutput) DbMaxRequestSize() pulumi.IntOutput

Max request size for the database

func (RedisDatabaseOutput) DbMemoryThreshold 

func (o RedisDatabaseOutput) DbMemoryThreshold() pulumi.IntOutput

Memory threshold for the database

func (RedisDatabaseOutput) ElementType 

func (RedisDatabaseOutput) ElementType() reflect.Type

func (RedisDatabaseOutput) Endpoint 

func (o RedisDatabaseOutput) Endpoint() pulumi.StringOutput

Database URL for connection

func (RedisDatabaseOutput) Eviction added in v0.2.0 

func (o RedisDatabaseOutput) Eviction() pulumi.BoolPtrOutput

Enable eviction, to evict keys when your database reaches the max size

func (RedisDatabaseOutput) Multizone deprecated 

func (o RedisDatabaseOutput) Multizone() pulumi.BoolPtrOutput

When enabled, database becomes highly available and is deployed in multiple zones. (If changed to false from true, results in deletion and recreation of the resource)

Deprecated: Multizone option is deprecated. It is enabled by default for paid databases.

func (RedisDatabaseOutput) Password 

func (o RedisDatabaseOutput) Password() pulumi.StringOutput

Password of the database

func (RedisDatabaseOutput) Port 

func (o RedisDatabaseOutput) Port() pulumi.IntOutput

Port of the endpoint

func (RedisDatabaseOutput) PrimaryRegion added in v0.2.0 

func (o RedisDatabaseOutput) PrimaryRegion() pulumi.StringPtrOutput

Primary region for the database (Only works if region='global'. Can be one of [us-east-1, us-west-1, us-west-2, eu-central-1, eu-west-1, sa-east-1, ap-southeast-1, ap-southeast-2])

func (RedisDatabaseOutput) ReadOnlyRestToken 

func (o RedisDatabaseOutput) ReadOnlyRestToken() pulumi.StringOutput

Rest Token for the database.

func (RedisDatabaseOutput) ReadRegions added in v0.2.0 

func (o RedisDatabaseOutput) ReadRegions() pulumi.StringArrayOutput

Read regions for the database (Only works if region='global' and primary_region is set. Can be any combination of [us-east-1, us-west-1, us-west-2, eu-central-1, eu-west-1, sa-east-1, ap-southeast-1, ap-southeast-2], excluding the one given as primary.)

func (RedisDatabaseOutput) Region 

func (o RedisDatabaseOutput) Region() pulumi.StringOutput

region of the database. Possible values are: "global", "eu-west-1", "us-east-1", "us-west-1", "ap-northeast-1" , "eu-central1"

func (RedisDatabaseOutput) RestToken 

func (o RedisDatabaseOutput) RestToken() pulumi.StringOutput

Rest Token for the database.

func (RedisDatabaseOutput) State 

func (o RedisDatabaseOutput) State() pulumi.StringOutput

State of the database

func (RedisDatabaseOutput) Tls 

func (o RedisDatabaseOutput) Tls() pulumi.BoolPtrOutput

When enabled, data is encrypted in transit. (If changed to false from true, results in deletion and recreation of the resource)

func (RedisDatabaseOutput) ToRedisDatabaseOutput 

func (o RedisDatabaseOutput) ToRedisDatabaseOutput() RedisDatabaseOutput

func (RedisDatabaseOutput) ToRedisDatabaseOutputWithContext 

func (o RedisDatabaseOutput) ToRedisDatabaseOutputWithContext(ctx context.Context) RedisDatabaseOutput

func (RedisDatabaseOutput) UserEmail 

func (o RedisDatabaseOutput) UserEmail() pulumi.StringOutput

User email for the database

type RedisDatabaseState 

type RedisDatabaseState struct {
	// Upgrade to higher plans automatically when it hits quotas
	AutoScale pulumi.BoolPtrInput
	// When enabled, all writes are synchronously persisted to the disk.
	//
	// Deprecated: Consistent option is deprecated.
	Consistent pulumi.BoolPtrInput
	// Creation time of the database
	CreationTime pulumi.IntPtrInput
	// Unique Database ID for created database
	DatabaseId pulumi.StringPtrInput
	// Name of the database
	DatabaseName pulumi.StringPtrInput
	// Type of the database
	DatabaseType pulumi.StringPtrInput
	// Daily bandwidth limit for the database
	DbDailyBandwidthLimit pulumi.IntPtrInput
	// Disk threshold for the database
	DbDiskThreshold pulumi.IntPtrInput
	// Max clients for the database
	DbMaxClients pulumi.IntPtrInput
	// Max commands per second for the database
	DbMaxCommandsPerSecond pulumi.IntPtrInput
	// Max entry size for the database
	DbMaxEntrySize pulumi.IntPtrInput
	// Max request size for the database
	DbMaxRequestSize pulumi.IntPtrInput
	// Memory threshold for the database
	DbMemoryThreshold pulumi.IntPtrInput
	// Database URL for connection
	Endpoint pulumi.StringPtrInput
	// Enable eviction, to evict keys when your database reaches the max size
	Eviction pulumi.BoolPtrInput
	// When enabled, database becomes highly available and is deployed in multiple zones. (If changed to false from true,
	// results in deletion and recreation of the resource)
	//
	// Deprecated: Multizone option is deprecated. It is enabled by default for paid databases.
	Multizone pulumi.BoolPtrInput
	// Password of the database
	Password pulumi.StringPtrInput
	// Port of the endpoint
	Port pulumi.IntPtrInput
	// Primary region for the database (Only works if region='global'. Can be one of [us-east-1, us-west-1, us-west-2,
	// eu-central-1, eu-west-1, sa-east-1, ap-southeast-1, ap-southeast-2])
	PrimaryRegion pulumi.StringPtrInput
	// Rest Token for the database.
	ReadOnlyRestToken pulumi.StringPtrInput
	// Read regions for the database (Only works if region='global' and primary_region is set. Can be any combination of
	// [us-east-1, us-west-1, us-west-2, eu-central-1, eu-west-1, sa-east-1, ap-southeast-1, ap-southeast-2], excluding the one
	// given as primary.)
	ReadRegions pulumi.StringArrayInput
	// region of the database. Possible values are: "global", "eu-west-1", "us-east-1", "us-west-1", "ap-northeast-1" ,
	// "eu-central1"
	Region pulumi.StringPtrInput
	// Rest Token for the database.
	RestToken pulumi.StringPtrInput
	// State of the database
	State pulumi.StringPtrInput
	// When enabled, data is encrypted in transit. (If changed to false from true, results in deletion and recreation of the
	// resource)
	Tls pulumi.BoolPtrInput
	// User email for the database
	UserEmail pulumi.StringPtrInput
}

func (RedisDatabaseState) ElementType 

func (RedisDatabaseState) ElementType() reflect.Type

type Team 

type Team struct {
	pulumi.CustomResourceState

	// Whether Credit Card is copied
	CopyCc pulumi.BoolOutput `pulumi:"copyCc"`
	// Unique Cluster ID for created cluster
	TeamId pulumi.StringOutput `pulumi:"teamId"`
	// Members of the team. (Owner must be specified, which is the owner of the api key.)
	TeamMembers pulumi.StringMapOutput `pulumi:"teamMembers"`
	// Name of the team
	TeamName pulumi.StringOutput `pulumi:"teamName"`
}

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/upstash/pulumi-upstash/sdk/go/upstash"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := upstash.NewTeam(ctx, "exampleTeam", &upstash.TeamArgs{
			TeamName: pulumi.String("TerraformTeam"),
			CopyCc:   pulumi.Bool(false),
			TeamMembers: pulumi.StringMap{
				"X@Y.Z": pulumi.String("owner"),
				"A@B.C": pulumi.String("dev"),
				"E@E.F": pulumi.String("finance"),
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

func GetTeam 

func GetTeam(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *TeamState, opts ...pulumi.ResourceOption) (*Team, error)

GetTeam gets an existing Team resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewTeam 

func NewTeam(ctx *pulumi.Context,
	name string, args *TeamArgs, opts ...pulumi.ResourceOption) (*Team, error)

NewTeam registers a new resource with the given unique name, arguments, and options.

func (*Team) ElementType 

func (*Team) ElementType() reflect.Type

func (*Team) ToTeamOutput 

func (i *Team) ToTeamOutput() TeamOutput

func (*Team) ToTeamOutputWithContext 

func (i *Team) ToTeamOutputWithContext(ctx context.Context) TeamOutput

type TeamArgs 

type TeamArgs struct {
	// Whether Credit Card is copied
	CopyCc pulumi.BoolInput
	// Members of the team. (Owner must be specified, which is the owner of the api key.)
	TeamMembers pulumi.StringMapInput
	// Name of the team
	TeamName pulumi.StringInput
}

The set of arguments for constructing a Team resource.

func (TeamArgs) ElementType 

func (TeamArgs) ElementType() reflect.Type

type TeamArray 

type TeamArray []TeamInput

func (TeamArray) ElementType 

func (TeamArray) ElementType() reflect.Type

func (TeamArray) ToTeamArrayOutput 

func (i TeamArray) ToTeamArrayOutput() TeamArrayOutput

func (TeamArray) ToTeamArrayOutputWithContext 

func (i TeamArray) ToTeamArrayOutputWithContext(ctx context.Context) TeamArrayOutput

type TeamArrayInput 

type TeamArrayInput interface {
	pulumi.Input

	ToTeamArrayOutput() TeamArrayOutput
	ToTeamArrayOutputWithContext(context.Context) TeamArrayOutput
}

TeamArrayInput is an input type that accepts TeamArray and TeamArrayOutput values. You can construct a concrete instance of `TeamArrayInput` via: 

TeamArray{ TeamArgs{...} }

type TeamArrayOutput 

type TeamArrayOutput struct{ *pulumi.OutputState }

func (TeamArrayOutput) ElementType 

func (TeamArrayOutput) ElementType() reflect.Type

func (TeamArrayOutput) Index 

func (o TeamArrayOutput) Index(i pulumi.IntInput) TeamOutput

func (TeamArrayOutput) ToTeamArrayOutput 

func (o TeamArrayOutput) ToTeamArrayOutput() TeamArrayOutput

func (TeamArrayOutput) ToTeamArrayOutputWithContext 

func (o TeamArrayOutput) ToTeamArrayOutputWithContext(ctx context.Context) TeamArrayOutput

type TeamInput 

type TeamInput interface {
	pulumi.Input

	ToTeamOutput() TeamOutput
	ToTeamOutputWithContext(ctx context.Context) TeamOutput
}

type TeamMap 

type TeamMap map[string]TeamInput

func (TeamMap) ElementType 

func (TeamMap) ElementType() reflect.Type

func (TeamMap) ToTeamMapOutput 

func (i TeamMap) ToTeamMapOutput() TeamMapOutput

func (TeamMap) ToTeamMapOutputWithContext 

func (i TeamMap) ToTeamMapOutputWithContext(ctx context.Context) TeamMapOutput

type TeamMapInput 

type TeamMapInput interface {
	pulumi.Input

	ToTeamMapOutput() TeamMapOutput
	ToTeamMapOutputWithContext(context.Context) TeamMapOutput
}

TeamMapInput is an input type that accepts TeamMap and TeamMapOutput values. You can construct a concrete instance of `TeamMapInput` via: 

TeamMap{ "key": TeamArgs{...} }

type TeamMapOutput 

type TeamMapOutput struct{ *pulumi.OutputState }

func (TeamMapOutput) ElementType 

func (TeamMapOutput) ElementType() reflect.Type

func (TeamMapOutput) MapIndex 

func (o TeamMapOutput) MapIndex(k pulumi.StringInput) TeamOutput

func (TeamMapOutput) ToTeamMapOutput 

func (o TeamMapOutput) ToTeamMapOutput() TeamMapOutput

func (TeamMapOutput) ToTeamMapOutputWithContext 

func (o TeamMapOutput) ToTeamMapOutputWithContext(ctx context.Context) TeamMapOutput

type TeamOutput 

type TeamOutput struct{ *pulumi.OutputState }

func (TeamOutput) CopyCc 

func (o TeamOutput) CopyCc() pulumi.BoolOutput

Whether Credit Card is copied

func (TeamOutput) ElementType 

func (TeamOutput) ElementType() reflect.Type

func (TeamOutput) TeamId 

func (o TeamOutput) TeamId() pulumi.StringOutput

Unique Cluster ID for created cluster

func (TeamOutput) TeamMembers 

func (o TeamOutput) TeamMembers() pulumi.StringMapOutput

Members of the team. (Owner must be specified, which is the owner of the api key.)

func (TeamOutput) TeamName 

func (o TeamOutput) TeamName() pulumi.StringOutput

Name of the team

func (TeamOutput) ToTeamOutput 

func (o TeamOutput) ToTeamOutput() TeamOutput

func (TeamOutput) ToTeamOutputWithContext 

func (o TeamOutput) ToTeamOutputWithContext(ctx context.Context) TeamOutput

type TeamState 

type TeamState struct {
	// Whether Credit Card is copied
	CopyCc pulumi.BoolPtrInput
	// Unique Cluster ID for created cluster
	TeamId pulumi.StringPtrInput
	// Members of the team. (Owner must be specified, which is the owner of the api key.)
	TeamMembers pulumi.StringMapInput
	// Name of the team
	TeamName pulumi.StringPtrInput
}

func (TeamState) ElementType 

func (TeamState) ElementType() reflect.Type

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.