rocketmq

package
v0.0.32 Latest Latest
Warning

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

 Go to latest Published: Apr 23, 2026 License: MPL-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AllowList added in v0.0.24 

type AllowList struct {
	pulumi.CustomResourceState

	// IP allowlist. Separate multiple IP addresses with commas (,) and do not repeat addresses
	AllowList pulumi.StringOutput `pulumi:"allowList"`
	// Allowlist Category
	AllowListCategory pulumi.StringOutput `pulumi:"allowListCategory"`
	// Allowlist Description
	AllowListDesc pulumi.StringOutput `pulumi:"allowListDesc"`
	// Allowlist ID
	AllowListId pulumi.StringOutput `pulumi:"allowListId"`
	// Total number of IP addresses (or address ranges) in the allowlist
	AllowListIpNum pulumi.IntOutput `pulumi:"allowListIpNum"`
	// Allowlist Name
	AllowListName pulumi.StringOutput `pulumi:"allowListName"`
	// IP address type in the allowlist. Only IPv4 is supported
	AllowListType pulumi.StringOutput `pulumi:"allowListType"`
	// Total number of instances bound to the allowlist
	AssociatedInstanceNum pulumi.IntOutput                       `pulumi:"associatedInstanceNum"`
	AssociatedInstances   AllowListAssociatedInstanceArrayOutput `pulumi:"associatedInstances"`
	// Instance ID
	InstanceId pulumi.StringOutput `pulumi:"instanceId"`
}

RocketMQ Access Allowlist

## Import

```sh $ pulumi import volcenginecc:rocketmq/allowList:AllowList example "allow_list_id" ```

func GetAllowList added in v0.0.24 

func GetAllowList(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *AllowListState, opts ...pulumi.ResourceOption) (*AllowList, error)

GetAllowList gets an existing AllowList 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 NewAllowList added in v0.0.24 

func NewAllowList(ctx *pulumi.Context,
	name string, args *AllowListArgs, opts ...pulumi.ResourceOption) (*AllowList, error)

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

func (*AllowList) ElementType added in v0.0.24 

func (*AllowList) ElementType() reflect.Type

func (*AllowList) ToAllowListOutput added in v0.0.24 

func (i *AllowList) ToAllowListOutput() AllowListOutput

func (*AllowList) ToAllowListOutputWithContext added in v0.0.24 

func (i *AllowList) ToAllowListOutputWithContext(ctx context.Context) AllowListOutput

type AllowListArgs added in v0.0.24 

type AllowListArgs struct {
	// IP allowlist. Separate multiple IP addresses with commas (,) and do not repeat addresses
	AllowList pulumi.StringPtrInput
	// Allowlist Category
	AllowListCategory pulumi.StringPtrInput
	// Allowlist Description
	AllowListDesc pulumi.StringPtrInput
	// Allowlist Name
	AllowListName pulumi.StringInput
	// IP address type in the allowlist. Only IPv4 is supported
	AllowListType       pulumi.StringPtrInput
	AssociatedInstances AllowListAssociatedInstanceArrayInput
	// Instance ID
	InstanceId pulumi.StringPtrInput
}

The set of arguments for constructing a AllowList resource.

func (AllowListArgs) ElementType added in v0.0.24 

func (AllowListArgs) ElementType() reflect.Type

type AllowListArray added in v0.0.24 

type AllowListArray []AllowListInput

func (AllowListArray) ElementType added in v0.0.24 

func (AllowListArray) ElementType() reflect.Type

func (AllowListArray) ToAllowListArrayOutput added in v0.0.24 

func (i AllowListArray) ToAllowListArrayOutput() AllowListArrayOutput

func (AllowListArray) ToAllowListArrayOutputWithContext added in v0.0.24 

func (i AllowListArray) ToAllowListArrayOutputWithContext(ctx context.Context) AllowListArrayOutput

type AllowListArrayInput added in v0.0.24 

type AllowListArrayInput interface {
	pulumi.Input

	ToAllowListArrayOutput() AllowListArrayOutput
	ToAllowListArrayOutputWithContext(context.Context) AllowListArrayOutput
}

AllowListArrayInput is an input type that accepts AllowListArray and AllowListArrayOutput values. You can construct a concrete instance of `AllowListArrayInput` via: 

AllowListArray{ AllowListArgs{...} }

type AllowListArrayOutput added in v0.0.24 

type AllowListArrayOutput struct{ *pulumi.OutputState }

func (AllowListArrayOutput) ElementType added in v0.0.24 

func (AllowListArrayOutput) ElementType() reflect.Type

func (AllowListArrayOutput) Index added in v0.0.24 

func (o AllowListArrayOutput) Index(i pulumi.IntInput) AllowListOutput

func (AllowListArrayOutput) ToAllowListArrayOutput added in v0.0.24 

func (o AllowListArrayOutput) ToAllowListArrayOutput() AllowListArrayOutput

func (AllowListArrayOutput) ToAllowListArrayOutputWithContext added in v0.0.24 

func (o AllowListArrayOutput) ToAllowListArrayOutputWithContext(ctx context.Context) AllowListArrayOutput

type AllowListAssociatedInstance added in v0.0.24 

type AllowListAssociatedInstance struct {
	// Instance ID
	InstanceId *string `pulumi:"instanceId"`
	// Instance Name
	InstanceName *string `pulumi:"instanceName"`
	// VPC ID of the instance
	Vpc *string `pulumi:"vpc"`
}

type AllowListAssociatedInstanceArgs added in v0.0.24 

type AllowListAssociatedInstanceArgs struct {
	// Instance ID
	InstanceId pulumi.StringPtrInput `pulumi:"instanceId"`
	// Instance Name
	InstanceName pulumi.StringPtrInput `pulumi:"instanceName"`
	// VPC ID of the instance
	Vpc pulumi.StringPtrInput `pulumi:"vpc"`
}

func (AllowListAssociatedInstanceArgs) ElementType added in v0.0.24 

func (AllowListAssociatedInstanceArgs) ElementType() reflect.Type

func (AllowListAssociatedInstanceArgs) ToAllowListAssociatedInstanceOutput added in v0.0.24 

func (i AllowListAssociatedInstanceArgs) ToAllowListAssociatedInstanceOutput() AllowListAssociatedInstanceOutput

func (AllowListAssociatedInstanceArgs) ToAllowListAssociatedInstanceOutputWithContext added in v0.0.24 

func (i AllowListAssociatedInstanceArgs) ToAllowListAssociatedInstanceOutputWithContext(ctx context.Context) AllowListAssociatedInstanceOutput

type AllowListAssociatedInstanceArray added in v0.0.24 

type AllowListAssociatedInstanceArray []AllowListAssociatedInstanceInput

func (AllowListAssociatedInstanceArray) ElementType added in v0.0.24 

func (AllowListAssociatedInstanceArray) ElementType() reflect.Type

func (AllowListAssociatedInstanceArray) ToAllowListAssociatedInstanceArrayOutput added in v0.0.24 

func (i AllowListAssociatedInstanceArray) ToAllowListAssociatedInstanceArrayOutput() AllowListAssociatedInstanceArrayOutput

func (AllowListAssociatedInstanceArray) ToAllowListAssociatedInstanceArrayOutputWithContext added in v0.0.24 

func (i AllowListAssociatedInstanceArray) ToAllowListAssociatedInstanceArrayOutputWithContext(ctx context.Context) AllowListAssociatedInstanceArrayOutput

type AllowListAssociatedInstanceArrayInput added in v0.0.24 

type AllowListAssociatedInstanceArrayInput interface {
	pulumi.Input

	ToAllowListAssociatedInstanceArrayOutput() AllowListAssociatedInstanceArrayOutput
	ToAllowListAssociatedInstanceArrayOutputWithContext(context.Context) AllowListAssociatedInstanceArrayOutput
}

AllowListAssociatedInstanceArrayInput is an input type that accepts AllowListAssociatedInstanceArray and AllowListAssociatedInstanceArrayOutput values. You can construct a concrete instance of `AllowListAssociatedInstanceArrayInput` via: 

AllowListAssociatedInstanceArray{ AllowListAssociatedInstanceArgs{...} }

type AllowListAssociatedInstanceArrayOutput added in v0.0.24 

type AllowListAssociatedInstanceArrayOutput struct{ *pulumi.OutputState }

func (AllowListAssociatedInstanceArrayOutput) ElementType added in v0.0.24 

func (AllowListAssociatedInstanceArrayOutput) ElementType() reflect.Type

func (AllowListAssociatedInstanceArrayOutput) Index added in v0.0.24 

func (o AllowListAssociatedInstanceArrayOutput) Index(i pulumi.IntInput) AllowListAssociatedInstanceOutput

func (AllowListAssociatedInstanceArrayOutput) ToAllowListAssociatedInstanceArrayOutput added in v0.0.24 

func (o AllowListAssociatedInstanceArrayOutput) ToAllowListAssociatedInstanceArrayOutput() AllowListAssociatedInstanceArrayOutput

func (AllowListAssociatedInstanceArrayOutput) ToAllowListAssociatedInstanceArrayOutputWithContext added in v0.0.24 

func (o AllowListAssociatedInstanceArrayOutput) ToAllowListAssociatedInstanceArrayOutputWithContext(ctx context.Context) AllowListAssociatedInstanceArrayOutput

type AllowListAssociatedInstanceInput added in v0.0.24 

type AllowListAssociatedInstanceInput interface {
	pulumi.Input

	ToAllowListAssociatedInstanceOutput() AllowListAssociatedInstanceOutput
	ToAllowListAssociatedInstanceOutputWithContext(context.Context) AllowListAssociatedInstanceOutput
}

AllowListAssociatedInstanceInput is an input type that accepts AllowListAssociatedInstanceArgs and AllowListAssociatedInstanceOutput values. You can construct a concrete instance of `AllowListAssociatedInstanceInput` via: 

AllowListAssociatedInstanceArgs{...}

type AllowListAssociatedInstanceOutput added in v0.0.24 

type AllowListAssociatedInstanceOutput struct{ *pulumi.OutputState }

func (AllowListAssociatedInstanceOutput) ElementType added in v0.0.24 

func (AllowListAssociatedInstanceOutput) ElementType() reflect.Type

func (AllowListAssociatedInstanceOutput) InstanceId added in v0.0.24 

func (o AllowListAssociatedInstanceOutput) InstanceId() pulumi.StringPtrOutput

Instance ID

func (AllowListAssociatedInstanceOutput) InstanceName added in v0.0.31 

func (o AllowListAssociatedInstanceOutput) InstanceName() pulumi.StringPtrOutput

Instance Name

func (AllowListAssociatedInstanceOutput) ToAllowListAssociatedInstanceOutput added in v0.0.24 

func (o AllowListAssociatedInstanceOutput) ToAllowListAssociatedInstanceOutput() AllowListAssociatedInstanceOutput

func (AllowListAssociatedInstanceOutput) ToAllowListAssociatedInstanceOutputWithContext added in v0.0.24 

func (o AllowListAssociatedInstanceOutput) ToAllowListAssociatedInstanceOutputWithContext(ctx context.Context) AllowListAssociatedInstanceOutput

func (AllowListAssociatedInstanceOutput) Vpc added in v0.0.31 

func (o AllowListAssociatedInstanceOutput) Vpc() pulumi.StringPtrOutput

VPC ID of the instance

type AllowListInput added in v0.0.24 

type AllowListInput interface {
	pulumi.Input

	ToAllowListOutput() AllowListOutput
	ToAllowListOutputWithContext(ctx context.Context) AllowListOutput
}

type AllowListMap added in v0.0.24 

type AllowListMap map[string]AllowListInput

func (AllowListMap) ElementType added in v0.0.24 

func (AllowListMap) ElementType() reflect.Type

func (AllowListMap) ToAllowListMapOutput added in v0.0.24 

func (i AllowListMap) ToAllowListMapOutput() AllowListMapOutput

func (AllowListMap) ToAllowListMapOutputWithContext added in v0.0.24 

func (i AllowListMap) ToAllowListMapOutputWithContext(ctx context.Context) AllowListMapOutput

type AllowListMapInput added in v0.0.24 

type AllowListMapInput interface {
	pulumi.Input

	ToAllowListMapOutput() AllowListMapOutput
	ToAllowListMapOutputWithContext(context.Context) AllowListMapOutput
}

AllowListMapInput is an input type that accepts AllowListMap and AllowListMapOutput values. You can construct a concrete instance of `AllowListMapInput` via: 

AllowListMap{ "key": AllowListArgs{...} }

type AllowListMapOutput added in v0.0.24 

type AllowListMapOutput struct{ *pulumi.OutputState }

func (AllowListMapOutput) ElementType added in v0.0.24 

func (AllowListMapOutput) ElementType() reflect.Type

func (AllowListMapOutput) MapIndex added in v0.0.24 

func (o AllowListMapOutput) MapIndex(k pulumi.StringInput) AllowListOutput

func (AllowListMapOutput) ToAllowListMapOutput added in v0.0.24 

func (o AllowListMapOutput) ToAllowListMapOutput() AllowListMapOutput

func (AllowListMapOutput) ToAllowListMapOutputWithContext added in v0.0.24 

func (o AllowListMapOutput) ToAllowListMapOutputWithContext(ctx context.Context) AllowListMapOutput

type AllowListOutput added in v0.0.24 

type AllowListOutput struct{ *pulumi.OutputState }

func (AllowListOutput) AllowList added in v0.0.24 

func (o AllowListOutput) AllowList() pulumi.StringOutput

IP allowlist. Separate multiple IP addresses with commas (,) and do not repeat addresses

func (AllowListOutput) AllowListCategory added in v0.0.24 

func (o AllowListOutput) AllowListCategory() pulumi.StringOutput

Allowlist Category

func (AllowListOutput) AllowListDesc added in v0.0.24 

func (o AllowListOutput) AllowListDesc() pulumi.StringOutput

Allowlist Description

func (AllowListOutput) AllowListId added in v0.0.24 

func (o AllowListOutput) AllowListId() pulumi.StringOutput

Allowlist ID

func (AllowListOutput) AllowListIpNum added in v0.0.24 

func (o AllowListOutput) AllowListIpNum() pulumi.IntOutput

Total number of IP addresses (or address ranges) in the allowlist

func (AllowListOutput) AllowListName added in v0.0.24 

func (o AllowListOutput) AllowListName() pulumi.StringOutput

Allowlist Name

func (AllowListOutput) AllowListType added in v0.0.24 

func (o AllowListOutput) AllowListType() pulumi.StringOutput

IP address type in the allowlist. Only IPv4 is supported

func (AllowListOutput) AssociatedInstanceNum added in v0.0.24 

func (o AllowListOutput) AssociatedInstanceNum() pulumi.IntOutput

Total number of instances bound to the allowlist

func (AllowListOutput) AssociatedInstances added in v0.0.24 

func (o AllowListOutput) AssociatedInstances() AllowListAssociatedInstanceArrayOutput

func (AllowListOutput) ElementType added in v0.0.24 

func (AllowListOutput) ElementType() reflect.Type

func (AllowListOutput) InstanceId added in v0.0.24 

func (o AllowListOutput) InstanceId() pulumi.StringOutput

Instance ID

func (AllowListOutput) ToAllowListOutput added in v0.0.24 

func (o AllowListOutput) ToAllowListOutput() AllowListOutput

func (AllowListOutput) ToAllowListOutputWithContext added in v0.0.24 

func (o AllowListOutput) ToAllowListOutputWithContext(ctx context.Context) AllowListOutput

type AllowListState added in v0.0.24 

type AllowListState struct {
	// IP allowlist. Separate multiple IP addresses with commas (,) and do not repeat addresses
	AllowList pulumi.StringPtrInput
	// Allowlist Category
	AllowListCategory pulumi.StringPtrInput
	// Allowlist Description
	AllowListDesc pulumi.StringPtrInput
	// Allowlist ID
	AllowListId pulumi.StringPtrInput
	// Total number of IP addresses (or address ranges) in the allowlist
	AllowListIpNum pulumi.IntPtrInput
	// Allowlist Name
	AllowListName pulumi.StringPtrInput
	// IP address type in the allowlist. Only IPv4 is supported
	AllowListType pulumi.StringPtrInput
	// Total number of instances bound to the allowlist
	AssociatedInstanceNum pulumi.IntPtrInput
	AssociatedInstances   AllowListAssociatedInstanceArrayInput
	// Instance ID
	InstanceId pulumi.StringPtrInput
}

func (AllowListState) ElementType added in v0.0.24 

func (AllowListState) ElementType() reflect.Type

type GetAllowListAssociatedInstance added in v0.0.24 

type GetAllowListAssociatedInstance struct {
	// Instance ID
	InstanceId string `pulumi:"instanceId"`
	// Instance Name
	InstanceName string `pulumi:"instanceName"`
	// VPC ID of the instance
	Vpc string `pulumi:"vpc"`
}

type GetAllowListAssociatedInstanceArgs added in v0.0.24 

type GetAllowListAssociatedInstanceArgs struct {
	// Instance ID
	InstanceId pulumi.StringInput `pulumi:"instanceId"`
	// Instance Name
	InstanceName pulumi.StringInput `pulumi:"instanceName"`
	// VPC ID of the instance
	Vpc pulumi.StringInput `pulumi:"vpc"`
}

func (GetAllowListAssociatedInstanceArgs) ElementType added in v0.0.24 

func (GetAllowListAssociatedInstanceArgs) ElementType() reflect.Type

func (GetAllowListAssociatedInstanceArgs) ToGetAllowListAssociatedInstanceOutput added in v0.0.24 

func (i GetAllowListAssociatedInstanceArgs) ToGetAllowListAssociatedInstanceOutput() GetAllowListAssociatedInstanceOutput

func (GetAllowListAssociatedInstanceArgs) ToGetAllowListAssociatedInstanceOutputWithContext added in v0.0.24 

func (i GetAllowListAssociatedInstanceArgs) ToGetAllowListAssociatedInstanceOutputWithContext(ctx context.Context) GetAllowListAssociatedInstanceOutput

type GetAllowListAssociatedInstanceArray added in v0.0.24 

type GetAllowListAssociatedInstanceArray []GetAllowListAssociatedInstanceInput

func (GetAllowListAssociatedInstanceArray) ElementType added in v0.0.24 

func (GetAllowListAssociatedInstanceArray) ElementType() reflect.Type

func (GetAllowListAssociatedInstanceArray) ToGetAllowListAssociatedInstanceArrayOutput added in v0.0.24 

func (i GetAllowListAssociatedInstanceArray) ToGetAllowListAssociatedInstanceArrayOutput() GetAllowListAssociatedInstanceArrayOutput

func (GetAllowListAssociatedInstanceArray) ToGetAllowListAssociatedInstanceArrayOutputWithContext added in v0.0.24 

func (i GetAllowListAssociatedInstanceArray) ToGetAllowListAssociatedInstanceArrayOutputWithContext(ctx context.Context) GetAllowListAssociatedInstanceArrayOutput

type GetAllowListAssociatedInstanceArrayInput added in v0.0.24 

type GetAllowListAssociatedInstanceArrayInput interface {
	pulumi.Input

	ToGetAllowListAssociatedInstanceArrayOutput() GetAllowListAssociatedInstanceArrayOutput
	ToGetAllowListAssociatedInstanceArrayOutputWithContext(context.Context) GetAllowListAssociatedInstanceArrayOutput
}

GetAllowListAssociatedInstanceArrayInput is an input type that accepts GetAllowListAssociatedInstanceArray and GetAllowListAssociatedInstanceArrayOutput values. You can construct a concrete instance of `GetAllowListAssociatedInstanceArrayInput` via: 

GetAllowListAssociatedInstanceArray{ GetAllowListAssociatedInstanceArgs{...} }

type GetAllowListAssociatedInstanceArrayOutput added in v0.0.24 

type GetAllowListAssociatedInstanceArrayOutput struct{ *pulumi.OutputState }

func (GetAllowListAssociatedInstanceArrayOutput) ElementType added in v0.0.24 

func (GetAllowListAssociatedInstanceArrayOutput) ElementType() reflect.Type

func (GetAllowListAssociatedInstanceArrayOutput) Index added in v0.0.24 

func (o GetAllowListAssociatedInstanceArrayOutput) Index(i pulumi.IntInput) GetAllowListAssociatedInstanceOutput

func (GetAllowListAssociatedInstanceArrayOutput) ToGetAllowListAssociatedInstanceArrayOutput added in v0.0.24 

func (o GetAllowListAssociatedInstanceArrayOutput) ToGetAllowListAssociatedInstanceArrayOutput() GetAllowListAssociatedInstanceArrayOutput

func (GetAllowListAssociatedInstanceArrayOutput) ToGetAllowListAssociatedInstanceArrayOutputWithContext added in v0.0.24 

func (o GetAllowListAssociatedInstanceArrayOutput) ToGetAllowListAssociatedInstanceArrayOutputWithContext(ctx context.Context) GetAllowListAssociatedInstanceArrayOutput

type GetAllowListAssociatedInstanceInput added in v0.0.24 

type GetAllowListAssociatedInstanceInput interface {
	pulumi.Input

	ToGetAllowListAssociatedInstanceOutput() GetAllowListAssociatedInstanceOutput
	ToGetAllowListAssociatedInstanceOutputWithContext(context.Context) GetAllowListAssociatedInstanceOutput
}

GetAllowListAssociatedInstanceInput is an input type that accepts GetAllowListAssociatedInstanceArgs and GetAllowListAssociatedInstanceOutput values. You can construct a concrete instance of `GetAllowListAssociatedInstanceInput` via: 

GetAllowListAssociatedInstanceArgs{...}

type GetAllowListAssociatedInstanceOutput added in v0.0.24 

type GetAllowListAssociatedInstanceOutput struct{ *pulumi.OutputState }

func (GetAllowListAssociatedInstanceOutput) ElementType added in v0.0.24 

func (GetAllowListAssociatedInstanceOutput) ElementType() reflect.Type

func (GetAllowListAssociatedInstanceOutput) InstanceId added in v0.0.24 

func (o GetAllowListAssociatedInstanceOutput) InstanceId() pulumi.StringOutput

Instance ID

func (GetAllowListAssociatedInstanceOutput) InstanceName added in v0.0.24 

func (o GetAllowListAssociatedInstanceOutput) InstanceName() pulumi.StringOutput

Instance Name

func (GetAllowListAssociatedInstanceOutput) ToGetAllowListAssociatedInstanceOutput added in v0.0.24 

func (o GetAllowListAssociatedInstanceOutput) ToGetAllowListAssociatedInstanceOutput() GetAllowListAssociatedInstanceOutput

func (GetAllowListAssociatedInstanceOutput) ToGetAllowListAssociatedInstanceOutputWithContext added in v0.0.24 

func (o GetAllowListAssociatedInstanceOutput) ToGetAllowListAssociatedInstanceOutputWithContext(ctx context.Context) GetAllowListAssociatedInstanceOutput

func (GetAllowListAssociatedInstanceOutput) Vpc added in v0.0.24 

func (o GetAllowListAssociatedInstanceOutput) Vpc() pulumi.StringOutput

VPC ID of the instance

type GetAllowListsResult added in v0.0.24 

type GetAllowListsResult struct {
	// Uniquely identifies the data source.
	Id string `pulumi:"id"`
	// Set of Resource Identifiers.
	Ids []string `pulumi:"ids"`
}

A collection of values returned by getAllowLists.

func GetAllowLists added in v0.0.24 

func GetAllowLists(ctx *pulumi.Context, opts ...pulumi.InvokeOption) (*GetAllowListsResult, error)

Plural Data Source schema for Volcengine::RocketMQ::AllowList

type GetAllowListsResultOutput added in v0.0.24 

type GetAllowListsResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getAllowLists.

func GetAllowListsOutput added in v0.0.24 

func GetAllowListsOutput(ctx *pulumi.Context, opts ...pulumi.InvokeOption) GetAllowListsResultOutput

func (GetAllowListsResultOutput) ElementType added in v0.0.24 

func (GetAllowListsResultOutput) ElementType() reflect.Type

func (GetAllowListsResultOutput) Id added in v0.0.24 

func (o GetAllowListsResultOutput) Id() pulumi.StringOutput

Uniquely identifies the data source.

func (GetAllowListsResultOutput) Ids added in v0.0.24 

func (o GetAllowListsResultOutput) Ids() pulumi.StringArrayOutput

Set of Resource Identifiers.

func (GetAllowListsResultOutput) ToGetAllowListsResultOutput added in v0.0.24 

func (o GetAllowListsResultOutput) ToGetAllowListsResultOutput() GetAllowListsResultOutput

func (GetAllowListsResultOutput) ToGetAllowListsResultOutputWithContext added in v0.0.24 

func (o GetAllowListsResultOutput) ToGetAllowListsResultOutputWithContext(ctx context.Context) GetAllowListsResultOutput

type GetGroupConsumedClient added in v0.0.22 

type GetGroupConsumedClient struct {
	// Address and port of this consumer instance.
	ClientAddress string `pulumi:"clientAddress"`
	// ID of this consumer instance.
	ClientId string `pulumi:"clientId"`
	// Message backlog.
	Diff int `pulumi:"diff"`
	// Development language of the consumer application.
	Language string `pulumi:"language"`
	// Consumer version.
	Version string `pulumi:"version"`
}

type GetGroupConsumedClientArgs added in v0.0.22 

type GetGroupConsumedClientArgs struct {
	// Address and port of this consumer instance.
	ClientAddress pulumi.StringInput `pulumi:"clientAddress"`
	// ID of this consumer instance.
	ClientId pulumi.StringInput `pulumi:"clientId"`
	// Message backlog.
	Diff pulumi.IntInput `pulumi:"diff"`
	// Development language of the consumer application.
	Language pulumi.StringInput `pulumi:"language"`
	// Consumer version.
	Version pulumi.StringInput `pulumi:"version"`
}

func (GetGroupConsumedClientArgs) ElementType added in v0.0.22 

func (GetGroupConsumedClientArgs) ElementType() reflect.Type

func (GetGroupConsumedClientArgs) ToGetGroupConsumedClientOutput added in v0.0.22 

func (i GetGroupConsumedClientArgs) ToGetGroupConsumedClientOutput() GetGroupConsumedClientOutput

func (GetGroupConsumedClientArgs) ToGetGroupConsumedClientOutputWithContext added in v0.0.22 

func (i GetGroupConsumedClientArgs) ToGetGroupConsumedClientOutputWithContext(ctx context.Context) GetGroupConsumedClientOutput

type GetGroupConsumedClientArray added in v0.0.22 

type GetGroupConsumedClientArray []GetGroupConsumedClientInput

func (GetGroupConsumedClientArray) ElementType added in v0.0.22 

func (GetGroupConsumedClientArray) ElementType() reflect.Type

func (GetGroupConsumedClientArray) ToGetGroupConsumedClientArrayOutput added in v0.0.22 

func (i GetGroupConsumedClientArray) ToGetGroupConsumedClientArrayOutput() GetGroupConsumedClientArrayOutput

func (GetGroupConsumedClientArray) ToGetGroupConsumedClientArrayOutputWithContext added in v0.0.22 

func (i GetGroupConsumedClientArray) ToGetGroupConsumedClientArrayOutputWithContext(ctx context.Context) GetGroupConsumedClientArrayOutput

type GetGroupConsumedClientArrayInput added in v0.0.22 

type GetGroupConsumedClientArrayInput interface {
	pulumi.Input

	ToGetGroupConsumedClientArrayOutput() GetGroupConsumedClientArrayOutput
	ToGetGroupConsumedClientArrayOutputWithContext(context.Context) GetGroupConsumedClientArrayOutput
}

GetGroupConsumedClientArrayInput is an input type that accepts GetGroupConsumedClientArray and GetGroupConsumedClientArrayOutput values. You can construct a concrete instance of `GetGroupConsumedClientArrayInput` via: 

GetGroupConsumedClientArray{ GetGroupConsumedClientArgs{...} }

type GetGroupConsumedClientArrayOutput added in v0.0.22 

type GetGroupConsumedClientArrayOutput struct{ *pulumi.OutputState }

func (GetGroupConsumedClientArrayOutput) ElementType added in v0.0.22 

func (GetGroupConsumedClientArrayOutput) ElementType() reflect.Type

func (GetGroupConsumedClientArrayOutput) Index added in v0.0.22 

func (o GetGroupConsumedClientArrayOutput) Index(i pulumi.IntInput) GetGroupConsumedClientOutput

func (GetGroupConsumedClientArrayOutput) ToGetGroupConsumedClientArrayOutput added in v0.0.22 

func (o GetGroupConsumedClientArrayOutput) ToGetGroupConsumedClientArrayOutput() GetGroupConsumedClientArrayOutput

func (GetGroupConsumedClientArrayOutput) ToGetGroupConsumedClientArrayOutputWithContext added in v0.0.22 

func (o GetGroupConsumedClientArrayOutput) ToGetGroupConsumedClientArrayOutputWithContext(ctx context.Context) GetGroupConsumedClientArrayOutput

type GetGroupConsumedClientInput added in v0.0.22 

type GetGroupConsumedClientInput interface {
	pulumi.Input

	ToGetGroupConsumedClientOutput() GetGroupConsumedClientOutput
	ToGetGroupConsumedClientOutputWithContext(context.Context) GetGroupConsumedClientOutput
}

GetGroupConsumedClientInput is an input type that accepts GetGroupConsumedClientArgs and GetGroupConsumedClientOutput values. You can construct a concrete instance of `GetGroupConsumedClientInput` via: 

GetGroupConsumedClientArgs{...}

type GetGroupConsumedClientOutput added in v0.0.22 

type GetGroupConsumedClientOutput struct{ *pulumi.OutputState }

func (GetGroupConsumedClientOutput) ClientAddress added in v0.0.22 

func (o GetGroupConsumedClientOutput) ClientAddress() pulumi.StringOutput

Address and port of this consumer instance.

func (GetGroupConsumedClientOutput) ClientId added in v0.0.22 

func (o GetGroupConsumedClientOutput) ClientId() pulumi.StringOutput

ID of this consumer instance.

func (GetGroupConsumedClientOutput) Diff added in v0.0.22 

func (o GetGroupConsumedClientOutput) Diff() pulumi.IntOutput

Message backlog.

func (GetGroupConsumedClientOutput) ElementType added in v0.0.22 

func (GetGroupConsumedClientOutput) ElementType() reflect.Type

func (GetGroupConsumedClientOutput) Language added in v0.0.22 

func (o GetGroupConsumedClientOutput) Language() pulumi.StringOutput

Development language of the consumer application.

func (GetGroupConsumedClientOutput) ToGetGroupConsumedClientOutput added in v0.0.22 

func (o GetGroupConsumedClientOutput) ToGetGroupConsumedClientOutput() GetGroupConsumedClientOutput

func (GetGroupConsumedClientOutput) ToGetGroupConsumedClientOutputWithContext added in v0.0.22 

func (o GetGroupConsumedClientOutput) ToGetGroupConsumedClientOutputWithContext(ctx context.Context) GetGroupConsumedClientOutput

func (GetGroupConsumedClientOutput) Version added in v0.0.22 

func (o GetGroupConsumedClientOutput) Version() pulumi.StringOutput

Consumer version.

type GetGroupConsumedTopic added in v0.0.22 

type GetGroupConsumedTopic struct {
	// Number of queues associated with the Topic. Each Topic contains one or more queues for storing messages.
	QueueNum int `pulumi:"queueNum"`
	// Subscription rules.
	SubString string `pulumi:"subString"`
	// Name of the Topic subscribed by the client.
	TopicName string `pulumi:"topicName"`
}

type GetGroupConsumedTopicArgs added in v0.0.22 

