Documentation ¶
Overview ¶
A Pulumi package for creating and managing Kafka.
Index ¶
- func PkgVersion() (semver.Version, error)
- type Acl
- type AclArgs
- type AclArray
- type AclArrayInput
- type AclArrayOutput
- type AclInput
- type AclMap
- type AclMapInput
- type AclMapOutput
- type AclOutput
- type AclPtrInput
- type AclPtrOutput
- type AclState
- type Provider
- func (*Provider) ElementType() reflect.Type
- func (i *Provider) ToProviderOutput() ProviderOutput
- func (i *Provider) ToProviderOutputWithContext(ctx context.Context) ProviderOutput
- func (i *Provider) ToProviderPtrOutput() ProviderPtrOutput
- func (i *Provider) ToProviderPtrOutputWithContext(ctx context.Context) ProviderPtrOutput
- type ProviderArgs
- type ProviderInput
- type ProviderOutput
- func (ProviderOutput) ElementType() reflect.Type
- func (o ProviderOutput) ToProviderOutput() ProviderOutput
- func (o ProviderOutput) ToProviderOutputWithContext(ctx context.Context) ProviderOutput
- func (o ProviderOutput) ToProviderPtrOutput() ProviderPtrOutput
- func (o ProviderOutput) ToProviderPtrOutputWithContext(ctx context.Context) ProviderPtrOutput
- type ProviderPtrInput
- type ProviderPtrOutput
- type Topic
- type TopicArgs
- type TopicArray
- type TopicArrayInput
- type TopicArrayOutput
- type TopicInput
- type TopicMap
- type TopicMapInput
- type TopicMapOutput
- type TopicOutput
- func (TopicOutput) ElementType() reflect.Type
- func (o TopicOutput) ToTopicOutput() TopicOutput
- func (o TopicOutput) ToTopicOutputWithContext(ctx context.Context) TopicOutput
- func (o TopicOutput) ToTopicPtrOutput() TopicPtrOutput
- func (o TopicOutput) ToTopicPtrOutputWithContext(ctx context.Context) TopicPtrOutput
- type TopicPtrInput
- type TopicPtrOutput
- type TopicState
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func PkgVersion ¶ added in v2.5.0
PkgVersion uses reflection to determine the version of the current package.
Types ¶
type Acl ¶
type Acl struct { pulumi.CustomResourceState // Host from which principal listed in `aclPrincipal` // will have access. AclHost pulumi.StringOutput `pulumi:"aclHost"` // Operation that is being allowed or denied. Valid // values are `Unknown`, `Any`, `All`, `Read`, `Write`, `Create`, `Delete`, `Alter`, // `Describe`, `ClusterAction`, `DescribeConfigs`, `AlterConfigs`, `IdempotentWrite`. AclOperation pulumi.StringOutput `pulumi:"aclOperation"` // Type of permission. Valid values are `Unknown`, // `Any`, `Allow`, `Deny`. AclPermissionType pulumi.StringOutput `pulumi:"aclPermissionType"` // Principal that is being allowed or denied. AclPrincipal pulumi.StringOutput `pulumi:"aclPrincipal"` // The name of the resource. AclResourceName pulumi.StringOutput `pulumi:"aclResourceName"` // The type of resource. Valid values are `Unknown`, // `Any`, `Topic`, `Group`, `Cluster`, `TransactionalID`. AclResourceType pulumi.StringOutput `pulumi:"aclResourceType"` // The pattern filter. Valid values // are `Prefixed`, `Any`, `Match`, `Literal`. ResourcePatternTypeFilter pulumi.StringPtrOutput `pulumi:"resourcePatternTypeFilter"` }
A resource for managing Kafka ACLs.
## Example Usage
```go package main
import (
"github.com/pulumi/pulumi-kafka/sdk/v2/go/kafka" "github.com/pulumi/pulumi/sdk/v2/go/pulumi"
)
func main() { pulumi.Run(func(ctx *pulumi.Context) error { _, err := kafka.NewAcl(ctx, "test", &kafka.AclArgs{ AclResourceName: pulumi.String("syslog"), AclResourceType: pulumi.String("Topic"), AclPrincipal: pulumi.String("User:Alice"), AclHost: pulumi.String("*"), AclOperation: pulumi.String("Write"), AclPermissionType: pulumi.String("Deny"), }) if err != nil { return err } return nil }) }
```
func GetAcl ¶
func GetAcl(ctx *pulumi.Context, name string, id pulumi.IDInput, state *AclState, opts ...pulumi.ResourceOption) (*Acl, error)
GetAcl gets an existing Acl 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 NewAcl ¶
func NewAcl(ctx *pulumi.Context, name string, args *AclArgs, opts ...pulumi.ResourceOption) (*Acl, error)
NewAcl registers a new resource with the given unique name, arguments, and options.
func (*Acl) ElementType ¶ added in v2.4.2
func (*Acl) ToAclOutput ¶ added in v2.4.2
func (*Acl) ToAclOutputWithContext ¶ added in v2.4.2
func (*Acl) ToAclPtrOutput ¶ added in v2.5.2
func (i *Acl) ToAclPtrOutput() AclPtrOutput
func (*Acl) ToAclPtrOutputWithContext ¶ added in v2.5.2
func (i *Acl) ToAclPtrOutputWithContext(ctx context.Context) AclPtrOutput
type AclArgs ¶
type AclArgs struct { // Host from which principal listed in `aclPrincipal` // will have access. AclHost pulumi.StringInput // Operation that is being allowed or denied. Valid // values are `Unknown`, `Any`, `All`, `Read`, `Write`, `Create`, `Delete`, `Alter`, // `Describe`, `ClusterAction`, `DescribeConfigs`, `AlterConfigs`, `IdempotentWrite`. AclOperation pulumi.StringInput // Type of permission. Valid values are `Unknown`, // `Any`, `Allow`, `Deny`. AclPermissionType pulumi.StringInput // Principal that is being allowed or denied. AclPrincipal pulumi.StringInput // The name of the resource. AclResourceName pulumi.StringInput // The type of resource. Valid values are `Unknown`, // `Any`, `Topic`, `Group`, `Cluster`, `TransactionalID`. AclResourceType pulumi.StringInput // The pattern filter. Valid values // are `Prefixed`, `Any`, `Match`, `Literal`. ResourcePatternTypeFilter pulumi.StringPtrInput }
The set of arguments for constructing a Acl resource.
func (AclArgs) ElementType ¶
type AclArray ¶ added in v2.5.2
type AclArray []AclInput
func (AclArray) ElementType ¶ added in v2.5.2
func (AclArray) ToAclArrayOutput ¶ added in v2.5.2
func (i AclArray) ToAclArrayOutput() AclArrayOutput
func (AclArray) ToAclArrayOutputWithContext ¶ added in v2.5.2
func (i AclArray) ToAclArrayOutputWithContext(ctx context.Context) AclArrayOutput
type AclArrayInput ¶ added in v2.5.2
type AclArrayInput interface { pulumi.Input ToAclArrayOutput() AclArrayOutput ToAclArrayOutputWithContext(context.Context) AclArrayOutput }
AclArrayInput is an input type that accepts AclArray and AclArrayOutput values. You can construct a concrete instance of `AclArrayInput` via:
AclArray{ AclArgs{...} }
type AclArrayOutput ¶ added in v2.5.2
type AclArrayOutput struct{ *pulumi.OutputState }
func (AclArrayOutput) ElementType ¶ added in v2.5.2
func (AclArrayOutput) ElementType() reflect.Type
func (AclArrayOutput) Index ¶ added in v2.5.2
func (o AclArrayOutput) Index(i pulumi.IntInput) AclOutput
func (AclArrayOutput) ToAclArrayOutput ¶ added in v2.5.2
func (o AclArrayOutput) ToAclArrayOutput() AclArrayOutput
func (AclArrayOutput) ToAclArrayOutputWithContext ¶ added in v2.5.2
func (o AclArrayOutput) ToAclArrayOutputWithContext(ctx context.Context) AclArrayOutput
type AclMap ¶ added in v2.5.2
func (AclMap) ElementType ¶ added in v2.5.2
func (AclMap) ToAclMapOutput ¶ added in v2.5.2
func (i AclMap) ToAclMapOutput() AclMapOutput
func (AclMap) ToAclMapOutputWithContext ¶ added in v2.5.2
func (i AclMap) ToAclMapOutputWithContext(ctx context.Context) AclMapOutput
type AclMapInput ¶ added in v2.5.2
type AclMapInput interface { pulumi.Input ToAclMapOutput() AclMapOutput ToAclMapOutputWithContext(context.Context) AclMapOutput }
AclMapInput is an input type that accepts AclMap and AclMapOutput values. You can construct a concrete instance of `AclMapInput` via:
AclMap{ "key": AclArgs{...} }
type AclMapOutput ¶ added in v2.5.2
type AclMapOutput struct{ *pulumi.OutputState }
func (AclMapOutput) ElementType ¶ added in v2.5.2
func (AclMapOutput) ElementType() reflect.Type
func (AclMapOutput) MapIndex ¶ added in v2.5.2
func (o AclMapOutput) MapIndex(k pulumi.StringInput) AclOutput
func (AclMapOutput) ToAclMapOutput ¶ added in v2.5.2
func (o AclMapOutput) ToAclMapOutput() AclMapOutput
func (AclMapOutput) ToAclMapOutputWithContext ¶ added in v2.5.2
func (o AclMapOutput) ToAclMapOutputWithContext(ctx context.Context) AclMapOutput
type AclOutput ¶ added in v2.4.2
type AclOutput struct {
*pulumi.OutputState
}
func (AclOutput) ElementType ¶ added in v2.4.2
func (AclOutput) ToAclOutput ¶ added in v2.4.2
func (AclOutput) ToAclOutputWithContext ¶ added in v2.4.2
func (AclOutput) ToAclPtrOutput ¶ added in v2.5.2
func (o AclOutput) ToAclPtrOutput() AclPtrOutput
func (AclOutput) ToAclPtrOutputWithContext ¶ added in v2.5.2
func (o AclOutput) ToAclPtrOutputWithContext(ctx context.Context) AclPtrOutput
type AclPtrInput ¶ added in v2.5.2
type AclPtrInput interface { pulumi.Input ToAclPtrOutput() AclPtrOutput ToAclPtrOutputWithContext(ctx context.Context) AclPtrOutput }
type AclPtrOutput ¶ added in v2.5.2
type AclPtrOutput struct {
*pulumi.OutputState
}
func (AclPtrOutput) ElementType ¶ added in v2.5.2
func (AclPtrOutput) ElementType() reflect.Type
func (AclPtrOutput) ToAclPtrOutput ¶ added in v2.5.2
func (o AclPtrOutput) ToAclPtrOutput() AclPtrOutput
func (AclPtrOutput) ToAclPtrOutputWithContext ¶ added in v2.5.2
func (o AclPtrOutput) ToAclPtrOutputWithContext(ctx context.Context) AclPtrOutput
type AclState ¶
type AclState struct { // Host from which principal listed in `aclPrincipal` // will have access. AclHost pulumi.StringPtrInput // Operation that is being allowed or denied. Valid // values are `Unknown`, `Any`, `All`, `Read`, `Write`, `Create`, `Delete`, `Alter`, // `Describe`, `ClusterAction`, `DescribeConfigs`, `AlterConfigs`, `IdempotentWrite`. AclOperation pulumi.StringPtrInput // Type of permission. Valid values are `Unknown`, // `Any`, `Allow`, `Deny`. AclPermissionType pulumi.StringPtrInput // Principal that is being allowed or denied. AclPrincipal pulumi.StringPtrInput // The name of the resource. AclResourceName pulumi.StringPtrInput // The type of resource. Valid values are `Unknown`, // `Any`, `Topic`, `Group`, `Cluster`, `TransactionalID`. AclResourceType pulumi.StringPtrInput // The pattern filter. Valid values // are `Prefixed`, `Any`, `Match`, `Literal`. ResourcePatternTypeFilter pulumi.StringPtrInput }
func (AclState) ElementType ¶
type Provider ¶
type Provider struct {
pulumi.ProviderResourceState
}
The provider type for the kafka 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 ¶ added in v2.4.2
func (*Provider) ToProviderOutput ¶ added in v2.4.2
func (i *Provider) ToProviderOutput() ProviderOutput
func (*Provider) ToProviderOutputWithContext ¶ added in v2.4.2
func (i *Provider) ToProviderOutputWithContext(ctx context.Context) ProviderOutput
func (*Provider) ToProviderPtrOutput ¶ added in v2.5.2
func (i *Provider) ToProviderPtrOutput() ProviderPtrOutput
func (*Provider) ToProviderPtrOutputWithContext ¶ added in v2.5.2
func (i *Provider) ToProviderPtrOutputWithContext(ctx context.Context) ProviderPtrOutput
type ProviderArgs ¶
type ProviderArgs struct { // A list of kafka brokers BootstrapServers pulumi.StringArrayInput // CA certificate file to validate the server's certificate. CaCert pulumi.StringPtrInput // Path to a CA certificate file to validate the server's certificate. // // Deprecated: This parameter is now deprecated and will be removed in a later release, please use `ca_cert` instead. CaCertFile pulumi.StringPtrInput // The client certificate. ClientCert pulumi.StringPtrInput // Path to a file containing the client certificate. // // Deprecated: This parameter is now deprecated and will be removed in a later release, please use `client_cert` instead. ClientCertFile pulumi.StringPtrInput // The private key that the certificate was issued for. ClientKey pulumi.StringPtrInput // Path to a file containing the private key that the certificate was issued for. // // Deprecated: This parameter is now deprecated and will be removed in a later release, please use `client_key` instead. ClientKeyFile pulumi.StringPtrInput // The passphrase for the private key that the certificate was issued for. ClientKeyPassphrase pulumi.StringPtrInput // SASL mechanism, can be plain, scram-sha512, scram-sha256 SaslMechanism pulumi.StringPtrInput // Password for SASL authentication. SaslPassword pulumi.StringPtrInput // Username for SASL authentication. SaslUsername pulumi.StringPtrInput // Set this to true only if the target Kafka server is an insecure development instance. SkipTlsVerify pulumi.BoolPtrInput // Timeout in seconds Timeout pulumi.IntPtrInput // Enable communication with the Kafka Cluster over TLS. TlsEnabled pulumi.BoolPtrInput }
The set of arguments for constructing a Provider resource.
func (ProviderArgs) ElementType ¶
func (ProviderArgs) ElementType() reflect.Type
type ProviderInput ¶ added in v2.4.2
type ProviderInput interface { pulumi.Input ToProviderOutput() ProviderOutput ToProviderOutputWithContext(ctx context.Context) ProviderOutput }
type ProviderOutput ¶ added in v2.4.2
type ProviderOutput struct {
*pulumi.OutputState
}
func (ProviderOutput) ElementType ¶ added in v2.4.2
func (ProviderOutput) ElementType() reflect.Type
func (ProviderOutput) ToProviderOutput ¶ added in v2.4.2
func (o ProviderOutput) ToProviderOutput() ProviderOutput
func (ProviderOutput) ToProviderOutputWithContext ¶ added in v2.4.2
func (o ProviderOutput) ToProviderOutputWithContext(ctx context.Context) ProviderOutput
func (ProviderOutput) ToProviderPtrOutput ¶ added in v2.5.2
func (o ProviderOutput) ToProviderPtrOutput() ProviderPtrOutput
func (ProviderOutput) ToProviderPtrOutputWithContext ¶ added in v2.5.2
func (o ProviderOutput) ToProviderPtrOutputWithContext(ctx context.Context) ProviderPtrOutput
type ProviderPtrInput ¶ added in v2.5.2
type ProviderPtrInput interface { pulumi.Input ToProviderPtrOutput() ProviderPtrOutput ToProviderPtrOutputWithContext(ctx context.Context) ProviderPtrOutput }
type ProviderPtrOutput ¶ added in v2.5.2
type ProviderPtrOutput struct {
*pulumi.OutputState
}
func (ProviderPtrOutput) ElementType ¶ added in v2.5.2
func (ProviderPtrOutput) ElementType() reflect.Type
func (ProviderPtrOutput) ToProviderPtrOutput ¶ added in v2.5.2
func (o ProviderPtrOutput) ToProviderPtrOutput() ProviderPtrOutput
func (ProviderPtrOutput) ToProviderPtrOutputWithContext ¶ added in v2.5.2
func (o ProviderPtrOutput) ToProviderPtrOutputWithContext(ctx context.Context) ProviderPtrOutput
type Topic ¶
type Topic struct { pulumi.CustomResourceState // A map of string k/v attributes. Config pulumi.MapOutput `pulumi:"config"` // The name of the topic. Name pulumi.StringOutput `pulumi:"name"` // The number of partitions the topic should have. Partitions pulumi.IntOutput `pulumi:"partitions"` // The number of replicas the topic should have. ReplicationFactor pulumi.IntOutput `pulumi:"replicationFactor"` }
A resource for managing Kafka topics. Increases partition count without destroying the topic.
## Example Usage
```go package main
import (
"github.com/pulumi/pulumi-kafka/sdk/v2/go/kafka" "github.com/pulumi/pulumi/sdk/v2/go/pulumi"
)
func main() { pulumi.Run(func(ctx *pulumi.Context) error { _, err := kafka.NewTopic(ctx, "logs", &kafka.TopicArgs{ Config: pulumi.StringMap{ "cleanup.policy": pulumi.String("compact"), "segment.ms": pulumi.String("20000"), }, Partitions: pulumi.Int(100), ReplicationFactor: pulumi.Int(2), }) if err != nil { return err } return nil }) }
```
## Import
Topics can be imported using their ARN, e.g.
```sh
$ pulumi import kafka:index/topic:Topic logs systemd_logs
```
func GetTopic ¶
func GetTopic(ctx *pulumi.Context, name string, id pulumi.IDInput, state *TopicState, opts ...pulumi.ResourceOption) (*Topic, error)
GetTopic gets an existing Topic 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 NewTopic ¶
func NewTopic(ctx *pulumi.Context, name string, args *TopicArgs, opts ...pulumi.ResourceOption) (*Topic, error)
NewTopic registers a new resource with the given unique name, arguments, and options.
func (*Topic) ElementType ¶ added in v2.4.2
func (*Topic) ToTopicOutput ¶ added in v2.4.2
func (i *Topic) ToTopicOutput() TopicOutput
func (*Topic) ToTopicOutputWithContext ¶ added in v2.4.2
func (i *Topic) ToTopicOutputWithContext(ctx context.Context) TopicOutput
func (*Topic) ToTopicPtrOutput ¶ added in v2.5.2
func (i *Topic) ToTopicPtrOutput() TopicPtrOutput
func (*Topic) ToTopicPtrOutputWithContext ¶ added in v2.5.2
func (i *Topic) ToTopicPtrOutputWithContext(ctx context.Context) TopicPtrOutput
type TopicArgs ¶
type TopicArgs struct { // A map of string k/v attributes. Config pulumi.MapInput // The name of the topic. Name pulumi.StringPtrInput // The number of partitions the topic should have. Partitions pulumi.IntInput // The number of replicas the topic should have. ReplicationFactor pulumi.IntInput }
The set of arguments for constructing a Topic resource.
func (TopicArgs) ElementType ¶
type TopicArray ¶ added in v2.5.2
type TopicArray []TopicInput
func (TopicArray) ElementType ¶ added in v2.5.2
func (TopicArray) ElementType() reflect.Type
func (TopicArray) ToTopicArrayOutput ¶ added in v2.5.2
func (i TopicArray) ToTopicArrayOutput() TopicArrayOutput
func (TopicArray) ToTopicArrayOutputWithContext ¶ added in v2.5.2
func (i TopicArray) ToTopicArrayOutputWithContext(ctx context.Context) TopicArrayOutput
type TopicArrayInput ¶ added in v2.5.2
type TopicArrayInput interface { pulumi.Input ToTopicArrayOutput() TopicArrayOutput ToTopicArrayOutputWithContext(context.Context) TopicArrayOutput }
TopicArrayInput is an input type that accepts TopicArray and TopicArrayOutput values. You can construct a concrete instance of `TopicArrayInput` via:
TopicArray{ TopicArgs{...} }
type TopicArrayOutput ¶ added in v2.5.2
type TopicArrayOutput struct{ *pulumi.OutputState }
func (TopicArrayOutput) ElementType ¶ added in v2.5.2
func (TopicArrayOutput) ElementType() reflect.Type
func (TopicArrayOutput) Index ¶ added in v2.5.2
func (o TopicArrayOutput) Index(i pulumi.IntInput) TopicOutput
func (TopicArrayOutput) ToTopicArrayOutput ¶ added in v2.5.2
func (o TopicArrayOutput) ToTopicArrayOutput() TopicArrayOutput
func (TopicArrayOutput) ToTopicArrayOutputWithContext ¶ added in v2.5.2
func (o TopicArrayOutput) ToTopicArrayOutputWithContext(ctx context.Context) TopicArrayOutput
type TopicInput ¶ added in v2.4.2
type TopicInput interface { pulumi.Input ToTopicOutput() TopicOutput ToTopicOutputWithContext(ctx context.Context) TopicOutput }
type TopicMap ¶ added in v2.5.2
type TopicMap map[string]TopicInput
func (TopicMap) ElementType ¶ added in v2.5.2
func (TopicMap) ToTopicMapOutput ¶ added in v2.5.2
func (i TopicMap) ToTopicMapOutput() TopicMapOutput
func (TopicMap) ToTopicMapOutputWithContext ¶ added in v2.5.2
func (i TopicMap) ToTopicMapOutputWithContext(ctx context.Context) TopicMapOutput
type TopicMapInput ¶ added in v2.5.2
type TopicMapInput interface { pulumi.Input ToTopicMapOutput() TopicMapOutput ToTopicMapOutputWithContext(context.Context) TopicMapOutput }
TopicMapInput is an input type that accepts TopicMap and TopicMapOutput values. You can construct a concrete instance of `TopicMapInput` via:
TopicMap{ "key": TopicArgs{...} }
type TopicMapOutput ¶ added in v2.5.2
type TopicMapOutput struct{ *pulumi.OutputState }
func (TopicMapOutput) ElementType ¶ added in v2.5.2
func (TopicMapOutput) ElementType() reflect.Type
func (TopicMapOutput) MapIndex ¶ added in v2.5.2
func (o TopicMapOutput) MapIndex(k pulumi.StringInput) TopicOutput
func (TopicMapOutput) ToTopicMapOutput ¶ added in v2.5.2
func (o TopicMapOutput) ToTopicMapOutput() TopicMapOutput
func (TopicMapOutput) ToTopicMapOutputWithContext ¶ added in v2.5.2
func (o TopicMapOutput) ToTopicMapOutputWithContext(ctx context.Context) TopicMapOutput
type TopicOutput ¶ added in v2.4.2
type TopicOutput struct {
*pulumi.OutputState
}
func (TopicOutput) ElementType ¶ added in v2.4.2
func (TopicOutput) ElementType() reflect.Type
func (TopicOutput) ToTopicOutput ¶ added in v2.4.2
func (o TopicOutput) ToTopicOutput() TopicOutput
func (TopicOutput) ToTopicOutputWithContext ¶ added in v2.4.2
func (o TopicOutput) ToTopicOutputWithContext(ctx context.Context) TopicOutput
func (TopicOutput) ToTopicPtrOutput ¶ added in v2.5.2
func (o TopicOutput) ToTopicPtrOutput() TopicPtrOutput
func (TopicOutput) ToTopicPtrOutputWithContext ¶ added in v2.5.2
func (o TopicOutput) ToTopicPtrOutputWithContext(ctx context.Context) TopicPtrOutput
type TopicPtrInput ¶ added in v2.5.2
type TopicPtrInput interface { pulumi.Input ToTopicPtrOutput() TopicPtrOutput ToTopicPtrOutputWithContext(ctx context.Context) TopicPtrOutput }
type TopicPtrOutput ¶ added in v2.5.2
type TopicPtrOutput struct {
*pulumi.OutputState
}
func (TopicPtrOutput) ElementType ¶ added in v2.5.2
func (TopicPtrOutput) ElementType() reflect.Type
func (TopicPtrOutput) ToTopicPtrOutput ¶ added in v2.5.2
func (o TopicPtrOutput) ToTopicPtrOutput() TopicPtrOutput
func (TopicPtrOutput) ToTopicPtrOutputWithContext ¶ added in v2.5.2
func (o TopicPtrOutput) ToTopicPtrOutputWithContext(ctx context.Context) TopicPtrOutput
type TopicState ¶
type TopicState struct { // A map of string k/v attributes. Config pulumi.MapInput // The name of the topic. Name pulumi.StringPtrInput // The number of partitions the topic should have. Partitions pulumi.IntPtrInput // The number of replicas the topic should have. ReplicationFactor pulumi.IntPtrInput }
func (TopicState) ElementType ¶
func (TopicState) ElementType() reflect.Type