kafka

Documentation

Index

• type Acl
  • func GetAcl(ctx *pulumi.Context, name string, id pulumi.ID, state *AclState, ...) (*Acl, error)
  • func NewAcl(ctx *pulumi.Context, name string, args *AclArgs, opts ...pulumi.ResourceOpt) (*Acl, error)
  • func (r *Acl) AclHost() *pulumi.StringOutput
  • func (r *Acl) AclOperation() *pulumi.StringOutput
  • func (r *Acl) AclPermissionType() *pulumi.StringOutput
  • func (r *Acl) AclPrincipal() *pulumi.StringOutput
  • func (r *Acl) AclResourceName() *pulumi.StringOutput
  • func (r *Acl) AclResourceType() *pulumi.StringOutput
  • func (r *Acl) ID() *pulumi.IDOutput
  • func (r *Acl) ResourcePatternTypeFilter() *pulumi.StringOutput
  • func (r *Acl) URN() *pulumi.URNOutput
• type AclArgs
• type AclState
• type Topic
  • func GetTopic(ctx *pulumi.Context, name string, id pulumi.ID, state *TopicState, ...) (*Topic, error)
  • func NewTopic(ctx *pulumi.Context, name string, args *TopicArgs, opts ...pulumi.ResourceOpt) (*Topic, error)
  • func (r *Topic) Config() *pulumi.MapOutput
  • func (r *Topic) ID() *pulumi.IDOutput
  • func (r *Topic) Name() *pulumi.StringOutput
  • func (r *Topic) Partitions() *pulumi.IntOutput
  • func (r *Topic) ReplicationFactor() *pulumi.IntOutput
  • func (r *Topic) URN() *pulumi.URNOutput
• type TopicArgs
• type TopicState

Types

type Acl

type Acl struct {
	// contains filtered or unexported fields
}

A resource for managing Kafka ACLs.

> This content is derived from https://github.com/terraform-providers/terraform-provider-kafka/blob/master/website/docs/r/acl.html.markdown.

func GetAcl

func GetAcl(ctx *pulumi.Context,
	name string, id pulumi.ID, state *AclState, opts ...pulumi.ResourceOpt) (*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.ResourceOpt) (*Acl, error)

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

func (*Acl) AclHost

func (r *Acl) AclHost() *pulumi.StringOutput

Host from which principal listed in `aclPrincipal` will have access.

func (*Acl) AclOperation

func (r *Acl) AclOperation() *pulumi.StringOutput

Operation that is being allowed or denied. Valid values are `Unknown`, `Any`, `All`, `Read`, `Write`, `Create`, `Delete`, `Alter`, `Describe`, `ClusterAction`, `DescribeConfigs`, `AlterConfigs`, `IdempotentWrite`.

func (*Acl) AclPermissionType

func (r *Acl) AclPermissionType() *pulumi.StringOutput

Type of permission. Valid values are `Unknown`, `Any`, `Allow`, `Deny`.

func (*Acl) AclPrincipal

func (r *Acl) AclPrincipal() *pulumi.StringOutput

Principal that is being allowed or denied.

func (*Acl) AclResourceName

func (r *Acl) AclResourceName() *pulumi.StringOutput

The name of the resource.

func (*Acl) AclResourceType

func (r *Acl) AclResourceType() *pulumi.StringOutput

The type of resource. Valid values are `Unknown`, `Any`, `Topic`, `Group`, `Cluster`, `TransactionalID`.

func (*Acl) ID

func (r *Acl) ID() *pulumi.IDOutput

ID is this resource's unique identifier assigned by its provider.

func (*Acl) ResourcePatternTypeFilter

func (r *Acl) ResourcePatternTypeFilter() *pulumi.StringOutput

The pattern filter. Valid values are `Prefixed`, `Any`, `Match`, `Literal`.

func (*Acl) URN

func (r *Acl) URN() *pulumi.URNOutput

URN is this resource's unique name assigned by Pulumi.

type AclArgs