type GetGroupConsumedTopicArgs struct {
	// Number of queues associated with the Topic. Each Topic contains one or more queues for storing messages.
	QueueNum pulumi.IntInput `pulumi:"queueNum"`
	// Subscription rules.
	SubString pulumi.StringInput `pulumi:"subString"`
	// Name of the Topic subscribed by the client.
	TopicName pulumi.StringInput `pulumi:"topicName"`
}

func (GetGroupConsumedTopicArgs) ElementType added in v0.0.22 

func (GetGroupConsumedTopicArgs) ElementType() reflect.Type

func (GetGroupConsumedTopicArgs) ToGetGroupConsumedTopicOutput added in v0.0.22 

func (i GetGroupConsumedTopicArgs) ToGetGroupConsumedTopicOutput() GetGroupConsumedTopicOutput

func (GetGroupConsumedTopicArgs) ToGetGroupConsumedTopicOutputWithContext added in v0.0.22 

func (i GetGroupConsumedTopicArgs) ToGetGroupConsumedTopicOutputWithContext(ctx context.Context) GetGroupConsumedTopicOutput

type GetGroupConsumedTopicArray added in v0.0.22 

type GetGroupConsumedTopicArray []GetGroupConsumedTopicInput

func (GetGroupConsumedTopicArray) ElementType added in v0.0.22 

func (GetGroupConsumedTopicArray) ElementType() reflect.Type

func (GetGroupConsumedTopicArray) ToGetGroupConsumedTopicArrayOutput added in v0.0.22 

func (i GetGroupConsumedTopicArray) ToGetGroupConsumedTopicArrayOutput() GetGroupConsumedTopicArrayOutput

func (GetGroupConsumedTopicArray) ToGetGroupConsumedTopicArrayOutputWithContext added in v0.0.22 

func (i GetGroupConsumedTopicArray) ToGetGroupConsumedTopicArrayOutputWithContext(ctx context.Context) GetGroupConsumedTopicArrayOutput

type GetGroupConsumedTopicArrayInput added in v0.0.22 

type GetGroupConsumedTopicArrayInput interface {
	pulumi.Input

	ToGetGroupConsumedTopicArrayOutput() GetGroupConsumedTopicArrayOutput
	ToGetGroupConsumedTopicArrayOutputWithContext(context.Context) GetGroupConsumedTopicArrayOutput
}

GetGroupConsumedTopicArrayInput is an input type that accepts GetGroupConsumedTopicArray and GetGroupConsumedTopicArrayOutput values. You can construct a concrete instance of `GetGroupConsumedTopicArrayInput` via: 

GetGroupConsumedTopicArray{ GetGroupConsumedTopicArgs{...} }

type GetGroupConsumedTopicArrayOutput added in v0.0.22 

type GetGroupConsumedTopicArrayOutput struct{ *pulumi.OutputState }

func (GetGroupConsumedTopicArrayOutput) ElementType added in v0.0.22 

func (GetGroupConsumedTopicArrayOutput) ElementType() reflect.Type

func (GetGroupConsumedTopicArrayOutput) Index added in v0.0.22 

func (o GetGroupConsumedTopicArrayOutput) Index(i pulumi.IntInput) GetGroupConsumedTopicOutput

func (GetGroupConsumedTopicArrayOutput) ToGetGroupConsumedTopicArrayOutput added in v0.0.22 

func (o GetGroupConsumedTopicArrayOutput) ToGetGroupConsumedTopicArrayOutput() GetGroupConsumedTopicArrayOutput

func (GetGroupConsumedTopicArrayOutput) ToGetGroupConsumedTopicArrayOutputWithContext added in v0.0.22 

func (o GetGroupConsumedTopicArrayOutput) ToGetGroupConsumedTopicArrayOutputWithContext(ctx context.Context) GetGroupConsumedTopicArrayOutput

type GetGroupConsumedTopicInput added in v0.0.22 

type GetGroupConsumedTopicInput interface {
	pulumi.Input

	ToGetGroupConsumedTopicOutput() GetGroupConsumedTopicOutput
	ToGetGroupConsumedTopicOutputWithContext(context.Context) GetGroupConsumedTopicOutput
}

GetGroupConsumedTopicInput is an input type that accepts GetGroupConsumedTopicArgs and GetGroupConsumedTopicOutput values. You can construct a concrete instance of `GetGroupConsumedTopicInput` via: 

GetGroupConsumedTopicArgs{...}

type GetGroupConsumedTopicOutput added in v0.0.22 

type GetGroupConsumedTopicOutput struct{ *pulumi.OutputState }

func (GetGroupConsumedTopicOutput) ElementType added in v0.0.22 

func (GetGroupConsumedTopicOutput) ElementType() reflect.Type

func (GetGroupConsumedTopicOutput) QueueNum added in v0.0.22 

func (o GetGroupConsumedTopicOutput) QueueNum() pulumi.IntOutput

Number of queues associated with the Topic. Each Topic contains one or more queues for storing messages.

func (GetGroupConsumedTopicOutput) SubString added in v0.0.22 

func (o GetGroupConsumedTopicOutput) SubString() pulumi.StringOutput

Subscription rules.

func (GetGroupConsumedTopicOutput) ToGetGroupConsumedTopicOutput added in v0.0.22 

func (o GetGroupConsumedTopicOutput) ToGetGroupConsumedTopicOutput() GetGroupConsumedTopicOutput

func (GetGroupConsumedTopicOutput) ToGetGroupConsumedTopicOutputWithContext added in v0.0.22 

func (o GetGroupConsumedTopicOutput) ToGetGroupConsumedTopicOutputWithContext(ctx context.Context) GetGroupConsumedTopicOutput

func (GetGroupConsumedTopicOutput) TopicName added in v0.0.22 

func (o GetGroupConsumedTopicOutput) TopicName() pulumi.StringOutput

Name of the Topic subscribed by the client.

type GetGroupsResult added in v0.0.22 

type GetGroupsResult struct {
	// Uniquely identifies the data source.
	Id string `pulumi:"id"`
	// Set of Resource Identifiers.
	Ids []string `pulumi:"ids"`
}

A collection of values returned by getGroups.

func GetGroups added in v0.0.22 

func GetGroups(ctx *pulumi.Context, opts ...pulumi.InvokeOption) (*GetGroupsResult, error)

Plural Data Source schema for Volcengine::RocketMQ::Group

type GetGroupsResultOutput added in v0.0.22 

type GetGroupsResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getGroups.

func GetGroupsOutput added in v0.0.22 

func GetGroupsOutput(ctx *pulumi.Context, opts ...pulumi.InvokeOption) GetGroupsResultOutput

func (GetGroupsResultOutput) ElementType added in v0.0.22 

func (GetGroupsResultOutput) ElementType() reflect.Type

func (GetGroupsResultOutput) Id added in v0.0.22 

func (o GetGroupsResultOutput) Id() pulumi.StringOutput

Uniquely identifies the data source.

func (GetGroupsResultOutput) Ids added in v0.0.22 

func (o GetGroupsResultOutput) Ids() pulumi.StringArrayOutput

Set of Resource Identifiers.

func (GetGroupsResultOutput) ToGetGroupsResultOutput added in v0.0.22 

func (o GetGroupsResultOutput) ToGetGroupsResultOutput() GetGroupsResultOutput

func (GetGroupsResultOutput) ToGetGroupsResultOutputWithContext added in v0.0.22 

func (o GetGroupsResultOutput) ToGetGroupsResultOutputWithContext(ctx context.Context) GetGroupsResultOutput

type GetInstanceChargeDetail 

type GetInstanceChargeDetail struct {
	// Whether the subscription instance is automatically renewed upon expiration. true: automatically renewed. false: not automatically renewed. Manual renewal is required after expiration; otherwise, the instance will be shut down.
	AutoRenew bool `pulumi:"autoRenew"`
	// Expiration time for yearly/monthly subscription instances. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'. For pay-as-you-go instances, this field defaults to 1970-01-01T00:00:00Z.
	ChargeExpireTime string `pulumi:"chargeExpireTime"`
	// Billing start time for the instance. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'.
	ChargeStartTime string `pulumi:"chargeStartTime"`
	// Instance billing status. Includes: Normal: normal Overdue: pay-as-you-go overdue Expired: subscription expired
	ChargeStatus string `pulumi:"chargeStatus"`
	// Billing type for the instance. Supported types include: PostPaid: pay-as-you-go; PrePaid: yearly/monthly subscription
	ChargeType string `pulumi:"chargeType"`
	// Estimated release time after the instance is suspended due to overdue payment. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'.
	OverdueReclaimTime string `pulumi:"overdueReclaimTime"`
	// Suspension time due to overdue payment for the instance. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'.
	OverdueTime string `pulumi:"overdueTime"`
	// Purchase duration for subscription instances. When PeriodUnit is set to Monthly, the value range is 1–9. When PeriodUnit is set to Yearly, the value range is 1–3. Only required for subscription instances, that is, when ChargeType is set to PrePaid.
	Period int `pulumi:"period"`
	// Lifecycle unit for subscription-based instances, specifying whether to purchase by month or by year. Monthly: (default) monthly subscription Yearly: annual subscription
	PeriodUnit string `pulumi:"periodUnit"`
}

type GetInstanceChargeDetailArgs 

type GetInstanceChargeDetailArgs struct {
	// Whether the subscription instance is automatically renewed upon expiration. true: automatically renewed. false: not automatically renewed. Manual renewal is required after expiration; otherwise, the instance will be shut down.
	AutoRenew pulumi.BoolInput `pulumi:"autoRenew"`
	// Expiration time for yearly/monthly subscription instances. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'. For pay-as-you-go instances, this field defaults to 1970-01-01T00:00:00Z.
	ChargeExpireTime pulumi.StringInput `pulumi:"chargeExpireTime"`
	// Billing start time for the instance. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'.
	ChargeStartTime pulumi.StringInput `pulumi:"chargeStartTime"`
	// Instance billing status. Includes: Normal: normal Overdue: pay-as-you-go overdue Expired: subscription expired
	ChargeStatus pulumi.StringInput `pulumi:"chargeStatus"`
	// Billing type for the instance. Supported types include: PostPaid: pay-as-you-go; PrePaid: yearly/monthly subscription
	ChargeType pulumi.StringInput `pulumi:"chargeType"`
	// Estimated release time after the instance is suspended due to overdue payment. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'.
	OverdueReclaimTime pulumi.StringInput `pulumi:"overdueReclaimTime"`
	// Suspension time due to overdue payment for the instance. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'.
	OverdueTime pulumi.StringInput `pulumi:"overdueTime"`
	// Purchase duration for subscription instances. When PeriodUnit is set to Monthly, the value range is 1–9. When PeriodUnit is set to Yearly, the value range is 1–3. Only required for subscription instances, that is, when ChargeType is set to PrePaid.
	Period pulumi.IntInput `pulumi:"period"`
	// Lifecycle unit for subscription-based instances, specifying whether to purchase by month or by year. Monthly: (default) monthly subscription Yearly: annual subscription
	PeriodUnit pulumi.StringInput `pulumi:"periodUnit"`
}

func (GetInstanceChargeDetailArgs) ElementType 

func (GetInstanceChargeDetailArgs) ElementType() reflect.Type

func (GetInstanceChargeDetailArgs) ToGetInstanceChargeDetailOutput 

func (i GetInstanceChargeDetailArgs) ToGetInstanceChargeDetailOutput() GetInstanceChargeDetailOutput

func (GetInstanceChargeDetailArgs) ToGetInstanceChargeDetailOutputWithContext 

func (i GetInstanceChargeDetailArgs) ToGetInstanceChargeDetailOutputWithContext(ctx context.Context) GetInstanceChargeDetailOutput

type GetInstanceChargeDetailInput 

type GetInstanceChargeDetailInput interface {
	pulumi.Input

	ToGetInstanceChargeDetailOutput() GetInstanceChargeDetailOutput
	ToGetInstanceChargeDetailOutputWithContext(context.Context) GetInstanceChargeDetailOutput
}

GetInstanceChargeDetailInput is an input type that accepts GetInstanceChargeDetailArgs and GetInstanceChargeDetailOutput values. You can construct a concrete instance of `GetInstanceChargeDetailInput` via: 

GetInstanceChargeDetailArgs{...}

type GetInstanceChargeDetailOutput 

type GetInstanceChargeDetailOutput struct{ *pulumi.OutputState }

func (GetInstanceChargeDetailOutput) AutoRenew 

func (o GetInstanceChargeDetailOutput) AutoRenew() pulumi.BoolOutput

Whether the subscription instance is automatically renewed upon expiration. true: automatically renewed. false: not automatically renewed. Manual renewal is required after expiration; otherwise, the instance will be shut down.

func (GetInstanceChargeDetailOutput) ChargeExpireTime 

func (o GetInstanceChargeDetailOutput) ChargeExpireTime() pulumi.StringOutput

Expiration time for yearly/monthly subscription instances. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'. For pay-as-you-go instances, this field defaults to 1970-01-01T00:00:00Z.

func (GetInstanceChargeDetailOutput) ChargeStartTime 

func (o GetInstanceChargeDetailOutput) ChargeStartTime() pulumi.StringOutput

Billing start time for the instance. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'.

func (GetInstanceChargeDetailOutput) ChargeStatus 

func (o GetInstanceChargeDetailOutput) ChargeStatus() pulumi.StringOutput

Instance billing status. Includes: Normal: normal Overdue: pay-as-you-go overdue Expired: subscription expired

func (GetInstanceChargeDetailOutput) ChargeType 

func (o GetInstanceChargeDetailOutput) ChargeType() pulumi.StringOutput

Billing type for the instance. Supported types include: PostPaid: pay-as-you-go; PrePaid: yearly/monthly subscription

func (GetInstanceChargeDetailOutput) ElementType 

func (GetInstanceChargeDetailOutput) ElementType() reflect.Type

func (GetInstanceChargeDetailOutput) OverdueReclaimTime 

func (o GetInstanceChargeDetailOutput) OverdueReclaimTime() pulumi.StringOutput

Estimated release time after the instance is suspended due to overdue payment. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'.

func (GetInstanceChargeDetailOutput) OverdueTime 

func (o GetInstanceChargeDetailOutput) OverdueTime() pulumi.StringOutput

Suspension time due to overdue payment for the instance. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'.

func (GetInstanceChargeDetailOutput) Period 

func (o GetInstanceChargeDetailOutput) Period() pulumi.IntOutput

Purchase duration for subscription instances. When PeriodUnit is set to Monthly, the value range is 1–9. When PeriodUnit is set to Yearly, the value range is 1–3. Only required for subscription instances, that is, when ChargeType is set to PrePaid.

func (GetInstanceChargeDetailOutput) PeriodUnit 

func (o GetInstanceChargeDetailOutput) PeriodUnit() pulumi.StringOutput

Lifecycle unit for subscription-based instances, specifying whether to purchase by month or by year. Monthly: (default) monthly subscription Yearly: annual subscription

func (GetInstanceChargeDetailOutput) ToGetInstanceChargeDetailOutput 

func (o GetInstanceChargeDetailOutput) ToGetInstanceChargeDetailOutput() GetInstanceChargeDetailOutput

func (GetInstanceChargeDetailOutput) ToGetInstanceChargeDetailOutputWithContext 

func (o GetInstanceChargeDetailOutput) ToGetInstanceChargeDetailOutputWithContext(ctx context.Context) GetInstanceChargeDetailOutput

type GetInstanceConnectionInfo 

type GetInstanceConnectionInfo struct {
	// Instance endpoint IP address.
	EndpointAddressIp string `pulumi:"endpointAddressIp"`
	// Instance access point type.
	EndpointType string `pulumi:"endpointType"`
	// Private network endpoint address for the instance.
	InternalEndpoint string `pulumi:"internalEndpoint"`
	// Instance access point type.
	NetworkType string `pulumi:"networkType"`
	// Public access point address of the instance.
	PublicEndpoint string `pulumi:"publicEndpoint"`
}

type GetInstanceConnectionInfoArgs 

type GetInstanceConnectionInfoArgs struct {
	// Instance endpoint IP address.
	EndpointAddressIp pulumi.StringInput `pulumi:"endpointAddressIp"`
	// Instance access point type.
	EndpointType pulumi.StringInput `pulumi:"endpointType"`
	// Private network endpoint address for the instance.
	InternalEndpoint pulumi.StringInput `pulumi:"internalEndpoint"`
	// Instance access point type.
	NetworkType pulumi.StringInput `pulumi:"networkType"`
	// Public access point address of the instance.
	PublicEndpoint pulumi.StringInput `pulumi:"publicEndpoint"`
}

func (GetInstanceConnectionInfoArgs) ElementType 

func (GetInstanceConnectionInfoArgs) ElementType() reflect.Type

func (GetInstanceConnectionInfoArgs) ToGetInstanceConnectionInfoOutput 

func (i GetInstanceConnectionInfoArgs) ToGetInstanceConnectionInfoOutput() GetInstanceConnectionInfoOutput

func (GetInstanceConnectionInfoArgs) ToGetInstanceConnectionInfoOutputWithContext 

func (i GetInstanceConnectionInfoArgs) ToGetInstanceConnectionInfoOutputWithContext(ctx context.Context) GetInstanceConnectionInfoOutput

type GetInstanceConnectionInfoArray 

type GetInstanceConnectionInfoArray []GetInstanceConnectionInfoInput

func (GetInstanceConnectionInfoArray) ElementType 

func (GetInstanceConnectionInfoArray) ElementType() reflect.Type

func (GetInstanceConnectionInfoArray) ToGetInstanceConnectionInfoArrayOutput 

func (i GetInstanceConnectionInfoArray) ToGetInstanceConnectionInfoArrayOutput() GetInstanceConnectionInfoArrayOutput

func (GetInstanceConnectionInfoArray) ToGetInstanceConnectionInfoArrayOutputWithContext 

func (i GetInstanceConnectionInfoArray) ToGetInstanceConnectionInfoArrayOutputWithContext(ctx context.Context) GetInstanceConnectionInfoArrayOutput

type GetInstanceConnectionInfoArrayInput 

type GetInstanceConnectionInfoArrayInput interface {
	pulumi.Input

	ToGetInstanceConnectionInfoArrayOutput() GetInstanceConnectionInfoArrayOutput
	ToGetInstanceConnectionInfoArrayOutputWithContext(context.Context) GetInstanceConnectionInfoArrayOutput
}

GetInstanceConnectionInfoArrayInput is an input type that accepts GetInstanceConnectionInfoArray and GetInstanceConnectionInfoArrayOutput values. You can construct a concrete instance of `GetInstanceConnectionInfoArrayInput` via: 

GetInstanceConnectionInfoArray{ GetInstanceConnectionInfoArgs{...} }

type GetInstanceConnectionInfoArrayOutput 

type GetInstanceConnectionInfoArrayOutput struct{ *pulumi.OutputState }

func (GetInstanceConnectionInfoArrayOutput) ElementType 

func (GetInstanceConnectionInfoArrayOutput) ElementType() reflect.Type

func (GetInstanceConnectionInfoArrayOutput) Index 

func (o GetInstanceConnectionInfoArrayOutput) Index(i pulumi.IntInput) GetInstanceConnectionInfoOutput

func (GetInstanceConnectionInfoArrayOutput) ToGetInstanceConnectionInfoArrayOutput 

func (o GetInstanceConnectionInfoArrayOutput) ToGetInstanceConnectionInfoArrayOutput() GetInstanceConnectionInfoArrayOutput

func (GetInstanceConnectionInfoArrayOutput) ToGetInstanceConnectionInfoArrayOutputWithContext 

func (o GetInstanceConnectionInfoArrayOutput) ToGetInstanceConnectionInfoArrayOutputWithContext(ctx context.Context) GetInstanceConnectionInfoArrayOutput

type GetInstanceConnectionInfoInput 

type GetInstanceConnectionInfoInput interface {
	pulumi.Input

	ToGetInstanceConnectionInfoOutput() GetInstanceConnectionInfoOutput
	ToGetInstanceConnectionInfoOutputWithContext(context.Context) GetInstanceConnectionInfoOutput
}

GetInstanceConnectionInfoInput is an input type that accepts GetInstanceConnectionInfoArgs and GetInstanceConnectionInfoOutput values. You can construct a concrete instance of `GetInstanceConnectionInfoInput` via: 

GetInstanceConnectionInfoArgs{...}

type GetInstanceConnectionInfoOutput 

type GetInstanceConnectionInfoOutput struct{ *pulumi.OutputState }

func (GetInstanceConnectionInfoOutput) ElementType 

func (GetInstanceConnectionInfoOutput) ElementType() reflect.Type

func (GetInstanceConnectionInfoOutput) EndpointAddressIp 

func (o GetInstanceConnectionInfoOutput) EndpointAddressIp() pulumi.StringOutput

Instance endpoint IP address.

func (GetInstanceConnectionInfoOutput) EndpointType 

func (o GetInstanceConnectionInfoOutput) EndpointType() pulumi.StringOutput

Instance access point type.

func (GetInstanceConnectionInfoOutput) InternalEndpoint 

func (o GetInstanceConnectionInfoOutput) InternalEndpoint() pulumi.StringOutput

Private network endpoint address for the instance.

func (GetInstanceConnectionInfoOutput) NetworkType 

func (o GetInstanceConnectionInfoOutput) NetworkType() pulumi.StringOutput

Instance access point type.

func (GetInstanceConnectionInfoOutput) PublicEndpoint 

func (o GetInstanceConnectionInfoOutput) PublicEndpoint() pulumi.StringOutput

Public access point address of the instance.

func (GetInstanceConnectionInfoOutput) ToGetInstanceConnectionInfoOutput 

func (o GetInstanceConnectionInfoOutput) ToGetInstanceConnectionInfoOutput() GetInstanceConnectionInfoOutput

func (GetInstanceConnectionInfoOutput) ToGetInstanceConnectionInfoOutputWithContext 

func (o GetInstanceConnectionInfoOutput) ToGetInstanceConnectionInfoOutputWithContext(ctx context.Context) GetInstanceConnectionInfoOutput

type GetInstanceProductInfo 

type GetInstanceProductInfo struct {
	// Edit the read/write throttling ratio. The default read/write ratio is 50% each. For example, if set to 40, the sending TPS ratio is 40% and the subscription ratio is 60%. Note: Only RocketMQ 5.x instances support adjusting the TPS ratio for the instance.
	SendReceiveRatio int `pulumi:"sendReceiveRatio"`
}

type GetInstanceProductInfoArgs 

type GetInstanceProductInfoArgs struct {
	// Edit the read/write throttling ratio. The default read/write ratio is 50% each. For example, if set to 40, the sending TPS ratio is 40% and the subscription ratio is 60%. Note: Only RocketMQ 5.x instances support adjusting the TPS ratio for the instance.
	SendReceiveRatio pulumi.IntInput `pulumi:"sendReceiveRatio"`
}

func (GetInstanceProductInfoArgs) ElementType 

func (GetInstanceProductInfoArgs) ElementType() reflect.Type

func (GetInstanceProductInfoArgs) ToGetInstanceProductInfoOutput 

func (i GetInstanceProductInfoArgs) ToGetInstanceProductInfoOutput() GetInstanceProductInfoOutput

func (GetInstanceProductInfoArgs) ToGetInstanceProductInfoOutputWithContext 

func (i GetInstanceProductInfoArgs) ToGetInstanceProductInfoOutputWithContext(ctx context.Context) GetInstanceProductInfoOutput

type GetInstanceProductInfoInput 

type GetInstanceProductInfoInput interface {
	pulumi.Input

	ToGetInstanceProductInfoOutput() GetInstanceProductInfoOutput
	ToGetInstanceProductInfoOutputWithContext(context.Context) GetInstanceProductInfoOutput
}

GetInstanceProductInfoInput is an input type that accepts GetInstanceProductInfoArgs and GetInstanceProductInfoOutput values. You can construct a concrete instance of `GetInstanceProductInfoInput` via: 

GetInstanceProductInfoArgs{...}

type GetInstanceProductInfoOutput 

type GetInstanceProductInfoOutput struct{ *pulumi.OutputState }

func (GetInstanceProductInfoOutput) ElementType 

func (GetInstanceProductInfoOutput) ElementType() reflect.Type

func (GetInstanceProductInfoOutput) SendReceiveRatio 

func (o GetInstanceProductInfoOutput) SendReceiveRatio() pulumi.IntOutput

Edit the read/write throttling ratio. The default read/write ratio is 50% each. For example, if set to 40, the sending TPS ratio is 40% and the subscription ratio is 60%. Note: Only RocketMQ 5.x instances support adjusting the TPS ratio for the instance.

func (GetInstanceProductInfoOutput) ToGetInstanceProductInfoOutput 

func (o GetInstanceProductInfoOutput) ToGetInstanceProductInfoOutput() GetInstanceProductInfoOutput

func (GetInstanceProductInfoOutput) ToGetInstanceProductInfoOutputWithContext 

func (o GetInstanceProductInfoOutput) ToGetInstanceProductInfoOutputWithContext(ctx context.Context) GetInstanceProductInfoOutput

type GetInstanceTag 

type GetInstanceTag struct {
	// Tag key.
	Key string `pulumi:"key"`
	// Tag value.
	Value string `pulumi:"value"`
}

type GetInstanceTagArgs 

type GetInstanceTagArgs struct {
	// Tag key.
	Key pulumi.StringInput `pulumi:"key"`
	// Tag value.
	Value pulumi.StringInput `pulumi:"value"`
}

func (GetInstanceTagArgs) ElementType 

func (GetInstanceTagArgs) ElementType() reflect.Type

func (GetInstanceTagArgs) ToGetInstanceTagOutput 

func (i GetInstanceTagArgs) ToGetInstanceTagOutput() GetInstanceTagOutput

func (GetInstanceTagArgs) ToGetInstanceTagOutputWithContext 

func (i GetInstanceTagArgs) ToGetInstanceTagOutputWithContext(ctx context.Context) GetInstanceTagOutput

type GetInstanceTagArray 

type GetInstanceTagArray []GetInstanceTagInput

func (GetInstanceTagArray) ElementType 

func (GetInstanceTagArray) ElementType() reflect.Type

func (GetInstanceTagArray) ToGetInstanceTagArrayOutput 

func (i GetInstanceTagArray) ToGetInstanceTagArrayOutput() GetInstanceTagArrayOutput

func (GetInstanceTagArray) ToGetInstanceTagArrayOutputWithContext 

func (i GetInstanceTagArray) ToGetInstanceTagArrayOutputWithContext(ctx context.Context) GetInstanceTagArrayOutput

type GetInstanceTagArrayInput 

type GetInstanceTagArrayInput interface {
	pulumi.Input

	ToGetInstanceTagArrayOutput() GetInstanceTagArrayOutput
	ToGetInstanceTagArrayOutputWithContext(context.Context) GetInstanceTagArrayOutput
}

GetInstanceTagArrayInput is an input type that accepts GetInstanceTagArray and GetInstanceTagArrayOutput values. You can construct a concrete instance of `GetInstanceTagArrayInput` via: 

GetInstanceTagArray{ GetInstanceTagArgs{...} }

type GetInstanceTagArrayOutput 

type GetInstanceTagArrayOutput struct{ *pulumi.OutputState }

func (GetInstanceTagArrayOutput) ElementType 

func (GetInstanceTagArrayOutput) ElementType() reflect.Type

func (GetInstanceTagArrayOutput) Index 

func (o GetInstanceTagArrayOutput) Index(i pulumi.IntInput) GetInstanceTagOutput

func (GetInstanceTagArrayOutput) ToGetInstanceTagArrayOutput 

func (o GetInstanceTagArrayOutput) ToGetInstanceTagArrayOutput() GetInstanceTagArrayOutput

func (GetInstanceTagArrayOutput) ToGetInstanceTagArrayOutputWithContext 

func (o GetInstanceTagArrayOutput) ToGetInstanceTagArrayOutputWithContext(ctx context.Context) GetInstanceTagArrayOutput

type GetInstanceTagInput 

type GetInstanceTagInput interface {
	pulumi.Input

	ToGetInstanceTagOutput() GetInstanceTagOutput
	ToGetInstanceTagOutputWithContext(context.Context) GetInstanceTagOutput
}

GetInstanceTagInput is an input type that accepts GetInstanceTagArgs and GetInstanceTagOutput values. You can construct a concrete instance of `GetInstanceTagInput` via: 

GetInstanceTagArgs{...}

type GetInstanceTagOutput 

type GetInstanceTagOutput struct{ *pulumi.OutputState }

func (GetInstanceTagOutput) ElementType 

func (GetInstanceTagOutput) ElementType() reflect.Type

func (GetInstanceTagOutput) Key 

func (o GetInstanceTagOutput) Key() pulumi.StringOutput

Tag key.

func (GetInstanceTagOutput) ToGetInstanceTagOutput 

func (o GetInstanceTagOutput) ToGetInstanceTagOutput() GetInstanceTagOutput

func (GetInstanceTagOutput) ToGetInstanceTagOutputWithContext 

func (o GetInstanceTagOutput) ToGetInstanceTagOutputWithContext(ctx context.Context) GetInstanceTagOutput

func (GetInstanceTagOutput) Value 

func (o GetInstanceTagOutput) Value() pulumi.StringOutput

Tag value.

type GetInstancesResult 

type GetInstancesResult struct {
	// Uniquely identifies the data source.
	Id string `pulumi:"id"`
	// Set of Resource Identifiers.
	Ids []string `pulumi:"ids"`
}

A collection of values returned by getInstances.

func GetInstances 

func GetInstances(ctx *pulumi.Context, opts ...pulumi.InvokeOption) (*GetInstancesResult, error)

Plural Data Source schema for Volcengine::RocketMQ::Instance

type GetInstancesResultOutput 

type GetInstancesResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getInstances.

func GetInstancesOutput 

func GetInstancesOutput(ctx *pulumi.Context, opts ...pulumi.InvokeOption) GetInstancesResultOutput

func (GetInstancesResultOutput) ElementType 

func (GetInstancesResultOutput) ElementType() reflect.Type

func (GetInstancesResultOutput) Id 

func (o GetInstancesResultOutput) Id() pulumi.StringOutput

Uniquely identifies the data source.

func (GetInstancesResultOutput) Ids 

func (o GetInstancesResultOutput) Ids() pulumi.StringArrayOutput

Set of Resource Identifiers.

func (GetInstancesResultOutput) ToGetInstancesResultOutput 

func (o GetInstancesResultOutput) ToGetInstancesResultOutput() GetInstancesResultOutput

func (GetInstancesResultOutput) ToGetInstancesResultOutputWithContext 

func (o GetInstancesResultOutput) ToGetInstancesResultOutputWithContext(ctx context.Context) GetInstancesResultOutput

type GetTopicAccessPolicy added in v0.0.22 

type GetTopicAccessPolicy struct {
	// AccessKey of the RocketMQ key.
	AccessKey string `pulumi:"accessKey"`
	// User access permissions for the current Topic. ALL: Publish and subscribe permissions. PUB: Publish permission. SUB: Subscribe permission. DENY: No publish or subscribe permissions.
	Authority string `pulumi:"authority"`
}

type GetTopicAccessPolicyArgs added in v0.0.22 

type GetTopicAccessPolicyArgs struct {
	// AccessKey of the RocketMQ key.
	AccessKey pulumi.StringInput `pulumi:"accessKey"`
	// User access permissions for the current Topic. ALL: Publish and subscribe permissions. PUB: Publish permission. SUB: Subscribe permission. DENY: No publish or subscribe permissions.
	Authority pulumi.StringInput `pulumi:"authority"`
}

func (GetTopicAccessPolicyArgs) ElementType added in v0.0.22 

func (GetTopicAccessPolicyArgs) ElementType() reflect.Type

func (GetTopicAccessPolicyArgs) ToGetTopicAccessPolicyOutput added in v0.0.22 

func (i GetTopicAccessPolicyArgs) ToGetTopicAccessPolicyOutput() GetTopicAccessPolicyOutput

func (GetTopicAccessPolicyArgs) ToGetTopicAccessPolicyOutputWithContext added in v0.0.22 

func (i GetTopicAccessPolicyArgs) ToGetTopicAccessPolicyOutputWithContext(ctx context.Context) GetTopicAccessPolicyOutput

type GetTopicAccessPolicyArray added in v0.0.22 

type GetTopicAccessPolicyArray []GetTopicAccessPolicyInput

func (GetTopicAccessPolicyArray) ElementType added in v0.0.22 

func (GetTopicAccessPolicyArray) ElementType() reflect.Type

func (GetTopicAccessPolicyArray) ToGetTopicAccessPolicyArrayOutput added in v0.0.22 

func (i GetTopicAccessPolicyArray) ToGetTopicAccessPolicyArrayOutput() GetTopicAccessPolicyArrayOutput

func (GetTopicAccessPolicyArray) ToGetTopicAccessPolicyArrayOutputWithContext added in v0.0.22 

func (i GetTopicAccessPolicyArray) ToGetTopicAccessPolicyArrayOutputWithContext(ctx context.Context) GetTopicAccessPolicyArrayOutput

type GetTopicAccessPolicyArrayInput added in v0.0.22 

type GetTopicAccessPolicyArrayInput interface {
	pulumi.Input

	ToGetTopicAccessPolicyArrayOutput() GetTopicAccessPolicyArrayOutput
	ToGetTopicAccessPolicyArrayOutputWithContext(context.Context) GetTopicAccessPolicyArrayOutput
}

GetTopicAccessPolicyArrayInput is an input type that accepts GetTopicAccessPolicyArray and GetTopicAccessPolicyArrayOutput values. You can construct a concrete instance of `GetTopicAccessPolicyArrayInput` via: 

GetTopicAccessPolicyArray{ GetTopicAccessPolicyArgs{...} }

type GetTopicAccessPolicyArrayOutput added in v0.0.22 

type GetTopicAccessPolicyArrayOutput struct{ *pulumi.OutputState }

func (GetTopicAccessPolicyArrayOutput) ElementType added in v0.0.22 

func (GetTopicAccessPolicyArrayOutput) ElementType() reflect.Type

func (GetTopicAccessPolicyArrayOutput) Index added in v0.0.22 

func (o GetTopicAccessPolicyArrayOutput) Index(i pulumi.IntInput) GetTopicAccessPolicyOutput

func (GetTopicAccessPolicyArrayOutput) ToGetTopicAccessPolicyArrayOutput added in v0.0.22 

func (o GetTopicAccessPolicyArrayOutput) ToGetTopicAccessPolicyArrayOutput() GetTopicAccessPolicyArrayOutput

func (GetTopicAccessPolicyArrayOutput) ToGetTopicAccessPolicyArrayOutputWithContext added in v0.0.22 

func (o GetTopicAccessPolicyArrayOutput) ToGetTopicAccessPolicyArrayOutputWithContext(ctx context.Context) GetTopicAccessPolicyArrayOutput

type GetTopicAccessPolicyInput added in v0.0.22 

type GetTopicAccessPolicyInput interface {
	pulumi.Input

	ToGetTopicAccessPolicyOutput() GetTopicAccessPolicyOutput
	ToGetTopicAccessPolicyOutputWithContext(context.Context) GetTopicAccessPolicyOutput
}

GetTopicAccessPolicyInput is an input type that accepts GetTopicAccessPolicyArgs and GetTopicAccessPolicyOutput values. You can construct a concrete instance of `GetTopicAccessPolicyInput` via: 

GetTopicAccessPolicyArgs{...}

type GetTopicAccessPolicyOutput added in v0.0.22 

type GetTopicAccessPolicyOutput struct{ *pulumi.OutputState }

func (GetTopicAccessPolicyOutput) AccessKey added in v0.0.22 

func (o GetTopicAccessPolicyOutput) AccessKey() pulumi.StringOutput

AccessKey of the RocketMQ key.

func (GetTopicAccessPolicyOutput) Authority added in v0.0.22 

func (o GetTopicAccessPolicyOutput) Authority() pulumi.StringOutput

User access permissions for the current Topic. ALL: Publish and subscribe permissions. PUB: Publish permission. SUB: Subscribe permission. DENY: No publish or subscribe permissions.

func (GetTopicAccessPolicyOutput) ElementType added in v0.0.22 

func (GetTopicAccessPolicyOutput) ElementType() reflect.Type

func (GetTopicAccessPolicyOutput) ToGetTopicAccessPolicyOutput added in v0.0.22 

func (o GetTopicAccessPolicyOutput) ToGetTopicAccessPolicyOutput() GetTopicAccessPolicyOutput

func (GetTopicAccessPolicyOutput) ToGetTopicAccessPolicyOutputWithContext added in v0.0.22 

func (o GetTopicAccessPolicyOutput) ToGetTopicAccessPolicyOutputWithContext(ctx context.Context) GetTopicAccessPolicyOutput

type GetTopicGroupsInfo added in v0.0.22 

type GetTopicGroupsInfo struct {
	// Group ID of the consumer group.
	GroupId string `pulumi:"groupId"`
	// Consumption mode. The values are as follows: Clustering: cluster consumption mode. Broadcasting: broadcast consumption mode.
	MessageModel string `pulumi:"messageModel"`
	// Subscription rule. This field contains the exact string specified by the consumer group when subscribing to this Topic, usually * or TAG1 || TAG2.
	SubString string `pulumi:"subString"`
}

type GetTopicGroupsInfoArgs added in v0.0.22 

type GetTopicGroupsInfoArgs struct {
	// Group ID of the consumer group.
	GroupId pulumi.StringInput `pulumi:"groupId"`
	// Consumption mode. The values are as follows: Clustering: cluster consumption mode. Broadcasting: broadcast consumption mode.
	MessageModel pulumi.StringInput `pulumi:"messageModel"`
	// Subscription rule. This field contains the exact string specified by the consumer group when subscribing to this Topic, usually * or TAG1 || TAG2.
	SubString pulumi.StringInput `pulumi:"subString"`
}

func (GetTopicGroupsInfoArgs) ElementType added in v0.0.22 

func (GetTopicGroupsInfoArgs) ElementType() reflect.Type

func (GetTopicGroupsInfoArgs) ToGetTopicGroupsInfoOutput added in v0.0.22 

func (i GetTopicGroupsInfoArgs) ToGetTopicGroupsInfoOutput() GetTopicGroupsInfoOutput

func (GetTopicGroupsInfoArgs) ToGetTopicGroupsInfoOutputWithContext added in v0.0.22 

func (i GetTopicGroupsInfoArgs) ToGetTopicGroupsInfoOutputWithContext(ctx context.Context) GetTopicGroupsInfoOutput

type GetTopicGroupsInfoArray added in v0.0.22 

type GetTopicGroupsInfoArray []GetTopicGroupsInfoInput

func (GetTopicGroupsInfoArray) ElementType added in v0.0.22 

func (GetTopicGroupsInfoArray) ElementType() reflect.Type

func (GetTopicGroupsInfoArray) ToGetTopicGroupsInfoArrayOutput added in v0.0.22 

func (i GetTopicGroupsInfoArray) ToGetTopicGroupsInfoArrayOutput() GetTopicGroupsInfoArrayOutput

func (GetTopicGroupsInfoArray) ToGetTopicGroupsInfoArrayOutputWithContext added in v0.0.22 

func (i GetTopicGroupsInfoArray) ToGetTopicGroupsInfoArrayOutputWithContext(ctx context.Context) GetTopicGroupsInfoArrayOutput

type GetTopicGroupsInfoArrayInput added in v0.0.22 

type GetTopicGroupsInfoArrayInput interface {
	pulumi.Input

	ToGetTopicGroupsInfoArrayOutput() GetTopicGroupsInfoArrayOutput
	ToGetTopicGroupsInfoArrayOutputWithContext(context.Context) GetTopicGroupsInfoArrayOutput
}

GetTopicGroupsInfoArrayInput is an input type that accepts GetTopicGroupsInfoArray and GetTopicGroupsInfoArrayOutput values. You can construct a concrete instance of `GetTopicGroupsInfoArrayInput` via: 

GetTopicGroupsInfoArray{ GetTopicGroupsInfoArgs{...} }

type GetTopicGroupsInfoArrayOutput added in v0.0.22 

type GetTopicGroupsInfoArrayOutput struct{ *pulumi.OutputState }

func (GetTopicGroupsInfoArrayOutput) ElementType added in v0.0.22 

func (GetTopicGroupsInfoArrayOutput) ElementType() reflect.Type

func (GetTopicGroupsInfoArrayOutput) Index added in v0.0.22 

func (o GetTopicGroupsInfoArrayOutput) Index(i pulumi.IntInput) GetTopicGroupsInfoOutput

func (GetTopicGroupsInfoArrayOutput) ToGetTopicGroupsInfoArrayOutput added in v0.0.22 

func (o GetTopicGroupsInfoArrayOutput) ToGetTopicGroupsInfoArrayOutput() GetTopicGroupsInfoArrayOutput

func (GetTopicGroupsInfoArrayOutput) ToGetTopicGroupsInfoArrayOutputWithContext added in v0.0.22 

func (o GetTopicGroupsInfoArrayOutput) ToGetTopicGroupsInfoArrayOutputWithContext(ctx context.Context) GetTopicGroupsInfoArrayOutput

type GetTopicGroupsInfoInput added in v0.0.22 

type GetTopicGroupsInfoInput interface {
	pulumi.Input

	ToGetTopicGroupsInfoOutput() GetTopicGroupsInfoOutput
	ToGetTopicGroupsInfoOutputWithContext(context.Context) GetTopicGroupsInfoOutput
}

GetTopicGroupsInfoInput is an input type that accepts GetTopicGroupsInfoArgs and GetTopicGroupsInfoOutput values. You can construct a concrete instance of `GetTopicGroupsInfoInput` via: 

GetTopicGroupsInfoArgs{...}

type GetTopicGroupsInfoOutput added in v0.0.22 

type GetTopicGroupsInfoOutput struct{ *pulumi.OutputState }

func (GetTopicGroupsInfoOutput) ElementType added in v0.0.22 

func (GetTopicGroupsInfoOutput) ElementType() reflect.Type

func (GetTopicGroupsInfoOutput) GroupId added in v0.0.22 

func (o GetTopicGroupsInfoOutput) GroupId() pulumi.StringOutput

Group ID of the consumer group.

func (GetTopicGroupsInfoOutput) MessageModel added in v0.0.22 

func (o GetTopicGroupsInfoOutput) MessageModel() pulumi.StringOutput

Consumption mode. The values are as follows: Clustering: cluster consumption mode. Broadcasting: broadcast consumption mode.

func (GetTopicGroupsInfoOutput) SubString added in v0.0.22 

func (o GetTopicGroupsInfoOutput) SubString() pulumi.StringOutput

Subscription rule. This field contains the exact string specified by the consumer group when subscribing to this Topic, usually * or TAG1 || TAG2.

func (GetTopicGroupsInfoOutput) ToGetTopicGroupsInfoOutput added in v0.0.22 

func (o GetTopicGroupsInfoOutput) ToGetTopicGroupsInfoOutput() GetTopicGroupsInfoOutput

func (GetTopicGroupsInfoOutput) ToGetTopicGroupsInfoOutputWithContext added in v0.0.22 

func (o GetTopicGroupsInfoOutput) ToGetTopicGroupsInfoOutputWithContext(ctx context.Context) GetTopicGroupsInfoOutput

type GetTopicQueuesInfo added in v0.0.22 

type GetTopicQueuesInfo struct {
	// The maximum offset of the current queue, which is the offset of the next message. The position of the latest message is EndOffset   - 1.
	EndOffset int `pulumi:"endOffset"`
	// The time of the most recent message written to this queue.
	LastUpdateTimestamp int `pulumi:"lastUpdateTimestamp"`
	// The number of messages in the current queue. EndOffset is the offset of the next message, so MessageCount = EndOffset   - StartOffset.
	MessageCount int `pulumi:"messageCount"`
	// Queue ID.
	QueueId string `pulumi:"queueId"`
	// The earliest message offset in the current queue.
	StartOffset int `pulumi:"startOffset"`
}

type GetTopicQueuesInfoArgs added in v0.0.22 

type GetTopicQueuesInfoArgs struct {
	// The maximum offset of the current queue, which is the offset of the next message. The position of the latest message is EndOffset   - 1.
	EndOffset pulumi.IntInput `pulumi:"endOffset"`
	// The time of the most recent message written to this queue.
	LastUpdateTimestamp pulumi.IntInput `pulumi:"lastUpdateTimestamp"`
	// The number of messages in the current queue. EndOffset is the offset of the next message, so MessageCount = EndOffset   - StartOffset.
	MessageCount pulumi.IntInput `pulumi:"messageCount"`
	// Queue ID.
	QueueId pulumi.StringInput `pulumi:"queueId"`
	// The earliest message offset in the current queue.
	StartOffset pulumi.IntInput `pulumi:"startOffset"`
}

func (GetTopicQueuesInfoArgs) ElementType added in v0.0.22 

func (GetTopicQueuesInfoArgs) ElementType() reflect.Type

func (GetTopicQueuesInfoArgs) ToGetTopicQueuesInfoOutput added in v0.0.22 

func (i GetTopicQueuesInfoArgs) ToGetTopicQueuesInfoOutput() GetTopicQueuesInfoOutput

func (GetTopicQueuesInfoArgs) ToGetTopicQueuesInfoOutputWithContext added in v0.0.22 

func (i GetTopicQueuesInfoArgs) ToGetTopicQueuesInfoOutputWithContext(ctx context.Context) GetTopicQueuesInfoOutput

type GetTopicQueuesInfoArray added in v0.0.22 

type GetTopicQueuesInfoArray []GetTopicQueuesInfoInput

func (GetTopicQueuesInfoArray) ElementType added in v0.0.22 

func (GetTopicQueuesInfoArray) ElementType() reflect.Type

func (GetTopicQueuesInfoArray) ToGetTopicQueuesInfoArrayOutput added in v0.0.22 

func (i GetTopicQueuesInfoArray) ToGetTopicQueuesInfoArrayOutput() GetTopicQueuesInfoArrayOutput

func (GetTopicQueuesInfoArray) ToGetTopicQueuesInfoArrayOutputWithContext added in v0.0.22 

func (i GetTopicQueuesInfoArray) ToGetTopicQueuesInfoArrayOutputWithContext(ctx context.Context) GetTopicQueuesInfoArrayOutput

type GetTopicQueuesInfoArrayInput added in v0.0.22 

type GetTopicQueuesInfoArrayInput interface {
	pulumi.Input

	ToGetTopicQueuesInfoArrayOutput() GetTopicQueuesInfoArrayOutput
	ToGetTopicQueuesInfoArrayOutputWithContext(context.Context) GetTopicQueuesInfoArrayOutput
}

GetTopicQueuesInfoArrayInput is an input type that accepts GetTopicQueuesInfoArray and GetTopicQueuesInfoArrayOutput values. You can construct a concrete instance of `GetTopicQueuesInfoArrayInput` via: 

GetTopicQueuesInfoArray{ GetTopicQueuesInfoArgs{...} }

type GetTopicQueuesInfoArrayOutput added in v0.0.22 

type GetTopicQueuesInfoArrayOutput struct{ *pulumi.OutputState }

func (GetTopicQueuesInfoArrayOutput) ElementType added in v0.0.22 

func (GetTopicQueuesInfoArrayOutput) ElementType() reflect.Type

func (GetTopicQueuesInfoArrayOutput) Index added in v0.0.22 

func (o GetTopicQueuesInfoArrayOutput) Index(i pulumi.IntInput) GetTopicQueuesInfoOutput

func (GetTopicQueuesInfoArrayOutput) ToGetTopicQueuesInfoArrayOutput added in v0.0.22 

func (o GetTopicQueuesInfoArrayOutput) ToGetTopicQueuesInfoArrayOutput() GetTopicQueuesInfoArrayOutput

func (GetTopicQueuesInfoArrayOutput) ToGetTopicQueuesInfoArrayOutputWithContext added in v0.0.22 

func (o GetTopicQueuesInfoArrayOutput) ToGetTopicQueuesInfoArrayOutputWithContext(ctx context.Context) GetTopicQueuesInfoArrayOutput

type GetTopicQueuesInfoInput added in v0.0.22 

type GetTopicQueuesInfoInput interface {
	pulumi.Input

	ToGetTopicQueuesInfoOutput() GetTopicQueuesInfoOutput
	ToGetTopicQueuesInfoOutputWithContext(context.Context) GetTopicQueuesInfoOutput
}

GetTopicQueuesInfoInput is an input type that accepts GetTopicQueuesInfoArgs and GetTopicQueuesInfoOutput values. You can construct a concrete instance of `GetTopicQueuesInfoInput` via: 

GetTopicQueuesInfoArgs{...}

type GetTopicQueuesInfoOutput added in v0.0.22 

type GetTopicQueuesInfoOutput struct{ *pulumi.OutputState }

func (GetTopicQueuesInfoOutput) ElementType added in v0.0.22 

func (GetTopicQueuesInfoOutput) ElementType() reflect.Type

func (GetTopicQueuesInfoOutput) EndOffset added in v0.0.22 

func (o GetTopicQueuesInfoOutput) EndOffset() pulumi.IntOutput

The maximum offset of the current queue, which is the offset of the next message. The position of the latest message is EndOffset - 1.

func (GetTopicQueuesInfoOutput) LastUpdateTimestamp added in v0.0.22 

func (o GetTopicQueuesInfoOutput) LastUpdateTimestamp() pulumi.IntOutput

The time of the most recent message written to this queue.

func (GetTopicQueuesInfoOutput) MessageCount added in v0.0.22 

func (o GetTopicQueuesInfoOutput) MessageCount() pulumi.IntOutput

The number of messages in the current queue. EndOffset is the offset of the next message, so MessageCount = EndOffset - StartOffset.

func (GetTopicQueuesInfoOutput) QueueId added in v0.0.22 

func (o GetTopicQueuesInfoOutput) QueueId() pulumi.StringOutput

Queue ID.

func (GetTopicQueuesInfoOutput) StartOffset added in v0.0.22 

func (o GetTopicQueuesInfoOutput) StartOffset() pulumi.IntOutput

The earliest message offset in the current queue.

func (GetTopicQueuesInfoOutput) ToGetTopicQueuesInfoOutput added in v0.0.22 

func (o GetTopicQueuesInfoOutput) ToGetTopicQueuesInfoOutput() GetTopicQueuesInfoOutput

func (GetTopicQueuesInfoOutput) ToGetTopicQueuesInfoOutputWithContext added in v0.0.22 

func (o GetTopicQueuesInfoOutput) ToGetTopicQueuesInfoOutputWithContext(ctx context.Context) GetTopicQueuesInfoOutput

type GetTopicReadAccessPolicy added in v0.0.22 

type GetTopicReadAccessPolicy struct {
	// AccessKey of the RocketMQ key.
	AccessKey string `pulumi:"accessKey"`
	// User access permissions for the current Topic. ALL: Publish and subscribe permissions. PUB: Publish permission. SUB: Subscribe permission. DENY: No publish or subscribe permissions.
	Authority string `pulumi:"authority"`
}

type GetTopicReadAccessPolicyArgs added in v0.0.22 

type GetTopicReadAccessPolicyArgs struct {
	// AccessKey of the RocketMQ key.
	AccessKey pulumi.StringInput `pulumi:"accessKey"`
	// User access permissions for the current Topic. ALL: Publish and subscribe permissions. PUB: Publish permission. SUB: Subscribe permission. DENY: No publish or subscribe permissions.
	Authority pulumi.StringInput `pulumi:"authority"`
}

func (GetTopicReadAccessPolicyArgs) ElementType added in v0.0.22 

func (GetTopicReadAccessPolicyArgs) ElementType() reflect.Type

func (GetTopicReadAccessPolicyArgs) ToGetTopicReadAccessPolicyOutput added in v0.0.22 

func (i GetTopicReadAccessPolicyArgs) ToGetTopicReadAccessPolicyOutput() GetTopicReadAccessPolicyOutput

func (GetTopicReadAccessPolicyArgs) ToGetTopicReadAccessPolicyOutputWithContext added in v0.0.22 

func (i GetTopicReadAccessPolicyArgs) ToGetTopicReadAccessPolicyOutputWithContext(ctx context.Context) GetTopicReadAccessPolicyOutput

type GetTopicReadAccessPolicyArray added in v0.0.22 

type GetTopicReadAccessPolicyArray []GetTopicReadAccessPolicyInput

func (GetTopicReadAccessPolicyArray) ElementType added in v0.0.22 

func (GetTopicReadAccessPolicyArray) ElementType() reflect.Type

func (GetTopicReadAccessPolicyArray) ToGetTopicReadAccessPolicyArrayOutput added in v0.0.22 

func (i GetTopicReadAccessPolicyArray) ToGetTopicReadAccessPolicyArrayOutput() GetTopicReadAccessPolicyArrayOutput

func (GetTopicReadAccessPolicyArray) ToGetTopicReadAccessPolicyArrayOutputWithContext added in v0.0.22 

func (i GetTopicReadAccessPolicyArray) ToGetTopicReadAccessPolicyArrayOutputWithContext(ctx context.Context) GetTopicReadAccessPolicyArrayOutput

type GetTopicReadAccessPolicyArrayInput added in v0.0.22 

type GetTopicReadAccessPolicyArrayInput interface {
	pulumi.Input

	ToGetTopicReadAccessPolicyArrayOutput() GetTopicReadAccessPolicyArrayOutput
	ToGetTopicReadAccessPolicyArrayOutputWithContext(context.Context) GetTopicReadAccessPolicyArrayOutput
}

GetTopicReadAccessPolicyArrayInput is an input type that accepts GetTopicReadAccessPolicyArray and GetTopicReadAccessPolicyArrayOutput values. You can construct a concrete instance of `GetTopicReadAccessPolicyArrayInput` via: 

GetTopicReadAccessPolicyArray{ GetTopicReadAccessPolicyArgs{...} }

type GetTopicReadAccessPolicyArrayOutput added in v0.0.22 

type GetTopicReadAccessPolicyArrayOutput struct{ *pulumi.OutputState }

func (GetTopicReadAccessPolicyArrayOutput) ElementType added in v0.0.22 

func (GetTopicReadAccessPolicyArrayOutput) ElementType() reflect.Type

func (GetTopicReadAccessPolicyArrayOutput) Index added in v0.0.22 

func (o GetTopicReadAccessPolicyArrayOutput) Index(i pulumi.IntInput) GetTopicReadAccessPolicyOutput

func (GetTopicReadAccessPolicyArrayOutput) ToGetTopicReadAccessPolicyArrayOutput added in v0.0.22 

func (o GetTopicReadAccessPolicyArrayOutput) ToGetTopicReadAccessPolicyArrayOutput() GetTopicReadAccessPolicyArrayOutput

func (GetTopicReadAccessPolicyArrayOutput) ToGetTopicReadAccessPolicyArrayOutputWithContext added in v0.0.22 

func (o GetTopicReadAccessPolicyArrayOutput) ToGetTopicReadAccessPolicyArrayOutputWithContext(ctx context.Context) GetTopicReadAccessPolicyArrayOutput

type GetTopicReadAccessPolicyInput added in v0.0.22 

type GetTopicReadAccessPolicyInput interface {
	pulumi.Input

	ToGetTopicReadAccessPolicyOutput() GetTopicReadAccessPolicyOutput
	ToGetTopicReadAccessPolicyOutputWithContext(context.Context) GetTopicReadAccessPolicyOutput
}

GetTopicReadAccessPolicyInput is an input type that accepts GetTopicReadAccessPolicyArgs and GetTopicReadAccessPolicyOutput values. You can construct a concrete instance of `GetTopicReadAccessPolicyInput` via: 

GetTopicReadAccessPolicyArgs{...}

type GetTopicReadAccessPolicyOutput added in v0.0.22 

type GetTopicReadAccessPolicyOutput struct{ *pulumi.OutputState }

func (GetTopicReadAccessPolicyOutput) AccessKey added in v0.0.22 

func (o GetTopicReadAccessPolicyOutput) AccessKey() pulumi.StringOutput

AccessKey of the RocketMQ key.

func (GetTopicReadAccessPolicyOutput) Authority added in v0.0.22 

func (o GetTopicReadAccessPolicyOutput) Authority() pulumi.StringOutput

User access permissions for the current Topic. ALL: Publish and subscribe permissions. PUB: Publish permission. SUB: Subscribe permission. DENY: No publish or subscribe permissions.

func (GetTopicReadAccessPolicyOutput) ElementType added in v0.0.22 

func (GetTopicReadAccessPolicyOutput) ElementType() reflect.Type

func (GetTopicReadAccessPolicyOutput) ToGetTopicReadAccessPolicyOutput added in v0.0.22 

func (o GetTopicReadAccessPolicyOutput) ToGetTopicReadAccessPolicyOutput() GetTopicReadAccessPolicyOutput

func (GetTopicReadAccessPolicyOutput) ToGetTopicReadAccessPolicyOutputWithContext added in v0.0.22 

func (o GetTopicReadAccessPolicyOutput) ToGetTopicReadAccessPolicyOutputWithContext(ctx context.Context) GetTopicReadAccessPolicyOutput

type GetTopicsResult added in v0.0.22 

type GetTopicsResult struct {
	// Uniquely identifies the data source.
	Id string `pulumi:"id"`
	// Set of Resource Identifiers.
	Ids []string `pulumi:"ids"`
}

A collection of values returned by getTopics.

func GetTopics added in v0.0.22 

func GetTopics(ctx *pulumi.Context, opts ...pulumi.InvokeOption) (*GetTopicsResult, error)

Plural Data Source schema for Volcengine::RocketMQ::Topic

type GetTopicsResultOutput added in v0.0.22 

type GetTopicsResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getTopics.

func GetTopicsOutput added in v0.0.22 

func GetTopicsOutput(ctx *pulumi.Context, opts ...pulumi.InvokeOption) GetTopicsResultOutput

func (GetTopicsResultOutput) ElementType added in v0.0.22 

func (GetTopicsResultOutput) ElementType() reflect.Type

func (GetTopicsResultOutput) Id added in v0.0.22 

func (o GetTopicsResultOutput) Id() pulumi.StringOutput

Uniquely identifies the data source.

func (GetTopicsResultOutput) Ids added in v0.0.22 

func (o GetTopicsResultOutput) Ids() pulumi.StringArrayOutput

Set of Resource Identifiers.

func (GetTopicsResultOutput) ToGetTopicsResultOutput added in v0.0.22 

func (o GetTopicsResultOutput) ToGetTopicsResultOutput() GetTopicsResultOutput

func (GetTopicsResultOutput) ToGetTopicsResultOutputWithContext added in v0.0.22 

func (o GetTopicsResultOutput) ToGetTopicsResultOutputWithContext(ctx context.Context) GetTopicsResultOutput

type Group added in v0.0.22 

type Group struct {
	pulumi.CustomResourceState

	// Whether the subscription relationships of consumer instance groups within the Group are consistent. true: Consistent, false: Inconsistent.
	ConsumeMessageOrderly pulumi.BoolOutput              `pulumi:"consumeMessageOrderly"`
	ConsumedClients       GroupConsumedClientArrayOutput `pulumi:"consumedClients"`
	ConsumedTopics        GroupConsumedTopicArrayOutput  `pulumi:"consumedTopics"`
	// Group creation time.
	CreatedTime pulumi.StringOutput `pulumi:"createdTime"`
	// Brief description of the Group.
	Description pulumi.StringOutput `pulumi:"description"`
	// Group ID. Length must be between 7 and 120 characters and can only contain letters, numbers, hyphens (-), and underscores (*). It is recommended to start with GID  - or GID*. The ID cannot be changed after the Group is created, so set it carefully. For RocketMQ instances created on or before June 5, 2023, the Group name cannot exceed 93 characters.
	GroupId pulumi.StringOutput `pulumi:"groupId"`
	// Group protocol identifier, used to indicate the production and consumption protocol type for this Group. Can be set to TCP.
	GroupType pulumi.StringOutput `pulumi:"groupType"`
	// Instance ID.
	InstanceId pulumi.StringOutput `pulumi:"instanceId"`
	// Whether the subscription relationships of consumer instance groups within the Group are consistent. true: Consistent, false: Inconsistent.
	IsSubSame pulumi.BoolOutput `pulumi:"isSubSame"`
	// Whether consumption is sequential.
	LastUpdateTimestamp pulumi.StringOutput `pulumi:"lastUpdateTimestamp"`
	// Message latency. The difference between the production time of the earliest unconsumed message in the consumer instance group and the current time, measured in milliseconds.
	MessageDelayTime pulumi.StringOutput `pulumi:"messageDelayTime"`
	// Message consumption mode. The default is clustering mode. Do not configure both clustering and broadcasting modes under the same Group. Clustering: Clustering consumption mode, Broadcasting: Broadcasting consumption mode.
	MessageModel pulumi.StringOutput `pulumi:"messageModel"`
	// Maximum number of consumption retries.
	RetryMaxTimes pulumi.IntOutput `pulumi:"retryMaxTimes"`
	// RocketMQ version.
	RocketmqVersion pulumi.StringOutput `pulumi:"rocketmqVersion"`
	// Service status. Creating: Being created, Running: Running, Deleting: Being deleted, Abnormal: Abnormal, Updating: Being updated.
	ServiceStatus pulumi.StringOutput `pulumi:"serviceStatus"`
	// Consumer group status. Online: Consuming, Offline: Not consuming.
	Status pulumi.StringOutput `pulumi:"status"`
	// Total TPS of consumer instance groups under this Group, measured in messages per second.
	TotalConsumedRate pulumi.StringOutput `pulumi:"totalConsumedRate"`
	// Total number of unconsumed messages in the consumer instance group. The message backlog shown here is the total backlog before Tag filtering, including messages for all Tags under the Topic.
	TotalDiff pulumi.IntOutput `pulumi:"totalDiff"`
}

Group, also known as Consumer Group, is a collection of consumers with similar consumption behavior, used to categorize and manage different consumers. Each consumer group consumes different types of messages. Within each consumer group, the logic for publishing or subscribing to messages is consistent. In RocketMQ Message Queue, you need to create a Group and use the Group ID to identify different types of producers or consumers.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/volcengine/pulumi-volcenginecc/sdk/go/volcenginecc/rocketmq"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := rocketmq.NewGroup(ctx, "RocketMQGroupDemo", &rocketmq.GroupArgs{
			InstanceId:            pulumi.String("rocketmq-cnnxxxxxc2d"),
			GroupId:               pulumi.String("ccapi-test-test-1"),
			ConsumeMessageOrderly: pulumi.Bool(true),
			Description:           pulumi.String("test"),
			GroupType:             pulumi.String("TCP"),
			RetryMaxTimes:         pulumi.Int(2),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

```sh $ pulumi import volcenginecc:rocketmq/group:Group example "instance_id|group_id" ```

func GetGroup added in v0.0.22 

func GetGroup(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *GroupState, opts ...pulumi.ResourceOption) (*Group, error)

GetGroup gets an existing Group 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 NewGroup added in v0.0.22 

func NewGroup(ctx *pulumi.Context,
	name string, args *GroupArgs, opts ...pulumi.ResourceOption) (*Group, error)

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

func (*Group) ElementType added in v0.0.22 

func (*Group) ElementType() reflect.Type

func (*Group) ToGroupOutput added in v0.0.22 

func (i *Group) ToGroupOutput() GroupOutput

func (*Group) ToGroupOutputWithContext added in v0.0.22 