type AclArgs struct {
	// Host from which principal listed in `aclPrincipal`
	// will have access.
	AclHost interface{}
	// Operation that is being allowed or denied. Valid
	// values are `Unknown`, `Any`, `All`, `Read`, `Write`, `Create`, `Delete`, `Alter`,
	// `Describe`, `ClusterAction`, `DescribeConfigs`, `AlterConfigs`, `IdempotentWrite`.
	AclOperation interface{}
	// Type of permission. Valid values are `Unknown`,
	// `Any`, `Allow`, `Deny`.
	AclPermissionType interface{}
	// Principal that is being allowed or denied.
	AclPrincipal interface{}
	// The name of the resource.
	AclResourceName interface{}
	// The pattern filter. Valid values
	// are `Prefixed`, `Any`, `Match`, `Literal`.
	ResourcePatternTypeFilter interface{}
	// The type of resource. Valid values are `Unknown`,
	// `Any`, `Topic`, `Group`, `Cluster`, `TransactionalID`.
	AclResourceType interface{}
}

The set of arguments for constructing a Acl resource.

type AclState

type AclState struct {
	// Host from which principal listed in `aclPrincipal`
	// will have access.
	AclHost interface{}
	// Operation that is being allowed or denied. Valid
	// values are `Unknown`, `Any`, `All`, `Read`, `Write`, `Create`, `Delete`, `Alter`,
	// `Describe`, `ClusterAction`, `DescribeConfigs`, `AlterConfigs`, `IdempotentWrite`.
	AclOperation interface{}
	// Type of permission. Valid values are `Unknown`,
	// `Any`, `Allow`, `Deny`.
	AclPermissionType interface{}
	// Principal that is being allowed or denied.
	AclPrincipal interface{}
	// The name of the resource.
	AclResourceName interface{}
	// The pattern filter. Valid values
	// are `Prefixed`, `Any`, `Match`, `Literal`.
	ResourcePatternTypeFilter interface{}
	// The type of resource. Valid values are `Unknown`,
	// `Any`, `Topic`, `Group`, `Cluster`, `TransactionalID`.
	AclResourceType interface{}
}

Input properties used for looking up and filtering Acl resources.

type Topic

type Topic struct {
	// contains filtered or unexported fields
}

A resource for managing Kafka topics. Increases partition count without destroying the topic.

> This content is derived from https://github.com/terraform-providers/terraform-provider-kafka/blob/master/website/docs/r/topic.html.markdown.

func GetTopic

func GetTopic(ctx *pulumi.Context,
	name string, id pulumi.ID, state *TopicState, opts ...pulumi.ResourceOpt) (*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.ResourceOpt) (*Topic, error)

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

func (*Topic) Config

func (r *Topic) Config() *pulumi.MapOutput

A map of string k/v attributes.

func (*Topic) ID

func (r *Topic) ID() *pulumi.IDOutput

ID is this resource's unique identifier assigned by its provider.

func (*Topic) Name

func (r *Topic) Name() *pulumi.StringOutput

The name of the topic.

func (*Topic) Partitions

func (r *Topic) Partitions() *pulumi.IntOutput

The number of partitions the topic should have.

func (*Topic) ReplicationFactor

func (r *Topic) ReplicationFactor() *pulumi.IntOutput

The number of replicas the topic should have.

func (*Topic) URN

func (r *Topic) URN() *pulumi.URNOutput

URN is this resource's unique name assigned by Pulumi.

type TopicArgs

type TopicArgs struct {
	// A map of string k/v attributes.
	Config interface{}
	// The name of the topic.
	Name interface{}
	// The number of partitions the topic should have.
	Partitions interface{}
	// The number of replicas the topic should have.
	ReplicationFactor interface{}
}

The set of arguments for constructing a Topic resource.

type TopicState

type TopicState struct {
	// A map of string k/v attributes.
	Config interface{}
	// The name of the topic.
	Name interface{}
	// The number of partitions the topic should have.
	Partitions interface{}
	// The number of replicas the topic should have.
	ReplicationFactor interface{}
}

Input properties used for looking up and filtering Topic resources.