func (i *Group) ToGroupOutputWithContext(ctx context.Context) GroupOutput

type GroupArgs added in v0.0.22 

type GroupArgs struct {
	// Whether the subscription relationships of consumer instance groups within the Group are consistent. true: Consistent, false: Inconsistent.
	ConsumeMessageOrderly pulumi.BoolPtrInput
	// Brief description of the Group.
	Description pulumi.StringPtrInput
	// Group ID. Length must be between 7 and 120 characters and can only contain letters, numbers, hyphens (-), and underscores (*). It is recommended to start with GID  - or GID*. The ID cannot be changed after the Group is created, so set it carefully. For RocketMQ instances created on or before June 5, 2023, the Group name cannot exceed 93 characters.
	GroupId pulumi.StringInput
	// Group protocol identifier, used to indicate the production and consumption protocol type for this Group. Can be set to TCP.
	GroupType pulumi.StringInput
	// Instance ID.
	InstanceId pulumi.StringInput
	// Maximum number of consumption retries.
	RetryMaxTimes pulumi.IntPtrInput
}

The set of arguments for constructing a Group resource.

func (GroupArgs) ElementType added in v0.0.22 

func (GroupArgs) ElementType() reflect.Type

type GroupArray added in v0.0.22 

type GroupArray []GroupInput

func (GroupArray) ElementType added in v0.0.22 

func (GroupArray) ElementType() reflect.Type

func (GroupArray) ToGroupArrayOutput added in v0.0.22 

func (i GroupArray) ToGroupArrayOutput() GroupArrayOutput

func (GroupArray) ToGroupArrayOutputWithContext added in v0.0.22 

func (i GroupArray) ToGroupArrayOutputWithContext(ctx context.Context) GroupArrayOutput

type GroupArrayInput added in v0.0.22 

type GroupArrayInput interface {
	pulumi.Input

	ToGroupArrayOutput() GroupArrayOutput
	ToGroupArrayOutputWithContext(context.Context) GroupArrayOutput
}

GroupArrayInput is an input type that accepts GroupArray and GroupArrayOutput values. You can construct a concrete instance of `GroupArrayInput` via: 

GroupArray{ GroupArgs{...} }

type GroupArrayOutput added in v0.0.22 

type GroupArrayOutput struct{ *pulumi.OutputState }

func (GroupArrayOutput) ElementType added in v0.0.22 

func (GroupArrayOutput) ElementType() reflect.Type

func (GroupArrayOutput) Index added in v0.0.22 

func (o GroupArrayOutput) Index(i pulumi.IntInput) GroupOutput

func (GroupArrayOutput) ToGroupArrayOutput added in v0.0.22 

func (o GroupArrayOutput) ToGroupArrayOutput() GroupArrayOutput

func (GroupArrayOutput) ToGroupArrayOutputWithContext added in v0.0.22 

func (o GroupArrayOutput) ToGroupArrayOutputWithContext(ctx context.Context) GroupArrayOutput

type GroupConsumedClient added in v0.0.22 

type GroupConsumedClient struct {
	// Address and port of this consumer instance.
	ClientAddress *string `pulumi:"clientAddress"`
	// ID of this consumer instance.
	ClientId *string `pulumi:"clientId"`
	// Message backlog.
	Diff *int `pulumi:"diff"`
	// Development language of the consumer application.
	Language *string `pulumi:"language"`
	// Consumer version.
	Version *string `pulumi:"version"`
}

type GroupConsumedClientArgs added in v0.0.22 

type GroupConsumedClientArgs struct {
	// Address and port of this consumer instance.
	ClientAddress pulumi.StringPtrInput `pulumi:"clientAddress"`
	// ID of this consumer instance.
	ClientId pulumi.StringPtrInput `pulumi:"clientId"`
	// Message backlog.
	Diff pulumi.IntPtrInput `pulumi:"diff"`
	// Development language of the consumer application.
	Language pulumi.StringPtrInput `pulumi:"language"`
	// Consumer version.
	Version pulumi.StringPtrInput `pulumi:"version"`
}

func (GroupConsumedClientArgs) ElementType added in v0.0.22 

func (GroupConsumedClientArgs) ElementType() reflect.Type

func (GroupConsumedClientArgs) ToGroupConsumedClientOutput added in v0.0.22 

func (i GroupConsumedClientArgs) ToGroupConsumedClientOutput() GroupConsumedClientOutput

func (GroupConsumedClientArgs) ToGroupConsumedClientOutputWithContext added in v0.0.22 

func (i GroupConsumedClientArgs) ToGroupConsumedClientOutputWithContext(ctx context.Context) GroupConsumedClientOutput

type GroupConsumedClientArray added in v0.0.22 

type GroupConsumedClientArray []GroupConsumedClientInput

func (GroupConsumedClientArray) ElementType added in v0.0.22 

func (GroupConsumedClientArray) ElementType() reflect.Type

func (GroupConsumedClientArray) ToGroupConsumedClientArrayOutput added in v0.0.22 

func (i GroupConsumedClientArray) ToGroupConsumedClientArrayOutput() GroupConsumedClientArrayOutput

func (GroupConsumedClientArray) ToGroupConsumedClientArrayOutputWithContext added in v0.0.22 

func (i GroupConsumedClientArray) ToGroupConsumedClientArrayOutputWithContext(ctx context.Context) GroupConsumedClientArrayOutput

type GroupConsumedClientArrayInput added in v0.0.22 

type GroupConsumedClientArrayInput interface {
	pulumi.Input

	ToGroupConsumedClientArrayOutput() GroupConsumedClientArrayOutput
	ToGroupConsumedClientArrayOutputWithContext(context.Context) GroupConsumedClientArrayOutput
}

GroupConsumedClientArrayInput is an input type that accepts GroupConsumedClientArray and GroupConsumedClientArrayOutput values. You can construct a concrete instance of `GroupConsumedClientArrayInput` via: 

GroupConsumedClientArray{ GroupConsumedClientArgs{...} }

type GroupConsumedClientArrayOutput added in v0.0.22 

type GroupConsumedClientArrayOutput struct{ *pulumi.OutputState }

func (GroupConsumedClientArrayOutput) ElementType added in v0.0.22 

func (GroupConsumedClientArrayOutput) ElementType() reflect.Type

func (GroupConsumedClientArrayOutput) Index added in v0.0.22 

func (o GroupConsumedClientArrayOutput) Index(i pulumi.IntInput) GroupConsumedClientOutput

func (GroupConsumedClientArrayOutput) ToGroupConsumedClientArrayOutput added in v0.0.22 

func (o GroupConsumedClientArrayOutput) ToGroupConsumedClientArrayOutput() GroupConsumedClientArrayOutput

func (GroupConsumedClientArrayOutput) ToGroupConsumedClientArrayOutputWithContext added in v0.0.22 

func (o GroupConsumedClientArrayOutput) ToGroupConsumedClientArrayOutputWithContext(ctx context.Context) GroupConsumedClientArrayOutput

type GroupConsumedClientInput added in v0.0.22 

type GroupConsumedClientInput interface {
	pulumi.Input

	ToGroupConsumedClientOutput() GroupConsumedClientOutput
	ToGroupConsumedClientOutputWithContext(context.Context) GroupConsumedClientOutput
}

GroupConsumedClientInput is an input type that accepts GroupConsumedClientArgs and GroupConsumedClientOutput values. You can construct a concrete instance of `GroupConsumedClientInput` via: 

GroupConsumedClientArgs{...}

type GroupConsumedClientOutput added in v0.0.22 

type GroupConsumedClientOutput struct{ *pulumi.OutputState }

func (GroupConsumedClientOutput) ClientAddress added in v0.0.22 

func (o GroupConsumedClientOutput) ClientAddress() pulumi.StringPtrOutput

Address and port of this consumer instance.

func (GroupConsumedClientOutput) ClientId added in v0.0.22 

func (o GroupConsumedClientOutput) ClientId() pulumi.StringPtrOutput

ID of this consumer instance.

func (GroupConsumedClientOutput) Diff added in v0.0.22 

func (o GroupConsumedClientOutput) Diff() pulumi.IntPtrOutput

Message backlog.

func (GroupConsumedClientOutput) ElementType added in v0.0.22 

func (GroupConsumedClientOutput) ElementType() reflect.Type

func (GroupConsumedClientOutput) Language added in v0.0.22 

func (o GroupConsumedClientOutput) Language() pulumi.StringPtrOutput

Development language of the consumer application.

func (GroupConsumedClientOutput) ToGroupConsumedClientOutput added in v0.0.22 

func (o GroupConsumedClientOutput) ToGroupConsumedClientOutput() GroupConsumedClientOutput

func (GroupConsumedClientOutput) ToGroupConsumedClientOutputWithContext added in v0.0.22 

func (o GroupConsumedClientOutput) ToGroupConsumedClientOutputWithContext(ctx context.Context) GroupConsumedClientOutput

func (GroupConsumedClientOutput) Version added in v0.0.22 

func (o GroupConsumedClientOutput) Version() pulumi.StringPtrOutput

Consumer version.

type GroupConsumedTopic added in v0.0.22 

type GroupConsumedTopic struct {
	// Number of queues associated with the Topic. Each Topic contains one or more queues for storing messages.
	QueueNum *int `pulumi:"queueNum"`
	// Subscription rules.
	SubString *string `pulumi:"subString"`
	// Name of the Topic subscribed by the client.
	TopicName *string `pulumi:"topicName"`
}

type GroupConsumedTopicArgs added in v0.0.22 

type GroupConsumedTopicArgs struct {
	// Number of queues associated with the Topic. Each Topic contains one or more queues for storing messages.
	QueueNum pulumi.IntPtrInput `pulumi:"queueNum"`
	// Subscription rules.
	SubString pulumi.StringPtrInput `pulumi:"subString"`
	// Name of the Topic subscribed by the client.
	TopicName pulumi.StringPtrInput `pulumi:"topicName"`
}

func (GroupConsumedTopicArgs) ElementType added in v0.0.22 

func (GroupConsumedTopicArgs) ElementType() reflect.Type

func (GroupConsumedTopicArgs) ToGroupConsumedTopicOutput added in v0.0.22 

func (i GroupConsumedTopicArgs) ToGroupConsumedTopicOutput() GroupConsumedTopicOutput

func (GroupConsumedTopicArgs) ToGroupConsumedTopicOutputWithContext added in v0.0.22 

func (i GroupConsumedTopicArgs) ToGroupConsumedTopicOutputWithContext(ctx context.Context) GroupConsumedTopicOutput

type GroupConsumedTopicArray added in v0.0.22 

type GroupConsumedTopicArray []GroupConsumedTopicInput

func (GroupConsumedTopicArray) ElementType added in v0.0.22 

func (GroupConsumedTopicArray) ElementType() reflect.Type

func (GroupConsumedTopicArray) ToGroupConsumedTopicArrayOutput added in v0.0.22 

func (i GroupConsumedTopicArray) ToGroupConsumedTopicArrayOutput() GroupConsumedTopicArrayOutput

func (GroupConsumedTopicArray) ToGroupConsumedTopicArrayOutputWithContext added in v0.0.22 

func (i GroupConsumedTopicArray) ToGroupConsumedTopicArrayOutputWithContext(ctx context.Context) GroupConsumedTopicArrayOutput

type GroupConsumedTopicArrayInput added in v0.0.22 

type GroupConsumedTopicArrayInput interface {
	pulumi.Input

	ToGroupConsumedTopicArrayOutput() GroupConsumedTopicArrayOutput
	ToGroupConsumedTopicArrayOutputWithContext(context.Context) GroupConsumedTopicArrayOutput
}

GroupConsumedTopicArrayInput is an input type that accepts GroupConsumedTopicArray and GroupConsumedTopicArrayOutput values. You can construct a concrete instance of `GroupConsumedTopicArrayInput` via: 

GroupConsumedTopicArray{ GroupConsumedTopicArgs{...} }

type GroupConsumedTopicArrayOutput added in v0.0.22 

type GroupConsumedTopicArrayOutput struct{ *pulumi.OutputState }

func (GroupConsumedTopicArrayOutput) ElementType added in v0.0.22 

func (GroupConsumedTopicArrayOutput) ElementType() reflect.Type

func (GroupConsumedTopicArrayOutput) Index added in v0.0.22 

func (o GroupConsumedTopicArrayOutput) Index(i pulumi.IntInput) GroupConsumedTopicOutput

func (GroupConsumedTopicArrayOutput) ToGroupConsumedTopicArrayOutput added in v0.0.22 

func (o GroupConsumedTopicArrayOutput) ToGroupConsumedTopicArrayOutput() GroupConsumedTopicArrayOutput

func (GroupConsumedTopicArrayOutput) ToGroupConsumedTopicArrayOutputWithContext added in v0.0.22 

func (o GroupConsumedTopicArrayOutput) ToGroupConsumedTopicArrayOutputWithContext(ctx context.Context) GroupConsumedTopicArrayOutput

type GroupConsumedTopicInput added in v0.0.22 

type GroupConsumedTopicInput interface {
	pulumi.Input

	ToGroupConsumedTopicOutput() GroupConsumedTopicOutput
	ToGroupConsumedTopicOutputWithContext(context.Context) GroupConsumedTopicOutput
}

GroupConsumedTopicInput is an input type that accepts GroupConsumedTopicArgs and GroupConsumedTopicOutput values. You can construct a concrete instance of `GroupConsumedTopicInput` via: 

GroupConsumedTopicArgs{...}

type GroupConsumedTopicOutput added in v0.0.22 

type GroupConsumedTopicOutput struct{ *pulumi.OutputState }

func (GroupConsumedTopicOutput) ElementType added in v0.0.22 

func (GroupConsumedTopicOutput) ElementType() reflect.Type

func (GroupConsumedTopicOutput) QueueNum added in v0.0.22 

func (o GroupConsumedTopicOutput) QueueNum() pulumi.IntPtrOutput

Number of queues associated with the Topic. Each Topic contains one or more queues for storing messages.

func (GroupConsumedTopicOutput) SubString added in v0.0.22 

func (o GroupConsumedTopicOutput) SubString() pulumi.StringPtrOutput

Subscription rules.

func (GroupConsumedTopicOutput) ToGroupConsumedTopicOutput added in v0.0.22 

func (o GroupConsumedTopicOutput) ToGroupConsumedTopicOutput() GroupConsumedTopicOutput

func (GroupConsumedTopicOutput) ToGroupConsumedTopicOutputWithContext added in v0.0.22 

func (o GroupConsumedTopicOutput) ToGroupConsumedTopicOutputWithContext(ctx context.Context) GroupConsumedTopicOutput

func (GroupConsumedTopicOutput) TopicName added in v0.0.22 

func (o GroupConsumedTopicOutput) TopicName() pulumi.StringPtrOutput

Name of the Topic subscribed by the client.

type GroupInput added in v0.0.22 

type GroupInput interface {
	pulumi.Input

	ToGroupOutput() GroupOutput
	ToGroupOutputWithContext(ctx context.Context) GroupOutput
}

type GroupMap added in v0.0.22 

type GroupMap map[string]GroupInput

func (GroupMap) ElementType added in v0.0.22 

func (GroupMap) ElementType() reflect.Type

func (GroupMap) ToGroupMapOutput added in v0.0.22 

func (i GroupMap) ToGroupMapOutput() GroupMapOutput

func (GroupMap) ToGroupMapOutputWithContext added in v0.0.22 

func (i GroupMap) ToGroupMapOutputWithContext(ctx context.Context) GroupMapOutput

type GroupMapInput added in v0.0.22 

type GroupMapInput interface {
	pulumi.Input

	ToGroupMapOutput() GroupMapOutput
	ToGroupMapOutputWithContext(context.Context) GroupMapOutput
}

GroupMapInput is an input type that accepts GroupMap and GroupMapOutput values. You can construct a concrete instance of `GroupMapInput` via: 

GroupMap{ "key": GroupArgs{...} }

type GroupMapOutput added in v0.0.22 

type GroupMapOutput struct{ *pulumi.OutputState }

func (GroupMapOutput) ElementType added in v0.0.22 

func (GroupMapOutput) ElementType() reflect.Type

func (GroupMapOutput) MapIndex added in v0.0.22 

func (o GroupMapOutput) MapIndex(k pulumi.StringInput) GroupOutput

func (GroupMapOutput) ToGroupMapOutput added in v0.0.22 

func (o GroupMapOutput) ToGroupMapOutput() GroupMapOutput

func (GroupMapOutput) ToGroupMapOutputWithContext added in v0.0.22 

func (o GroupMapOutput) ToGroupMapOutputWithContext(ctx context.Context) GroupMapOutput

type GroupOutput added in v0.0.22 

type GroupOutput struct{ *pulumi.OutputState }

func (GroupOutput) ConsumeMessageOrderly added in v0.0.22 

func (o GroupOutput) ConsumeMessageOrderly() pulumi.BoolOutput

Whether the subscription relationships of consumer instance groups within the Group are consistent. true: Consistent, false: Inconsistent.

func (GroupOutput) ConsumedClients added in v0.0.22 

func (o GroupOutput) ConsumedClients() GroupConsumedClientArrayOutput

func (GroupOutput) ConsumedTopics added in v0.0.22 

func (o GroupOutput) ConsumedTopics() GroupConsumedTopicArrayOutput

func (GroupOutput) CreatedTime added in v0.0.22 

func (o GroupOutput) CreatedTime() pulumi.StringOutput

Group creation time.

func (GroupOutput) Description added in v0.0.22 

func (o GroupOutput) Description() pulumi.StringOutput

Brief description of the Group.

func (GroupOutput) ElementType added in v0.0.22 

func (GroupOutput) ElementType() reflect.Type

func (GroupOutput) GroupId added in v0.0.22 

func (o GroupOutput) GroupId() pulumi.StringOutput

Group ID. Length must be between 7 and 120 characters and can only contain letters, numbers, hyphens (-), and underscores (*). It is recommended to start with GID - or GID*. The ID cannot be changed after the Group is created, so set it carefully. For RocketMQ instances created on or before June 5, 2023, the Group name cannot exceed 93 characters.

func (GroupOutput) GroupType added in v0.0.22 

func (o GroupOutput) GroupType() pulumi.StringOutput

Group protocol identifier, used to indicate the production and consumption protocol type for this Group. Can be set to TCP.

func (GroupOutput) InstanceId added in v0.0.22 

func (o GroupOutput) InstanceId() pulumi.StringOutput

Instance ID.

func (GroupOutput) IsSubSame added in v0.0.22 

func (o GroupOutput) IsSubSame() pulumi.BoolOutput

Whether the subscription relationships of consumer instance groups within the Group are consistent. true: Consistent, false: Inconsistent.

func (GroupOutput) LastUpdateTimestamp added in v0.0.22 

func (o GroupOutput) LastUpdateTimestamp() pulumi.StringOutput

Whether consumption is sequential.

func (GroupOutput) MessageDelayTime added in v0.0.22 

func (o GroupOutput) MessageDelayTime() pulumi.StringOutput

Message latency. The difference between the production time of the earliest unconsumed message in the consumer instance group and the current time, measured in milliseconds.

func (GroupOutput) MessageModel added in v0.0.22 

func (o GroupOutput) MessageModel() pulumi.StringOutput

Message consumption mode. The default is clustering mode. Do not configure both clustering and broadcasting modes under the same Group. Clustering: Clustering consumption mode, Broadcasting: Broadcasting consumption mode.

func (GroupOutput) RetryMaxTimes added in v0.0.22 

func (o GroupOutput) RetryMaxTimes() pulumi.IntOutput

Maximum number of consumption retries.

func (GroupOutput) RocketmqVersion added in v0.0.22 

func (o GroupOutput) RocketmqVersion() pulumi.StringOutput

RocketMQ version.

func (GroupOutput) ServiceStatus added in v0.0.22 

func (o GroupOutput) ServiceStatus() pulumi.StringOutput

Service status. Creating: Being created, Running: Running, Deleting: Being deleted, Abnormal: Abnormal, Updating: Being updated.

func (GroupOutput) Status added in v0.0.22 

func (o GroupOutput) Status() pulumi.StringOutput

Consumer group status. Online: Consuming, Offline: Not consuming.

func (GroupOutput) ToGroupOutput added in v0.0.22 

func (o GroupOutput) ToGroupOutput() GroupOutput

func (GroupOutput) ToGroupOutputWithContext added in v0.0.22 

func (o GroupOutput) ToGroupOutputWithContext(ctx context.Context) GroupOutput

func (GroupOutput) TotalConsumedRate added in v0.0.22 

func (o GroupOutput) TotalConsumedRate() pulumi.StringOutput

Total TPS of consumer instance groups under this Group, measured in messages per second.

func (GroupOutput) TotalDiff added in v0.0.22 

func (o GroupOutput) TotalDiff() pulumi.IntOutput

Total number of unconsumed messages in the consumer instance group. The message backlog shown here is the total backlog before Tag filtering, including messages for all Tags under the Topic.

type GroupState added in v0.0.22 

type GroupState struct {
	// Whether the subscription relationships of consumer instance groups within the Group are consistent. true: Consistent, false: Inconsistent.
	ConsumeMessageOrderly pulumi.BoolPtrInput
	ConsumedClients       GroupConsumedClientArrayInput
	ConsumedTopics        GroupConsumedTopicArrayInput
	// Group creation time.
	CreatedTime pulumi.StringPtrInput
	// Brief description of the Group.
	Description pulumi.StringPtrInput
	// Group ID. Length must be between 7 and 120 characters and can only contain letters, numbers, hyphens (-), and underscores (*). It is recommended to start with GID  - or GID*. The ID cannot be changed after the Group is created, so set it carefully. For RocketMQ instances created on or before June 5, 2023, the Group name cannot exceed 93 characters.
	GroupId pulumi.StringPtrInput
	// Group protocol identifier, used to indicate the production and consumption protocol type for this Group. Can be set to TCP.
	GroupType pulumi.StringPtrInput
	// Instance ID.
	InstanceId pulumi.StringPtrInput
	// Whether the subscription relationships of consumer instance groups within the Group are consistent. true: Consistent, false: Inconsistent.
	IsSubSame pulumi.BoolPtrInput
	// Whether consumption is sequential.
	LastUpdateTimestamp pulumi.StringPtrInput
	// Message latency. The difference between the production time of the earliest unconsumed message in the consumer instance group and the current time, measured in milliseconds.
	MessageDelayTime pulumi.StringPtrInput
	// Message consumption mode. The default is clustering mode. Do not configure both clustering and broadcasting modes under the same Group. Clustering: Clustering consumption mode, Broadcasting: Broadcasting consumption mode.
	MessageModel pulumi.StringPtrInput
	// Maximum number of consumption retries.
	RetryMaxTimes pulumi.IntPtrInput
	// RocketMQ version.
	RocketmqVersion pulumi.StringPtrInput
	// Service status. Creating: Being created, Running: Running, Deleting: Being deleted, Abnormal: Abnormal, Updating: Being updated.
	ServiceStatus pulumi.StringPtrInput
	// Consumer group status. Online: Consuming, Offline: Not consuming.
	Status pulumi.StringPtrInput
	// Total TPS of consumer instance groups under this Group, measured in messages per second.
	TotalConsumedRate pulumi.StringPtrInput
	// Total number of unconsumed messages in the consumer instance group. The message backlog shown here is the total backlog before Tag filtering, including messages for all Tags under the Topic.
	TotalDiff pulumi.IntPtrInput
}

func (GroupState) ElementType added in v0.0.22 

func (GroupState) ElementType() reflect.Type

type Instance 

type Instance struct {
	pulumi.CustomResourceState

	// Account ID to which the instance belongs.
	AccountId pulumi.StringOutput `pulumi:"accountId"`
	// List of allowlist IDs bound to the instance. After binding an allowlist, only IP addresses and address ranges configured in the allowlist can access this instance. If no allowlist is bound to the instance, all IP addresses are denied access to the instance.
	AllowListIds pulumi.StringArrayOutput `pulumi:"allowListIds"`
	// Whether private network domain name supports public resolution. true: enabled false: disabled
	ApplyPrivateDnsToPublic pulumi.BoolOutput `pulumi:"applyPrivateDnsToPublic"`
	// Whether to automatically create queues when the instance specification changes.
	AutoScaleQueue pulumi.BoolOutput `pulumi:"autoScaleQueue"`
	// Remaining number of partitions that can be created.
	AvailableQueueNumber pulumi.IntOutput `pulumi:"availableQueueNumber"`
	// Billing method and related billing information for the instance.
	ChargeDetail InstanceChargeDetailOutput `pulumi:"chargeDetail"`
	// Instance compute specification. You can view the currently available compute specifications in the product specifications list.
	ComputeSpec     pulumi.StringOutput               `pulumi:"computeSpec"`
	ConnectionInfos InstanceConnectionInfoArrayOutput `pulumi:"connectionInfos"`
	// Instance creation time. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'.
	CreateTime pulumi.StringOutput `pulumi:"createTime"`
	// EIP ID. Specifying EipId enables public access for the instance. EIP provides independent public IP resources, including public IP addresses and outbound bandwidth services. After enabling public access by specifying this parameter, the public address will be bound to your Elastic IP (EIP), and fees will be charged for the EIP resource.
	EipId pulumi.StringOutput `pulumi:"eipId"`
	// Whether to use SSL encryption.
	EnableSsl pulumi.BoolOutput `pulumi:"enableSsl"`
	// Message retention period on the RocketMQ Message Queue server. Messages exceeding the retention period will be expired and cleaned up. Unit: hours. Value range: 1–72 hours.
	FileReservedTime pulumi.IntOutput `pulumi:"fileReservedTime"`
	// Brief description of the instance. Length range: 1–128 characters.
	InstanceDescription pulumi.StringOutput `pulumi:"instanceDescription"`
	// Instance ID.
	InstanceId pulumi.StringOutput `pulumi:"instanceId"`
	// Instance name. Must meet the following requirements: can only contain Chinese characters, letters, numbers, underscores (_), and hyphens (-); cannot start with a number or hyphen (-); length must be 1–128 characters. If no name is specified when creating the instance, the instance ID will be used as the default name.
	InstanceName pulumi.StringOutput `pulumi:"instanceName"`
	// Instance status.
	InstanceStatus pulumi.StringOutput `pulumi:"instanceStatus"`
	// IP version. Options are IPv4 or DualStack.
	IpVersionType pulumi.StringOutput `pulumi:"ipVersionType"`
	// Instance network type, fixed as PrivateNetwork.
	NetworkTypes pulumi.StringOutput `pulumi:"networkTypes"`
	// Product configuration information. Note: Only RocketMQ 5.x instances support adjusting the TPS ratio for the instance.
	ProductInfo InstanceProductInfoOutput `pulumi:"productInfo"`
	// The IAM project to which the newly created instance belongs. If not set, the new instance will be bound to the IAM project named 'default'.
	ProjectName pulumi.StringOutput `pulumi:"projectName"`
	// Region ID where the instance is located.
	RegionId pulumi.StringOutput `pulumi:"regionId"`
	// The instance's public network connection policy only needs to be set when public access is enabled. Supported settings are: enforcing: When accessing the instance via the public network, SSL authentication is required. SSL authentication enables encrypted data transmission, offering higher security compared to standard public access, but may reduce performance. permissive: When accessing the instance via the public network, SSL authentication is optional. After the instance is created and public access is enabled, the SSL connection policy cannot be modified. To change it, you must disable and re-enable public access for the instance, and set the SSL connection policy again when re-enabling. For details, see Setting Public Access and SSL Authentication Policy.
	SslMode pulumi.StringOutput `pulumi:"sslMode"`
	// Instance storage space, measured in GiB and must be specified in multiples of 100. The value range depends on the currently selected compute specification.
	StorageSpace pulumi.IntOutput `pulumi:"storageSpace"`
	// VPC subnet ID where the instance resides. After the instance is created, the associated VPC and subnet cannot be modified. Please operate carefully when creating the instance. You can call the DescribeVpcs API of the VPC to query the available VPC and subnet list.
	SubnetId pulumi.StringOutput    `pulumi:"subnetId"`
	Tags     InstanceTagArrayOutput `pulumi:"tags"`
	// Number of consumer groups (Group) currently created for the instance.
	UsedGroupNumber pulumi.IntOutput `pulumi:"usedGroupNumber"`
	// Number of queues already used by the instance.
	UsedQueueNumber pulumi.IntOutput `pulumi:"usedQueueNumber"`
	// Used storage space for the instance, in GiB.
	UsedStorageSpace pulumi.IntOutput `pulumi:"usedStorageSpace"`
	// Number of topics created in the current instance.
	UsedTopicNumber pulumi.IntOutput `pulumi:"usedTopicNumber"`
	// Supported RocketMQ versions. Currently supported versions include: 4.8: compatible with RocketMQ 4.x series. 5.x: compatible with RocketMQ 5.x series. The 5.x version is currently available by whitelist application. To use it, contact technical support to apply for access.
	Version pulumi.StringOutput `pulumi:"version"`
	// VPC ID where the instance resides. After the instance is created, the associated VPC and subnet cannot be modified. Please operate carefully when creating the instance. You can call the DescribeVpcs API of the VPC to query the available VPC and subnet list.
	VpcId pulumi.StringOutput `pulumi:"vpcId"`
	// Availability zone ID where the instance is located. RocketMQ Message Queue instances support cross-AZ deployment. When viewing available compute specifications in a specified availability zone, you can specify multiple zones. Separate multiple availability zone IDs with commas (,). You can call DescribeAvailabilityZones to query the list of currently available zones.
	ZoneId pulumi.StringOutput `pulumi:"zoneId"`
}

RocketMQ Message Queue is a distributed messaging middleware service built on Apache RocketMQ. It is fully compatible with all open-source RocketMQ components and concepts, offering low latency, high elasticity and high reliability, and high throughput. No changes to business code are required, enabling users to quickly migrate to the cloud.

## Import

```sh $ pulumi import volcenginecc:rocketmq/instance:Instance example "instance_id" ```

func GetInstance 

func GetInstance(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *InstanceState, opts ...pulumi.ResourceOption) (*Instance, error)

GetInstance gets an existing Instance 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 NewInstance 

func NewInstance(ctx *pulumi.Context,
	name string, args *InstanceArgs, opts ...pulumi.ResourceOption) (*Instance, error)

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

func (*Instance) ElementType 

func (*Instance) ElementType() reflect.Type

func (*Instance) ToInstanceOutput 

func (i *Instance) ToInstanceOutput() InstanceOutput

func (*Instance) ToInstanceOutputWithContext 

func (i *Instance) ToInstanceOutputWithContext(ctx context.Context) InstanceOutput

type InstanceArgs 

type InstanceArgs struct {
	// List of allowlist IDs bound to the instance. After binding an allowlist, only IP addresses and address ranges configured in the allowlist can access this instance. If no allowlist is bound to the instance, all IP addresses are denied access to the instance.
	AllowListIds pulumi.StringArrayInput
	// Whether to automatically create queues when the instance specification changes.
	AutoScaleQueue pulumi.BoolPtrInput
	// Billing method and related billing information for the instance.
	ChargeDetail InstanceChargeDetailInput
	// Instance compute specification. You can view the currently available compute specifications in the product specifications list.
	ComputeSpec pulumi.StringInput
	// EIP ID. Specifying EipId enables public access for the instance. EIP provides independent public IP resources, including public IP addresses and outbound bandwidth services. After enabling public access by specifying this parameter, the public address will be bound to your Elastic IP (EIP), and fees will be charged for the EIP resource.
	EipId pulumi.StringPtrInput
	// Whether to use SSL encryption.
	EnableSsl pulumi.BoolPtrInput
	// Message retention period on the RocketMQ Message Queue server. Messages exceeding the retention period will be expired and cleaned up. Unit: hours. Value range: 1–72 hours.
	FileReservedTime pulumi.IntInput
	// Brief description of the instance. Length range: 1–128 characters.
	InstanceDescription pulumi.StringPtrInput
	// Instance name. Must meet the following requirements: can only contain Chinese characters, letters, numbers, underscores (_), and hyphens (-); cannot start with a number or hyphen (-); length must be 1–128 characters. If no name is specified when creating the instance, the instance ID will be used as the default name.
	InstanceName pulumi.StringPtrInput
	// IP version. Options are IPv4 or DualStack.
	IpVersionType pulumi.StringPtrInput
	// Instance network type, fixed as PrivateNetwork.
	NetworkTypes pulumi.StringInput
	// Product configuration information. Note: Only RocketMQ 5.x instances support adjusting the TPS ratio for the instance.
	ProductInfo InstanceProductInfoPtrInput
	// The IAM project to which the newly created instance belongs. If not set, the new instance will be bound to the IAM project named 'default'.
	ProjectName pulumi.StringPtrInput
	// The instance's public network connection policy only needs to be set when public access is enabled. Supported settings are: enforcing: When accessing the instance via the public network, SSL authentication is required. SSL authentication enables encrypted data transmission, offering higher security compared to standard public access, but may reduce performance. permissive: When accessing the instance via the public network, SSL authentication is optional. After the instance is created and public access is enabled, the SSL connection policy cannot be modified. To change it, you must disable and re-enable public access for the instance, and set the SSL connection policy again when re-enabling. For details, see Setting Public Access and SSL Authentication Policy.
	SslMode pulumi.StringPtrInput
	// Instance storage space, measured in GiB and must be specified in multiples of 100. The value range depends on the currently selected compute specification.
	StorageSpace pulumi.IntInput
	// VPC subnet ID where the instance resides. After the instance is created, the associated VPC and subnet cannot be modified. Please operate carefully when creating the instance. You can call the DescribeVpcs API of the VPC to query the available VPC and subnet list.
	SubnetId pulumi.StringInput
	Tags     InstanceTagArrayInput
	// Supported RocketMQ versions. Currently supported versions include: 4.8: compatible with RocketMQ 4.x series. 5.x: compatible with RocketMQ 5.x series. The 5.x version is currently available by whitelist application. To use it, contact technical support to apply for access.
	Version pulumi.StringInput
	// VPC ID where the instance resides. After the instance is created, the associated VPC and subnet cannot be modified. Please operate carefully when creating the instance. You can call the DescribeVpcs API of the VPC to query the available VPC and subnet list.
	VpcId pulumi.StringInput
	// Availability zone ID where the instance is located. RocketMQ Message Queue instances support cross-AZ deployment. When viewing available compute specifications in a specified availability zone, you can specify multiple zones. Separate multiple availability zone IDs with commas (,). You can call DescribeAvailabilityZones to query the list of currently available zones.
	ZoneId pulumi.StringInput
}

The set of arguments for constructing a Instance resource.

func (InstanceArgs) ElementType 

func (InstanceArgs) ElementType() reflect.Type

type InstanceArray 

type InstanceArray []InstanceInput

func (InstanceArray) ElementType 

func (InstanceArray) ElementType() reflect.Type

func (InstanceArray) ToInstanceArrayOutput 

func (i InstanceArray) ToInstanceArrayOutput() InstanceArrayOutput

func (InstanceArray) ToInstanceArrayOutputWithContext 

func (i InstanceArray) ToInstanceArrayOutputWithContext(ctx context.Context) InstanceArrayOutput

type InstanceArrayInput 

type InstanceArrayInput interface {
	pulumi.Input

	ToInstanceArrayOutput() InstanceArrayOutput
	ToInstanceArrayOutputWithContext(context.Context) InstanceArrayOutput
}

InstanceArrayInput is an input type that accepts InstanceArray and InstanceArrayOutput values. You can construct a concrete instance of `InstanceArrayInput` via: 

InstanceArray{ InstanceArgs{...} }

type InstanceArrayOutput 

type InstanceArrayOutput struct{ *pulumi.OutputState }

func (InstanceArrayOutput) ElementType 

func (InstanceArrayOutput) ElementType() reflect.Type

func (InstanceArrayOutput) Index 

func (o InstanceArrayOutput) Index(i pulumi.IntInput) InstanceOutput

func (InstanceArrayOutput) ToInstanceArrayOutput 

func (o InstanceArrayOutput) ToInstanceArrayOutput() InstanceArrayOutput

func (InstanceArrayOutput) ToInstanceArrayOutputWithContext 

func (o InstanceArrayOutput) ToInstanceArrayOutputWithContext(ctx context.Context) InstanceArrayOutput

type InstanceChargeDetail 

type InstanceChargeDetail struct {
	// Whether the subscription instance is automatically renewed upon expiration. true: automatically renewed. false: not automatically renewed. Manual renewal is required after expiration; otherwise, the instance will be shut down.
	AutoRenew *bool `pulumi:"autoRenew"`
	// Expiration time for yearly/monthly subscription instances. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'. For pay-as-you-go instances, this field defaults to 1970-01-01T00:00:00Z.
	ChargeExpireTime *string `pulumi:"chargeExpireTime"`
	// Billing start time for the instance. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'.
	ChargeStartTime *string `pulumi:"chargeStartTime"`
	// Instance billing status. Includes: Normal: normal Overdue: pay-as-you-go overdue Expired: subscription expired
	ChargeStatus *string `pulumi:"chargeStatus"`
	// Billing type for the instance. Supported types include: PostPaid: pay-as-you-go; PrePaid: yearly/monthly subscription
	ChargeType *string `pulumi:"chargeType"`
	// Estimated release time after the instance is suspended due to overdue payment. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'.
	OverdueReclaimTime *string `pulumi:"overdueReclaimTime"`
	// Suspension time due to overdue payment for the instance. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'.
	OverdueTime *string `pulumi:"overdueTime"`
	// Purchase duration for subscription instances. When PeriodUnit is set to Monthly, the value range is 1–9. When PeriodUnit is set to Yearly, the value range is 1–3. Only required for subscription instances, that is, when ChargeType is set to PrePaid.
	Period *int `pulumi:"period"`
	// Lifecycle unit for subscription-based instances, specifying whether to purchase by month or by year. Monthly: (default) monthly subscription Yearly: annual subscription
	PeriodUnit *string `pulumi:"periodUnit"`
}

type InstanceChargeDetailArgs 

type InstanceChargeDetailArgs struct {
	// Whether the subscription instance is automatically renewed upon expiration. true: automatically renewed. false: not automatically renewed. Manual renewal is required after expiration; otherwise, the instance will be shut down.
	AutoRenew pulumi.BoolPtrInput `pulumi:"autoRenew"`
	// Expiration time for yearly/monthly subscription instances. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'. For pay-as-you-go instances, this field defaults to 1970-01-01T00:00:00Z.
	ChargeExpireTime pulumi.StringPtrInput `pulumi:"chargeExpireTime"`
	// Billing start time for the instance. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'.
	ChargeStartTime pulumi.StringPtrInput `pulumi:"chargeStartTime"`
	// Instance billing status. Includes: Normal: normal Overdue: pay-as-you-go overdue Expired: subscription expired
	ChargeStatus pulumi.StringPtrInput `pulumi:"chargeStatus"`
	// Billing type for the instance. Supported types include: PostPaid: pay-as-you-go; PrePaid: yearly/monthly subscription
	ChargeType pulumi.StringPtrInput `pulumi:"chargeType"`
	// Estimated release time after the instance is suspended due to overdue payment. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'.
	OverdueReclaimTime pulumi.StringPtrInput `pulumi:"overdueReclaimTime"`
	// Suspension time due to overdue payment for the instance. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'.
	OverdueTime pulumi.StringPtrInput `pulumi:"overdueTime"`
	// Purchase duration for subscription instances. When PeriodUnit is set to Monthly, the value range is 1–9. When PeriodUnit is set to Yearly, the value range is 1–3. Only required for subscription instances, that is, when ChargeType is set to PrePaid.
	Period pulumi.IntPtrInput `pulumi:"period"`
	// Lifecycle unit for subscription-based instances, specifying whether to purchase by month or by year. Monthly: (default) monthly subscription Yearly: annual subscription
	PeriodUnit pulumi.StringPtrInput `pulumi:"periodUnit"`
}

func (InstanceChargeDetailArgs) ElementType 

func (InstanceChargeDetailArgs) ElementType() reflect.Type

func (InstanceChargeDetailArgs) ToInstanceChargeDetailOutput 

func (i InstanceChargeDetailArgs) ToInstanceChargeDetailOutput() InstanceChargeDetailOutput

func (InstanceChargeDetailArgs) ToInstanceChargeDetailOutputWithContext 

func (i InstanceChargeDetailArgs) ToInstanceChargeDetailOutputWithContext(ctx context.Context) InstanceChargeDetailOutput

func (InstanceChargeDetailArgs) ToInstanceChargeDetailPtrOutput 

func (i InstanceChargeDetailArgs) ToInstanceChargeDetailPtrOutput() InstanceChargeDetailPtrOutput

func (InstanceChargeDetailArgs) ToInstanceChargeDetailPtrOutputWithContext 

func (i InstanceChargeDetailArgs) ToInstanceChargeDetailPtrOutputWithContext(ctx context.Context) InstanceChargeDetailPtrOutput

type InstanceChargeDetailInput 

type InstanceChargeDetailInput interface {
	pulumi.Input

	ToInstanceChargeDetailOutput() InstanceChargeDetailOutput
	ToInstanceChargeDetailOutputWithContext(context.Context) InstanceChargeDetailOutput
}

InstanceChargeDetailInput is an input type that accepts InstanceChargeDetailArgs and InstanceChargeDetailOutput values. You can construct a concrete instance of `InstanceChargeDetailInput` via: 

InstanceChargeDetailArgs{...}

type InstanceChargeDetailOutput 

type InstanceChargeDetailOutput struct{ *pulumi.OutputState }

func (InstanceChargeDetailOutput) AutoRenew 

func (o InstanceChargeDetailOutput) AutoRenew() pulumi.BoolPtrOutput

Whether the subscription instance is automatically renewed upon expiration. true: automatically renewed. false: not automatically renewed. Manual renewal is required after expiration; otherwise, the instance will be shut down.

func (InstanceChargeDetailOutput) ChargeExpireTime 

func (o InstanceChargeDetailOutput) ChargeExpireTime() pulumi.StringPtrOutput

Expiration time for yearly/monthly subscription instances. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'. For pay-as-you-go instances, this field defaults to 1970-01-01T00:00:00Z.

func (InstanceChargeDetailOutput) ChargeStartTime 

func (o InstanceChargeDetailOutput) ChargeStartTime() pulumi.StringPtrOutput

Billing start time for the instance. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'.

func (InstanceChargeDetailOutput) ChargeStatus 

func (o InstanceChargeDetailOutput) ChargeStatus() pulumi.StringPtrOutput

Instance billing status. Includes: Normal: normal Overdue: pay-as-you-go overdue Expired: subscription expired

func (InstanceChargeDetailOutput) ChargeType 

func (o InstanceChargeDetailOutput) ChargeType() pulumi.StringPtrOutput

Billing type for the instance. Supported types include: PostPaid: pay-as-you-go; PrePaid: yearly/monthly subscription

func (InstanceChargeDetailOutput) ElementType 

func (InstanceChargeDetailOutput) ElementType() reflect.Type

func (InstanceChargeDetailOutput) OverdueReclaimTime 

func (o InstanceChargeDetailOutput) OverdueReclaimTime() pulumi.StringPtrOutput

Estimated release time after the instance is suspended due to overdue payment. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'.

func (InstanceChargeDetailOutput) OverdueTime 

func (o InstanceChargeDetailOutput) OverdueTime() pulumi.StringPtrOutput

Suspension time due to overdue payment for the instance. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'.

func (InstanceChargeDetailOutput) Period 

func (o InstanceChargeDetailOutput) Period() pulumi.IntPtrOutput

Purchase duration for subscription instances. When PeriodUnit is set to Monthly, the value range is 1–9. When PeriodUnit is set to Yearly, the value range is 1–3. Only required for subscription instances, that is, when ChargeType is set to PrePaid.

func (InstanceChargeDetailOutput) PeriodUnit 

func (o InstanceChargeDetailOutput) PeriodUnit() pulumi.StringPtrOutput

Lifecycle unit for subscription-based instances, specifying whether to purchase by month or by year. Monthly: (default) monthly subscription Yearly: annual subscription

func (InstanceChargeDetailOutput) ToInstanceChargeDetailOutput 

func (o InstanceChargeDetailOutput) ToInstanceChargeDetailOutput() InstanceChargeDetailOutput

func (InstanceChargeDetailOutput) ToInstanceChargeDetailOutputWithContext 

func (o InstanceChargeDetailOutput) ToInstanceChargeDetailOutputWithContext(ctx context.Context) InstanceChargeDetailOutput

func (InstanceChargeDetailOutput) ToInstanceChargeDetailPtrOutput 

func (o InstanceChargeDetailOutput) ToInstanceChargeDetailPtrOutput() InstanceChargeDetailPtrOutput

func (InstanceChargeDetailOutput) ToInstanceChargeDetailPtrOutputWithContext 

func (o InstanceChargeDetailOutput) ToInstanceChargeDetailPtrOutputWithContext(ctx context.Context) InstanceChargeDetailPtrOutput

type InstanceChargeDetailPtrInput 

type InstanceChargeDetailPtrInput interface {
	pulumi.Input

	ToInstanceChargeDetailPtrOutput() InstanceChargeDetailPtrOutput
	ToInstanceChargeDetailPtrOutputWithContext(context.Context) InstanceChargeDetailPtrOutput
}

InstanceChargeDetailPtrInput is an input type that accepts InstanceChargeDetailArgs, InstanceChargeDetailPtr and InstanceChargeDetailPtrOutput values. You can construct a concrete instance of `InstanceChargeDetailPtrInput` via: 

        InstanceChargeDetailArgs{...}

or:

        nil

func InstanceChargeDetailPtr 

func InstanceChargeDetailPtr(v *InstanceChargeDetailArgs) InstanceChargeDetailPtrInput

type InstanceChargeDetailPtrOutput 

type InstanceChargeDetailPtrOutput struct{ *pulumi.OutputState }

func (InstanceChargeDetailPtrOutput) AutoRenew 

func (o InstanceChargeDetailPtrOutput) AutoRenew() pulumi.BoolPtrOutput

Whether the subscription instance is automatically renewed upon expiration. true: automatically renewed. false: not automatically renewed. Manual renewal is required after expiration; otherwise, the instance will be shut down.

func (InstanceChargeDetailPtrOutput) ChargeExpireTime 

func (o InstanceChargeDetailPtrOutput) ChargeExpireTime() pulumi.StringPtrOutput

Expiration time for yearly/monthly subscription instances. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'. For pay-as-you-go instances, this field defaults to 1970-01-01T00:00:00Z.

func (InstanceChargeDetailPtrOutput) ChargeStartTime 

func (o InstanceChargeDetailPtrOutput) ChargeStartTime() pulumi.StringPtrOutput

Billing start time for the instance. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'.

func (InstanceChargeDetailPtrOutput) ChargeStatus 

func (o InstanceChargeDetailPtrOutput) ChargeStatus() pulumi.StringPtrOutput

Instance billing status. Includes: Normal: normal Overdue: pay-as-you-go overdue Expired: subscription expired

func (InstanceChargeDetailPtrOutput) ChargeType 

func (o InstanceChargeDetailPtrOutput) ChargeType() pulumi.StringPtrOutput

Billing type for the instance. Supported types include: PostPaid: pay-as-you-go; PrePaid: yearly/monthly subscription

func (InstanceChargeDetailPtrOutput) Elem 

func (o InstanceChargeDetailPtrOutput) Elem() InstanceChargeDetailOutput

func (InstanceChargeDetailPtrOutput) ElementType 

func (InstanceChargeDetailPtrOutput) ElementType() reflect.Type

func (InstanceChargeDetailPtrOutput) OverdueReclaimTime 

func (o InstanceChargeDetailPtrOutput) OverdueReclaimTime() pulumi.StringPtrOutput

Estimated release time after the instance is suspended due to overdue payment. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'.

func (InstanceChargeDetailPtrOutput) OverdueTime 

func (o InstanceChargeDetailPtrOutput) OverdueTime() pulumi.StringPtrOutput

Suspension time due to overdue payment for the instance. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'.

func (InstanceChargeDetailPtrOutput) Period 

func (o InstanceChargeDetailPtrOutput) Period() pulumi.IntPtrOutput

Purchase duration for subscription instances. When PeriodUnit is set to Monthly, the value range is 1–9. When PeriodUnit is set to Yearly, the value range is 1–3. Only required for subscription instances, that is, when ChargeType is set to PrePaid.

func (InstanceChargeDetailPtrOutput) PeriodUnit 

func (o InstanceChargeDetailPtrOutput) PeriodUnit() pulumi.StringPtrOutput

Lifecycle unit for subscription-based instances, specifying whether to purchase by month or by year. Monthly: (default) monthly subscription Yearly: annual subscription

func (InstanceChargeDetailPtrOutput) ToInstanceChargeDetailPtrOutput 

func (o InstanceChargeDetailPtrOutput) ToInstanceChargeDetailPtrOutput() InstanceChargeDetailPtrOutput

func (InstanceChargeDetailPtrOutput) ToInstanceChargeDetailPtrOutputWithContext 

func (o InstanceChargeDetailPtrOutput) ToInstanceChargeDetailPtrOutputWithContext(ctx context.Context) InstanceChargeDetailPtrOutput

type InstanceConnectionInfo 

type InstanceConnectionInfo struct {
	// Instance endpoint IP address.
	EndpointAddressIp *string `pulumi:"endpointAddressIp"`
	// Instance access point type.
	EndpointType *string `pulumi:"endpointType"`
	// Private network endpoint address for the instance.
	InternalEndpoint *string `pulumi:"internalEndpoint"`
	// Instance access point type.
	NetworkType *string `pulumi:"networkType"`
	// Public access point address of the instance.
	PublicEndpoint *string `pulumi:"publicEndpoint"`
}

type InstanceConnectionInfoArgs 

type InstanceConnectionInfoArgs struct {
	// Instance endpoint IP address.
	EndpointAddressIp pulumi.StringPtrInput `pulumi:"endpointAddressIp"`
	// Instance access point type.
	EndpointType pulumi.StringPtrInput `pulumi:"endpointType"`
	// Private network endpoint address for the instance.
	InternalEndpoint pulumi.StringPtrInput `pulumi:"internalEndpoint"`
	// Instance access point type.
	NetworkType pulumi.StringPtrInput `pulumi:"networkType"`
	// Public access point address of the instance.
	PublicEndpoint pulumi.StringPtrInput `pulumi:"publicEndpoint"`
}

func (InstanceConnectionInfoArgs) ElementType 

func (InstanceConnectionInfoArgs) ElementType() reflect.Type

func (InstanceConnectionInfoArgs) ToInstanceConnectionInfoOutput 

func (i InstanceConnectionInfoArgs) ToInstanceConnectionInfoOutput() InstanceConnectionInfoOutput

func (InstanceConnectionInfoArgs) ToInstanceConnectionInfoOutputWithContext 

func (i InstanceConnectionInfoArgs) ToInstanceConnectionInfoOutputWithContext(ctx context.Context) InstanceConnectionInfoOutput

type InstanceConnectionInfoArray 

type InstanceConnectionInfoArray []InstanceConnectionInfoInput

func (InstanceConnectionInfoArray) ElementType 

func (InstanceConnectionInfoArray) ElementType() reflect.Type

func (InstanceConnectionInfoArray) ToInstanceConnectionInfoArrayOutput 

func (i InstanceConnectionInfoArray) ToInstanceConnectionInfoArrayOutput() InstanceConnectionInfoArrayOutput

func (InstanceConnectionInfoArray) ToInstanceConnectionInfoArrayOutputWithContext 

func (i InstanceConnectionInfoArray) ToInstanceConnectionInfoArrayOutputWithContext(ctx context.Context) InstanceConnectionInfoArrayOutput

type InstanceConnectionInfoArrayInput 

type InstanceConnectionInfoArrayInput interface {
	pulumi.Input

	ToInstanceConnectionInfoArrayOutput() InstanceConnectionInfoArrayOutput
	ToInstanceConnectionInfoArrayOutputWithContext(context.Context) InstanceConnectionInfoArrayOutput
}

InstanceConnectionInfoArrayInput is an input type that accepts InstanceConnectionInfoArray and InstanceConnectionInfoArrayOutput values. You can construct a concrete instance of `InstanceConnectionInfoArrayInput` via: 

InstanceConnectionInfoArray{ InstanceConnectionInfoArgs{...} }

type InstanceConnectionInfoArrayOutput 

type InstanceConnectionInfoArrayOutput struct{ *pulumi.OutputState }

func (InstanceConnectionInfoArrayOutput) ElementType 

func (InstanceConnectionInfoArrayOutput) ElementType() reflect.Type

func (InstanceConnectionInfoArrayOutput) Index 

func (o InstanceConnectionInfoArrayOutput) Index(i pulumi.IntInput) InstanceConnectionInfoOutput

func (InstanceConnectionInfoArrayOutput) ToInstanceConnectionInfoArrayOutput 

func (o InstanceConnectionInfoArrayOutput) ToInstanceConnectionInfoArrayOutput() InstanceConnectionInfoArrayOutput

func (InstanceConnectionInfoArrayOutput) ToInstanceConnectionInfoArrayOutputWithContext 

func (o InstanceConnectionInfoArrayOutput) ToInstanceConnectionInfoArrayOutputWithContext(ctx context.Context) InstanceConnectionInfoArrayOutput

type InstanceConnectionInfoInput 

type InstanceConnectionInfoInput interface {
	pulumi.Input

	ToInstanceConnectionInfoOutput() InstanceConnectionInfoOutput
	ToInstanceConnectionInfoOutputWithContext(context.Context) InstanceConnectionInfoOutput
}

InstanceConnectionInfoInput is an input type that accepts InstanceConnectionInfoArgs and InstanceConnectionInfoOutput values. You can construct a concrete instance of `InstanceConnectionInfoInput` via: 

InstanceConnectionInfoArgs{...}

type InstanceConnectionInfoOutput 

type InstanceConnectionInfoOutput struct{ *pulumi.OutputState }

func (InstanceConnectionInfoOutput) ElementType 

func (InstanceConnectionInfoOutput) ElementType() reflect.Type

func (InstanceConnectionInfoOutput) EndpointAddressIp 

func (o InstanceConnectionInfoOutput) EndpointAddressIp() pulumi.StringPtrOutput

Instance endpoint IP address.

func (InstanceConnectionInfoOutput) EndpointType 

func (o InstanceConnectionInfoOutput) EndpointType() pulumi.StringPtrOutput

Instance access point type.

func (InstanceConnectionInfoOutput) InternalEndpoint 

func (o InstanceConnectionInfoOutput) InternalEndpoint() pulumi.StringPtrOutput

Private network endpoint address for the instance.

func (InstanceConnectionInfoOutput) NetworkType 

func (o InstanceConnectionInfoOutput) NetworkType() pulumi.StringPtrOutput

Instance access point type.

func (InstanceConnectionInfoOutput) PublicEndpoint 

func (o InstanceConnectionInfoOutput) PublicEndpoint() pulumi.StringPtrOutput

Public access point address of the instance.

func (InstanceConnectionInfoOutput) ToInstanceConnectionInfoOutput 

func (o InstanceConnectionInfoOutput) ToInstanceConnectionInfoOutput() InstanceConnectionInfoOutput

func (InstanceConnectionInfoOutput) ToInstanceConnectionInfoOutputWithContext 

func (o InstanceConnectionInfoOutput) ToInstanceConnectionInfoOutputWithContext(ctx context.Context) InstanceConnectionInfoOutput

type InstanceInput 

type InstanceInput interface {
	pulumi.Input

	ToInstanceOutput() InstanceOutput
	ToInstanceOutputWithContext(ctx context.Context) InstanceOutput
}

type InstanceMap 

type InstanceMap map[string]InstanceInput

func (InstanceMap) ElementType 

func (InstanceMap) ElementType() reflect.Type

func (InstanceMap) ToInstanceMapOutput 

func (i InstanceMap) ToInstanceMapOutput() InstanceMapOutput

func (InstanceMap) ToInstanceMapOutputWithContext 

func (i InstanceMap) ToInstanceMapOutputWithContext(ctx context.Context) InstanceMapOutput

type InstanceMapInput 

type InstanceMapInput interface {
	pulumi.Input

	ToInstanceMapOutput() InstanceMapOutput
	ToInstanceMapOutputWithContext(context.Context) InstanceMapOutput
}

InstanceMapInput is an input type that accepts InstanceMap and InstanceMapOutput values. You can construct a concrete instance of `InstanceMapInput` via: 

InstanceMap{ "key": InstanceArgs{...} }

type InstanceMapOutput 

type InstanceMapOutput struct{ *pulumi.OutputState }

func (InstanceMapOutput) ElementType 

func (InstanceMapOutput) ElementType() reflect.Type

func (InstanceMapOutput) MapIndex 

func (o InstanceMapOutput) MapIndex(k pulumi.StringInput) InstanceOutput

func (InstanceMapOutput) ToInstanceMapOutput 

func (o InstanceMapOutput) ToInstanceMapOutput() InstanceMapOutput

func (InstanceMapOutput) ToInstanceMapOutputWithContext 

func (o InstanceMapOutput) ToInstanceMapOutputWithContext(ctx context.Context) InstanceMapOutput

type InstanceOutput 

type InstanceOutput struct{ *pulumi.OutputState }

func (InstanceOutput) AccountId 

func (o InstanceOutput) AccountId() pulumi.StringOutput

Account ID to which the instance belongs.

func (InstanceOutput) AllowListIds 

func (o InstanceOutput) AllowListIds() pulumi.StringArrayOutput

List of allowlist IDs bound to the instance. After binding an allowlist, only IP addresses and address ranges configured in the allowlist can access this instance. If no allowlist is bound to the instance, all IP addresses are denied access to the instance.

func (InstanceOutput) ApplyPrivateDnsToPublic 

func (o InstanceOutput) ApplyPrivateDnsToPublic() pulumi.BoolOutput

Whether private network domain name supports public resolution. true: enabled false: disabled

func (InstanceOutput) AutoScaleQueue 

func (o InstanceOutput) AutoScaleQueue() pulumi.BoolOutput

Whether to automatically create queues when the instance specification changes.

func (InstanceOutput) AvailableQueueNumber 

func (o InstanceOutput) AvailableQueueNumber() pulumi.IntOutput

Remaining number of partitions that can be created.

func (InstanceOutput) ChargeDetail 

func (o InstanceOutput) ChargeDetail() InstanceChargeDetailOutput

Billing method and related billing information for the instance.

func (InstanceOutput) ComputeSpec 

func (o InstanceOutput) ComputeSpec() pulumi.StringOutput

Instance compute specification. You can view the currently available compute specifications in the product specifications list.

func (InstanceOutput) ConnectionInfos 

func (o InstanceOutput) ConnectionInfos() InstanceConnectionInfoArrayOutput

func (InstanceOutput) CreateTime 

func (o InstanceOutput) CreateTime() pulumi.StringOutput

Instance creation time. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'.

func (InstanceOutput) EipId 

func (o InstanceOutput) EipId() pulumi.StringOutput

EIP ID. Specifying EipId enables public access for the instance. EIP provides independent public IP resources, including public IP addresses and outbound bandwidth services. After enabling public access by specifying this parameter, the public address will be bound to your Elastic IP (EIP), and fees will be charged for the EIP resource.

func (InstanceOutput) ElementType 

func (InstanceOutput) ElementType() reflect.Type

func (InstanceOutput) EnableSsl 

func (o InstanceOutput) EnableSsl() pulumi.BoolOutput

Whether to use SSL encryption.

func (InstanceOutput) FileReservedTime 

func (o InstanceOutput) FileReservedTime() pulumi.IntOutput

Message retention period on the RocketMQ Message Queue server. Messages exceeding the retention period will be expired and cleaned up. Unit: hours. Value range: 1–72 hours.

func (InstanceOutput) InstanceDescription 

func (o InstanceOutput) InstanceDescription() pulumi.StringOutput

Brief description of the instance. Length range: 1–128 characters.

func (InstanceOutput) InstanceId 

func (o InstanceOutput) InstanceId() pulumi.StringOutput

Instance ID.

func (InstanceOutput) InstanceName 

func (o InstanceOutput) InstanceName() pulumi.StringOutput

Instance name. Must meet the following requirements: can only contain Chinese characters, letters, numbers, underscores (_), and hyphens (-); cannot start with a number or hyphen (-); length must be 1–128 characters. If no name is specified when creating the instance, the instance ID will be used as the default name.

func (InstanceOutput) InstanceStatus 

func (o InstanceOutput) InstanceStatus() pulumi.StringOutput

Instance status.

func (InstanceOutput) IpVersionType 

func (o InstanceOutput) IpVersionType() pulumi.StringOutput

IP version. Options are IPv4 or DualStack.

func (InstanceOutput) NetworkTypes 

func (o InstanceOutput) NetworkTypes() pulumi.StringOutput

Instance network type, fixed as PrivateNetwork.

func (InstanceOutput) ProductInfo 

func (o InstanceOutput) ProductInfo() InstanceProductInfoOutput

Product configuration information. Note: Only RocketMQ 5.x instances support adjusting the TPS ratio for the instance.

func (InstanceOutput) ProjectName 

func (o InstanceOutput) ProjectName() pulumi.StringOutput

The IAM project to which the newly created instance belongs. If not set, the new instance will be bound to the IAM project named 'default'.

func (InstanceOutput) RegionId 

func (o InstanceOutput) RegionId() pulumi.StringOutput

Region ID where the instance is located.

func (InstanceOutput) SslMode 

func (o InstanceOutput) SslMode() pulumi.StringOutput

The instance's public network connection policy only needs to be set when public access is enabled. Supported settings are: enforcing: When accessing the instance via the public network, SSL authentication is required. SSL authentication enables encrypted data transmission, offering higher security compared to standard public access, but may reduce performance. permissive: When accessing the instance via the public network, SSL authentication is optional. After the instance is created and public access is enabled, the SSL connection policy cannot be modified. To change it, you must disable and re-enable public access for the instance, and set the SSL connection policy again when re-enabling. For details, see Setting Public Access and SSL Authentication Policy.

func (InstanceOutput) StorageSpace 

func (o InstanceOutput) StorageSpace() pulumi.IntOutput

Instance storage space, measured in GiB and must be specified in multiples of 100. The value range depends on the currently selected compute specification.

func (InstanceOutput) SubnetId 

func (o InstanceOutput) SubnetId() pulumi.StringOutput

VPC subnet ID where the instance resides. After the instance is created, the associated VPC and subnet cannot be modified. Please operate carefully when creating the instance. You can call the DescribeVpcs API of the VPC to query the available VPC and subnet list.

func (InstanceOutput) Tags 

func (o InstanceOutput) Tags() InstanceTagArrayOutput

func (InstanceOutput) ToInstanceOutput 

func (o InstanceOutput) ToInstanceOutput() InstanceOutput

func (InstanceOutput) ToInstanceOutputWithContext 

func (o InstanceOutput) ToInstanceOutputWithContext(ctx context.Context) InstanceOutput

func (InstanceOutput) UsedGroupNumber 

func (o InstanceOutput) UsedGroupNumber() pulumi.IntOutput

Number of consumer groups (Group) currently created for the instance.

func (InstanceOutput) UsedQueueNumber 

func (o InstanceOutput) UsedQueueNumber() pulumi.IntOutput

Number of queues already used by the instance.

func (InstanceOutput) UsedStorageSpace 

func (o InstanceOutput) UsedStorageSpace() pulumi.IntOutput

Used storage space for the instance, in GiB.

func (InstanceOutput) UsedTopicNumber 

func (o InstanceOutput) UsedTopicNumber() pulumi.IntOutput

Number of topics created in the current instance.

func (InstanceOutput) Version 

func (o InstanceOutput) Version() pulumi.StringOutput

Supported RocketMQ versions. Currently supported versions include: 4.8: compatible with RocketMQ 4.x series. 5.x: compatible with RocketMQ 5.x series. The 5.x version is currently available by whitelist application. To use it, contact technical support to apply for access.

func (InstanceOutput) VpcId 

func (o InstanceOutput) VpcId() pulumi.StringOutput

VPC ID where the instance resides. After the instance is created, the associated VPC and subnet cannot be modified. Please operate carefully when creating the instance. You can call the DescribeVpcs API of the VPC to query the available VPC and subnet list.

func (InstanceOutput) ZoneId 

func (o InstanceOutput) ZoneId() pulumi.StringOutput

Availability zone ID where the instance is located. RocketMQ Message Queue instances support cross-AZ deployment. When viewing available compute specifications in a specified availability zone, you can specify multiple zones. Separate multiple availability zone IDs with commas (,). You can call DescribeAvailabilityZones to query the list of currently available zones.

type InstanceProductInfo 

type InstanceProductInfo struct {
	// Edit the read/write throttling ratio. The default read/write ratio is 50% each. For example, if set to 40, the sending TPS ratio is 40% and the subscription ratio is 60%. Note: Only RocketMQ 5.x instances support adjusting the TPS ratio for the instance.
	SendReceiveRatio *int `pulumi:"sendReceiveRatio"`
}

type InstanceProductInfoArgs 

type InstanceProductInfoArgs struct {
	// Edit the read/write throttling ratio. The default read/write ratio is 50% each. For example, if set to 40, the sending TPS ratio is 40% and the subscription ratio is 60%. Note: Only RocketMQ 5.x instances support adjusting the TPS ratio for the instance.
	SendReceiveRatio pulumi.IntPtrInput `pulumi:"sendReceiveRatio"`
}

func (InstanceProductInfoArgs) ElementType 

func (InstanceProductInfoArgs) ElementType() reflect.Type

func (InstanceProductInfoArgs) ToInstanceProductInfoOutput 

func (i InstanceProductInfoArgs) ToInstanceProductInfoOutput() InstanceProductInfoOutput

func (InstanceProductInfoArgs) ToInstanceProductInfoOutputWithContext 

func (i InstanceProductInfoArgs) ToInstanceProductInfoOutputWithContext(ctx context.Context) InstanceProductInfoOutput

func (InstanceProductInfoArgs) ToInstanceProductInfoPtrOutput 

func (i InstanceProductInfoArgs) ToInstanceProductInfoPtrOutput() InstanceProductInfoPtrOutput

func (InstanceProductInfoArgs) ToInstanceProductInfoPtrOutputWithContext 

func (i InstanceProductInfoArgs) ToInstanceProductInfoPtrOutputWithContext(ctx context.Context) InstanceProductInfoPtrOutput

type InstanceProductInfoInput 

type InstanceProductInfoInput interface {
	pulumi.Input

	ToInstanceProductInfoOutput() InstanceProductInfoOutput
	ToInstanceProductInfoOutputWithContext(context.Context) InstanceProductInfoOutput
}

InstanceProductInfoInput is an input type that accepts InstanceProductInfoArgs and InstanceProductInfoOutput values. You can construct a concrete instance of `InstanceProductInfoInput` via: 

InstanceProductInfoArgs{...}

type InstanceProductInfoOutput 

type InstanceProductInfoOutput struct{ *pulumi.OutputState }

func (InstanceProductInfoOutput) ElementType 

func (InstanceProductInfoOutput) ElementType() reflect.Type

func (InstanceProductInfoOutput) SendReceiveRatio 

func (o InstanceProductInfoOutput) SendReceiveRatio() pulumi.IntPtrOutput

Edit the read/write throttling ratio. The default read/write ratio is 50% each. For example, if set to 40, the sending TPS ratio is 40% and the subscription ratio is 60%. Note: Only RocketMQ 5.x instances support adjusting the TPS ratio for the instance.

func (InstanceProductInfoOutput) ToInstanceProductInfoOutput 

func (o InstanceProductInfoOutput) ToInstanceProductInfoOutput() InstanceProductInfoOutput

func (InstanceProductInfoOutput) ToInstanceProductInfoOutputWithContext 

func (o InstanceProductInfoOutput) ToInstanceProductInfoOutputWithContext(ctx context.Context) InstanceProductInfoOutput

func (InstanceProductInfoOutput) ToInstanceProductInfoPtrOutput 

func (o InstanceProductInfoOutput) ToInstanceProductInfoPtrOutput() InstanceProductInfoPtrOutput

func (InstanceProductInfoOutput) ToInstanceProductInfoPtrOutputWithContext 

func (o InstanceProductInfoOutput) ToInstanceProductInfoPtrOutputWithContext(ctx context.Context) InstanceProductInfoPtrOutput

type InstanceProductInfoPtrInput 

type InstanceProductInfoPtrInput interface {
	pulumi.Input

	ToInstanceProductInfoPtrOutput() InstanceProductInfoPtrOutput
	ToInstanceProductInfoPtrOutputWithContext(context.Context) InstanceProductInfoPtrOutput
}

InstanceProductInfoPtrInput is an input type that accepts InstanceProductInfoArgs, InstanceProductInfoPtr and InstanceProductInfoPtrOutput values. You can construct a concrete instance of `InstanceProductInfoPtrInput` via: 

        InstanceProductInfoArgs{...}

or:

        nil

func InstanceProductInfoPtr 

func InstanceProductInfoPtr(v *InstanceProductInfoArgs) InstanceProductInfoPtrInput

type InstanceProductInfoPtrOutput 

type InstanceProductInfoPtrOutput struct{ *pulumi.OutputState }

func (InstanceProductInfoPtrOutput) Elem 

func (o InstanceProductInfoPtrOutput) Elem() InstanceProductInfoOutput

func (InstanceProductInfoPtrOutput) ElementType 

func (InstanceProductInfoPtrOutput) ElementType() reflect.Type

func (InstanceProductInfoPtrOutput) SendReceiveRatio 

func (o InstanceProductInfoPtrOutput) SendReceiveRatio() pulumi.IntPtrOutput

Edit the read/write throttling ratio. The default read/write ratio is 50% each. For example, if set to 40, the sending TPS ratio is 40% and the subscription ratio is 60%. Note: Only RocketMQ 5.x instances support adjusting the TPS ratio for the instance.

func (InstanceProductInfoPtrOutput) ToInstanceProductInfoPtrOutput 

func (o InstanceProductInfoPtrOutput) ToInstanceProductInfoPtrOutput() InstanceProductInfoPtrOutput

func (InstanceProductInfoPtrOutput) ToInstanceProductInfoPtrOutputWithContext 

func (o InstanceProductInfoPtrOutput) ToInstanceProductInfoPtrOutputWithContext(ctx context.Context) InstanceProductInfoPtrOutput

type InstanceState 

type InstanceState struct {
	// Account ID to which the instance belongs.
	AccountId pulumi.StringPtrInput
	// List of allowlist IDs bound to the instance. After binding an allowlist, only IP addresses and address ranges configured in the allowlist can access this instance. If no allowlist is bound to the instance, all IP addresses are denied access to the instance.
	AllowListIds pulumi.StringArrayInput
	// Whether private network domain name supports public resolution. true: enabled false: disabled
	ApplyPrivateDnsToPublic pulumi.BoolPtrInput
	// Whether to automatically create queues when the instance specification changes.
	AutoScaleQueue pulumi.BoolPtrInput
	// Remaining number of partitions that can be created.
	AvailableQueueNumber pulumi.IntPtrInput
	// Billing method and related billing information for the instance.
	ChargeDetail InstanceChargeDetailPtrInput
	// Instance compute specification. You can view the currently available compute specifications in the product specifications list.
	ComputeSpec     pulumi.StringPtrInput
	ConnectionInfos InstanceConnectionInfoArrayInput
	// Instance creation time. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'.
	CreateTime pulumi.StringPtrInput
	// EIP ID. Specifying EipId enables public access for the instance. EIP provides independent public IP resources, including public IP addresses and outbound bandwidth services. After enabling public access by specifying this parameter, the public address will be bound to your Elastic IP (EIP), and fees will be charged for the EIP resource.
	EipId pulumi.StringPtrInput
	// Whether to use SSL encryption.
	EnableSsl pulumi.BoolPtrInput
	// Message retention period on the RocketMQ Message Queue server. Messages exceeding the retention period will be expired and cleaned up. Unit: hours. Value range: 1–72 hours.
	FileReservedTime pulumi.IntPtrInput
	// Brief description of the instance. Length range: 1–128 characters.
	InstanceDescription pulumi.StringPtrInput
	// Instance ID.
	InstanceId pulumi.StringPtrInput
	// Instance name. Must meet the following requirements: can only contain Chinese characters, letters, numbers, underscores (_), and hyphens (-); cannot start with a number or hyphen (-); length must be 1–128 characters. If no name is specified when creating the instance, the instance ID will be used as the default name.
	InstanceName pulumi.StringPtrInput
	// Instance status.
	InstanceStatus pulumi.StringPtrInput
	// IP version. Options are IPv4 or DualStack.
	IpVersionType pulumi.StringPtrInput
	// Instance network type, fixed as PrivateNetwork.
	NetworkTypes pulumi.StringPtrInput
	// Product configuration information. Note: Only RocketMQ 5.x instances support adjusting the TPS ratio for the instance.
	ProductInfo InstanceProductInfoPtrInput
	// The IAM project to which the newly created instance belongs. If not set, the new instance will be bound to the IAM project named 'default'.
	ProjectName pulumi.StringPtrInput
	// Region ID where the instance is located.
	RegionId pulumi.StringPtrInput
	// The instance's public network connection policy only needs to be set when public access is enabled. Supported settings are: enforcing: When accessing the instance via the public network, SSL authentication is required. SSL authentication enables encrypted data transmission, offering higher security compared to standard public access, but may reduce performance. permissive: When accessing the instance via the public network, SSL authentication is optional. After the instance is created and public access is enabled, the SSL connection policy cannot be modified. To change it, you must disable and re-enable public access for the instance, and set the SSL connection policy again when re-enabling. For details, see Setting Public Access and SSL Authentication Policy.
	SslMode pulumi.StringPtrInput
	// Instance storage space, measured in GiB and must be specified in multiples of 100. The value range depends on the currently selected compute specification.
	StorageSpace pulumi.IntPtrInput
	// VPC subnet ID where the instance resides. After the instance is created, the associated VPC and subnet cannot be modified. Please operate carefully when creating the instance. You can call the DescribeVpcs API of the VPC to query the available VPC and subnet list.
	SubnetId pulumi.StringPtrInput
	Tags     InstanceTagArrayInput
	// Number of consumer groups (Group) currently created for the instance.
	UsedGroupNumber pulumi.IntPtrInput
	// Number of queues already used by the instance.
	UsedQueueNumber pulumi.IntPtrInput
	// Used storage space for the instance, in GiB.
	UsedStorageSpace pulumi.IntPtrInput
	// Number of topics created in the current instance.
	UsedTopicNumber pulumi.IntPtrInput
	// Supported RocketMQ versions. Currently supported versions include: 4.8: compatible with RocketMQ 4.x series. 5.x: compatible with RocketMQ 5.x series. The 5.x version is currently available by whitelist application. To use it, contact technical support to apply for access.
	Version pulumi.StringPtrInput
	// VPC ID where the instance resides. After the instance is created, the associated VPC and subnet cannot be modified. Please operate carefully when creating the instance. You can call the DescribeVpcs API of the VPC to query the available VPC and subnet list.
	VpcId pulumi.StringPtrInput
	// Availability zone ID where the instance is located. RocketMQ Message Queue instances support cross-AZ deployment. When viewing available compute specifications in a specified availability zone, you can specify multiple zones. Separate multiple availability zone IDs with commas (,). You can call DescribeAvailabilityZones to query the list of currently available zones.
	ZoneId pulumi.StringPtrInput
}

func (InstanceState) ElementType 

func (InstanceState) ElementType() reflect.Type

type InstanceTag 

type InstanceTag struct {
	// Tag key.
	Key *string `pulumi:"key"`
	// Tag value.
	Value *string `pulumi:"value"`
}

type InstanceTagArgs 

type InstanceTagArgs struct {
	// Tag key.
	Key pulumi.StringPtrInput `pulumi:"key"`
	// Tag value.
	Value pulumi.StringPtrInput `pulumi:"value"`
}

func (InstanceTagArgs) ElementType 

func (InstanceTagArgs) ElementType() reflect.Type

func (InstanceTagArgs) ToInstanceTagOutput 

func (i InstanceTagArgs) ToInstanceTagOutput() InstanceTagOutput

func (InstanceTagArgs) ToInstanceTagOutputWithContext 

func (i InstanceTagArgs) ToInstanceTagOutputWithContext(ctx context.Context) InstanceTagOutput

type InstanceTagArray 

type InstanceTagArray []InstanceTagInput

func (InstanceTagArray) ElementType 

func (InstanceTagArray) ElementType() reflect.Type

func (InstanceTagArray) ToInstanceTagArrayOutput 

func (i InstanceTagArray) ToInstanceTagArrayOutput() InstanceTagArrayOutput

func (InstanceTagArray) ToInstanceTagArrayOutputWithContext 

func (i InstanceTagArray) ToInstanceTagArrayOutputWithContext(ctx context.Context) InstanceTagArrayOutput

type InstanceTagArrayInput 

type InstanceTagArrayInput interface {
	pulumi.Input

	ToInstanceTagArrayOutput() InstanceTagArrayOutput
	ToInstanceTagArrayOutputWithContext(context.Context) InstanceTagArrayOutput
}

InstanceTagArrayInput is an input type that accepts InstanceTagArray and InstanceTagArrayOutput values. You can construct a concrete instance of `InstanceTagArrayInput` via: 

InstanceTagArray{ InstanceTagArgs{...} }

type InstanceTagArrayOutput 

type InstanceTagArrayOutput struct{ *pulumi.OutputState }

func (InstanceTagArrayOutput) ElementType 

func (InstanceTagArrayOutput) ElementType() reflect.Type

func (InstanceTagArrayOutput) Index 

func (o InstanceTagArrayOutput) Index(i pulumi.IntInput) InstanceTagOutput

func (InstanceTagArrayOutput) ToInstanceTagArrayOutput 

func (o InstanceTagArrayOutput) ToInstanceTagArrayOutput() InstanceTagArrayOutput

func (InstanceTagArrayOutput) ToInstanceTagArrayOutputWithContext 

func (o InstanceTagArrayOutput) ToInstanceTagArrayOutputWithContext(ctx context.Context) InstanceTagArrayOutput

type InstanceTagInput 

type InstanceTagInput interface {
	pulumi.Input

	ToInstanceTagOutput() InstanceTagOutput
	ToInstanceTagOutputWithContext(context.Context) InstanceTagOutput
}

InstanceTagInput is an input type that accepts InstanceTagArgs and InstanceTagOutput values. You can construct a concrete instance of `InstanceTagInput` via: 

InstanceTagArgs{...}

type InstanceTagOutput 

type InstanceTagOutput struct{ *pulumi.OutputState }

func (InstanceTagOutput) ElementType 

func (InstanceTagOutput) ElementType() reflect.Type

func (InstanceTagOutput) Key 

func (o InstanceTagOutput) Key() pulumi.StringPtrOutput

Tag key.

func (InstanceTagOutput) ToInstanceTagOutput 

func (o InstanceTagOutput) ToInstanceTagOutput() InstanceTagOutput

func (InstanceTagOutput) ToInstanceTagOutputWithContext 

func (o InstanceTagOutput) ToInstanceTagOutputWithContext(ctx context.Context) InstanceTagOutput

func (InstanceTagOutput) Value 

func (o InstanceTagOutput) Value() pulumi.StringPtrOutput

Tag value.

type LookupAllowListArgs added in v0.0.24 

type LookupAllowListArgs struct {
	// Uniquely identifies the resource.
	Id string `pulumi:"id"`
}

A collection of arguments for invoking getAllowList.

type LookupAllowListOutputArgs added in v0.0.24 

type LookupAllowListOutputArgs struct {
	// Uniquely identifies the resource.
	Id pulumi.StringInput `pulumi:"id"`
}

A collection of arguments for invoking getAllowList.

func (LookupAllowListOutputArgs) ElementType added in v0.0.24 

func (LookupAllowListOutputArgs) ElementType() reflect.Type

type LookupAllowListResult added in v0.0.24 

type LookupAllowListResult struct {
	// IP allowlist. Separate multiple IP addresses with commas (,) and do not repeat addresses
	AllowList string `pulumi:"allowList"`
	// Allowlist Category
	AllowListCategory string `pulumi:"allowListCategory"`
	// Allowlist Description
	AllowListDesc string `pulumi:"allowListDesc"`
	// Allowlist ID
	AllowListId string `pulumi:"allowListId"`
	// Total number of IP addresses (or address ranges) in the allowlist
	AllowListIpNum int `pulumi:"allowListIpNum"`
	// Allowlist Name
	AllowListName string `pulumi:"allowListName"`
	// IP address type in the allowlist. Only IPv4 is supported
	AllowListType string `pulumi:"allowListType"`
	// Total number of instances bound to the allowlist
	AssociatedInstanceNum int `pulumi:"associatedInstanceNum"`
	// Bound Instance List
	AssociatedInstances []GetAllowListAssociatedInstance `pulumi:"associatedInstances"`
	// Uniquely identifies the resource.
	Id string `pulumi:"id"`
	// Instance ID
	InstanceId string `pulumi:"instanceId"`
}

A collection of values returned by getAllowList.

func LookupAllowList added in v0.0.24 

func LookupAllowList(ctx *pulumi.Context, args *LookupAllowListArgs, opts ...pulumi.InvokeOption) (*LookupAllowListResult, error)

Data Source schema for Volcengine::RocketMQ::AllowList

type LookupAllowListResultOutput added in v0.0.24 

type LookupAllowListResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getAllowList.

func LookupAllowListOutput added in v0.0.24 

func LookupAllowListOutput(ctx *pulumi.Context, args LookupAllowListOutputArgs, opts ...pulumi.InvokeOption) LookupAllowListResultOutput

func (LookupAllowListResultOutput) AllowList added in v0.0.24 

func (o LookupAllowListResultOutput) AllowList() pulumi.StringOutput

IP allowlist. Separate multiple IP addresses with commas (,) and do not repeat addresses

func (LookupAllowListResultOutput) AllowListCategory added in v0.0.24 

func (o LookupAllowListResultOutput) AllowListCategory() pulumi.StringOutput

Allowlist Category

func (LookupAllowListResultOutput) AllowListDesc added in v0.0.24 

func (o LookupAllowListResultOutput) AllowListDesc() pulumi.StringOutput

Allowlist Description

func (LookupAllowListResultOutput) AllowListId added in v0.0.24 

func (o LookupAllowListResultOutput) AllowListId() pulumi.StringOutput

Allowlist ID

func (LookupAllowListResultOutput) AllowListIpNum added in v0.0.24 

func (o LookupAllowListResultOutput) AllowListIpNum() pulumi.IntOutput

Total number of IP addresses (or address ranges) in the allowlist

func (LookupAllowListResultOutput) AllowListName added in v0.0.24 

func (o LookupAllowListResultOutput) AllowListName() pulumi.StringOutput

Allowlist Name

func (LookupAllowListResultOutput) AllowListType added in v0.0.24 

func (o LookupAllowListResultOutput) AllowListType() pulumi.StringOutput

IP address type in the allowlist. Only IPv4 is supported

func (LookupAllowListResultOutput) AssociatedInstanceNum added in v0.0.24 

func (o LookupAllowListResultOutput) AssociatedInstanceNum() pulumi.IntOutput

Total number of instances bound to the allowlist

func (LookupAllowListResultOutput) AssociatedInstances added in v0.0.24 

func (o LookupAllowListResultOutput) AssociatedInstances() GetAllowListAssociatedInstanceArrayOutput

Bound Instance List

func (LookupAllowListResultOutput) ElementType added in v0.0.24 

func (LookupAllowListResultOutput) ElementType() reflect.Type

func (LookupAllowListResultOutput) Id added in v0.0.24 

func (o LookupAllowListResultOutput) Id() pulumi.StringOutput

Uniquely identifies the resource.

func (LookupAllowListResultOutput) InstanceId added in v0.0.24 

func (o LookupAllowListResultOutput) InstanceId() pulumi.StringOutput

Instance ID

func (LookupAllowListResultOutput) ToLookupAllowListResultOutput added in v0.0.24 

func (o LookupAllowListResultOutput) ToLookupAllowListResultOutput() LookupAllowListResultOutput

func (LookupAllowListResultOutput) ToLookupAllowListResultOutputWithContext added in v0.0.24 

func (o LookupAllowListResultOutput) ToLookupAllowListResultOutputWithContext(ctx context.Context) LookupAllowListResultOutput

type LookupGroupArgs added in v0.0.22 

type LookupGroupArgs struct {
	// Uniquely identifies the resource.
	Id string `pulumi:"id"`
}

A collection of arguments for invoking getGroup.

type LookupGroupOutputArgs added in v0.0.22 

type LookupGroupOutputArgs struct {
	// Uniquely identifies the resource.
	Id pulumi.StringInput `pulumi:"id"`
}

A collection of arguments for invoking getGroup.

func (LookupGroupOutputArgs) ElementType added in v0.0.22 

func (LookupGroupOutputArgs) ElementType() reflect.Type

type LookupGroupResult added in v0.0.22 

type LookupGroupResult struct {
	// Whether the subscription relationships of consumer instance groups within the Group are consistent. true: Consistent, false: Inconsistent.
	ConsumeMessageOrderly bool `pulumi:"consumeMessageOrderly"`
	// Consumer client list.
	ConsumedClients []GetGroupConsumedClient `pulumi:"consumedClients"`
	// Topic information subscribed by consumer instance groups under this Group.
	ConsumedTopics []GetGroupConsumedTopic `pulumi:"consumedTopics"`
	// Group creation time.
	CreatedTime string `pulumi:"createdTime"`
	// Brief description of the Group.
	Description string `pulumi:"description"`
	// Group ID. Length must be between 7 and 120 characters and can only contain letters, numbers, hyphens (-), and underscores (*). It is recommended to start with GID  - or GID*. The ID cannot be changed after the Group is created, so set it carefully. For RocketMQ instances created on or before June 5, 2023, the Group name cannot exceed 93 characters.
	GroupId string `pulumi:"groupId"`
	// Group protocol identifier, used to indicate the production and consumption protocol type for this Group. Can be set to TCP.
	GroupType string `pulumi:"groupType"`
	// Uniquely identifies the resource.
	Id string `pulumi:"id"`
	// Instance ID.
	InstanceId string `pulumi:"instanceId"`
	// Whether the subscription relationships of consumer instance groups within the Group are consistent. true: Consistent, false: Inconsistent.
	IsSubSame bool `pulumi:"isSubSame"`
	// Whether consumption is sequential.
	LastUpdateTimestamp string `pulumi:"lastUpdateTimestamp"`
	// Message latency. The difference between the production time of the earliest unconsumed message in the consumer instance group and the current time, measured in milliseconds.
	MessageDelayTime string `pulumi:"messageDelayTime"`
	// Message consumption mode. The default is clustering mode. Do not configure both clustering and broadcasting modes under the same Group. Clustering: Clustering consumption mode, Broadcasting: Broadcasting consumption mode.
	MessageModel string `pulumi:"messageModel"`
	// Maximum number of consumption retries.
	RetryMaxTimes int `pulumi:"retryMaxTimes"`
	// RocketMQ version.
	RocketmqVersion string `pulumi:"rocketmqVersion"`
	// Service status. Creating: Being created, Running: Running, Deleting: Being deleted, Abnormal: Abnormal, Updating: Being updated.
	ServiceStatus string `pulumi:"serviceStatus"`
	// Consumer group status. Online: Consuming, Offline: Not consuming.
	Status string `pulumi:"status"`
	// Total TPS of consumer instance groups under this Group, measured in messages per second.
	TotalConsumedRate string `pulumi:"totalConsumedRate"`
	// Total number of unconsumed messages in the consumer instance group. The message backlog shown here is the total backlog before Tag filtering, including messages for all Tags under the Topic.
	TotalDiff int `pulumi:"totalDiff"`
}

A collection of values returned by getGroup.

func LookupGroup added in v0.0.22 

func LookupGroup(ctx *pulumi.Context, args *LookupGroupArgs, opts ...pulumi.InvokeOption) (*LookupGroupResult, error)

Data Source schema for Volcengine::RocketMQ::Group

type LookupGroupResultOutput added in v0.0.22 

type LookupGroupResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getGroup.

func LookupGroupOutput added in v0.0.22 

func LookupGroupOutput(ctx *pulumi.Context, args LookupGroupOutputArgs, opts ...pulumi.InvokeOption) LookupGroupResultOutput

func (LookupGroupResultOutput) ConsumeMessageOrderly added in v0.0.22 

func (o LookupGroupResultOutput) ConsumeMessageOrderly() pulumi.BoolOutput

Whether the subscription relationships of consumer instance groups within the Group are consistent. true: Consistent, false: Inconsistent.

func (LookupGroupResultOutput) ConsumedClients added in v0.0.22 

func (o LookupGroupResultOutput) ConsumedClients() GetGroupConsumedClientArrayOutput

Consumer client list.

func (LookupGroupResultOutput) ConsumedTopics added in v0.0.22 

func (o LookupGroupResultOutput) ConsumedTopics() GetGroupConsumedTopicArrayOutput

Topic information subscribed by consumer instance groups under this Group.

func (LookupGroupResultOutput) CreatedTime added in v0.0.22 

func (o LookupGroupResultOutput) CreatedTime() pulumi.StringOutput

Group creation time.

func (LookupGroupResultOutput) Description added in v0.0.22 

func (o LookupGroupResultOutput) Description() pulumi.StringOutput

Brief description of the Group.

func (LookupGroupResultOutput) ElementType added in v0.0.22 

func (LookupGroupResultOutput) ElementType() reflect.Type

func (LookupGroupResultOutput) GroupId added in v0.0.22 

func (o LookupGroupResultOutput) GroupId() pulumi.StringOutput

Group ID. Length must be between 7 and 120 characters and can only contain letters, numbers, hyphens (-), and underscores (*). It is recommended to start with GID - or GID*. The ID cannot be changed after the Group is created, so set it carefully. For RocketMQ instances created on or before June 5, 2023, the Group name cannot exceed 93 characters.

func (LookupGroupResultOutput) GroupType added in v0.0.22 

func (o LookupGroupResultOutput) GroupType() pulumi.StringOutput

Group protocol identifier, used to indicate the production and consumption protocol type for this Group. Can be set to TCP.

func (LookupGroupResultOutput) Id added in v0.0.22 

func (o LookupGroupResultOutput) Id() pulumi.StringOutput

Uniquely identifies the resource.

func (LookupGroupResultOutput) InstanceId added in v0.0.22 

func (o LookupGroupResultOutput) InstanceId() pulumi.StringOutput

Instance ID.

func (LookupGroupResultOutput) IsSubSame added in v0.0.22 

func (o LookupGroupResultOutput) IsSubSame() pulumi.BoolOutput

Whether the subscription relationships of consumer instance groups within the Group are consistent. true: Consistent, false: Inconsistent.

func (LookupGroupResultOutput) LastUpdateTimestamp added in v0.0.22 

func (o LookupGroupResultOutput) LastUpdateTimestamp() pulumi.StringOutput

Whether consumption is sequential.

func (LookupGroupResultOutput) MessageDelayTime added in v0.0.22 

func (o LookupGroupResultOutput) MessageDelayTime() pulumi.StringOutput

Message latency. The difference between the production time of the earliest unconsumed message in the consumer instance group and the current time, measured in milliseconds.

func (LookupGroupResultOutput) MessageModel added in v0.0.22 

func (o LookupGroupResultOutput) MessageModel() pulumi.StringOutput

Message consumption mode. The default is clustering mode. Do not configure both clustering and broadcasting modes under the same Group. Clustering: Clustering consumption mode, Broadcasting: Broadcasting consumption mode.

func (LookupGroupResultOutput) RetryMaxTimes added in v0.0.22 

func (o LookupGroupResultOutput) RetryMaxTimes() pulumi.IntOutput

Maximum number of consumption retries.

func (LookupGroupResultOutput) RocketmqVersion added in v0.0.22 

func (o LookupGroupResultOutput) RocketmqVersion() pulumi.StringOutput

RocketMQ version.

func (LookupGroupResultOutput) ServiceStatus added in v0.0.22 

func (o LookupGroupResultOutput) ServiceStatus() pulumi.StringOutput

Service status. Creating: Being created, Running: Running, Deleting: Being deleted, Abnormal: Abnormal, Updating: Being updated.

func (LookupGroupResultOutput) Status added in v0.0.22 

func (o LookupGroupResultOutput) Status() pulumi.StringOutput

Consumer group status. Online: Consuming, Offline: Not consuming.

func (LookupGroupResultOutput) ToLookupGroupResultOutput added in v0.0.22 

func (o LookupGroupResultOutput) ToLookupGroupResultOutput() LookupGroupResultOutput

func (LookupGroupResultOutput) ToLookupGroupResultOutputWithContext added in v0.0.22 

func (o LookupGroupResultOutput) ToLookupGroupResultOutputWithContext(ctx context.Context) LookupGroupResultOutput

func (LookupGroupResultOutput) TotalConsumedRate added in v0.0.22 

func (o LookupGroupResultOutput) TotalConsumedRate() pulumi.StringOutput

Total TPS of consumer instance groups under this Group, measured in messages per second.

func (LookupGroupResultOutput) TotalDiff added in v0.0.22 

func (o LookupGroupResultOutput) TotalDiff() pulumi.IntOutput

Total number of unconsumed messages in the consumer instance group. The message backlog shown here is the total backlog before Tag filtering, including messages for all Tags under the Topic.

type LookupInstanceArgs 

type LookupInstanceArgs struct {
	// Uniquely identifies the resource.
	Id string `pulumi:"id"`
}

A collection of arguments for invoking getInstance.

type LookupInstanceOutputArgs 

type LookupInstanceOutputArgs struct {
	// Uniquely identifies the resource.
	Id pulumi.StringInput `pulumi:"id"`
}

A collection of arguments for invoking getInstance.

func (LookupInstanceOutputArgs) ElementType 

func (LookupInstanceOutputArgs) ElementType() reflect.Type

type LookupInstanceResult 

type LookupInstanceResult struct {
	// Account ID to which the instance belongs.
	AccountId string `pulumi:"accountId"`
	// List of allowlist IDs bound to the instance. After binding an allowlist, only IP addresses and address ranges configured in the allowlist can access this instance. If no allowlist is bound to the instance, all IP addresses are denied access to the instance.
	AllowListIds []string `pulumi:"allowListIds"`
	// Whether private network domain name supports public resolution. true: enabled false: disabled
	ApplyPrivateDnsToPublic bool `pulumi:"applyPrivateDnsToPublic"`
	// Whether to automatically create queues when the instance specification changes.
	AutoScaleQueue bool `pulumi:"autoScaleQueue"`
	// Remaining number of partitions that can be created.
	AvailableQueueNumber int `pulumi:"availableQueueNumber"`
	// Billing method and related billing information for the instance.
	ChargeDetail GetInstanceChargeDetail `pulumi:"chargeDetail"`
	// Instance compute specification. You can view the currently available compute specifications in the product specifications list.
	ComputeSpec string `pulumi:"computeSpec"`
	// Instance connection information.
	ConnectionInfos []GetInstanceConnectionInfo `pulumi:"connectionInfos"`
	// Instance creation time. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'.
	CreateTime string `pulumi:"createTime"`
	// EIP ID. Specifying EipId enables public access for the instance. EIP provides independent public IP resources, including public IP addresses and outbound bandwidth services. After enabling public access by specifying this parameter, the public address will be bound to your Elastic IP (EIP), and fees will be charged for the EIP resource.
	EipId string `pulumi:"eipId"`
	// Whether to use SSL encryption.
	EnableSsl bool `pulumi:"enableSsl"`
	// Message retention period on the RocketMQ Message Queue server. Messages exceeding the retention period will be expired and cleaned up. Unit: hours. Value range: 1–72 hours.
	FileReservedTime int `pulumi:"fileReservedTime"`
	// Uniquely identifies the resource.
	Id string `pulumi:"id"`
	// Brief description of the instance. Length range: 1–128 characters.
	InstanceDescription string `pulumi:"instanceDescription"`
	// Instance ID.
	InstanceId string `pulumi:"instanceId"`
	// Instance name. Must meet the following requirements: can only contain Chinese characters, letters, numbers, underscores (_), and hyphens (-); cannot start with a number or hyphen (-); length must be 1–128 characters. If no name is specified when creating the instance, the instance ID will be used as the default name.
	InstanceName string `pulumi:"instanceName"`
	// Instance status.
	InstanceStatus string `pulumi:"instanceStatus"`
	// IP version. Options are IPv4 or DualStack.
	IpVersionType string `pulumi:"ipVersionType"`
	// Instance network type, fixed as PrivateNetwork.
	NetworkTypes string `pulumi:"networkTypes"`
	// Product configuration information. Note: Only RocketMQ 5.x instances support adjusting the TPS ratio for the instance.
	ProductInfo GetInstanceProductInfo `pulumi:"productInfo"`
	// The IAM project to which the newly created instance belongs. If not set, the new instance will be bound to the IAM project named 'default'.
	ProjectName string `pulumi:"projectName"`
	// Region ID where the instance is located.
	RegionId string `pulumi:"regionId"`
	// The instance's public network connection policy only needs to be set when public access is enabled. Supported settings are: enforcing: When accessing the instance via the public network, SSL authentication is required. SSL authentication enables encrypted data transmission, offering higher security compared to standard public access, but may reduce performance. permissive: When accessing the instance via the public network, SSL authentication is optional. After the instance is created and public access is enabled, the SSL connection policy cannot be modified. To change it, you must disable and re-enable public access for the instance, and set the SSL connection policy again when re-enabling. For details, see Setting Public Access and SSL Authentication Policy.
	SslMode string `pulumi:"sslMode"`
	// Instance storage space, measured in GiB and must be specified in multiples of 100. The value range depends on the currently selected compute specification.
	StorageSpace int `pulumi:"storageSpace"`
	// VPC subnet ID where the instance resides. After the instance is created, the associated VPC and subnet cannot be modified. Please operate carefully when creating the instance. You can call the DescribeVpcs API of the VPC to query the available VPC and subnet list.
	SubnetId string `pulumi:"subnetId"`
	// Cloud resource tags. You can categorize instances by tags for easier search and resource aggregation. For details, see Tag Overview.
	Tags []GetInstanceTag `pulumi:"tags"`
	// Number of consumer groups (Group) currently created for the instance.
	UsedGroupNumber int `pulumi:"usedGroupNumber"`
	// Number of queues already used by the instance.
	UsedQueueNumber int `pulumi:"usedQueueNumber"`
	// Used storage space for the instance, in GiB.
	UsedStorageSpace int `pulumi:"usedStorageSpace"`
	// Number of topics created in the current instance.
	UsedTopicNumber int `pulumi:"usedTopicNumber"`
	// Supported RocketMQ versions. Currently supported versions include: 4.8: compatible with RocketMQ 4.x series. 5.x: compatible with RocketMQ 5.x series. The 5.x version is currently available by whitelist application. To use it, contact technical support to apply for access.
	Version string `pulumi:"version"`
	// VPC ID where the instance resides. After the instance is created, the associated VPC and subnet cannot be modified. Please operate carefully when creating the instance. You can call the DescribeVpcs API of the VPC to query the available VPC and subnet list.
	VpcId string `pulumi:"vpcId"`
	// Availability zone ID where the instance is located. RocketMQ Message Queue instances support cross-AZ deployment. When viewing available compute specifications in a specified availability zone, you can specify multiple zones. Separate multiple availability zone IDs with commas (,). You can call DescribeAvailabilityZones to query the list of currently available zones.
	ZoneId string `pulumi:"zoneId"`
}

A collection of values returned by getInstance.

func LookupInstance 

func LookupInstance(ctx *pulumi.Context, args *LookupInstanceArgs, opts ...pulumi.InvokeOption) (*LookupInstanceResult, error)

Data Source schema for Volcengine::RocketMQ::Instance

type LookupInstanceResultOutput 

type LookupInstanceResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getInstance.

func LookupInstanceOutput 

func LookupInstanceOutput(ctx *pulumi.Context, args LookupInstanceOutputArgs, opts ...pulumi.InvokeOption) LookupInstanceResultOutput

func (LookupInstanceResultOutput) AccountId 

func (o LookupInstanceResultOutput) AccountId() pulumi.StringOutput

Account ID to which the instance belongs.

func (LookupInstanceResultOutput) AllowListIds 

func (o LookupInstanceResultOutput) AllowListIds() pulumi.StringArrayOutput

List of allowlist IDs bound to the instance. After binding an allowlist, only IP addresses and address ranges configured in the allowlist can access this instance. If no allowlist is bound to the instance, all IP addresses are denied access to the instance.

func (LookupInstanceResultOutput) ApplyPrivateDnsToPublic 

func (o LookupInstanceResultOutput) ApplyPrivateDnsToPublic() pulumi.BoolOutput

Whether private network domain name supports public resolution. true: enabled false: disabled

func (LookupInstanceResultOutput) AutoScaleQueue 

func (o LookupInstanceResultOutput) AutoScaleQueue() pulumi.BoolOutput

Whether to automatically create queues when the instance specification changes.

func (LookupInstanceResultOutput) AvailableQueueNumber 

func (o LookupInstanceResultOutput) AvailableQueueNumber() pulumi.IntOutput

Remaining number of partitions that can be created.

func (LookupInstanceResultOutput) ChargeDetail 

func (o LookupInstanceResultOutput) ChargeDetail() GetInstanceChargeDetailOutput

Billing method and related billing information for the instance.

func (LookupInstanceResultOutput) ComputeSpec 

func (o LookupInstanceResultOutput) ComputeSpec() pulumi.StringOutput

Instance compute specification. You can view the currently available compute specifications in the product specifications list.

func (LookupInstanceResultOutput) ConnectionInfos 

func (o LookupInstanceResultOutput) ConnectionInfos() GetInstanceConnectionInfoArrayOutput

Instance connection information.

func (LookupInstanceResultOutput) CreateTime 

func (o LookupInstanceResultOutput) CreateTime() pulumi.StringOutput

Instance creation time. The time format is YYYY-MM-DD'T'HH:MM:SS'Z'.

func (LookupInstanceResultOutput) EipId 

func (o LookupInstanceResultOutput) EipId() pulumi.StringOutput

EIP ID. Specifying EipId enables public access for the instance. EIP provides independent public IP resources, including public IP addresses and outbound bandwidth services. After enabling public access by specifying this parameter, the public address will be bound to your Elastic IP (EIP), and fees will be charged for the EIP resource.

func (LookupInstanceResultOutput) ElementType 

func (LookupInstanceResultOutput) ElementType() reflect.Type

func (LookupInstanceResultOutput) EnableSsl 

func (o LookupInstanceResultOutput) EnableSsl() pulumi.BoolOutput

Whether to use SSL encryption.

func (LookupInstanceResultOutput) FileReservedTime 

func (o LookupInstanceResultOutput) FileReservedTime() pulumi.IntOutput

Message retention period on the RocketMQ Message Queue server. Messages exceeding the retention period will be expired and cleaned up. Unit: hours. Value range: 1–72 hours.

func (LookupInstanceResultOutput) Id 

func (o LookupInstanceResultOutput) Id() pulumi.StringOutput

Uniquely identifies the resource.

func (LookupInstanceResultOutput) InstanceDescription 

func (o LookupInstanceResultOutput) InstanceDescription() pulumi.StringOutput

Brief description of the instance. Length range: 1–128 characters.

func (LookupInstanceResultOutput) InstanceId 

func (o LookupInstanceResultOutput) InstanceId() pulumi.StringOutput

Instance ID.

func (LookupInstanceResultOutput) InstanceName 

func (o LookupInstanceResultOutput) InstanceName() pulumi.StringOutput

Instance name. Must meet the following requirements: can only contain Chinese characters, letters, numbers, underscores (_), and hyphens (-); cannot start with a number or hyphen (-); length must be 1–128 characters. If no name is specified when creating the instance, the instance ID will be used as the default name.

func (LookupInstanceResultOutput) InstanceStatus 

func (o LookupInstanceResultOutput) InstanceStatus() pulumi.StringOutput

Instance status.

func (LookupInstanceResultOutput) IpVersionType 

func (o LookupInstanceResultOutput) IpVersionType() pulumi.StringOutput

IP version. Options are IPv4 or DualStack.

func (LookupInstanceResultOutput) NetworkTypes 

func (o LookupInstanceResultOutput) NetworkTypes() pulumi.StringOutput

Instance network type, fixed as PrivateNetwork.

func (LookupInstanceResultOutput) ProductInfo 

func (o LookupInstanceResultOutput) ProductInfo() GetInstanceProductInfoOutput

Product configuration information. Note: Only RocketMQ 5.x instances support adjusting the TPS ratio for the instance.

func (LookupInstanceResultOutput) ProjectName 

func (o LookupInstanceResultOutput) ProjectName() pulumi.StringOutput

The IAM project to which the newly created instance belongs. If not set, the new instance will be bound to the IAM project named 'default'.

func (LookupInstanceResultOutput) RegionId 

func (o LookupInstanceResultOutput) RegionId() pulumi.StringOutput

Region ID where the instance is located.

func (LookupInstanceResultOutput) SslMode 

func (o LookupInstanceResultOutput) SslMode() pulumi.StringOutput

The instance's public network connection policy only needs to be set when public access is enabled. Supported settings are: enforcing: When accessing the instance via the public network, SSL authentication is required. SSL authentication enables encrypted data transmission, offering higher security compared to standard public access, but may reduce performance. permissive: When accessing the instance via the public network, SSL authentication is optional. After the instance is created and public access is enabled, the SSL connection policy cannot be modified. To change it, you must disable and re-enable public access for the instance, and set the SSL connection policy again when re-enabling. For details, see Setting Public Access and SSL Authentication Policy.

func (LookupInstanceResultOutput) StorageSpace 

func (o LookupInstanceResultOutput) StorageSpace() pulumi.IntOutput

Instance storage space, measured in GiB and must be specified in multiples of 100. The value range depends on the currently selected compute specification.

func (LookupInstanceResultOutput) SubnetId 

func (o LookupInstanceResultOutput) SubnetId() pulumi.StringOutput

VPC subnet ID where the instance resides. After the instance is created, the associated VPC and subnet cannot be modified. Please operate carefully when creating the instance. You can call the DescribeVpcs API of the VPC to query the available VPC and subnet list.

func (LookupInstanceResultOutput) Tags 

func (o LookupInstanceResultOutput) Tags() GetInstanceTagArrayOutput

Cloud resource tags. You can categorize instances by tags for easier search and resource aggregation. For details, see Tag Overview.

func (LookupInstanceResultOutput) ToLookupInstanceResultOutput 

func (o LookupInstanceResultOutput) ToLookupInstanceResultOutput() LookupInstanceResultOutput

func (LookupInstanceResultOutput) ToLookupInstanceResultOutputWithContext 

func (o LookupInstanceResultOutput) ToLookupInstanceResultOutputWithContext(ctx context.Context) LookupInstanceResultOutput

func (LookupInstanceResultOutput) UsedGroupNumber 

func (o LookupInstanceResultOutput) UsedGroupNumber() pulumi.IntOutput

Number of consumer groups (Group) currently created for the instance.

func (LookupInstanceResultOutput) UsedQueueNumber 

func (o LookupInstanceResultOutput) UsedQueueNumber() pulumi.IntOutput

Number of queues already used by the instance.

func (LookupInstanceResultOutput) UsedStorageSpace 

func (o LookupInstanceResultOutput) UsedStorageSpace() pulumi.IntOutput

Used storage space for the instance, in GiB.

func (LookupInstanceResultOutput) UsedTopicNumber 

func (o LookupInstanceResultOutput) UsedTopicNumber() pulumi.IntOutput

Number of topics created in the current instance.

func (LookupInstanceResultOutput) Version 

func (o LookupInstanceResultOutput) Version() pulumi.StringOutput

Supported RocketMQ versions. Currently supported versions include: 4.8: compatible with RocketMQ 4.x series. 5.x: compatible with RocketMQ 5.x series. The 5.x version is currently available by whitelist application. To use it, contact technical support to apply for access.

func (LookupInstanceResultOutput) VpcId 

func (o LookupInstanceResultOutput) VpcId() pulumi.StringOutput

VPC ID where the instance resides. After the instance is created, the associated VPC and subnet cannot be modified. Please operate carefully when creating the instance. You can call the DescribeVpcs API of the VPC to query the available VPC and subnet list.

func (LookupInstanceResultOutput) ZoneId 

func (o LookupInstanceResultOutput) ZoneId() pulumi.StringOutput

Availability zone ID where the instance is located. RocketMQ Message Queue instances support cross-AZ deployment. When viewing available compute specifications in a specified availability zone, you can specify multiple zones. Separate multiple availability zone IDs with commas (,). You can call DescribeAvailabilityZones to query the list of currently available zones.

type LookupTopicArgs added in v0.0.22 

type LookupTopicArgs struct {
	// Uniquely identifies the resource.
	Id string `pulumi:"id"`
}

A collection of arguments for invoking getTopic.

type LookupTopicOutputArgs added in v0.0.22 

type LookupTopicOutputArgs struct {
	// Uniquely identifies the resource.
	Id pulumi.StringInput `pulumi:"id"`
}

A collection of arguments for invoking getTopic.

func (LookupTopicOutputArgs) ElementType added in v0.0.22 

func (LookupTopicOutputArgs) ElementType() reflect.Type

type LookupTopicResult added in v0.0.22 

type LookupTopicResult struct {
	// Permissions for each RocketMQ key on the current Topic, supports batch permission settings. If not set, each key retains its default permissions for the current Topic.
	AccessPolicies []GetTopicAccessPolicy `pulumi:"accessPolicies"`
	// Topic creation time.
	CreatedTime string `pulumi:"createdTime"`
	// Topic description, length: 0–128 characters.
	Description string `pulumi:"description"`
	// Consumer group information list.
	GroupsInfos []GetTopicGroupsInfo `pulumi:"groupsInfos"`
	// Uniquely identifies the resource.
	Id string `pulumi:"id"`
	// Instance ID.
	InstanceId string `pulumi:"instanceId"`
	// Instance name.
	InstanceName string `pulumi:"instanceName"`
	// Message type. Set this parameter to filter the Topic list by the specified message type. Value description: 0: Normal message. 1: Transaction message. 2: Partitioned ordered message. 3: Globally ordered message. 4: Delayed message.
	MessageType int `pulumi:"messageType"`
	// Set the number of queues for the current Topic. The maximum cannot exceed the remaining available queues for the current instance. For queue limits per instance specification, refer to the product specifications. When creating a Topic in a 4.x version instance, set the number of queues as follows: For globally ordered Topics, the default queue number is 1. For other Topic types, the queue number depends on the compute specification. For n3 and below, the default is 6; for above n3, the default is twice the number of broker groups. It is recommended to set the queue number as a multiple of the number of compute nodes to avoid data imbalance across Brokers. For example, for the rocketmq.n3.x2.medium specification with 3 compute nodes, set the queue number to a multiple of 3, such as 3, 6, or 9. When creating a Topic in a 5.x version instance, set the number of queues as follows: For globally ordered Topics, the default queue number is 1. For other Topic types, the default is twice the number of broker groups. In non-ordered scenarios, performance is not affected by the number of queues; more queues only improve concurrent performance for ordered consumption.
	QueueNumber int `pulumi:"queueNumber"`
	// Queue information list.
	QueuesInfos []GetTopicQueuesInfo `pulumi:"queuesInfos"`
	// Permissions for each RocketMQ key on the current Topic, permission field
	ReadAccessPolicies []GetTopicReadAccessPolicy `pulumi:"readAccessPolicies"`
	// Service status. Creating: being created, Running: running, Deleting: being deleted, Abnormal: abnormal, Updating: being updated.
	ServiceStatus string `pulumi:"serviceStatus"`
	// Topic name. Naming rules: Length must be 3–100 characters. Only English letters, numbers, hyphens (-), and underscores (*) are allowed. Topic names cannot contain the following reserved characters or special prefixes. Reserved characters: RMQ*SYS*TRANS*OP*HALF*TOPIC, BenchmarkTest, TBW102, OFFSET*MOVED*EVENT, SELF*TEST*TOPIC, RMQ*SYS*TRANS*HALF*TOPIC, SCHEDULE*TOPIC*XXXX, RMQ*SYS*TRACE*TOPIC. Special prefixes: rocketmq-broker-, %RETRY%, rmq*sys_, %DLQ%.
	TopicName string `pulumi:"topicName"`
}

A collection of values returned by getTopic.

func LookupTopic added in v0.0.22 

func LookupTopic(ctx *pulumi.Context, args *LookupTopicArgs, opts ...pulumi.InvokeOption) (*LookupTopicResult, error)

Data Source schema for Volcengine::RocketMQ::Topic

type LookupTopicResultOutput added in v0.0.22 

type LookupTopicResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getTopic.

func LookupTopicOutput added in v0.0.22 

func LookupTopicOutput(ctx *pulumi.Context, args LookupTopicOutputArgs, opts ...pulumi.InvokeOption) LookupTopicResultOutput

func (LookupTopicResultOutput) AccessPolicies added in v0.0.22 

func (o LookupTopicResultOutput) AccessPolicies() GetTopicAccessPolicyArrayOutput

Permissions for each RocketMQ key on the current Topic, supports batch permission settings. If not set, each key retains its default permissions for the current Topic.

func (LookupTopicResultOutput) CreatedTime added in v0.0.22 

func (o LookupTopicResultOutput) CreatedTime() pulumi.StringOutput

Topic creation time.

func (LookupTopicResultOutput) Description added in v0.0.22 

func (o LookupTopicResultOutput) Description() pulumi.StringOutput

Topic description, length: 0–128 characters.

func (LookupTopicResultOutput) ElementType added in v0.0.22 

func (LookupTopicResultOutput) ElementType() reflect.Type

func (LookupTopicResultOutput) GroupsInfos added in v0.0.22 

func (o LookupTopicResultOutput) GroupsInfos() GetTopicGroupsInfoArrayOutput

Consumer group information list.

func (LookupTopicResultOutput) Id added in v0.0.22 

func (o LookupTopicResultOutput) Id() pulumi.StringOutput

Uniquely identifies the resource.

func (LookupTopicResultOutput) InstanceId added in v0.0.22 

func (o LookupTopicResultOutput) InstanceId() pulumi.StringOutput

Instance ID.

func (LookupTopicResultOutput) InstanceName added in v0.0.22 

func (o LookupTopicResultOutput) InstanceName() pulumi.StringOutput

Instance name.

func (LookupTopicResultOutput) MessageType added in v0.0.22 

func (o LookupTopicResultOutput) MessageType() pulumi.IntOutput

Message type. Set this parameter to filter the Topic list by the specified message type. Value description: 0: Normal message. 1: Transaction message. 2: Partitioned ordered message. 3: Globally ordered message. 4: Delayed message.

func (LookupTopicResultOutput) QueueNumber added in v0.0.22 

func (o LookupTopicResultOutput) QueueNumber() pulumi.IntOutput

Set the number of queues for the current Topic. The maximum cannot exceed the remaining available queues for the current instance. For queue limits per instance specification, refer to the product specifications. When creating a Topic in a 4.x version instance, set the number of queues as follows: For globally ordered Topics, the default queue number is 1. For other Topic types, the queue number depends on the compute specification. For n3 and below, the default is 6; for above n3, the default is twice the number of broker groups. It is recommended to set the queue number as a multiple of the number of compute nodes to avoid data imbalance across Brokers. For example, for the rocketmq.n3.x2.medium specification with 3 compute nodes, set the queue number to a multiple of 3, such as 3, 6, or 9. When creating a Topic in a 5.x version instance, set the number of queues as follows: For globally ordered Topics, the default queue number is 1. For other Topic types, the default is twice the number of broker groups. In non-ordered scenarios, performance is not affected by the number of queues; more queues only improve concurrent performance for ordered consumption.

func (LookupTopicResultOutput) QueuesInfos added in v0.0.22 

func (o LookupTopicResultOutput) QueuesInfos() GetTopicQueuesInfoArrayOutput

Queue information list.

func (LookupTopicResultOutput) ReadAccessPolicies added in v0.0.22 

func (o LookupTopicResultOutput) ReadAccessPolicies() GetTopicReadAccessPolicyArrayOutput

Permissions for each RocketMQ key on the current Topic, permission field

func (LookupTopicResultOutput) ServiceStatus added in v0.0.22 

func (o LookupTopicResultOutput) ServiceStatus() pulumi.StringOutput

Service status. Creating: being created, Running: running, Deleting: being deleted, Abnormal: abnormal, Updating: being updated.

func (LookupTopicResultOutput) ToLookupTopicResultOutput added in v0.0.22 

func (o LookupTopicResultOutput) ToLookupTopicResultOutput() LookupTopicResultOutput

func (LookupTopicResultOutput) ToLookupTopicResultOutputWithContext added in v0.0.22 

func (o LookupTopicResultOutput) ToLookupTopicResultOutputWithContext(ctx context.Context) LookupTopicResultOutput

func (LookupTopicResultOutput) TopicName added in v0.0.22 

func (o LookupTopicResultOutput) TopicName() pulumi.StringOutput

Topic name. Naming rules: Length must be 3–100 characters. Only English letters, numbers, hyphens (-), and underscores (*) are allowed. Topic names cannot contain the following reserved characters or special prefixes. Reserved characters: RMQ*SYS*TRANS*OP*HALF*TOPIC, BenchmarkTest, TBW102, OFFSET*MOVED*EVENT, SELF*TEST*TOPIC, RMQ*SYS*TRANS*HALF*TOPIC, SCHEDULE*TOPIC*XXXX, RMQ*SYS*TRACE*TOPIC. Special prefixes: rocketmq-broker-, %RETRY%, rmq*sys_, %DLQ%.

type Topic added in v0.0.22 

type Topic struct {
	pulumi.CustomResourceState

	AccessPolicies TopicAccessPolicyArrayOutput `pulumi:"accessPolicies"`
	// Topic creation time.
	CreatedTime pulumi.StringOutput `pulumi:"createdTime"`
	// Topic description, length: 0–128 characters.
	Description pulumi.StringOutput        `pulumi:"description"`
	GroupsInfos TopicGroupsInfoArrayOutput `pulumi:"groupsInfos"`
	// Instance ID.
	InstanceId pulumi.StringOutput `pulumi:"instanceId"`
	// Instance name.
	InstanceName pulumi.StringOutput `pulumi:"instanceName"`
	// Message type. Set this parameter to filter the Topic list by the specified message type. Value description: 0: Normal message. 1: Transaction message. 2: Partitioned ordered message. 3: Globally ordered message. 4: Delayed message.
	MessageType pulumi.IntOutput `pulumi:"messageType"`
	// Set the number of queues for the current Topic. The maximum cannot exceed the remaining available queues for the current instance. For queue limits per instance specification, refer to the product specifications. When creating a Topic in a 4.x version instance, set the number of queues as follows: For globally ordered Topics, the default queue number is 1. For other Topic types, the queue number depends on the compute specification. For n3 and below, the default is 6; for above n3, the default is twice the number of broker groups. It is recommended to set the queue number as a multiple of the number of compute nodes to avoid data imbalance across Brokers. For example, for the rocketmq.n3.x2.medium specification with 3 compute nodes, set the queue number to a multiple of 3, such as 3, 6, or 9. When creating a Topic in a 5.x version instance, set the number of queues as follows: For globally ordered Topics, the default queue number is 1. For other Topic types, the default is twice the number of broker groups. In non-ordered scenarios, performance is not affected by the number of queues; more queues only improve concurrent performance for ordered consumption.
	QueueNumber        pulumi.IntOutput                 `pulumi:"queueNumber"`
	QueuesInfos        TopicQueuesInfoArrayOutput       `pulumi:"queuesInfos"`
	ReadAccessPolicies TopicReadAccessPolicyArrayOutput `pulumi:"readAccessPolicies"`
	// Service status. Creating: being created, Running: running, Deleting: being deleted, Abnormal: abnormal, Updating: being updated.
	ServiceStatus pulumi.StringOutput `pulumi:"serviceStatus"`
	// Topic name. Naming rules: Length must be 3–100 characters. Only English letters, numbers, hyphens (-), and underscores (*) are allowed. Topic names cannot contain the following reserved characters or special prefixes. Reserved characters: RMQ*SYS*TRANS*OP*HALF*TOPIC, BenchmarkTest, TBW102, OFFSET*MOVED*EVENT, SELF*TEST*TOPIC, RMQ*SYS*TRANS*HALF*TOPIC, SCHEDULE*TOPIC*XXXX, RMQ*SYS*TRACE*TOPIC. Special prefixes: rocketmq-broker-, %RETRY%, rmq*sys_, %DLQ%.
	TopicName pulumi.StringOutput `pulumi:"topicName"`
}

In a RocketMQ instance, a Topic is the basic unit for sending and consuming messages. RocketMQ Message Queue categorizes and manages different types of messages using Topics. Producers send messages to RocketMQ Topics, and consumers consume messages by subscribing to those Topics.

## Import

```sh $ pulumi import volcenginecc:rocketmq/topic:Topic example "instance_id|topic_name" ```

func GetTopic added in v0.0.22 

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 added in v0.0.22 

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 v0.0.22 

func (*Topic) ElementType() reflect.Type

func (*Topic) ToTopicOutput added in v0.0.22 

func (i *Topic) ToTopicOutput() TopicOutput

func (*Topic) ToTopicOutputWithContext added in v0.0.22 

func (i *Topic) ToTopicOutputWithContext(ctx context.Context) TopicOutput

type TopicAccessPolicy added in v0.0.22 

type TopicAccessPolicy struct {
	// AccessKey of the RocketMQ key.
	AccessKey *string `pulumi:"accessKey"`
	// User access permissions for the current Topic. ALL: Publish and subscribe permissions. PUB: Publish permission. SUB: Subscribe permission. DENY: No publish or subscribe permissions.
	Authority *string `pulumi:"authority"`
}

type TopicAccessPolicyArgs added in v0.0.22 

type TopicAccessPolicyArgs struct {
	// AccessKey of the RocketMQ key.
	AccessKey pulumi.StringPtrInput `pulumi:"accessKey"`
	// User access permissions for the current Topic. ALL: Publish and subscribe permissions. PUB: Publish permission. SUB: Subscribe permission. DENY: No publish or subscribe permissions.
	Authority pulumi.StringPtrInput `pulumi:"authority"`
}

func (TopicAccessPolicyArgs) ElementType added in v0.0.22 

func (TopicAccessPolicyArgs) ElementType() reflect.Type

func (TopicAccessPolicyArgs) ToTopicAccessPolicyOutput added in v0.0.22 

func (i TopicAccessPolicyArgs) ToTopicAccessPolicyOutput() TopicAccessPolicyOutput

func (TopicAccessPolicyArgs) ToTopicAccessPolicyOutputWithContext added in v0.0.22 

func (i TopicAccessPolicyArgs) ToTopicAccessPolicyOutputWithContext(ctx context.Context) TopicAccessPolicyOutput

type TopicAccessPolicyArray added in v0.0.22 

type TopicAccessPolicyArray []TopicAccessPolicyInput

func (TopicAccessPolicyArray) ElementType added in v0.0.22 

func (TopicAccessPolicyArray) ElementType() reflect.Type

func (TopicAccessPolicyArray) ToTopicAccessPolicyArrayOutput added in v0.0.22 

func (i TopicAccessPolicyArray) ToTopicAccessPolicyArrayOutput() TopicAccessPolicyArrayOutput

func (TopicAccessPolicyArray) ToTopicAccessPolicyArrayOutputWithContext added in v0.0.22 

func (i TopicAccessPolicyArray) ToTopicAccessPolicyArrayOutputWithContext(ctx context.Context) TopicAccessPolicyArrayOutput

type TopicAccessPolicyArrayInput added in v0.0.22 

type TopicAccessPolicyArrayInput interface {
	pulumi.Input

	ToTopicAccessPolicyArrayOutput() TopicAccessPolicyArrayOutput
	ToTopicAccessPolicyArrayOutputWithContext(context.Context) TopicAccessPolicyArrayOutput
}

TopicAccessPolicyArrayInput is an input type that accepts TopicAccessPolicyArray and TopicAccessPolicyArrayOutput values. You can construct a concrete instance of `TopicAccessPolicyArrayInput` via: 

TopicAccessPolicyArray{ TopicAccessPolicyArgs{...} }

type TopicAccessPolicyArrayOutput added in v0.0.22 

type TopicAccessPolicyArrayOutput struct{ *pulumi.OutputState }

func (TopicAccessPolicyArrayOutput) ElementType added in v0.0.22 

func (TopicAccessPolicyArrayOutput) ElementType() reflect.Type

func (TopicAccessPolicyArrayOutput) Index added in v0.0.22 

func (o TopicAccessPolicyArrayOutput) Index(i pulumi.IntInput) TopicAccessPolicyOutput

func (TopicAccessPolicyArrayOutput) ToTopicAccessPolicyArrayOutput added in v0.0.22 

func (o TopicAccessPolicyArrayOutput) ToTopicAccessPolicyArrayOutput() TopicAccessPolicyArrayOutput

func (TopicAccessPolicyArrayOutput) ToTopicAccessPolicyArrayOutputWithContext added in v0.0.22 

func (o TopicAccessPolicyArrayOutput) ToTopicAccessPolicyArrayOutputWithContext(ctx context.Context) TopicAccessPolicyArrayOutput

type TopicAccessPolicyInput added in v0.0.22 

type TopicAccessPolicyInput interface {
	pulumi.Input

	ToTopicAccessPolicyOutput() TopicAccessPolicyOutput
	ToTopicAccessPolicyOutputWithContext(context.Context) TopicAccessPolicyOutput
}

TopicAccessPolicyInput is an input type that accepts TopicAccessPolicyArgs and TopicAccessPolicyOutput values. You can construct a concrete instance of `TopicAccessPolicyInput` via: 

TopicAccessPolicyArgs{...}

type TopicAccessPolicyOutput added in v0.0.22 

type TopicAccessPolicyOutput struct{ *pulumi.OutputState }

func (TopicAccessPolicyOutput) AccessKey added in v0.0.22 

func (o TopicAccessPolicyOutput) AccessKey() pulumi.StringPtrOutput

AccessKey of the RocketMQ key.

func (TopicAccessPolicyOutput) Authority added in v0.0.22 

func (o TopicAccessPolicyOutput) Authority() pulumi.StringPtrOutput

User access permissions for the current Topic. ALL: Publish and subscribe permissions. PUB: Publish permission. SUB: Subscribe permission. DENY: No publish or subscribe permissions.

func (TopicAccessPolicyOutput) ElementType added in v0.0.22 

func (TopicAccessPolicyOutput) ElementType() reflect.Type

func (TopicAccessPolicyOutput) ToTopicAccessPolicyOutput added in v0.0.22 

func (o TopicAccessPolicyOutput) ToTopicAccessPolicyOutput() TopicAccessPolicyOutput

func (TopicAccessPolicyOutput) ToTopicAccessPolicyOutputWithContext added in v0.0.22 

func (o TopicAccessPolicyOutput) ToTopicAccessPolicyOutputWithContext(ctx context.Context) TopicAccessPolicyOutput

type TopicArgs added in v0.0.22 

type TopicArgs struct {
	AccessPolicies TopicAccessPolicyArrayInput
	// Topic description, length: 0–128 characters.
	Description pulumi.StringPtrInput
	// Instance ID.
	InstanceId pulumi.StringInput
	// Message type. Set this parameter to filter the Topic list by the specified message type. Value description: 0: Normal message. 1: Transaction message. 2: Partitioned ordered message. 3: Globally ordered message. 4: Delayed message.
	MessageType pulumi.IntInput
	// Set the number of queues for the current Topic. The maximum cannot exceed the remaining available queues for the current instance. For queue limits per instance specification, refer to the product specifications. When creating a Topic in a 4.x version instance, set the number of queues as follows: For globally ordered Topics, the default queue number is 1. For other Topic types, the queue number depends on the compute specification. For n3 and below, the default is 6; for above n3, the default is twice the number of broker groups. It is recommended to set the queue number as a multiple of the number of compute nodes to avoid data imbalance across Brokers. For example, for the rocketmq.n3.x2.medium specification with 3 compute nodes, set the queue number to a multiple of 3, such as 3, 6, or 9. When creating a Topic in a 5.x version instance, set the number of queues as follows: For globally ordered Topics, the default queue number is 1. For other Topic types, the default is twice the number of broker groups. In non-ordered scenarios, performance is not affected by the number of queues; more queues only improve concurrent performance for ordered consumption.
	QueueNumber pulumi.IntInput
	// Topic name. Naming rules: Length must be 3–100 characters. Only English letters, numbers, hyphens (-), and underscores (*) are allowed. Topic names cannot contain the following reserved characters or special prefixes. Reserved characters: RMQ*SYS*TRANS*OP*HALF*TOPIC, BenchmarkTest, TBW102, OFFSET*MOVED*EVENT, SELF*TEST*TOPIC, RMQ*SYS*TRANS*HALF*TOPIC, SCHEDULE*TOPIC*XXXX, RMQ*SYS*TRACE*TOPIC. Special prefixes: rocketmq-broker-, %RETRY%, rmq*sys_, %DLQ%.
	TopicName pulumi.StringInput
}

The set of arguments for constructing a Topic resource.

func (TopicArgs) ElementType added in v0.0.22 

func (TopicArgs) ElementType() reflect.Type

type TopicArray added in v0.0.22 

type TopicArray []TopicInput

func (TopicArray) ElementType added in v0.0.22 

func (TopicArray) ElementType() reflect.Type

func (TopicArray) ToTopicArrayOutput added in v0.0.22 

func (i TopicArray) ToTopicArrayOutput() TopicArrayOutput

func (TopicArray) ToTopicArrayOutputWithContext added in v0.0.22 

func (i TopicArray) ToTopicArrayOutputWithContext(ctx context.Context) TopicArrayOutput

type TopicArrayInput added in v0.0.22 

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 v0.0.22 

type TopicArrayOutput struct{ *pulumi.OutputState }

func (TopicArrayOutput) ElementType added in v0.0.22 

func (TopicArrayOutput) ElementType() reflect.Type

func (TopicArrayOutput) Index added in v0.0.22 

func (o TopicArrayOutput) Index(i pulumi.IntInput) TopicOutput

func (TopicArrayOutput) ToTopicArrayOutput added in v0.0.22 

func (o TopicArrayOutput) ToTopicArrayOutput() TopicArrayOutput

func (TopicArrayOutput) ToTopicArrayOutputWithContext added in v0.0.22 

func (o TopicArrayOutput) ToTopicArrayOutputWithContext(ctx context.Context) TopicArrayOutput

type TopicGroupsInfo added in v0.0.22 

type TopicGroupsInfo struct {
	// Group ID of the consumer group.
	GroupId *string `pulumi:"groupId"`
	// Consumption mode. The values are as follows: Clustering: cluster consumption mode. Broadcasting: broadcast consumption mode.
	MessageModel *string `pulumi:"messageModel"`
	// Subscription rule. This field contains the exact string specified by the consumer group when subscribing to this Topic, usually * or TAG1 || TAG2.
	SubString *string `pulumi:"subString"`
}

type TopicGroupsInfoArgs added in v0.0.22 

type TopicGroupsInfoArgs struct {
	// Group ID of the consumer group.
	GroupId pulumi.StringPtrInput `pulumi:"groupId"`
	// Consumption mode. The values are as follows: Clustering: cluster consumption mode. Broadcasting: broadcast consumption mode.
	MessageModel pulumi.StringPtrInput `pulumi:"messageModel"`
	// Subscription rule. This field contains the exact string specified by the consumer group when subscribing to this Topic, usually * or TAG1 || TAG2.
	SubString pulumi.StringPtrInput `pulumi:"subString"`
}

func (TopicGroupsInfoArgs) ElementType added in v0.0.22 

func (TopicGroupsInfoArgs) ElementType() reflect.Type

func (TopicGroupsInfoArgs) ToTopicGroupsInfoOutput added in v0.0.22 

func (i TopicGroupsInfoArgs) ToTopicGroupsInfoOutput() TopicGroupsInfoOutput

func (TopicGroupsInfoArgs) ToTopicGroupsInfoOutputWithContext added in v0.0.22 

func (i TopicGroupsInfoArgs) ToTopicGroupsInfoOutputWithContext(ctx context.Context) TopicGroupsInfoOutput

type TopicGroupsInfoArray added in v0.0.22 

type TopicGroupsInfoArray []TopicGroupsInfoInput

func (TopicGroupsInfoArray) ElementType added in v0.0.22 

func (TopicGroupsInfoArray) ElementType() reflect.Type

func (TopicGroupsInfoArray) ToTopicGroupsInfoArrayOutput added in v0.0.22 

func (i TopicGroupsInfoArray) ToTopicGroupsInfoArrayOutput() TopicGroupsInfoArrayOutput

func (TopicGroupsInfoArray) ToTopicGroupsInfoArrayOutputWithContext added in v0.0.22 

func (i TopicGroupsInfoArray) ToTopicGroupsInfoArrayOutputWithContext(ctx context.Context) TopicGroupsInfoArrayOutput

type TopicGroupsInfoArrayInput added in v0.0.22 

type TopicGroupsInfoArrayInput interface {
	pulumi.Input

	ToTopicGroupsInfoArrayOutput() TopicGroupsInfoArrayOutput
	ToTopicGroupsInfoArrayOutputWithContext(context.Context) TopicGroupsInfoArrayOutput
}

TopicGroupsInfoArrayInput is an input type that accepts TopicGroupsInfoArray and TopicGroupsInfoArrayOutput values. You can construct a concrete instance of `TopicGroupsInfoArrayInput` via: 

TopicGroupsInfoArray{ TopicGroupsInfoArgs{...} }

type TopicGroupsInfoArrayOutput added in v0.0.22 

type TopicGroupsInfoArrayOutput struct{ *pulumi.OutputState }

func (TopicGroupsInfoArrayOutput) ElementType added in v0.0.22 

func (TopicGroupsInfoArrayOutput) ElementType() reflect.Type

func (TopicGroupsInfoArrayOutput) Index added in v0.0.22 

func (o TopicGroupsInfoArrayOutput) Index(i pulumi.IntInput) TopicGroupsInfoOutput

func (TopicGroupsInfoArrayOutput) ToTopicGroupsInfoArrayOutput added in v0.0.22 

func (o TopicGroupsInfoArrayOutput) ToTopicGroupsInfoArrayOutput() TopicGroupsInfoArrayOutput

func (TopicGroupsInfoArrayOutput) ToTopicGroupsInfoArrayOutputWithContext added in v0.0.22 

func (o TopicGroupsInfoArrayOutput) ToTopicGroupsInfoArrayOutputWithContext(ctx context.Context) TopicGroupsInfoArrayOutput

type TopicGroupsInfoInput added in v0.0.22 

type TopicGroupsInfoInput interface {
	pulumi.Input

	ToTopicGroupsInfoOutput() TopicGroupsInfoOutput
	ToTopicGroupsInfoOutputWithContext(context.Context) TopicGroupsInfoOutput
}

TopicGroupsInfoInput is an input type that accepts TopicGroupsInfoArgs and TopicGroupsInfoOutput values. You can construct a concrete instance of `TopicGroupsInfoInput` via: 

TopicGroupsInfoArgs{...}

type TopicGroupsInfoOutput added in v0.0.22 

type TopicGroupsInfoOutput struct{ *pulumi.OutputState }

func (TopicGroupsInfoOutput) ElementType added in v0.0.22 

func (TopicGroupsInfoOutput) ElementType() reflect.Type

func (TopicGroupsInfoOutput) GroupId added in v0.0.22 

func (o TopicGroupsInfoOutput) GroupId() pulumi.StringPtrOutput

Group ID of the consumer group.

func (TopicGroupsInfoOutput) MessageModel added in v0.0.22 

func (o TopicGroupsInfoOutput) MessageModel() pulumi.StringPtrOutput

Consumption mode. The values are as follows: Clustering: cluster consumption mode. Broadcasting: broadcast consumption mode.

func (TopicGroupsInfoOutput) SubString added in v0.0.22 

func (o TopicGroupsInfoOutput) SubString() pulumi.StringPtrOutput

Subscription rule. This field contains the exact string specified by the consumer group when subscribing to this Topic, usually * or TAG1 || TAG2.

func (TopicGroupsInfoOutput) ToTopicGroupsInfoOutput added in v0.0.22 

func (o TopicGroupsInfoOutput) ToTopicGroupsInfoOutput() TopicGroupsInfoOutput

func (TopicGroupsInfoOutput) ToTopicGroupsInfoOutputWithContext added in v0.0.22 

func (o TopicGroupsInfoOutput) ToTopicGroupsInfoOutputWithContext(ctx context.Context) TopicGroupsInfoOutput

type TopicInput added in v0.0.22 

type TopicInput interface {
	pulumi.Input

	ToTopicOutput() TopicOutput
	ToTopicOutputWithContext(ctx context.Context) TopicOutput
}

type TopicMap added in v0.0.22 

type TopicMap map[string]TopicInput

func (TopicMap) ElementType added in v0.0.22 

func (TopicMap) ElementType() reflect.Type

func (TopicMap) ToTopicMapOutput added in v0.0.22 

func (i TopicMap) ToTopicMapOutput() TopicMapOutput

func (TopicMap) ToTopicMapOutputWithContext added in v0.0.22 

func (i TopicMap) ToTopicMapOutputWithContext(ctx context.Context) TopicMapOutput

type TopicMapInput added in v0.0.22 

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 v0.0.22 

type TopicMapOutput struct{ *pulumi.OutputState }

func (TopicMapOutput) ElementType added in v0.0.22 

func (TopicMapOutput) ElementType() reflect.Type

func (TopicMapOutput) MapIndex added in v0.0.22 

func (o TopicMapOutput) MapIndex(k pulumi.StringInput) TopicOutput

func (TopicMapOutput) ToTopicMapOutput added in v0.0.22 

func (o TopicMapOutput) ToTopicMapOutput() TopicMapOutput

func (TopicMapOutput) ToTopicMapOutputWithContext added in v0.0.22 

func (o TopicMapOutput) ToTopicMapOutputWithContext(ctx context.Context) TopicMapOutput

type TopicOutput added in v0.0.22 

type TopicOutput struct{ *pulumi.OutputState }

func (TopicOutput) AccessPolicies added in v0.0.22 

func (o TopicOutput) AccessPolicies() TopicAccessPolicyArrayOutput

func (TopicOutput) CreatedTime added in v0.0.22 

func (o TopicOutput) CreatedTime() pulumi.StringOutput

Topic creation time.

func (TopicOutput) Description added in v0.0.22 

func (o TopicOutput) Description() pulumi.StringOutput

Topic description, length: 0–128 characters.

func (TopicOutput) ElementType added in v0.0.22 

func (TopicOutput) ElementType() reflect.Type

func (TopicOutput) GroupsInfos added in v0.0.22 

func (o TopicOutput) GroupsInfos() TopicGroupsInfoArrayOutput

func (TopicOutput) InstanceId added in v0.0.22 

func (o TopicOutput) InstanceId() pulumi.StringOutput

Instance ID.

func (TopicOutput) InstanceName added in v0.0.22 

func (o TopicOutput) InstanceName() pulumi.StringOutput

Instance name.

func (TopicOutput) MessageType added in v0.0.22 

func (o TopicOutput) MessageType() pulumi.IntOutput

Message type. Set this parameter to filter the Topic list by the specified message type. Value description: 0: Normal message. 1: Transaction message. 2: Partitioned ordered message. 3: Globally ordered message. 4: Delayed message.

func (TopicOutput) QueueNumber added in v0.0.22 

func (o TopicOutput) QueueNumber() pulumi.IntOutput

Set the number of queues for the current Topic. The maximum cannot exceed the remaining available queues for the current instance. For queue limits per instance specification, refer to the product specifications. When creating a Topic in a 4.x version instance, set the number of queues as follows: For globally ordered Topics, the default queue number is 1. For other Topic types, the queue number depends on the compute specification. For n3 and below, the default is 6; for above n3, the default is twice the number of broker groups. It is recommended to set the queue number as a multiple of the number of compute nodes to avoid data imbalance across Brokers. For example, for the rocketmq.n3.x2.medium specification with 3 compute nodes, set the queue number to a multiple of 3, such as 3, 6, or 9. When creating a Topic in a 5.x version instance, set the number of queues as follows: For globally ordered Topics, the default queue number is 1. For other Topic types, the default is twice the number of broker groups. In non-ordered scenarios, performance is not affected by the number of queues; more queues only improve concurrent performance for ordered consumption.

func (TopicOutput) QueuesInfos added in v0.0.22 

func (o TopicOutput) QueuesInfos() TopicQueuesInfoArrayOutput

func (TopicOutput) ReadAccessPolicies added in v0.0.22 

func (o TopicOutput) ReadAccessPolicies() TopicReadAccessPolicyArrayOutput

func (TopicOutput) ServiceStatus added in v0.0.22 

func (o TopicOutput) ServiceStatus() pulumi.StringOutput

Service status. Creating: being created, Running: running, Deleting: being deleted, Abnormal: abnormal, Updating: being updated.

func (TopicOutput) ToTopicOutput added in v0.0.22 

func (o TopicOutput) ToTopicOutput() TopicOutput

func (TopicOutput) ToTopicOutputWithContext added in v0.0.22 

func (o TopicOutput) ToTopicOutputWithContext(ctx context.Context) TopicOutput

func (TopicOutput) TopicName added in v0.0.22 

func (o TopicOutput) TopicName() pulumi.StringOutput

Topic name. Naming rules: Length must be 3–100 characters. Only English letters, numbers, hyphens (-), and underscores (*) are allowed. Topic names cannot contain the following reserved characters or special prefixes. Reserved characters: RMQ*SYS*TRANS*OP*HALF*TOPIC, BenchmarkTest, TBW102, OFFSET*MOVED*EVENT, SELF*TEST*TOPIC, RMQ*SYS*TRANS*HALF*TOPIC, SCHEDULE*TOPIC*XXXX, RMQ*SYS*TRACE*TOPIC. Special prefixes: rocketmq-broker-, %RETRY%, rmq*sys_, %DLQ%.

type TopicQueuesInfo added in v0.0.22 

type TopicQueuesInfo struct {
	// The maximum offset of the current queue, which is the offset of the next message. The position of the latest message is EndOffset   - 1.
	EndOffset *int `pulumi:"endOffset"`
	// The time of the most recent message written to this queue.
	LastUpdateTimestamp *int `pulumi:"lastUpdateTimestamp"`
	// The number of messages in the current queue. EndOffset is the offset of the next message, so MessageCount = EndOffset   - StartOffset.
	MessageCount *int `pulumi:"messageCount"`
	// Queue ID.
	QueueId *string `pulumi:"queueId"`
	// The earliest message offset in the current queue.
	StartOffset *int `pulumi:"startOffset"`
}

type TopicQueuesInfoArgs added in v0.0.22 

type TopicQueuesInfoArgs struct {
	// The maximum offset of the current queue, which is the offset of the next message. The position of the latest message is EndOffset   - 1.
	EndOffset pulumi.IntPtrInput `pulumi:"endOffset"`
	// The time of the most recent message written to this queue.
	LastUpdateTimestamp pulumi.IntPtrInput `pulumi:"lastUpdateTimestamp"`
	// The number of messages in the current queue. EndOffset is the offset of the next message, so MessageCount = EndOffset   - StartOffset.
	MessageCount pulumi.IntPtrInput `pulumi:"messageCount"`
	// Queue ID.
	QueueId pulumi.StringPtrInput `pulumi:"queueId"`
	// The earliest message offset in the current queue.
	StartOffset pulumi.IntPtrInput `pulumi:"startOffset"`
}

func (TopicQueuesInfoArgs) ElementType added in v0.0.22 

func (TopicQueuesInfoArgs) ElementType() reflect.Type

func (TopicQueuesInfoArgs) ToTopicQueuesInfoOutput added in v0.0.22 

func (i TopicQueuesInfoArgs) ToTopicQueuesInfoOutput() TopicQueuesInfoOutput

func (TopicQueuesInfoArgs) ToTopicQueuesInfoOutputWithContext added in v0.0.22 

func (i TopicQueuesInfoArgs) ToTopicQueuesInfoOutputWithContext(ctx context.Context) TopicQueuesInfoOutput

type TopicQueuesInfoArray added in v0.0.22 

type TopicQueuesInfoArray []TopicQueuesInfoInput

func (TopicQueuesInfoArray) ElementType added in v0.0.22 

func (TopicQueuesInfoArray) ElementType() reflect.Type

func (TopicQueuesInfoArray) ToTopicQueuesInfoArrayOutput added in v0.0.22 

func (i TopicQueuesInfoArray) ToTopicQueuesInfoArrayOutput() TopicQueuesInfoArrayOutput

func (TopicQueuesInfoArray) ToTopicQueuesInfoArrayOutputWithContext added in v0.0.22 

func (i TopicQueuesInfoArray) ToTopicQueuesInfoArrayOutputWithContext(ctx context.Context) TopicQueuesInfoArrayOutput

type TopicQueuesInfoArrayInput added in v0.0.22 

type TopicQueuesInfoArrayInput interface {
	pulumi.Input

	ToTopicQueuesInfoArrayOutput() TopicQueuesInfoArrayOutput
	ToTopicQueuesInfoArrayOutputWithContext(context.Context) TopicQueuesInfoArrayOutput
}

TopicQueuesInfoArrayInput is an input type that accepts TopicQueuesInfoArray and TopicQueuesInfoArrayOutput values. You can construct a concrete instance of `TopicQueuesInfoArrayInput` via: 

TopicQueuesInfoArray{ TopicQueuesInfoArgs{...} }

type TopicQueuesInfoArrayOutput added in v0.0.22 

type TopicQueuesInfoArrayOutput struct{ *pulumi.OutputState }

func (TopicQueuesInfoArrayOutput) ElementType added in v0.0.22 

func (TopicQueuesInfoArrayOutput) ElementType() reflect.Type

func (TopicQueuesInfoArrayOutput) Index added in v0.0.22 

func (o TopicQueuesInfoArrayOutput) Index(i pulumi.IntInput) TopicQueuesInfoOutput

func (TopicQueuesInfoArrayOutput) ToTopicQueuesInfoArrayOutput added in v0.0.22 

func (o TopicQueuesInfoArrayOutput) ToTopicQueuesInfoArrayOutput() TopicQueuesInfoArrayOutput

func (TopicQueuesInfoArrayOutput) ToTopicQueuesInfoArrayOutputWithContext added in v0.0.22 

func (o TopicQueuesInfoArrayOutput) ToTopicQueuesInfoArrayOutputWithContext(ctx context.Context) TopicQueuesInfoArrayOutput

type TopicQueuesInfoInput added in v0.0.22 

type TopicQueuesInfoInput interface {
	pulumi.Input

	ToTopicQueuesInfoOutput() TopicQueuesInfoOutput
	ToTopicQueuesInfoOutputWithContext(context.Context) TopicQueuesInfoOutput
}

TopicQueuesInfoInput is an input type that accepts TopicQueuesInfoArgs and TopicQueuesInfoOutput values. You can construct a concrete instance of `TopicQueuesInfoInput` via: 

TopicQueuesInfoArgs{...}

type TopicQueuesInfoOutput added in v0.0.22 

type TopicQueuesInfoOutput struct{ *pulumi.OutputState }

func (TopicQueuesInfoOutput) ElementType added in v0.0.22 

func (TopicQueuesInfoOutput) ElementType() reflect.Type

func (TopicQueuesInfoOutput) EndOffset added in v0.0.22 

func (o TopicQueuesInfoOutput) EndOffset() pulumi.IntPtrOutput

The maximum offset of the current queue, which is the offset of the next message. The position of the latest message is EndOffset - 1.

func (TopicQueuesInfoOutput) LastUpdateTimestamp added in v0.0.22 

func (o TopicQueuesInfoOutput) LastUpdateTimestamp() pulumi.IntPtrOutput

The time of the most recent message written to this queue.

func (TopicQueuesInfoOutput) MessageCount added in v0.0.22 

func (o TopicQueuesInfoOutput) MessageCount() pulumi.IntPtrOutput

The number of messages in the current queue. EndOffset is the offset of the next message, so MessageCount = EndOffset - StartOffset.

func (TopicQueuesInfoOutput) QueueId added in v0.0.22 

func (o TopicQueuesInfoOutput) QueueId() pulumi.StringPtrOutput

Queue ID.

func (TopicQueuesInfoOutput) StartOffset added in v0.0.22 

func (o TopicQueuesInfoOutput) StartOffset() pulumi.IntPtrOutput

The earliest message offset in the current queue.

func (TopicQueuesInfoOutput) ToTopicQueuesInfoOutput added in v0.0.22 

func (o TopicQueuesInfoOutput) ToTopicQueuesInfoOutput() TopicQueuesInfoOutput

func (TopicQueuesInfoOutput) ToTopicQueuesInfoOutputWithContext added in v0.0.22 

func (o TopicQueuesInfoOutput) ToTopicQueuesInfoOutputWithContext(ctx context.Context) TopicQueuesInfoOutput

type TopicReadAccessPolicy added in v0.0.22 

type TopicReadAccessPolicy struct {
	// AccessKey of the RocketMQ key.
	AccessKey *string `pulumi:"accessKey"`
	// User access permissions for the current Topic. ALL: Publish and subscribe permissions. PUB: Publish permission. SUB: Subscribe permission. DENY: No publish or subscribe permissions.
	Authority *string `pulumi:"authority"`
}

type TopicReadAccessPolicyArgs added in v0.0.22 

type TopicReadAccessPolicyArgs struct {
	// AccessKey of the RocketMQ key.
	AccessKey pulumi.StringPtrInput `pulumi:"accessKey"`
	// User access permissions for the current Topic. ALL: Publish and subscribe permissions. PUB: Publish permission. SUB: Subscribe permission. DENY: No publish or subscribe permissions.
	Authority pulumi.StringPtrInput `pulumi:"authority"`
}

func (TopicReadAccessPolicyArgs) ElementType added in v0.0.22 

func (TopicReadAccessPolicyArgs) ElementType() reflect.Type

func (TopicReadAccessPolicyArgs) ToTopicReadAccessPolicyOutput added in v0.0.22 

func (i TopicReadAccessPolicyArgs) ToTopicReadAccessPolicyOutput() TopicReadAccessPolicyOutput

func (TopicReadAccessPolicyArgs) ToTopicReadAccessPolicyOutputWithContext added in v0.0.22 

func (i TopicReadAccessPolicyArgs) ToTopicReadAccessPolicyOutputWithContext(ctx context.Context) TopicReadAccessPolicyOutput

type TopicReadAccessPolicyArray added in v0.0.22 

type TopicReadAccessPolicyArray []TopicReadAccessPolicyInput

func (TopicReadAccessPolicyArray) ElementType added in v0.0.22 

func (TopicReadAccessPolicyArray) ElementType() reflect.Type

func (TopicReadAccessPolicyArray) ToTopicReadAccessPolicyArrayOutput added in v0.0.22 

func (i TopicReadAccessPolicyArray) ToTopicReadAccessPolicyArrayOutput() TopicReadAccessPolicyArrayOutput

func (TopicReadAccessPolicyArray) ToTopicReadAccessPolicyArrayOutputWithContext added in v0.0.22 

func (i TopicReadAccessPolicyArray) ToTopicReadAccessPolicyArrayOutputWithContext(ctx context.Context) TopicReadAccessPolicyArrayOutput

type TopicReadAccessPolicyArrayInput added in v0.0.22 

type TopicReadAccessPolicyArrayInput interface {
	pulumi.Input

	ToTopicReadAccessPolicyArrayOutput() TopicReadAccessPolicyArrayOutput
	ToTopicReadAccessPolicyArrayOutputWithContext(context.Context) TopicReadAccessPolicyArrayOutput
}

TopicReadAccessPolicyArrayInput is an input type that accepts TopicReadAccessPolicyArray and TopicReadAccessPolicyArrayOutput values. You can construct a concrete instance of `TopicReadAccessPolicyArrayInput` via: 

TopicReadAccessPolicyArray{ TopicReadAccessPolicyArgs{...} }

type TopicReadAccessPolicyArrayOutput added in v0.0.22 

type TopicReadAccessPolicyArrayOutput struct{ *pulumi.OutputState }

func (TopicReadAccessPolicyArrayOutput) ElementType added in v0.0.22 

func (TopicReadAccessPolicyArrayOutput) ElementType() reflect.Type

func (TopicReadAccessPolicyArrayOutput) Index added in v0.0.22 

func (o TopicReadAccessPolicyArrayOutput) Index(i pulumi.IntInput) TopicReadAccessPolicyOutput

func (TopicReadAccessPolicyArrayOutput) ToTopicReadAccessPolicyArrayOutput added in v0.0.22 

func (o TopicReadAccessPolicyArrayOutput) ToTopicReadAccessPolicyArrayOutput() TopicReadAccessPolicyArrayOutput

func (TopicReadAccessPolicyArrayOutput) ToTopicReadAccessPolicyArrayOutputWithContext added in v0.0.22 

func (o TopicReadAccessPolicyArrayOutput) ToTopicReadAccessPolicyArrayOutputWithContext(ctx context.Context) TopicReadAccessPolicyArrayOutput

type TopicReadAccessPolicyInput added in v0.0.22 

type TopicReadAccessPolicyInput interface {
	pulumi.Input

	ToTopicReadAccessPolicyOutput() TopicReadAccessPolicyOutput
	ToTopicReadAccessPolicyOutputWithContext(context.Context) TopicReadAccessPolicyOutput
}

TopicReadAccessPolicyInput is an input type that accepts TopicReadAccessPolicyArgs and TopicReadAccessPolicyOutput values. You can construct a concrete instance of `TopicReadAccessPolicyInput` via: 

TopicReadAccessPolicyArgs{...}

type TopicReadAccessPolicyOutput added in v0.0.22 

type TopicReadAccessPolicyOutput struct{ *pulumi.OutputState }

func (TopicReadAccessPolicyOutput) AccessKey added in v0.0.22 

func (o TopicReadAccessPolicyOutput) AccessKey() pulumi.StringPtrOutput

AccessKey of the RocketMQ key.

func (TopicReadAccessPolicyOutput) Authority added in v0.0.22 

func (o TopicReadAccessPolicyOutput) Authority() pulumi.StringPtrOutput

User access permissions for the current Topic. ALL: Publish and subscribe permissions. PUB: Publish permission. SUB: Subscribe permission. DENY: No publish or subscribe permissions.

func (TopicReadAccessPolicyOutput) ElementType added in v0.0.22 

func (TopicReadAccessPolicyOutput) ElementType() reflect.Type

func (TopicReadAccessPolicyOutput) ToTopicReadAccessPolicyOutput added in v0.0.22 

func (o TopicReadAccessPolicyOutput) ToTopicReadAccessPolicyOutput() TopicReadAccessPolicyOutput

func (TopicReadAccessPolicyOutput) ToTopicReadAccessPolicyOutputWithContext added in v0.0.22 

func (o TopicReadAccessPolicyOutput) ToTopicReadAccessPolicyOutputWithContext(ctx context.Context) TopicReadAccessPolicyOutput

type TopicState added in v0.0.22 

type TopicState struct {
	AccessPolicies TopicAccessPolicyArrayInput
	// Topic creation time.
	CreatedTime pulumi.StringPtrInput
	// Topic description, length: 0–128 characters.
	Description pulumi.StringPtrInput
	GroupsInfos TopicGroupsInfoArrayInput
	// Instance ID.
	InstanceId pulumi.StringPtrInput
	// Instance name.
	InstanceName pulumi.StringPtrInput
	// Message type. Set this parameter to filter the Topic list by the specified message type. Value description: 0: Normal message. 1: Transaction message. 2: Partitioned ordered message. 3: Globally ordered message. 4: Delayed message.
	MessageType pulumi.IntPtrInput
	// Set the number of queues for the current Topic. The maximum cannot exceed the remaining available queues for the current instance. For queue limits per instance specification, refer to the product specifications. When creating a Topic in a 4.x version instance, set the number of queues as follows: For globally ordered Topics, the default queue number is 1. For other Topic types, the queue number depends on the compute specification. For n3 and below, the default is 6; for above n3, the default is twice the number of broker groups. It is recommended to set the queue number as a multiple of the number of compute nodes to avoid data imbalance across Brokers. For example, for the rocketmq.n3.x2.medium specification with 3 compute nodes, set the queue number to a multiple of 3, such as 3, 6, or 9. When creating a Topic in a 5.x version instance, set the number of queues as follows: For globally ordered Topics, the default queue number is 1. For other Topic types, the default is twice the number of broker groups. In non-ordered scenarios, performance is not affected by the number of queues; more queues only improve concurrent performance for ordered consumption.
	QueueNumber        pulumi.IntPtrInput
	QueuesInfos        TopicQueuesInfoArrayInput
	ReadAccessPolicies TopicReadAccessPolicyArrayInput
	// Service status. Creating: being created, Running: running, Deleting: being deleted, Abnormal: abnormal, Updating: being updated.
	ServiceStatus pulumi.StringPtrInput
	// Topic name. Naming rules: Length must be 3–100 characters. Only English letters, numbers, hyphens (-), and underscores (*) are allowed. Topic names cannot contain the following reserved characters or special prefixes. Reserved characters: RMQ*SYS*TRANS*OP*HALF*TOPIC, BenchmarkTest, TBW102, OFFSET*MOVED*EVENT, SELF*TEST*TOPIC, RMQ*SYS*TRANS*HALF*TOPIC, SCHEDULE*TOPIC*XXXX, RMQ*SYS*TRACE*TOPIC. Special prefixes: rocketmq-broker-, %RETRY%, rmq*sys_, %DLQ%.
	TopicName pulumi.StringPtrInput
}

func (TopicState) ElementType added in v0.0.22 

func (TopicState) ElementType() reflect.Type

Source Files

View all Source files

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.