tcmq

package
v0.1.8 Latest Latest
Warning

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

 Go to latest Published: Jan 26, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func PkgVersion 

func PkgVersion() (semver.Version, error)

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

Types

type GetQueueFilter 

type GetQueueFilter struct {
	// Filter parameter name.
	Name *string `pulumi:"name"`
	// Value.
	Values []string `pulumi:"values"`
}

type GetQueueFilterArgs 

type GetQueueFilterArgs struct {
	// Filter parameter name.
	Name pulumi.StringPtrInput `pulumi:"name"`
	// Value.
	Values pulumi.StringArrayInput `pulumi:"values"`
}

func (GetQueueFilterArgs) ElementType 

func (GetQueueFilterArgs) ElementType() reflect.Type

func (GetQueueFilterArgs) ToGetQueueFilterOutput 

func (i GetQueueFilterArgs) ToGetQueueFilterOutput() GetQueueFilterOutput

func (GetQueueFilterArgs) ToGetQueueFilterOutputWithContext 

func (i GetQueueFilterArgs) ToGetQueueFilterOutputWithContext(ctx context.Context) GetQueueFilterOutput

type GetQueueFilterArray 

type GetQueueFilterArray []GetQueueFilterInput

func (GetQueueFilterArray) ElementType 

func (GetQueueFilterArray) ElementType() reflect.Type

func (GetQueueFilterArray) ToGetQueueFilterArrayOutput 

func (i GetQueueFilterArray) ToGetQueueFilterArrayOutput() GetQueueFilterArrayOutput

func (GetQueueFilterArray) ToGetQueueFilterArrayOutputWithContext 

func (i GetQueueFilterArray) ToGetQueueFilterArrayOutputWithContext(ctx context.Context) GetQueueFilterArrayOutput

type GetQueueFilterArrayInput 

type GetQueueFilterArrayInput interface {
	pulumi.Input

	ToGetQueueFilterArrayOutput() GetQueueFilterArrayOutput
	ToGetQueueFilterArrayOutputWithContext(context.Context) GetQueueFilterArrayOutput
}

GetQueueFilterArrayInput is an input type that accepts GetQueueFilterArray and GetQueueFilterArrayOutput values. You can construct a concrete instance of `GetQueueFilterArrayInput` via: 

GetQueueFilterArray{ GetQueueFilterArgs{...} }

type GetQueueFilterArrayOutput 

type GetQueueFilterArrayOutput struct{ *pulumi.OutputState }

func (GetQueueFilterArrayOutput) ElementType 

func (GetQueueFilterArrayOutput) ElementType() reflect.Type

func (GetQueueFilterArrayOutput) Index 

func (o GetQueueFilterArrayOutput) Index(i pulumi.IntInput) GetQueueFilterOutput

func (GetQueueFilterArrayOutput) ToGetQueueFilterArrayOutput 

func (o GetQueueFilterArrayOutput) ToGetQueueFilterArrayOutput() GetQueueFilterArrayOutput

func (GetQueueFilterArrayOutput) ToGetQueueFilterArrayOutputWithContext 

func (o GetQueueFilterArrayOutput) ToGetQueueFilterArrayOutputWithContext(ctx context.Context) GetQueueFilterArrayOutput

type GetQueueFilterInput 

type GetQueueFilterInput interface {
	pulumi.Input

	ToGetQueueFilterOutput() GetQueueFilterOutput
	ToGetQueueFilterOutputWithContext(context.Context) GetQueueFilterOutput
}

GetQueueFilterInput is an input type that accepts GetQueueFilterArgs and GetQueueFilterOutput values. You can construct a concrete instance of `GetQueueFilterInput` via: 

GetQueueFilterArgs{...}

type GetQueueFilterOutput 

type GetQueueFilterOutput struct{ *pulumi.OutputState }

func (GetQueueFilterOutput) ElementType 

func (GetQueueFilterOutput) ElementType() reflect.Type

func (GetQueueFilterOutput) Name 

func (o GetQueueFilterOutput) Name() pulumi.StringPtrOutput

Filter parameter name.

func (GetQueueFilterOutput) ToGetQueueFilterOutput 

func (o GetQueueFilterOutput) ToGetQueueFilterOutput() GetQueueFilterOutput

func (GetQueueFilterOutput) ToGetQueueFilterOutputWithContext 

func (o GetQueueFilterOutput) ToGetQueueFilterOutputWithContext(ctx context.Context) GetQueueFilterOutput

func (GetQueueFilterOutput) Values 

func (o GetQueueFilterOutput) Values() pulumi.StringArrayOutput

Value.

type GetQueueQueueList 

type GetQueueQueueList struct {
	// Total number of messages in `Active` status (i.e., unconsumed) in the queue, which is an approximate value.
	ActiveMsgNum int `pulumi:"activeMsgNum"`
	// Bandwidth limit.
	Bps int `pulumi:"bps"`
	// Queue creation time. A Unix timestamp accurate down to the millisecond will be returned.
	CreateTime int `pulumi:"createTime"`
	// Creator `Uin`.
	CreateUin int `pulumi:"createUin"`
	// Dead letter queue policy.
	DeadLetterPolicies []GetQueueQueueListDeadLetterPolicy `pulumi:"deadLetterPolicies"`
	// Dead letter queue.
	DeadLetterSources []GetQueueQueueListDeadLetterSource `pulumi:"deadLetterSources"`
	// Number of delayed messages.
	DelayMsgNum int `pulumi:"delayMsgNum"`
	// Total number of messages in `Inactive` status (i.e., being consumed) in the queue, which is an approximate value.
	InactiveMsgNum int `pulumi:"inactiveMsgNum"`
	// Time when the queue attribute is last modified. A Unix timestamp accurate down to the millisecond will be returned.
	LastModifyTime int `pulumi:"lastModifyTime"`
	// Maximum retention period for inflight messages.
	MaxDelaySeconds int `pulumi:"maxDelaySeconds"`
	// Maximum size of heaped messages in bytes.
	MaxMsgBacklogSize int `pulumi:"maxMsgBacklogSize"`
	// Maximum number of heaped messages. The value range is 1,000,000-10,000,000 during the beta test and can be 1,000,000-1,000,000,000 after the product is officially released. The default value is 10,000,000 during the beta test and will be 100,000,000 after the product is officially released.
	MaxMsgHeapNum int `pulumi:"maxMsgHeapNum"`
	// Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.
	MaxMsgSize int `pulumi:"maxMsgSize"`
	// The maximum number of unacknowledged messages.
	MaxUnackedMsgNum int `pulumi:"maxUnackedMsgNum"`
	// Minimum unconsumed time of message in seconds.
	MinMsgTime int `pulumi:"minMsgTime"`
	// The max period during which a message is retained before it is automatically acknowledged. Value range: 30-43,200 seconds (30 seconds to 12 hours). Default value: 3600 seconds (1 hour).
	MsgRetentionSeconds int `pulumi:"msgRetentionSeconds"`
	// Namespace name.
	NamespaceName string `pulumi:"namespaceName"`
	// Long polling wait time for message reception. Value range: 0-30 seconds. Default value: 0.
	PollingWaitSeconds int `pulumi:"pollingWaitSeconds"`
	// Limit of the number of messages produced per second. The value for consumed messages is 1.1 times this value.
	Qps int `pulumi:"qps"`
	// Message queue ID.
	QueueId string `pulumi:"queueId"`
	// Filter by QueueName.
	QueueName string `pulumi:"queueName"`
	// Queue storage space configured for message rewind. Value range: 1,024-10,240 MB (if message rewind is enabled). The value `0` indicates that message rewind is not enabled.
	RetentionSizeInMb int `pulumi:"retentionSizeInMb"`
	// Number of retained messages which have been deleted by the `DelMsg` API but are still within their rewind time range.
	RewindMsgNum int `pulumi:"rewindMsgNum"`
	// Rewindable time of messages in the queue. Value range: 0-1,296,000s (if message rewind is enabled). The value `0` indicates that message rewind is not enabled.
	RewindSeconds int `pulumi:"rewindSeconds"`
	// Cluster status. `0`: creating; `1`: normal; `2`: terminating; `3`: deleted; `4`: isolated; `5`: creation failed; `6`: deletion failed.
	Status int `pulumi:"status"`
	// Associated tag.
	Tags []GetQueueQueueListTag `pulumi:"tags"`
	// Tenant ID.
	TenantId string `pulumi:"tenantId"`
	// Message trace. true: enabled; false: not enabled.
	Trace bool `pulumi:"trace"`
	// 1: transaction queue; 0: general queue.
	Transaction bool `pulumi:"transaction"`
	// Transaction message policy.
	TransactionPolicies []GetQueueQueueListTransactionPolicy `pulumi:"transactionPolicies"`
	// Message visibility timeout period. Value range: 1-43200 seconds (i.e., 12 hours). Default value: 30.
	VisibilityTimeout int `pulumi:"visibilityTimeout"`
}

type GetQueueQueueListArgs 

type GetQueueQueueListArgs struct {
	// Total number of messages in `Active` status (i.e., unconsumed) in the queue, which is an approximate value.
	ActiveMsgNum pulumi.IntInput `pulumi:"activeMsgNum"`
	// Bandwidth limit.
	Bps pulumi.IntInput `pulumi:"bps"`
	// Queue creation time. A Unix timestamp accurate down to the millisecond will be returned.
	CreateTime pulumi.IntInput `pulumi:"createTime"`
	// Creator `Uin`.
	CreateUin pulumi.IntInput `pulumi:"createUin"`
	// Dead letter queue policy.
	DeadLetterPolicies GetQueueQueueListDeadLetterPolicyArrayInput `pulumi:"deadLetterPolicies"`
	// Dead letter queue.
	DeadLetterSources GetQueueQueueListDeadLetterSourceArrayInput `pulumi:"deadLetterSources"`
	// Number of delayed messages.
	DelayMsgNum pulumi.IntInput `pulumi:"delayMsgNum"`
	// Total number of messages in `Inactive` status (i.e., being consumed) in the queue, which is an approximate value.
	InactiveMsgNum pulumi.IntInput `pulumi:"inactiveMsgNum"`
	// Time when the queue attribute is last modified. A Unix timestamp accurate down to the millisecond will be returned.
	LastModifyTime pulumi.IntInput `pulumi:"lastModifyTime"`
	// Maximum retention period for inflight messages.
	MaxDelaySeconds pulumi.IntInput `pulumi:"maxDelaySeconds"`
	// Maximum size of heaped messages in bytes.
	MaxMsgBacklogSize pulumi.IntInput `pulumi:"maxMsgBacklogSize"`
	// Maximum number of heaped messages. The value range is 1,000,000-10,000,000 during the beta test and can be 1,000,000-1,000,000,000 after the product is officially released. The default value is 10,000,000 during the beta test and will be 100,000,000 after the product is officially released.
	MaxMsgHeapNum pulumi.IntInput `pulumi:"maxMsgHeapNum"`
	// Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.
	MaxMsgSize pulumi.IntInput `pulumi:"maxMsgSize"`
	// The maximum number of unacknowledged messages.
	MaxUnackedMsgNum pulumi.IntInput `pulumi:"maxUnackedMsgNum"`
	// Minimum unconsumed time of message in seconds.
	MinMsgTime pulumi.IntInput `pulumi:"minMsgTime"`
	// The max period during which a message is retained before it is automatically acknowledged. Value range: 30-43,200 seconds (30 seconds to 12 hours). Default value: 3600 seconds (1 hour).
	MsgRetentionSeconds pulumi.IntInput `pulumi:"msgRetentionSeconds"`
	// Namespace name.
	NamespaceName pulumi.StringInput `pulumi:"namespaceName"`
	// Long polling wait time for message reception. Value range: 0-30 seconds. Default value: 0.
	PollingWaitSeconds pulumi.IntInput `pulumi:"pollingWaitSeconds"`
	// Limit of the number of messages produced per second. The value for consumed messages is 1.1 times this value.
	Qps pulumi.IntInput `pulumi:"qps"`
	// Message queue ID.
	QueueId pulumi.StringInput `pulumi:"queueId"`
	// Filter by QueueName.
	QueueName pulumi.StringInput `pulumi:"queueName"`
	// Queue storage space configured for message rewind. Value range: 1,024-10,240 MB (if message rewind is enabled). The value `0` indicates that message rewind is not enabled.
	RetentionSizeInMb pulumi.IntInput `pulumi:"retentionSizeInMb"`
	// Number of retained messages which have been deleted by the `DelMsg` API but are still within their rewind time range.
	RewindMsgNum pulumi.IntInput `pulumi:"rewindMsgNum"`
	// Rewindable time of messages in the queue. Value range: 0-1,296,000s (if message rewind is enabled). The value `0` indicates that message rewind is not enabled.
	RewindSeconds pulumi.IntInput `pulumi:"rewindSeconds"`
	// Cluster status. `0`: creating; `1`: normal; `2`: terminating; `3`: deleted; `4`: isolated; `5`: creation failed; `6`: deletion failed.
	Status pulumi.IntInput `pulumi:"status"`
	// Associated tag.
	Tags GetQueueQueueListTagArrayInput `pulumi:"tags"`
	// Tenant ID.
	TenantId pulumi.StringInput `pulumi:"tenantId"`
	// Message trace. true: enabled; false: not enabled.
	Trace pulumi.BoolInput `pulumi:"trace"`
	// 1: transaction queue; 0: general queue.
	Transaction pulumi.BoolInput `pulumi:"transaction"`
	// Transaction message policy.
	TransactionPolicies GetQueueQueueListTransactionPolicyArrayInput `pulumi:"transactionPolicies"`
	// Message visibility timeout period. Value range: 1-43200 seconds (i.e., 12 hours). Default value: 30.
	VisibilityTimeout pulumi.IntInput `pulumi:"visibilityTimeout"`
}

func (GetQueueQueueListArgs) ElementType 

func (GetQueueQueueListArgs) ElementType() reflect.Type

func (GetQueueQueueListArgs) ToGetQueueQueueListOutput 

func (i GetQueueQueueListArgs) ToGetQueueQueueListOutput() GetQueueQueueListOutput

func (GetQueueQueueListArgs) ToGetQueueQueueListOutputWithContext 

func (i GetQueueQueueListArgs) ToGetQueueQueueListOutputWithContext(ctx context.Context) GetQueueQueueListOutput

type GetQueueQueueListArray 

type GetQueueQueueListArray []GetQueueQueueListInput

func (GetQueueQueueListArray) ElementType 

func (GetQueueQueueListArray) ElementType() reflect.Type

func (GetQueueQueueListArray) ToGetQueueQueueListArrayOutput 

func (i GetQueueQueueListArray) ToGetQueueQueueListArrayOutput() GetQueueQueueListArrayOutput

func (GetQueueQueueListArray) ToGetQueueQueueListArrayOutputWithContext 

func (i GetQueueQueueListArray) ToGetQueueQueueListArrayOutputWithContext(ctx context.Context) GetQueueQueueListArrayOutput

type GetQueueQueueListArrayInput 

type GetQueueQueueListArrayInput interface {
	pulumi.Input

	ToGetQueueQueueListArrayOutput() GetQueueQueueListArrayOutput
	ToGetQueueQueueListArrayOutputWithContext(context.Context) GetQueueQueueListArrayOutput
}

GetQueueQueueListArrayInput is an input type that accepts GetQueueQueueListArray and GetQueueQueueListArrayOutput values. You can construct a concrete instance of `GetQueueQueueListArrayInput` via: 

GetQueueQueueListArray{ GetQueueQueueListArgs{...} }

type GetQueueQueueListArrayOutput 

type GetQueueQueueListArrayOutput struct{ *pulumi.OutputState }

func (GetQueueQueueListArrayOutput) ElementType 

func (GetQueueQueueListArrayOutput) ElementType() reflect.Type

func (GetQueueQueueListArrayOutput) Index 

func (o GetQueueQueueListArrayOutput) Index(i pulumi.IntInput) GetQueueQueueListOutput

func (GetQueueQueueListArrayOutput) ToGetQueueQueueListArrayOutput 

func (o GetQueueQueueListArrayOutput) ToGetQueueQueueListArrayOutput() GetQueueQueueListArrayOutput

func (GetQueueQueueListArrayOutput) ToGetQueueQueueListArrayOutputWithContext 

func (o GetQueueQueueListArrayOutput) ToGetQueueQueueListArrayOutputWithContext(ctx context.Context) GetQueueQueueListArrayOutput

type GetQueueQueueListDeadLetterPolicy 

type GetQueueQueueListDeadLetterPolicy struct {
	// Dead letter queue.
	DeadLetterQueue string `pulumi:"deadLetterQueue"`
	// Maximum number of receipts.
	MaxReceiveCount int `pulumi:"maxReceiveCount"`
	// Maximum period in seconds before an unconsumed message expires, which is required if `Policy` is 1. Value range: 300-43200. This value should be smaller than `MsgRetentionSeconds` (maximum message retention period).
	MaxTimeToLive int `pulumi:"maxTimeToLive"`
	// Dead letter queue policy.
	Policy int `pulumi:"policy"`
}

type GetQueueQueueListDeadLetterPolicyArgs 

type GetQueueQueueListDeadLetterPolicyArgs struct {
	// Dead letter queue.
	DeadLetterQueue pulumi.StringInput `pulumi:"deadLetterQueue"`
	// Maximum number of receipts.
	MaxReceiveCount pulumi.IntInput `pulumi:"maxReceiveCount"`
	// Maximum period in seconds before an unconsumed message expires, which is required if `Policy` is 1. Value range: 300-43200. This value should be smaller than `MsgRetentionSeconds` (maximum message retention period).
	MaxTimeToLive pulumi.IntInput `pulumi:"maxTimeToLive"`
	// Dead letter queue policy.
	Policy pulumi.IntInput `pulumi:"policy"`
}

func (GetQueueQueueListDeadLetterPolicyArgs) ElementType 

func (GetQueueQueueListDeadLetterPolicyArgs) ElementType() reflect.Type

func (GetQueueQueueListDeadLetterPolicyArgs) ToGetQueueQueueListDeadLetterPolicyOutput 

func (i GetQueueQueueListDeadLetterPolicyArgs) ToGetQueueQueueListDeadLetterPolicyOutput() GetQueueQueueListDeadLetterPolicyOutput

func (GetQueueQueueListDeadLetterPolicyArgs) ToGetQueueQueueListDeadLetterPolicyOutputWithContext 

func (i GetQueueQueueListDeadLetterPolicyArgs) ToGetQueueQueueListDeadLetterPolicyOutputWithContext(ctx context.Context) GetQueueQueueListDeadLetterPolicyOutput

type GetQueueQueueListDeadLetterPolicyArray 

type GetQueueQueueListDeadLetterPolicyArray []GetQueueQueueListDeadLetterPolicyInput

func (GetQueueQueueListDeadLetterPolicyArray) ElementType 

func (GetQueueQueueListDeadLetterPolicyArray) ElementType() reflect.Type

func (GetQueueQueueListDeadLetterPolicyArray) ToGetQueueQueueListDeadLetterPolicyArrayOutput 

func (i GetQueueQueueListDeadLetterPolicyArray) ToGetQueueQueueListDeadLetterPolicyArrayOutput() GetQueueQueueListDeadLetterPolicyArrayOutput

func (GetQueueQueueListDeadLetterPolicyArray) ToGetQueueQueueListDeadLetterPolicyArrayOutputWithContext 

func (i GetQueueQueueListDeadLetterPolicyArray) ToGetQueueQueueListDeadLetterPolicyArrayOutputWithContext(ctx context.Context) GetQueueQueueListDeadLetterPolicyArrayOutput

type GetQueueQueueListDeadLetterPolicyArrayInput 

type GetQueueQueueListDeadLetterPolicyArrayInput interface {
	pulumi.Input

	ToGetQueueQueueListDeadLetterPolicyArrayOutput() GetQueueQueueListDeadLetterPolicyArrayOutput
	ToGetQueueQueueListDeadLetterPolicyArrayOutputWithContext(context.Context) GetQueueQueueListDeadLetterPolicyArrayOutput
}

GetQueueQueueListDeadLetterPolicyArrayInput is an input type that accepts GetQueueQueueListDeadLetterPolicyArray and GetQueueQueueListDeadLetterPolicyArrayOutput values. You can construct a concrete instance of `GetQueueQueueListDeadLetterPolicyArrayInput` via: 

GetQueueQueueListDeadLetterPolicyArray{ GetQueueQueueListDeadLetterPolicyArgs{...} }

type GetQueueQueueListDeadLetterPolicyArrayOutput 

type GetQueueQueueListDeadLetterPolicyArrayOutput struct{ *pulumi.OutputState }

func (GetQueueQueueListDeadLetterPolicyArrayOutput) ElementType 

func (GetQueueQueueListDeadLetterPolicyArrayOutput) ElementType() reflect.Type

func (GetQueueQueueListDeadLetterPolicyArrayOutput) Index 

func (o GetQueueQueueListDeadLetterPolicyArrayOutput) Index(i pulumi.IntInput) GetQueueQueueListDeadLetterPolicyOutput

func (GetQueueQueueListDeadLetterPolicyArrayOutput) ToGetQueueQueueListDeadLetterPolicyArrayOutput 

func (o GetQueueQueueListDeadLetterPolicyArrayOutput) ToGetQueueQueueListDeadLetterPolicyArrayOutput() GetQueueQueueListDeadLetterPolicyArrayOutput

func (GetQueueQueueListDeadLetterPolicyArrayOutput) ToGetQueueQueueListDeadLetterPolicyArrayOutputWithContext 

func (o GetQueueQueueListDeadLetterPolicyArrayOutput) ToGetQueueQueueListDeadLetterPolicyArrayOutputWithContext(ctx context.Context) GetQueueQueueListDeadLetterPolicyArrayOutput

type GetQueueQueueListDeadLetterPolicyInput 

type GetQueueQueueListDeadLetterPolicyInput interface {
	pulumi.Input

	ToGetQueueQueueListDeadLetterPolicyOutput() GetQueueQueueListDeadLetterPolicyOutput
	ToGetQueueQueueListDeadLetterPolicyOutputWithContext(context.Context) GetQueueQueueListDeadLetterPolicyOutput
}

GetQueueQueueListDeadLetterPolicyInput is an input type that accepts GetQueueQueueListDeadLetterPolicyArgs and GetQueueQueueListDeadLetterPolicyOutput values. You can construct a concrete instance of `GetQueueQueueListDeadLetterPolicyInput` via: 

GetQueueQueueListDeadLetterPolicyArgs{...}

type GetQueueQueueListDeadLetterPolicyOutput 

type GetQueueQueueListDeadLetterPolicyOutput struct{ *pulumi.OutputState }

func (GetQueueQueueListDeadLetterPolicyOutput) DeadLetterQueue 

func (o GetQueueQueueListDeadLetterPolicyOutput) DeadLetterQueue() pulumi.StringOutput

Dead letter queue.

func (GetQueueQueueListDeadLetterPolicyOutput) ElementType 

func (GetQueueQueueListDeadLetterPolicyOutput) ElementType() reflect.Type

func (GetQueueQueueListDeadLetterPolicyOutput) MaxReceiveCount 

func (o GetQueueQueueListDeadLetterPolicyOutput) MaxReceiveCount() pulumi.IntOutput

Maximum number of receipts.

func (GetQueueQueueListDeadLetterPolicyOutput) MaxTimeToLive 

func (o GetQueueQueueListDeadLetterPolicyOutput) MaxTimeToLive() pulumi.IntOutput

Maximum period in seconds before an unconsumed message expires, which is required if `Policy` is 1. Value range: 300-43200. This value should be smaller than `MsgRetentionSeconds` (maximum message retention period).

func (GetQueueQueueListDeadLetterPolicyOutput) Policy 

func (o GetQueueQueueListDeadLetterPolicyOutput) Policy() pulumi.IntOutput

Dead letter queue policy.

func (GetQueueQueueListDeadLetterPolicyOutput) ToGetQueueQueueListDeadLetterPolicyOutput 

func (o GetQueueQueueListDeadLetterPolicyOutput) ToGetQueueQueueListDeadLetterPolicyOutput() GetQueueQueueListDeadLetterPolicyOutput

func (GetQueueQueueListDeadLetterPolicyOutput) ToGetQueueQueueListDeadLetterPolicyOutputWithContext 

func (o GetQueueQueueListDeadLetterPolicyOutput) ToGetQueueQueueListDeadLetterPolicyOutputWithContext(ctx context.Context) GetQueueQueueListDeadLetterPolicyOutput

type GetQueueQueueListDeadLetterSource 

type GetQueueQueueListDeadLetterSource struct {
	// Message queue ID.
	QueueId string `pulumi:"queueId"`
	// Filter by QueueName.
	QueueName string `pulumi:"queueName"`
}

type GetQueueQueueListDeadLetterSourceArgs 

type GetQueueQueueListDeadLetterSourceArgs struct {
	// Message queue ID.
	QueueId pulumi.StringInput `pulumi:"queueId"`
	// Filter by QueueName.
	QueueName pulumi.StringInput `pulumi:"queueName"`
}

func (GetQueueQueueListDeadLetterSourceArgs) ElementType 

func (GetQueueQueueListDeadLetterSourceArgs) ElementType() reflect.Type

func (GetQueueQueueListDeadLetterSourceArgs) ToGetQueueQueueListDeadLetterSourceOutput 

func (i GetQueueQueueListDeadLetterSourceArgs) ToGetQueueQueueListDeadLetterSourceOutput() GetQueueQueueListDeadLetterSourceOutput

func (GetQueueQueueListDeadLetterSourceArgs) ToGetQueueQueueListDeadLetterSourceOutputWithContext 

func (i GetQueueQueueListDeadLetterSourceArgs) ToGetQueueQueueListDeadLetterSourceOutputWithContext(ctx context.Context) GetQueueQueueListDeadLetterSourceOutput

type GetQueueQueueListDeadLetterSourceArray 

type GetQueueQueueListDeadLetterSourceArray []GetQueueQueueListDeadLetterSourceInput

func (GetQueueQueueListDeadLetterSourceArray) ElementType 

func (GetQueueQueueListDeadLetterSourceArray) ElementType() reflect.Type

func (GetQueueQueueListDeadLetterSourceArray) ToGetQueueQueueListDeadLetterSourceArrayOutput 

func (i GetQueueQueueListDeadLetterSourceArray) ToGetQueueQueueListDeadLetterSourceArrayOutput() GetQueueQueueListDeadLetterSourceArrayOutput

func (GetQueueQueueListDeadLetterSourceArray) ToGetQueueQueueListDeadLetterSourceArrayOutputWithContext 

func (i GetQueueQueueListDeadLetterSourceArray) ToGetQueueQueueListDeadLetterSourceArrayOutputWithContext(ctx context.Context) GetQueueQueueListDeadLetterSourceArrayOutput

type GetQueueQueueListDeadLetterSourceArrayInput 

type GetQueueQueueListDeadLetterSourceArrayInput interface {
	pulumi.Input

	ToGetQueueQueueListDeadLetterSourceArrayOutput() GetQueueQueueListDeadLetterSourceArrayOutput
	ToGetQueueQueueListDeadLetterSourceArrayOutputWithContext(context.Context) GetQueueQueueListDeadLetterSourceArrayOutput
}

GetQueueQueueListDeadLetterSourceArrayInput is an input type that accepts GetQueueQueueListDeadLetterSourceArray and GetQueueQueueListDeadLetterSourceArrayOutput values. You can construct a concrete instance of `GetQueueQueueListDeadLetterSourceArrayInput` via: 

GetQueueQueueListDeadLetterSourceArray{ GetQueueQueueListDeadLetterSourceArgs{...} }

type GetQueueQueueListDeadLetterSourceArrayOutput 

type GetQueueQueueListDeadLetterSourceArrayOutput struct{ *pulumi.OutputState }

func (GetQueueQueueListDeadLetterSourceArrayOutput) ElementType 

func (GetQueueQueueListDeadLetterSourceArrayOutput) ElementType() reflect.Type

func (GetQueueQueueListDeadLetterSourceArrayOutput) Index 

func (o GetQueueQueueListDeadLetterSourceArrayOutput) Index(i pulumi.IntInput) GetQueueQueueListDeadLetterSourceOutput

func (GetQueueQueueListDeadLetterSourceArrayOutput) ToGetQueueQueueListDeadLetterSourceArrayOutput 

func (o GetQueueQueueListDeadLetterSourceArrayOutput) ToGetQueueQueueListDeadLetterSourceArrayOutput() GetQueueQueueListDeadLetterSourceArrayOutput

func (GetQueueQueueListDeadLetterSourceArrayOutput) ToGetQueueQueueListDeadLetterSourceArrayOutputWithContext 

func (o GetQueueQueueListDeadLetterSourceArrayOutput) ToGetQueueQueueListDeadLetterSourceArrayOutputWithContext(ctx context.Context) GetQueueQueueListDeadLetterSourceArrayOutput

type GetQueueQueueListDeadLetterSourceInput 

type GetQueueQueueListDeadLetterSourceInput interface {
	pulumi.Input

	ToGetQueueQueueListDeadLetterSourceOutput() GetQueueQueueListDeadLetterSourceOutput
	ToGetQueueQueueListDeadLetterSourceOutputWithContext(context.Context) GetQueueQueueListDeadLetterSourceOutput
}

GetQueueQueueListDeadLetterSourceInput is an input type that accepts GetQueueQueueListDeadLetterSourceArgs and GetQueueQueueListDeadLetterSourceOutput values. You can construct a concrete instance of `GetQueueQueueListDeadLetterSourceInput` via: 

GetQueueQueueListDeadLetterSourceArgs{...}

type GetQueueQueueListDeadLetterSourceOutput 

type GetQueueQueueListDeadLetterSourceOutput struct{ *pulumi.OutputState }

func (GetQueueQueueListDeadLetterSourceOutput) ElementType 

func (GetQueueQueueListDeadLetterSourceOutput) ElementType() reflect.Type

func (GetQueueQueueListDeadLetterSourceOutput) QueueId 

func (o GetQueueQueueListDeadLetterSourceOutput) QueueId() pulumi.StringOutput

Message queue ID.

func (GetQueueQueueListDeadLetterSourceOutput) QueueName 

func (o GetQueueQueueListDeadLetterSourceOutput) QueueName() pulumi.StringOutput

Filter by QueueName.

func (GetQueueQueueListDeadLetterSourceOutput) ToGetQueueQueueListDeadLetterSourceOutput 

func (o GetQueueQueueListDeadLetterSourceOutput) ToGetQueueQueueListDeadLetterSourceOutput() GetQueueQueueListDeadLetterSourceOutput

func (GetQueueQueueListDeadLetterSourceOutput) ToGetQueueQueueListDeadLetterSourceOutputWithContext 

func (o GetQueueQueueListDeadLetterSourceOutput) ToGetQueueQueueListDeadLetterSourceOutputWithContext(ctx context.Context) GetQueueQueueListDeadLetterSourceOutput

type GetQueueQueueListInput 

type GetQueueQueueListInput interface {
	pulumi.Input

	ToGetQueueQueueListOutput() GetQueueQueueListOutput
	ToGetQueueQueueListOutputWithContext(context.Context) GetQueueQueueListOutput
}

GetQueueQueueListInput is an input type that accepts GetQueueQueueListArgs and GetQueueQueueListOutput values. You can construct a concrete instance of `GetQueueQueueListInput` via: 

GetQueueQueueListArgs{...}

type GetQueueQueueListOutput 

type GetQueueQueueListOutput struct{ *pulumi.OutputState }

func (GetQueueQueueListOutput) ActiveMsgNum 

func (o GetQueueQueueListOutput) ActiveMsgNum() pulumi.IntOutput

Total number of messages in `Active` status (i.e., unconsumed) in the queue, which is an approximate value.

func (GetQueueQueueListOutput) Bps 

func (o GetQueueQueueListOutput) Bps() pulumi.IntOutput

Bandwidth limit.

func (GetQueueQueueListOutput) CreateTime 

func (o GetQueueQueueListOutput) CreateTime() pulumi.IntOutput

Queue creation time. A Unix timestamp accurate down to the millisecond will be returned.

func (GetQueueQueueListOutput) CreateUin 

func (o GetQueueQueueListOutput) CreateUin() pulumi.IntOutput

Creator `Uin`.

func (GetQueueQueueListOutput) DeadLetterPolicies 

func (o GetQueueQueueListOutput) DeadLetterPolicies() GetQueueQueueListDeadLetterPolicyArrayOutput

Dead letter queue policy.

func (GetQueueQueueListOutput) DeadLetterSources 

func (o GetQueueQueueListOutput) DeadLetterSources() GetQueueQueueListDeadLetterSourceArrayOutput

Dead letter queue.

func (GetQueueQueueListOutput) DelayMsgNum 

func (o GetQueueQueueListOutput) DelayMsgNum() pulumi.IntOutput

Number of delayed messages.

func (GetQueueQueueListOutput) ElementType 

func (GetQueueQueueListOutput) ElementType() reflect.Type

func (GetQueueQueueListOutput) InactiveMsgNum 

func (o GetQueueQueueListOutput) InactiveMsgNum() pulumi.IntOutput

Total number of messages in `Inactive` status (i.e., being consumed) in the queue, which is an approximate value.

func (GetQueueQueueListOutput) LastModifyTime 

func (o GetQueueQueueListOutput) LastModifyTime() pulumi.IntOutput

Time when the queue attribute is last modified. A Unix timestamp accurate down to the millisecond will be returned.

func (GetQueueQueueListOutput) MaxDelaySeconds 

func (o GetQueueQueueListOutput) MaxDelaySeconds() pulumi.IntOutput

Maximum retention period for inflight messages.

func (GetQueueQueueListOutput) MaxMsgBacklogSize 

func (o GetQueueQueueListOutput) MaxMsgBacklogSize() pulumi.IntOutput

Maximum size of heaped messages in bytes.

func (GetQueueQueueListOutput) MaxMsgHeapNum 

func (o GetQueueQueueListOutput) MaxMsgHeapNum() pulumi.IntOutput

Maximum number of heaped messages. The value range is 1,000,000-10,000,000 during the beta test and can be 1,000,000-1,000,000,000 after the product is officially released. The default value is 10,000,000 during the beta test and will be 100,000,000 after the product is officially released.

func (GetQueueQueueListOutput) MaxMsgSize 

func (o GetQueueQueueListOutput) MaxMsgSize() pulumi.IntOutput

Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.

func (GetQueueQueueListOutput) MaxUnackedMsgNum 

func (o GetQueueQueueListOutput) MaxUnackedMsgNum() pulumi.IntOutput

The maximum number of unacknowledged messages.

func (GetQueueQueueListOutput) MinMsgTime 

func (o GetQueueQueueListOutput) MinMsgTime() pulumi.IntOutput

Minimum unconsumed time of message in seconds.

func (GetQueueQueueListOutput) MsgRetentionSeconds 

func (o GetQueueQueueListOutput) MsgRetentionSeconds() pulumi.IntOutput

The max period during which a message is retained before it is automatically acknowledged. Value range: 30-43,200 seconds (30 seconds to 12 hours). Default value: 3600 seconds (1 hour).

func (GetQueueQueueListOutput) NamespaceName 

func (o GetQueueQueueListOutput) NamespaceName() pulumi.StringOutput

Namespace name.

func (GetQueueQueueListOutput) PollingWaitSeconds 

func (o GetQueueQueueListOutput) PollingWaitSeconds() pulumi.IntOutput

Long polling wait time for message reception. Value range: 0-30 seconds. Default value: 0.

func (GetQueueQueueListOutput) Qps 

func (o GetQueueQueueListOutput) Qps() pulumi.IntOutput

Limit of the number of messages produced per second. The value for consumed messages is 1.1 times this value.

func (GetQueueQueueListOutput) QueueId 

func (o GetQueueQueueListOutput) QueueId() pulumi.StringOutput

Message queue ID.

func (GetQueueQueueListOutput) QueueName 

func (o GetQueueQueueListOutput) QueueName() pulumi.StringOutput

Filter by QueueName.

func (GetQueueQueueListOutput) RetentionSizeInMb 

func (o GetQueueQueueListOutput) RetentionSizeInMb() pulumi.IntOutput

Queue storage space configured for message rewind. Value range: 1,024-10,240 MB (if message rewind is enabled). The value `0` indicates that message rewind is not enabled.

func (GetQueueQueueListOutput) RewindMsgNum 

func (o GetQueueQueueListOutput) RewindMsgNum() pulumi.IntOutput

Number of retained messages which have been deleted by the `DelMsg` API but are still within their rewind time range.

func (GetQueueQueueListOutput) RewindSeconds 

func (o GetQueueQueueListOutput) RewindSeconds() pulumi.IntOutput

Rewindable time of messages in the queue. Value range: 0-1,296,000s (if message rewind is enabled). The value `0` indicates that message rewind is not enabled.

func (GetQueueQueueListOutput) Status 

func (o GetQueueQueueListOutput) Status() pulumi.IntOutput

Cluster status. `0`: creating; `1`: normal; `2`: terminating; `3`: deleted; `4`: isolated; `5`: creation failed; `6`: deletion failed.

func (GetQueueQueueListOutput) Tags 

func (o GetQueueQueueListOutput) Tags() GetQueueQueueListTagArrayOutput

Associated tag.

func (GetQueueQueueListOutput) TenantId 

func (o GetQueueQueueListOutput) TenantId() pulumi.StringOutput

Tenant ID.

func (GetQueueQueueListOutput) ToGetQueueQueueListOutput 

func (o GetQueueQueueListOutput) ToGetQueueQueueListOutput() GetQueueQueueListOutput

func (GetQueueQueueListOutput) ToGetQueueQueueListOutputWithContext 

func (o GetQueueQueueListOutput) ToGetQueueQueueListOutputWithContext(ctx context.Context) GetQueueQueueListOutput

func (GetQueueQueueListOutput) Trace 

func (o GetQueueQueueListOutput) Trace() pulumi.BoolOutput

Message trace. true: enabled; false: not enabled.

func (GetQueueQueueListOutput) Transaction 

func (o GetQueueQueueListOutput) Transaction() pulumi.BoolOutput

1: transaction queue; 0: general queue.

func (GetQueueQueueListOutput) TransactionPolicies 

func (o GetQueueQueueListOutput) TransactionPolicies() GetQueueQueueListTransactionPolicyArrayOutput

Transaction message policy.

func (GetQueueQueueListOutput) VisibilityTimeout 

func (o GetQueueQueueListOutput) VisibilityTimeout() pulumi.IntOutput

Message visibility timeout period. Value range: 1-43200 seconds (i.e., 12 hours). Default value: 30.

type GetQueueQueueListTag 

type GetQueueQueueListTag struct {
	// Value of the tag key.
	TagKey string `pulumi:"tagKey"`
	// Value of the tag value.
	TagValue string `pulumi:"tagValue"`
}

type GetQueueQueueListTagArgs 

type GetQueueQueueListTagArgs struct {
	// Value of the tag key.
	TagKey pulumi.StringInput `pulumi:"tagKey"`
	// Value of the tag value.
	TagValue pulumi.StringInput `pulumi:"tagValue"`
}

func (GetQueueQueueListTagArgs) ElementType 

func (GetQueueQueueListTagArgs) ElementType() reflect.Type

func (GetQueueQueueListTagArgs) ToGetQueueQueueListTagOutput 

func (i GetQueueQueueListTagArgs) ToGetQueueQueueListTagOutput() GetQueueQueueListTagOutput

func (GetQueueQueueListTagArgs) ToGetQueueQueueListTagOutputWithContext 

func (i GetQueueQueueListTagArgs) ToGetQueueQueueListTagOutputWithContext(ctx context.Context) GetQueueQueueListTagOutput

type GetQueueQueueListTagArray 

type GetQueueQueueListTagArray []GetQueueQueueListTagInput

func (GetQueueQueueListTagArray) ElementType 

func (GetQueueQueueListTagArray) ElementType() reflect.Type

func (GetQueueQueueListTagArray) ToGetQueueQueueListTagArrayOutput 

func (i GetQueueQueueListTagArray) ToGetQueueQueueListTagArrayOutput() GetQueueQueueListTagArrayOutput

func (GetQueueQueueListTagArray) ToGetQueueQueueListTagArrayOutputWithContext 

func (i GetQueueQueueListTagArray) ToGetQueueQueueListTagArrayOutputWithContext(ctx context.Context) GetQueueQueueListTagArrayOutput

type GetQueueQueueListTagArrayInput 

type GetQueueQueueListTagArrayInput interface {
	pulumi.Input

	ToGetQueueQueueListTagArrayOutput() GetQueueQueueListTagArrayOutput
	ToGetQueueQueueListTagArrayOutputWithContext(context.Context) GetQueueQueueListTagArrayOutput
}

GetQueueQueueListTagArrayInput is an input type that accepts GetQueueQueueListTagArray and GetQueueQueueListTagArrayOutput values. You can construct a concrete instance of `GetQueueQueueListTagArrayInput` via: 

GetQueueQueueListTagArray{ GetQueueQueueListTagArgs{...} }

type GetQueueQueueListTagArrayOutput 

type GetQueueQueueListTagArrayOutput struct{ *pulumi.OutputState }

func (GetQueueQueueListTagArrayOutput) ElementType 

func (GetQueueQueueListTagArrayOutput) ElementType() reflect.Type

func (GetQueueQueueListTagArrayOutput) Index 

func (o GetQueueQueueListTagArrayOutput) Index(i pulumi.IntInput) GetQueueQueueListTagOutput

func (GetQueueQueueListTagArrayOutput) ToGetQueueQueueListTagArrayOutput 

func (o GetQueueQueueListTagArrayOutput) ToGetQueueQueueListTagArrayOutput() GetQueueQueueListTagArrayOutput

func (GetQueueQueueListTagArrayOutput) ToGetQueueQueueListTagArrayOutputWithContext 

func (o GetQueueQueueListTagArrayOutput) ToGetQueueQueueListTagArrayOutputWithContext(ctx context.Context) GetQueueQueueListTagArrayOutput

type GetQueueQueueListTagInput 

type GetQueueQueueListTagInput interface {
	pulumi.Input

	ToGetQueueQueueListTagOutput() GetQueueQueueListTagOutput
	ToGetQueueQueueListTagOutputWithContext(context.Context) GetQueueQueueListTagOutput
}

GetQueueQueueListTagInput is an input type that accepts GetQueueQueueListTagArgs and GetQueueQueueListTagOutput values. You can construct a concrete instance of `GetQueueQueueListTagInput` via: 

GetQueueQueueListTagArgs{...}

type GetQueueQueueListTagOutput 

type GetQueueQueueListTagOutput struct{ *pulumi.OutputState }

func (GetQueueQueueListTagOutput) ElementType 

func (GetQueueQueueListTagOutput) ElementType() reflect.Type

func (GetQueueQueueListTagOutput) TagKey 

func (o GetQueueQueueListTagOutput) TagKey() pulumi.StringOutput

Value of the tag key.

func (GetQueueQueueListTagOutput) TagValue 

func (o GetQueueQueueListTagOutput) TagValue() pulumi.StringOutput

Value of the tag value.

func (GetQueueQueueListTagOutput) ToGetQueueQueueListTagOutput 

func (o GetQueueQueueListTagOutput) ToGetQueueQueueListTagOutput() GetQueueQueueListTagOutput

func (GetQueueQueueListTagOutput) ToGetQueueQueueListTagOutputWithContext 

func (o GetQueueQueueListTagOutput) ToGetQueueQueueListTagOutputWithContext(ctx context.Context) GetQueueQueueListTagOutput

type GetQueueQueueListTransactionPolicy 

type GetQueueQueueListTransactionPolicy struct {
	// First lookback time.
	FirstQueryInterval int `pulumi:"firstQueryInterval"`
	// Maximum number of queries.
	MaxQueryCount int `pulumi:"maxQueryCount"`
}

type GetQueueQueueListTransactionPolicyArgs 

type GetQueueQueueListTransactionPolicyArgs struct {
	// First lookback time.
	FirstQueryInterval pulumi.IntInput `pulumi:"firstQueryInterval"`
	// Maximum number of queries.
	MaxQueryCount pulumi.IntInput `pulumi:"maxQueryCount"`
}

func (GetQueueQueueListTransactionPolicyArgs) ElementType 

func (GetQueueQueueListTransactionPolicyArgs) ElementType() reflect.Type

func (GetQueueQueueListTransactionPolicyArgs) ToGetQueueQueueListTransactionPolicyOutput 

func (i GetQueueQueueListTransactionPolicyArgs) ToGetQueueQueueListTransactionPolicyOutput() GetQueueQueueListTransactionPolicyOutput

func (GetQueueQueueListTransactionPolicyArgs) ToGetQueueQueueListTransactionPolicyOutputWithContext 

func (i GetQueueQueueListTransactionPolicyArgs) ToGetQueueQueueListTransactionPolicyOutputWithContext(ctx context.Context) GetQueueQueueListTransactionPolicyOutput

type GetQueueQueueListTransactionPolicyArray 

type GetQueueQueueListTransactionPolicyArray []GetQueueQueueListTransactionPolicyInput

func (GetQueueQueueListTransactionPolicyArray) ElementType 

func (GetQueueQueueListTransactionPolicyArray) ElementType() reflect.Type

func (GetQueueQueueListTransactionPolicyArray) ToGetQueueQueueListTransactionPolicyArrayOutput 

func (i GetQueueQueueListTransactionPolicyArray) ToGetQueueQueueListTransactionPolicyArrayOutput() GetQueueQueueListTransactionPolicyArrayOutput

func (GetQueueQueueListTransactionPolicyArray) ToGetQueueQueueListTransactionPolicyArrayOutputWithContext 

func (i GetQueueQueueListTransactionPolicyArray) ToGetQueueQueueListTransactionPolicyArrayOutputWithContext(ctx context.Context) GetQueueQueueListTransactionPolicyArrayOutput

type GetQueueQueueListTransactionPolicyArrayInput 

type GetQueueQueueListTransactionPolicyArrayInput interface {
	pulumi.Input

	ToGetQueueQueueListTransactionPolicyArrayOutput() GetQueueQueueListTransactionPolicyArrayOutput
	ToGetQueueQueueListTransactionPolicyArrayOutputWithContext(context.Context) GetQueueQueueListTransactionPolicyArrayOutput
}

GetQueueQueueListTransactionPolicyArrayInput is an input type that accepts GetQueueQueueListTransactionPolicyArray and GetQueueQueueListTransactionPolicyArrayOutput values. You can construct a concrete instance of `GetQueueQueueListTransactionPolicyArrayInput` via: 

GetQueueQueueListTransactionPolicyArray{ GetQueueQueueListTransactionPolicyArgs{...} }

type GetQueueQueueListTransactionPolicyArrayOutput 

type GetQueueQueueListTransactionPolicyArrayOutput struct{ *pulumi.OutputState }

func (GetQueueQueueListTransactionPolicyArrayOutput) ElementType 

func (GetQueueQueueListTransactionPolicyArrayOutput) ElementType() reflect.Type

func (GetQueueQueueListTransactionPolicyArrayOutput) Index 

func (o GetQueueQueueListTransactionPolicyArrayOutput) Index(i pulumi.IntInput) GetQueueQueueListTransactionPolicyOutput

func (GetQueueQueueListTransactionPolicyArrayOutput) ToGetQueueQueueListTransactionPolicyArrayOutput 

func (o GetQueueQueueListTransactionPolicyArrayOutput) ToGetQueueQueueListTransactionPolicyArrayOutput() GetQueueQueueListTransactionPolicyArrayOutput

func (GetQueueQueueListTransactionPolicyArrayOutput) ToGetQueueQueueListTransactionPolicyArrayOutputWithContext 

func (o GetQueueQueueListTransactionPolicyArrayOutput) ToGetQueueQueueListTransactionPolicyArrayOutputWithContext(ctx context.Context) GetQueueQueueListTransactionPolicyArrayOutput

type GetQueueQueueListTransactionPolicyInput 

type GetQueueQueueListTransactionPolicyInput interface {
	pulumi.Input

	ToGetQueueQueueListTransactionPolicyOutput() GetQueueQueueListTransactionPolicyOutput
	ToGetQueueQueueListTransactionPolicyOutputWithContext(context.Context) GetQueueQueueListTransactionPolicyOutput
}

GetQueueQueueListTransactionPolicyInput is an input type that accepts GetQueueQueueListTransactionPolicyArgs and GetQueueQueueListTransactionPolicyOutput values. You can construct a concrete instance of `GetQueueQueueListTransactionPolicyInput` via: 

GetQueueQueueListTransactionPolicyArgs{...}

type GetQueueQueueListTransactionPolicyOutput 

type GetQueueQueueListTransactionPolicyOutput struct{ *pulumi.OutputState }

func (GetQueueQueueListTransactionPolicyOutput) ElementType 

func (GetQueueQueueListTransactionPolicyOutput) ElementType() reflect.Type

func (GetQueueQueueListTransactionPolicyOutput) FirstQueryInterval 

func (o GetQueueQueueListTransactionPolicyOutput) FirstQueryInterval() pulumi.IntOutput

First lookback time.

func (GetQueueQueueListTransactionPolicyOutput) MaxQueryCount 

func (o GetQueueQueueListTransactionPolicyOutput) MaxQueryCount() pulumi.IntOutput

Maximum number of queries.

func (GetQueueQueueListTransactionPolicyOutput) ToGetQueueQueueListTransactionPolicyOutput 

func (o GetQueueQueueListTransactionPolicyOutput) ToGetQueueQueueListTransactionPolicyOutput() GetQueueQueueListTransactionPolicyOutput

func (GetQueueQueueListTransactionPolicyOutput) ToGetQueueQueueListTransactionPolicyOutputWithContext 

func (o GetQueueQueueListTransactionPolicyOutput) ToGetQueueQueueListTransactionPolicyOutputWithContext(ctx context.Context) GetQueueQueueListTransactionPolicyOutput

type GetSubscribeSubscriptionList 

type GetSubscribeSubscriptionList struct {
	// Filtering policy for subscribing to and receiving messages.
	BindingKeys []string `pulumi:"bindingKeys"`
	// Subscription creation time. A Unix timestamp accurate down to the millisecond will be returned.
	CreateTime int `pulumi:"createTime"`
	// Endpoint that receives notifications, which varies by `protocol`: for HTTP, the endpoint must start with `http://`, and the `host` can be a domain or IP; for `queue`, `queueName` should be entered.
	Endpoint string `pulumi:"endpoint"`
	// Filtering policy selected when a subscription is created:If `filterType` is 1, `filterTag` will be used for filtering. If `filterType` is 2, `bindingKey` will be used for filtering.
	FilterTags []string `pulumi:"filterTags"`
	// Time when the subscription attribute is last modified. A Unix timestamp accurate down to the millisecond will be returned.
	LastModifyTime int `pulumi:"lastModifyTime"`
	// Number of messages to be delivered in the subscription.
	MsgCount int `pulumi:"msgCount"`
	// Push content format. Valid values: 1. `JSON`; 2. `SIMPLIFIED`, i.e., the raw format. If `Protocol` is `queue`, this value must be `SIMPLIFIED`. If `Protocol` is `http`, both options are acceptable, and the default value is `JSON`.
	NotifyContentFormat string `pulumi:"notifyContentFormat"`
	// CMQ push server retry policy in case an error occurs while pushing a message to `Endpoint`. Valid values: 1. `BACKOFF_RETRY`: backoff retry, which is to retry at a fixed interval, discard the message after a certain number of retries, and continue to push the next message; 2. `EXPONENTIAL_DECAY_RETRY`: exponential decay retry, which is to retry at an exponentially increasing interval, such as 1s, 2s, 4s, 8s, and so on. As a message can be retained in a topic for one day, failed messages will be discarded at most after one day of retry. Default value: `EXPONENTIAL_DECAY_RETRY`.
	NotifyStrategy string `pulumi:"notifyStrategy"`
	// Subscription protocol. Currently, two protocols are supported: HTTP and queue. To use the HTTP protocol, you need to build your own web server to receive messages. With the queue protocol, messages are automatically pushed to a CMQ queue and you can pull them concurrently.
	Protocol string `pulumi:"protocol"`
	// Subscription ID, which will be used during monitoring data pull.
	SubscriptionId string `pulumi:"subscriptionId"`
	// Fuzzy search by SubscriptionName.
	SubscriptionName string `pulumi:"subscriptionName"`
	// Subscription owner APPID.
	TopicOwner int `pulumi:"topicOwner"`
}

type GetSubscribeSubscriptionListArgs 

type GetSubscribeSubscriptionListArgs struct {
	// Filtering policy for subscribing to and receiving messages.
	BindingKeys pulumi.StringArrayInput `pulumi:"bindingKeys"`
	// Subscription creation time. A Unix timestamp accurate down to the millisecond will be returned.
	CreateTime pulumi.IntInput `pulumi:"createTime"`
	// Endpoint that receives notifications, which varies by `protocol`: for HTTP, the endpoint must start with `http://`, and the `host` can be a domain or IP; for `queue`, `queueName` should be entered.
	Endpoint pulumi.StringInput `pulumi:"endpoint"`
	// Filtering policy selected when a subscription is created:If `filterType` is 1, `filterTag` will be used for filtering. If `filterType` is 2, `bindingKey` will be used for filtering.
	FilterTags pulumi.StringArrayInput `pulumi:"filterTags"`
	// Time when the subscription attribute is last modified. A Unix timestamp accurate down to the millisecond will be returned.
	LastModifyTime pulumi.IntInput `pulumi:"lastModifyTime"`
	// Number of messages to be delivered in the subscription.
	MsgCount pulumi.IntInput `pulumi:"msgCount"`
	// Push content format. Valid values: 1. `JSON`; 2. `SIMPLIFIED`, i.e., the raw format. If `Protocol` is `queue`, this value must be `SIMPLIFIED`. If `Protocol` is `http`, both options are acceptable, and the default value is `JSON`.
	NotifyContentFormat pulumi.StringInput `pulumi:"notifyContentFormat"`
	// CMQ push server retry policy in case an error occurs while pushing a message to `Endpoint`. Valid values: 1. `BACKOFF_RETRY`: backoff retry, which is to retry at a fixed interval, discard the message after a certain number of retries, and continue to push the next message; 2. `EXPONENTIAL_DECAY_RETRY`: exponential decay retry, which is to retry at an exponentially increasing interval, such as 1s, 2s, 4s, 8s, and so on. As a message can be retained in a topic for one day, failed messages will be discarded at most after one day of retry. Default value: `EXPONENTIAL_DECAY_RETRY`.
	NotifyStrategy pulumi.StringInput `pulumi:"notifyStrategy"`
	// Subscription protocol. Currently, two protocols are supported: HTTP and queue. To use the HTTP protocol, you need to build your own web server to receive messages. With the queue protocol, messages are automatically pushed to a CMQ queue and you can pull them concurrently.
	Protocol pulumi.StringInput `pulumi:"protocol"`
	// Subscription ID, which will be used during monitoring data pull.
	SubscriptionId pulumi.StringInput `pulumi:"subscriptionId"`
	// Fuzzy search by SubscriptionName.
	SubscriptionName pulumi.StringInput `pulumi:"subscriptionName"`
	// Subscription owner APPID.
	TopicOwner pulumi.IntInput `pulumi:"topicOwner"`
}

func (GetSubscribeSubscriptionListArgs) ElementType 

func (GetSubscribeSubscriptionListArgs) ElementType() reflect.Type

func (GetSubscribeSubscriptionListArgs) ToGetSubscribeSubscriptionListOutput 

func (i GetSubscribeSubscriptionListArgs) ToGetSubscribeSubscriptionListOutput() GetSubscribeSubscriptionListOutput

func (GetSubscribeSubscriptionListArgs) ToGetSubscribeSubscriptionListOutputWithContext 

func (i GetSubscribeSubscriptionListArgs) ToGetSubscribeSubscriptionListOutputWithContext(ctx context.Context) GetSubscribeSubscriptionListOutput

type GetSubscribeSubscriptionListArray 

type GetSubscribeSubscriptionListArray []GetSubscribeSubscriptionListInput

func (GetSubscribeSubscriptionListArray) ElementType 

func (GetSubscribeSubscriptionListArray) ElementType() reflect.Type

func (GetSubscribeSubscriptionListArray) ToGetSubscribeSubscriptionListArrayOutput 

func (i GetSubscribeSubscriptionListArray) ToGetSubscribeSubscriptionListArrayOutput() GetSubscribeSubscriptionListArrayOutput

func (GetSubscribeSubscriptionListArray) ToGetSubscribeSubscriptionListArrayOutputWithContext 

func (i GetSubscribeSubscriptionListArray) ToGetSubscribeSubscriptionListArrayOutputWithContext(ctx context.Context) GetSubscribeSubscriptionListArrayOutput

type GetSubscribeSubscriptionListArrayInput 

type GetSubscribeSubscriptionListArrayInput interface {
	pulumi.Input

	ToGetSubscribeSubscriptionListArrayOutput() GetSubscribeSubscriptionListArrayOutput
	ToGetSubscribeSubscriptionListArrayOutputWithContext(context.Context) GetSubscribeSubscriptionListArrayOutput
}

GetSubscribeSubscriptionListArrayInput is an input type that accepts GetSubscribeSubscriptionListArray and GetSubscribeSubscriptionListArrayOutput values. You can construct a concrete instance of `GetSubscribeSubscriptionListArrayInput` via: 

GetSubscribeSubscriptionListArray{ GetSubscribeSubscriptionListArgs{...} }

type GetSubscribeSubscriptionListArrayOutput 

type GetSubscribeSubscriptionListArrayOutput struct{ *pulumi.OutputState }

func (GetSubscribeSubscriptionListArrayOutput) ElementType 

func (GetSubscribeSubscriptionListArrayOutput) ElementType() reflect.Type

func (GetSubscribeSubscriptionListArrayOutput) Index 

func (o GetSubscribeSubscriptionListArrayOutput) Index(i pulumi.IntInput) GetSubscribeSubscriptionListOutput

func (GetSubscribeSubscriptionListArrayOutput) ToGetSubscribeSubscriptionListArrayOutput 

func (o GetSubscribeSubscriptionListArrayOutput) ToGetSubscribeSubscriptionListArrayOutput() GetSubscribeSubscriptionListArrayOutput

func (GetSubscribeSubscriptionListArrayOutput) ToGetSubscribeSubscriptionListArrayOutputWithContext 

func (o GetSubscribeSubscriptionListArrayOutput) ToGetSubscribeSubscriptionListArrayOutputWithContext(ctx context.Context) GetSubscribeSubscriptionListArrayOutput

type GetSubscribeSubscriptionListInput 

type GetSubscribeSubscriptionListInput interface {
	pulumi.Input

	ToGetSubscribeSubscriptionListOutput() GetSubscribeSubscriptionListOutput
	ToGetSubscribeSubscriptionListOutputWithContext(context.Context) GetSubscribeSubscriptionListOutput
}

GetSubscribeSubscriptionListInput is an input type that accepts GetSubscribeSubscriptionListArgs and GetSubscribeSubscriptionListOutput values. You can construct a concrete instance of `GetSubscribeSubscriptionListInput` via: 

GetSubscribeSubscriptionListArgs{...}

type GetSubscribeSubscriptionListOutput 

type GetSubscribeSubscriptionListOutput struct{ *pulumi.OutputState }

func (GetSubscribeSubscriptionListOutput) BindingKeys 

func (o GetSubscribeSubscriptionListOutput) BindingKeys() pulumi.StringArrayOutput

Filtering policy for subscribing to and receiving messages.

func (GetSubscribeSubscriptionListOutput) CreateTime 

func (o GetSubscribeSubscriptionListOutput) CreateTime() pulumi.IntOutput

Subscription creation time. A Unix timestamp accurate down to the millisecond will be returned.

func (GetSubscribeSubscriptionListOutput) ElementType 

func (GetSubscribeSubscriptionListOutput) ElementType() reflect.Type

func (GetSubscribeSubscriptionListOutput) Endpoint 

func (o GetSubscribeSubscriptionListOutput) Endpoint() pulumi.StringOutput

Endpoint that receives notifications, which varies by `protocol`: for HTTP, the endpoint must start with `http://`, and the `host` can be a domain or IP; for `queue`, `queueName` should be entered.

func (GetSubscribeSubscriptionListOutput) FilterTags 

func (o GetSubscribeSubscriptionListOutput) FilterTags() pulumi.StringArrayOutput

Filtering policy selected when a subscription is created:If `filterType` is 1, `filterTag` will be used for filtering. If `filterType` is 2, `bindingKey` will be used for filtering.

func (GetSubscribeSubscriptionListOutput) LastModifyTime 

func (o GetSubscribeSubscriptionListOutput) LastModifyTime() pulumi.IntOutput

Time when the subscription attribute is last modified. A Unix timestamp accurate down to the millisecond will be returned.

func (GetSubscribeSubscriptionListOutput) MsgCount 

func (o GetSubscribeSubscriptionListOutput) MsgCount() pulumi.IntOutput

Number of messages to be delivered in the subscription.

func (GetSubscribeSubscriptionListOutput) NotifyContentFormat 

func (o GetSubscribeSubscriptionListOutput) NotifyContentFormat() pulumi.StringOutput

Push content format. Valid values: 1. `JSON`; 2. `SIMPLIFIED`, i.e., the raw format. If `Protocol` is `queue`, this value must be `SIMPLIFIED`. If `Protocol` is `http`, both options are acceptable, and the default value is `JSON`.

func (GetSubscribeSubscriptionListOutput) NotifyStrategy 

func (o GetSubscribeSubscriptionListOutput) NotifyStrategy() pulumi.StringOutput

CMQ push server retry policy in case an error occurs while pushing a message to `Endpoint`. Valid values: 1. `BACKOFF_RETRY`: backoff retry, which is to retry at a fixed interval, discard the message after a certain number of retries, and continue to push the next message; 2. `EXPONENTIAL_DECAY_RETRY`: exponential decay retry, which is to retry at an exponentially increasing interval, such as 1s, 2s, 4s, 8s, and so on. As a message can be retained in a topic for one day, failed messages will be discarded at most after one day of retry. Default value: `EXPONENTIAL_DECAY_RETRY`.

func (GetSubscribeSubscriptionListOutput) Protocol 

func (o GetSubscribeSubscriptionListOutput) Protocol() pulumi.StringOutput

Subscription protocol. Currently, two protocols are supported: HTTP and queue. To use the HTTP protocol, you need to build your own web server to receive messages. With the queue protocol, messages are automatically pushed to a CMQ queue and you can pull them concurrently.

func (GetSubscribeSubscriptionListOutput) SubscriptionId 

func (o GetSubscribeSubscriptionListOutput) SubscriptionId() pulumi.StringOutput

Subscription ID, which will be used during monitoring data pull.

func (GetSubscribeSubscriptionListOutput) SubscriptionName 

func (o GetSubscribeSubscriptionListOutput) SubscriptionName() pulumi.StringOutput

Fuzzy search by SubscriptionName.

func (GetSubscribeSubscriptionListOutput) ToGetSubscribeSubscriptionListOutput 

func (o GetSubscribeSubscriptionListOutput) ToGetSubscribeSubscriptionListOutput() GetSubscribeSubscriptionListOutput

func (GetSubscribeSubscriptionListOutput) ToGetSubscribeSubscriptionListOutputWithContext 

func (o GetSubscribeSubscriptionListOutput) ToGetSubscribeSubscriptionListOutputWithContext(ctx context.Context) GetSubscribeSubscriptionListOutput

func (GetSubscribeSubscriptionListOutput) TopicOwner 

func (o GetSubscribeSubscriptionListOutput) TopicOwner() pulumi.IntOutput

Subscription owner APPID.

type GetTopicFilter 

type GetTopicFilter struct {
	// Filter parameter name.
	Name *string `pulumi:"name"`
	// Value.
	Values []string `pulumi:"values"`
}

type GetTopicFilterArgs 

type GetTopicFilterArgs struct {
	// Filter parameter name.
	Name pulumi.StringPtrInput `pulumi:"name"`
	// Value.
	Values pulumi.StringArrayInput `pulumi:"values"`
}

func (GetTopicFilterArgs) ElementType 

func (GetTopicFilterArgs) ElementType() reflect.Type

func (GetTopicFilterArgs) ToGetTopicFilterOutput 

func (i GetTopicFilterArgs) ToGetTopicFilterOutput() GetTopicFilterOutput

func (GetTopicFilterArgs) ToGetTopicFilterOutputWithContext 

func (i GetTopicFilterArgs) ToGetTopicFilterOutputWithContext(ctx context.Context) GetTopicFilterOutput

type GetTopicFilterArray 

type GetTopicFilterArray []GetTopicFilterInput

func (GetTopicFilterArray) ElementType 

func (GetTopicFilterArray) ElementType() reflect.Type

func (GetTopicFilterArray) ToGetTopicFilterArrayOutput 

func (i GetTopicFilterArray) ToGetTopicFilterArrayOutput() GetTopicFilterArrayOutput

func (GetTopicFilterArray) ToGetTopicFilterArrayOutputWithContext 

func (i GetTopicFilterArray) ToGetTopicFilterArrayOutputWithContext(ctx context.Context) GetTopicFilterArrayOutput

type GetTopicFilterArrayInput 

type GetTopicFilterArrayInput interface {
	pulumi.Input

	ToGetTopicFilterArrayOutput() GetTopicFilterArrayOutput
	ToGetTopicFilterArrayOutputWithContext(context.Context) GetTopicFilterArrayOutput
}

GetTopicFilterArrayInput is an input type that accepts GetTopicFilterArray and GetTopicFilterArrayOutput values. You can construct a concrete instance of `GetTopicFilterArrayInput` via: 

GetTopicFilterArray{ GetTopicFilterArgs{...} }

type GetTopicFilterArrayOutput 

type GetTopicFilterArrayOutput struct{ *pulumi.OutputState }

func (GetTopicFilterArrayOutput) ElementType 

func (GetTopicFilterArrayOutput) ElementType() reflect.Type

func (GetTopicFilterArrayOutput) Index 

func (o GetTopicFilterArrayOutput) Index(i pulumi.IntInput) GetTopicFilterOutput

func (GetTopicFilterArrayOutput) ToGetTopicFilterArrayOutput 

func (o GetTopicFilterArrayOutput) ToGetTopicFilterArrayOutput() GetTopicFilterArrayOutput

func (GetTopicFilterArrayOutput) ToGetTopicFilterArrayOutputWithContext 

func (o GetTopicFilterArrayOutput) ToGetTopicFilterArrayOutputWithContext(ctx context.Context) GetTopicFilterArrayOutput

type GetTopicFilterInput 

type GetTopicFilterInput interface {
	pulumi.Input

	ToGetTopicFilterOutput() GetTopicFilterOutput
	ToGetTopicFilterOutputWithContext(context.Context) GetTopicFilterOutput
}

GetTopicFilterInput is an input type that accepts GetTopicFilterArgs and GetTopicFilterOutput values. You can construct a concrete instance of `GetTopicFilterInput` via: 

GetTopicFilterArgs{...}

type GetTopicFilterOutput 

type GetTopicFilterOutput struct{ *pulumi.OutputState }

func (GetTopicFilterOutput) ElementType 

func (GetTopicFilterOutput) ElementType() reflect.Type

func (GetTopicFilterOutput) Name 

func (o GetTopicFilterOutput) Name() pulumi.StringPtrOutput

Filter parameter name.

func (GetTopicFilterOutput) ToGetTopicFilterOutput 

func (o GetTopicFilterOutput) ToGetTopicFilterOutput() GetTopicFilterOutput

func (GetTopicFilterOutput) ToGetTopicFilterOutputWithContext 

func (o GetTopicFilterOutput) ToGetTopicFilterOutputWithContext(ctx context.Context) GetTopicFilterOutput

func (GetTopicFilterOutput) Values 

func (o GetTopicFilterOutput) Values() pulumi.StringArrayOutput

Value.

type GetTopicTopicList 

type GetTopicTopicList struct {
	// Valid values: `0` (Pulsar), `1` (RocketMQ).
	BrokerType int `pulumi:"brokerType"`
	// Topic creation time. A Unix timestamp accurate down to the millisecond will be returned.
	CreateTime int `pulumi:"createTime"`
	// Creator `Uin`. The `resource` field for CAM authentication is composed of this field.
	CreateUin int `pulumi:"createUin"`
	// Filtering policy selected when a subscription is created: If `filterType` is 1, `FilterTag` will be used for filtering. If `filterType` is 2, `BindingKey` will be used for filtering.
	FilterType int `pulumi:"filterType"`
	// Time when the topic attribute is last modified. A Unix timestamp accurate down to the millisecond will be returned.
	LastModifyTime int `pulumi:"lastModifyTime"`
	// Maximum message size, which ranges from 1,024 to 1,048,576 bytes (i.e., 1-1,024 KB). The default value is 65,536.
	MaxMsgSize int `pulumi:"maxMsgSize"`
	// Number of current messages in the topic (number of retained messages).
	MsgCount int `pulumi:"msgCount"`
	// Maximum lifecycle of message in topic. After the period specified by this parameter has elapsed since a message is sent to the topic, the message will be deleted no matter whether it has been successfully pushed to the user. This parameter is measured in seconds and defaulted to one day (86,400 seconds), which cannot be modified.
	MsgRetentionSeconds int `pulumi:"msgRetentionSeconds"`
	// Namespace name.
	NamespaceName string `pulumi:"namespaceName"`
	// Number of messages published per second.
	Qps int `pulumi:"qps"`
	// Cluster status. `0`: creating; `1`: normal; `2`: terminating; `3`: deleted; `4`: isolated; `5`: creation failed; `6`: deletion failed.
	Status int `pulumi:"status"`
	// Associated tag.
	Tags []GetTopicTopicListTag `pulumi:"tags"`
	// Tenant ID.
	TenantId string `pulumi:"tenantId"`
	// Topic ID.
	TopicId string `pulumi:"topicId"`
	// Fuzzy search by TopicName.
	TopicName string `pulumi:"topicName"`
	// Message trace. true: enabled; false: not enabled.
	Trace bool `pulumi:"trace"`
}

type GetTopicTopicListArgs 

type GetTopicTopicListArgs struct {
	// Valid values: `0` (Pulsar), `1` (RocketMQ).
	BrokerType pulumi.IntInput `pulumi:"brokerType"`
	// Topic creation time. A Unix timestamp accurate down to the millisecond will be returned.
	CreateTime pulumi.IntInput `pulumi:"createTime"`
	// Creator `Uin`. The `resource` field for CAM authentication is composed of this field.
	CreateUin pulumi.IntInput `pulumi:"createUin"`
	// Filtering policy selected when a subscription is created: If `filterType` is 1, `FilterTag` will be used for filtering. If `filterType` is 2, `BindingKey` will be used for filtering.
	FilterType pulumi.IntInput `pulumi:"filterType"`
	// Time when the topic attribute is last modified. A Unix timestamp accurate down to the millisecond will be returned.
	LastModifyTime pulumi.IntInput `pulumi:"lastModifyTime"`
	// Maximum message size, which ranges from 1,024 to 1,048,576 bytes (i.e., 1-1,024 KB). The default value is 65,536.
	MaxMsgSize pulumi.IntInput `pulumi:"maxMsgSize"`
	// Number of current messages in the topic (number of retained messages).
	MsgCount pulumi.IntInput `pulumi:"msgCount"`
	// Maximum lifecycle of message in topic. After the period specified by this parameter has elapsed since a message is sent to the topic, the message will be deleted no matter whether it has been successfully pushed to the user. This parameter is measured in seconds and defaulted to one day (86,400 seconds), which cannot be modified.
	MsgRetentionSeconds pulumi.IntInput `pulumi:"msgRetentionSeconds"`
	// Namespace name.
	NamespaceName pulumi.StringInput `pulumi:"namespaceName"`
	// Number of messages published per second.
	Qps pulumi.IntInput `pulumi:"qps"`
	// Cluster status. `0`: creating; `1`: normal; `2`: terminating; `3`: deleted; `4`: isolated; `5`: creation failed; `6`: deletion failed.
	Status pulumi.IntInput `pulumi:"status"`
	// Associated tag.
	Tags GetTopicTopicListTagArrayInput `pulumi:"tags"`
	// Tenant ID.
	TenantId pulumi.StringInput `pulumi:"tenantId"`
	// Topic ID.
	TopicId pulumi.StringInput `pulumi:"topicId"`
	// Fuzzy search by TopicName.
	TopicName pulumi.StringInput `pulumi:"topicName"`
	// Message trace. true: enabled; false: not enabled.
	Trace pulumi.BoolInput `pulumi:"trace"`
}

func (GetTopicTopicListArgs) ElementType 

func (GetTopicTopicListArgs) ElementType() reflect.Type

func (GetTopicTopicListArgs) ToGetTopicTopicListOutput 

func (i GetTopicTopicListArgs) ToGetTopicTopicListOutput() GetTopicTopicListOutput

func (GetTopicTopicListArgs) ToGetTopicTopicListOutputWithContext 

func (i GetTopicTopicListArgs) ToGetTopicTopicListOutputWithContext(ctx context.Context) GetTopicTopicListOutput

type GetTopicTopicListArray 

type GetTopicTopicListArray []GetTopicTopicListInput

func (GetTopicTopicListArray) ElementType 

func (GetTopicTopicListArray) ElementType() reflect.Type

func (GetTopicTopicListArray) ToGetTopicTopicListArrayOutput 

func (i GetTopicTopicListArray) ToGetTopicTopicListArrayOutput() GetTopicTopicListArrayOutput

func (GetTopicTopicListArray) ToGetTopicTopicListArrayOutputWithContext 

func (i GetTopicTopicListArray) ToGetTopicTopicListArrayOutputWithContext(ctx context.Context) GetTopicTopicListArrayOutput

type GetTopicTopicListArrayInput 

type GetTopicTopicListArrayInput interface {
	pulumi.Input

	ToGetTopicTopicListArrayOutput() GetTopicTopicListArrayOutput
	ToGetTopicTopicListArrayOutputWithContext(context.Context) GetTopicTopicListArrayOutput
}

GetTopicTopicListArrayInput is an input type that accepts GetTopicTopicListArray and GetTopicTopicListArrayOutput values. You can construct a concrete instance of `GetTopicTopicListArrayInput` via: 

GetTopicTopicListArray{ GetTopicTopicListArgs{...} }

type GetTopicTopicListArrayOutput 

type GetTopicTopicListArrayOutput struct{ *pulumi.OutputState }

func (GetTopicTopicListArrayOutput) ElementType 

func (GetTopicTopicListArrayOutput) ElementType() reflect.Type

func (GetTopicTopicListArrayOutput) Index 

func (o GetTopicTopicListArrayOutput) Index(i pulumi.IntInput) GetTopicTopicListOutput

func (GetTopicTopicListArrayOutput) ToGetTopicTopicListArrayOutput 

func (o GetTopicTopicListArrayOutput) ToGetTopicTopicListArrayOutput() GetTopicTopicListArrayOutput

func (GetTopicTopicListArrayOutput) ToGetTopicTopicListArrayOutputWithContext 

func (o GetTopicTopicListArrayOutput) ToGetTopicTopicListArrayOutputWithContext(ctx context.Context) GetTopicTopicListArrayOutput

type GetTopicTopicListInput 

type GetTopicTopicListInput interface {
	pulumi.Input

	ToGetTopicTopicListOutput() GetTopicTopicListOutput
	ToGetTopicTopicListOutputWithContext(context.Context) GetTopicTopicListOutput
}

GetTopicTopicListInput is an input type that accepts GetTopicTopicListArgs and GetTopicTopicListOutput values. You can construct a concrete instance of `GetTopicTopicListInput` via: 

GetTopicTopicListArgs{...}

type GetTopicTopicListOutput 

type GetTopicTopicListOutput struct{ *pulumi.OutputState }

func (GetTopicTopicListOutput) BrokerType 

func (o GetTopicTopicListOutput) BrokerType() pulumi.IntOutput

Valid values: `0` (Pulsar), `1` (RocketMQ).

func (GetTopicTopicListOutput) CreateTime 

func (o GetTopicTopicListOutput) CreateTime() pulumi.IntOutput

Topic creation time. A Unix timestamp accurate down to the millisecond will be returned.

func (GetTopicTopicListOutput) CreateUin 

func (o GetTopicTopicListOutput) CreateUin() pulumi.IntOutput

Creator `Uin`. The `resource` field for CAM authentication is composed of this field.

func (GetTopicTopicListOutput) ElementType 

func (GetTopicTopicListOutput) ElementType() reflect.Type

func (GetTopicTopicListOutput) FilterType 

func (o GetTopicTopicListOutput) FilterType() pulumi.IntOutput

Filtering policy selected when a subscription is created: If `filterType` is 1, `FilterTag` will be used for filtering. If `filterType` is 2, `BindingKey` will be used for filtering.

func (GetTopicTopicListOutput) LastModifyTime 

func (o GetTopicTopicListOutput) LastModifyTime() pulumi.IntOutput

Time when the topic attribute is last modified. A Unix timestamp accurate down to the millisecond will be returned.

func (GetTopicTopicListOutput) MaxMsgSize 

func (o GetTopicTopicListOutput) MaxMsgSize() pulumi.IntOutput

Maximum message size, which ranges from 1,024 to 1,048,576 bytes (i.e., 1-1,024 KB). The default value is 65,536.

func (GetTopicTopicListOutput) MsgCount 

func (o GetTopicTopicListOutput) MsgCount() pulumi.IntOutput

Number of current messages in the topic (number of retained messages).

func (GetTopicTopicListOutput) MsgRetentionSeconds 

func (o GetTopicTopicListOutput) MsgRetentionSeconds() pulumi.IntOutput

Maximum lifecycle of message in topic. After the period specified by this parameter has elapsed since a message is sent to the topic, the message will be deleted no matter whether it has been successfully pushed to the user. This parameter is measured in seconds and defaulted to one day (86,400 seconds), which cannot be modified.

func (GetTopicTopicListOutput) NamespaceName 

func (o GetTopicTopicListOutput) NamespaceName() pulumi.StringOutput

Namespace name.

func (GetTopicTopicListOutput) Qps 

func (o GetTopicTopicListOutput) Qps() pulumi.IntOutput

Number of messages published per second.

func (GetTopicTopicListOutput) Status 

func (o GetTopicTopicListOutput) Status() pulumi.IntOutput

Cluster status. `0`: creating; `1`: normal; `2`: terminating; `3`: deleted; `4`: isolated; `5`: creation failed; `6`: deletion failed.

func (GetTopicTopicListOutput) Tags 

func (o GetTopicTopicListOutput) Tags() GetTopicTopicListTagArrayOutput

Associated tag.

func (GetTopicTopicListOutput) TenantId 

func (o GetTopicTopicListOutput) TenantId() pulumi.StringOutput

Tenant ID.

func (GetTopicTopicListOutput) ToGetTopicTopicListOutput 

func (o GetTopicTopicListOutput) ToGetTopicTopicListOutput() GetTopicTopicListOutput

func (GetTopicTopicListOutput) ToGetTopicTopicListOutputWithContext 

func (o GetTopicTopicListOutput) ToGetTopicTopicListOutputWithContext(ctx context.Context) GetTopicTopicListOutput

func (GetTopicTopicListOutput) TopicId 

func (o GetTopicTopicListOutput) TopicId() pulumi.StringOutput

Topic ID.

func (GetTopicTopicListOutput) TopicName 

func (o GetTopicTopicListOutput) TopicName() pulumi.StringOutput

Fuzzy search by TopicName.

func (GetTopicTopicListOutput) Trace 

func (o GetTopicTopicListOutput) Trace() pulumi.BoolOutput

Message trace. true: enabled; false: not enabled.

type GetTopicTopicListTag 

type GetTopicTopicListTag struct {
	// Value of the tag key.
	TagKey string `pulumi:"tagKey"`
	// Value of the tag value.
	TagValue string `pulumi:"tagValue"`
}

type GetTopicTopicListTagArgs 

type GetTopicTopicListTagArgs struct {
	// Value of the tag key.
	TagKey pulumi.StringInput `pulumi:"tagKey"`
	// Value of the tag value.
	TagValue pulumi.StringInput `pulumi:"tagValue"`
}

func (GetTopicTopicListTagArgs) ElementType 

func (GetTopicTopicListTagArgs) ElementType() reflect.Type

func (GetTopicTopicListTagArgs) ToGetTopicTopicListTagOutput 

func (i GetTopicTopicListTagArgs) ToGetTopicTopicListTagOutput() GetTopicTopicListTagOutput

func (GetTopicTopicListTagArgs) ToGetTopicTopicListTagOutputWithContext 

func (i GetTopicTopicListTagArgs) ToGetTopicTopicListTagOutputWithContext(ctx context.Context) GetTopicTopicListTagOutput

type GetTopicTopicListTagArray 

type GetTopicTopicListTagArray []GetTopicTopicListTagInput

func (GetTopicTopicListTagArray) ElementType 

func (GetTopicTopicListTagArray) ElementType() reflect.Type

func (GetTopicTopicListTagArray) ToGetTopicTopicListTagArrayOutput 

func (i GetTopicTopicListTagArray) ToGetTopicTopicListTagArrayOutput() GetTopicTopicListTagArrayOutput

func (GetTopicTopicListTagArray) ToGetTopicTopicListTagArrayOutputWithContext 

func (i GetTopicTopicListTagArray) ToGetTopicTopicListTagArrayOutputWithContext(ctx context.Context) GetTopicTopicListTagArrayOutput

type GetTopicTopicListTagArrayInput 

type GetTopicTopicListTagArrayInput interface {
	pulumi.Input

	ToGetTopicTopicListTagArrayOutput() GetTopicTopicListTagArrayOutput
	ToGetTopicTopicListTagArrayOutputWithContext(context.Context) GetTopicTopicListTagArrayOutput
}

GetTopicTopicListTagArrayInput is an input type that accepts GetTopicTopicListTagArray and GetTopicTopicListTagArrayOutput values. You can construct a concrete instance of `GetTopicTopicListTagArrayInput` via: 

GetTopicTopicListTagArray{ GetTopicTopicListTagArgs{...} }

type GetTopicTopicListTagArrayOutput 

type GetTopicTopicListTagArrayOutput struct{ *pulumi.OutputState }

func (GetTopicTopicListTagArrayOutput) ElementType 

func (GetTopicTopicListTagArrayOutput) ElementType() reflect.Type

func (GetTopicTopicListTagArrayOutput) Index 

func (o GetTopicTopicListTagArrayOutput) Index(i pulumi.IntInput) GetTopicTopicListTagOutput

func (GetTopicTopicListTagArrayOutput) ToGetTopicTopicListTagArrayOutput 

func (o GetTopicTopicListTagArrayOutput) ToGetTopicTopicListTagArrayOutput() GetTopicTopicListTagArrayOutput

func (GetTopicTopicListTagArrayOutput) ToGetTopicTopicListTagArrayOutputWithContext 

func (o GetTopicTopicListTagArrayOutput) ToGetTopicTopicListTagArrayOutputWithContext(ctx context.Context) GetTopicTopicListTagArrayOutput

type GetTopicTopicListTagInput 

type GetTopicTopicListTagInput interface {
	pulumi.Input

	ToGetTopicTopicListTagOutput() GetTopicTopicListTagOutput
	ToGetTopicTopicListTagOutputWithContext(context.Context) GetTopicTopicListTagOutput
}

GetTopicTopicListTagInput is an input type that accepts GetTopicTopicListTagArgs and GetTopicTopicListTagOutput values. You can construct a concrete instance of `GetTopicTopicListTagInput` via: 

GetTopicTopicListTagArgs{...}

type GetTopicTopicListTagOutput 

type GetTopicTopicListTagOutput struct{ *pulumi.OutputState }

func (GetTopicTopicListTagOutput) ElementType 

func (GetTopicTopicListTagOutput) ElementType() reflect.Type

func (GetTopicTopicListTagOutput) TagKey 

func (o GetTopicTopicListTagOutput) TagKey() pulumi.StringOutput

Value of the tag key.

func (GetTopicTopicListTagOutput) TagValue 

func (o GetTopicTopicListTagOutput) TagValue() pulumi.StringOutput

Value of the tag value.

func (GetTopicTopicListTagOutput) ToGetTopicTopicListTagOutput 

func (o GetTopicTopicListTagOutput) ToGetTopicTopicListTagOutput() GetTopicTopicListTagOutput

func (GetTopicTopicListTagOutput) ToGetTopicTopicListTagOutputWithContext 

func (o GetTopicTopicListTagOutput) ToGetTopicTopicListTagOutputWithContext(ctx context.Context) GetTopicTopicListTagOutput

type LookupQueueArgs 

type LookupQueueArgs struct {
	// Filter. Currently, you can filter by tag. The tag name must be prefixed with `tag:`, such as `tag: owner`, `tag: environment`, or `tag: business`.
	Filters []GetQueueFilter `pulumi:"filters"`
	// For filtering by tag, this parameter must be set to `true`.
	IsTagFilter *bool `pulumi:"isTagFilter"`
	// The number of queues to be returned per page in case of paginated return. If this parameter is not passed in, 20 will be used by default. Maximum value: 50.
	Limit *int `pulumi:"limit"`
	// Starting position of a queue list to be returned on the current page in case of paginated return. If a value is entered, limit must be specified. If this parameter is left empty, 0 will be used by default.
	Offset *int `pulumi:"offset"`
	// Filter by QueueName.
	QueueName *string `pulumi:"queueName"`
	// Filter by CMQ queue name.
	QueueNameLists []string `pulumi:"queueNameLists"`
	// Used to save results.
	ResultOutputFile *string `pulumi:"resultOutputFile"`
}

A collection of arguments for invoking getQueue.

type LookupQueueOutputArgs 

type LookupQueueOutputArgs struct {
	// Filter. Currently, you can filter by tag. The tag name must be prefixed with `tag:`, such as `tag: owner`, `tag: environment`, or `tag: business`.
	Filters GetQueueFilterArrayInput `pulumi:"filters"`
	// For filtering by tag, this parameter must be set to `true`.
	IsTagFilter pulumi.BoolPtrInput `pulumi:"isTagFilter"`
	// The number of queues to be returned per page in case of paginated return. If this parameter is not passed in, 20 will be used by default. Maximum value: 50.
	Limit pulumi.IntPtrInput `pulumi:"limit"`
	// Starting position of a queue list to be returned on the current page in case of paginated return. If a value is entered, limit must be specified. If this parameter is left empty, 0 will be used by default.
	Offset pulumi.IntPtrInput `pulumi:"offset"`
	// Filter by QueueName.
	QueueName pulumi.StringPtrInput `pulumi:"queueName"`
	// Filter by CMQ queue name.
	QueueNameLists pulumi.StringArrayInput `pulumi:"queueNameLists"`
	// Used to save results.
	ResultOutputFile pulumi.StringPtrInput `pulumi:"resultOutputFile"`
}

A collection of arguments for invoking getQueue.

func (LookupQueueOutputArgs) ElementType 

func (LookupQueueOutputArgs) ElementType() reflect.Type

type LookupQueueResult 

type LookupQueueResult struct {
	Filters []GetQueueFilter `pulumi:"filters"`
	// The provider-assigned unique ID for this managed resource.
	Id          string `pulumi:"id"`
	IsTagFilter *bool  `pulumi:"isTagFilter"`
	Limit       *int   `pulumi:"limit"`
	Offset      *int   `pulumi:"offset"`
	// Queue list.
	QueueLists []GetQueueQueueList `pulumi:"queueLists"`
	// Message queue name.
	QueueName        *string  `pulumi:"queueName"`
	QueueNameLists   []string `pulumi:"queueNameLists"`
	ResultOutputFile *string  `pulumi:"resultOutputFile"`
}

A collection of values returned by getQueue.

func LookupQueue 

func LookupQueue(ctx *pulumi.Context, args *LookupQueueArgs, opts ...pulumi.InvokeOption) (*LookupQueueResult, error)

Use this data source to query detailed information of tcmq queue

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-tencentcloud/sdk/go/tencentcloud/Tcmq"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/tencentcloudstack/pulumi-tencentcloud/sdk/go/tencentcloud/Tcmq"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := Tcmq.GetQueue(ctx, &tcmq.GetQueueArgs{
			QueueName: pulumi.StringRef("queue_name"),
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type LookupQueueResultOutput 

type LookupQueueResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getQueue.

func LookupQueueOutput 

func LookupQueueOutput(ctx *pulumi.Context, args LookupQueueOutputArgs, opts ...pulumi.InvokeOption) LookupQueueResultOutput

func (LookupQueueResultOutput) ElementType 

func (LookupQueueResultOutput) ElementType() reflect.Type

func (LookupQueueResultOutput) Filters 

func (o LookupQueueResultOutput) Filters() GetQueueFilterArrayOutput

func (LookupQueueResultOutput) Id 

func (o LookupQueueResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (LookupQueueResultOutput) IsTagFilter 

func (o LookupQueueResultOutput) IsTagFilter() pulumi.BoolPtrOutput

func (LookupQueueResultOutput) Limit 

func (o LookupQueueResultOutput) Limit() pulumi.IntPtrOutput

func (LookupQueueResultOutput) Offset 

func (o LookupQueueResultOutput) Offset() pulumi.IntPtrOutput

func (LookupQueueResultOutput) QueueLists 

func (o LookupQueueResultOutput) QueueLists() GetQueueQueueListArrayOutput

Queue list.

func (LookupQueueResultOutput) QueueName 

func (o LookupQueueResultOutput) QueueName() pulumi.StringPtrOutput

Message queue name.

func (LookupQueueResultOutput) QueueNameLists 

func (o LookupQueueResultOutput) QueueNameLists() pulumi.StringArrayOutput

func (LookupQueueResultOutput) ResultOutputFile 

func (o LookupQueueResultOutput) ResultOutputFile() pulumi.StringPtrOutput

func (LookupQueueResultOutput) ToLookupQueueResultOutput 

func (o LookupQueueResultOutput) ToLookupQueueResultOutput() LookupQueueResultOutput

func (LookupQueueResultOutput) ToLookupQueueResultOutputWithContext 

func (o LookupQueueResultOutput) ToLookupQueueResultOutputWithContext(ctx context.Context) LookupQueueResultOutput

type LookupSubscribeArgs 

type LookupSubscribeArgs struct {
	// Number of topics to be returned per page in case of paginated return. If this parameter is not passed in, 20 will be used by default. Maximum value: 50.
	Limit *int `pulumi:"limit"`
	// Starting position of the list of topics to be returned on the current page in case of paginated return. If a value is entered, limit is required. If this parameter is left empty, 0 will be used by default.
	Offset *int `pulumi:"offset"`
	// Used to save results.
	ResultOutputFile *string `pulumi:"resultOutputFile"`
	// Fuzzy search by SubscriptionName.
	SubscriptionName *string `pulumi:"subscriptionName"`
	// Topic name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	TopicName string `pulumi:"topicName"`
}

A collection of arguments for invoking getSubscribe.

type LookupSubscribeOutputArgs 

type LookupSubscribeOutputArgs struct {
	// Number of topics to be returned per page in case of paginated return. If this parameter is not passed in, 20 will be used by default. Maximum value: 50.
	Limit pulumi.IntPtrInput `pulumi:"limit"`
	// Starting position of the list of topics to be returned on the current page in case of paginated return. If a value is entered, limit is required. If this parameter is left empty, 0 will be used by default.
	Offset pulumi.IntPtrInput `pulumi:"offset"`
	// Used to save results.
	ResultOutputFile pulumi.StringPtrInput `pulumi:"resultOutputFile"`
	// Fuzzy search by SubscriptionName.
	SubscriptionName pulumi.StringPtrInput `pulumi:"subscriptionName"`
	// Topic name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	TopicName pulumi.StringInput `pulumi:"topicName"`
}

A collection of arguments for invoking getSubscribe.

func (LookupSubscribeOutputArgs) ElementType 

func (LookupSubscribeOutputArgs) ElementType() reflect.Type

type LookupSubscribeResult 

type LookupSubscribeResult struct {
	// The provider-assigned unique ID for this managed resource.
	Id               string  `pulumi:"id"`
	Limit            *int    `pulumi:"limit"`
	Offset           *int    `pulumi:"offset"`
	ResultOutputFile *string `pulumi:"resultOutputFile"`
	// Set of subscription attributes.
	SubscriptionLists []GetSubscribeSubscriptionList `pulumi:"subscriptionLists"`
	// Subscription name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	SubscriptionName *string `pulumi:"subscriptionName"`
	TopicName        string  `pulumi:"topicName"`
}

A collection of values returned by getSubscribe.

func LookupSubscribe 

func LookupSubscribe(ctx *pulumi.Context, args *LookupSubscribeArgs, opts ...pulumi.InvokeOption) (*LookupSubscribeResult, error)

Use this data source to query detailed information of tcmq subscribe

type LookupSubscribeResultOutput 

type LookupSubscribeResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getSubscribe.

func LookupSubscribeOutput 

func LookupSubscribeOutput(ctx *pulumi.Context, args LookupSubscribeOutputArgs, opts ...pulumi.InvokeOption) LookupSubscribeResultOutput

func (LookupSubscribeResultOutput) ElementType 

func (LookupSubscribeResultOutput) ElementType() reflect.Type

func (LookupSubscribeResultOutput) Id 

func (o LookupSubscribeResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (LookupSubscribeResultOutput) Limit 

func (o LookupSubscribeResultOutput) Limit() pulumi.IntPtrOutput

func (LookupSubscribeResultOutput) Offset 

func (o LookupSubscribeResultOutput) Offset() pulumi.IntPtrOutput

func (LookupSubscribeResultOutput) ResultOutputFile 

func (o LookupSubscribeResultOutput) ResultOutputFile() pulumi.StringPtrOutput

func (LookupSubscribeResultOutput) SubscriptionLists 

func (o LookupSubscribeResultOutput) SubscriptionLists() GetSubscribeSubscriptionListArrayOutput

Set of subscription attributes.

func (LookupSubscribeResultOutput) SubscriptionName 

func (o LookupSubscribeResultOutput) SubscriptionName() pulumi.StringPtrOutput

Subscription name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.

func (LookupSubscribeResultOutput) ToLookupSubscribeResultOutput 

func (o LookupSubscribeResultOutput) ToLookupSubscribeResultOutput() LookupSubscribeResultOutput

func (LookupSubscribeResultOutput) ToLookupSubscribeResultOutputWithContext 

func (o LookupSubscribeResultOutput) ToLookupSubscribeResultOutputWithContext(ctx context.Context) LookupSubscribeResultOutput

func (LookupSubscribeResultOutput) TopicName 

func (o LookupSubscribeResultOutput) TopicName() pulumi.StringOutput

type LookupTopicArgs 

type LookupTopicArgs struct {
	// Filter. Currently, you can filter by tag. The tag name must be prefixed with `tag:`, such as `tag: owner`, `tag: environment`, or `tag: business`.
	Filters []GetTopicFilter `pulumi:"filters"`
	// For filtering by tag, this parameter must be set to `true`.
	IsTagFilter *bool `pulumi:"isTagFilter"`
	// Number of topics to be returned per page in case of paginated return. If this parameter is not passed in, 20 will be used by default. Maximum value: 50.
	Limit *int `pulumi:"limit"`
	// Starting position of the list of topics to be returned on the current page in case of paginated return. If a value is entered, limit is required. If this parameter is left empty, 0 will be used by default.
	Offset *int `pulumi:"offset"`
	// Used to save results.
	ResultOutputFile *string `pulumi:"resultOutputFile"`
	// Fuzzy search by TopicName.
	TopicName *string `pulumi:"topicName"`
	// Filter by CMQ topic name.
	TopicNameLists []string `pulumi:"topicNameLists"`
}

A collection of arguments for invoking getTopic.

type LookupTopicOutputArgs 

type LookupTopicOutputArgs struct {
	// Filter. Currently, you can filter by tag. The tag name must be prefixed with `tag:`, such as `tag: owner`, `tag: environment`, or `tag: business`.
	Filters GetTopicFilterArrayInput `pulumi:"filters"`
	// For filtering by tag, this parameter must be set to `true`.
	IsTagFilter pulumi.BoolPtrInput `pulumi:"isTagFilter"`
	// Number of topics to be returned per page in case of paginated return. If this parameter is not passed in, 20 will be used by default. Maximum value: 50.
	Limit pulumi.IntPtrInput `pulumi:"limit"`
	// Starting position of the list of topics to be returned on the current page in case of paginated return. If a value is entered, limit is required. If this parameter is left empty, 0 will be used by default.
	Offset pulumi.IntPtrInput `pulumi:"offset"`
	// Used to save results.
	ResultOutputFile pulumi.StringPtrInput `pulumi:"resultOutputFile"`
	// Fuzzy search by TopicName.
	TopicName pulumi.StringPtrInput `pulumi:"topicName"`
	// Filter by CMQ topic name.
	TopicNameLists pulumi.StringArrayInput `pulumi:"topicNameLists"`
}

A collection of arguments for invoking getTopic.

func (LookupTopicOutputArgs) ElementType 

func (LookupTopicOutputArgs) ElementType() reflect.Type

type LookupTopicResult 

type LookupTopicResult struct {
	Filters []GetTopicFilter `pulumi:"filters"`
	// The provider-assigned unique ID for this managed resource.
	Id               string  `pulumi:"id"`
	IsTagFilter      *bool   `pulumi:"isTagFilter"`
	Limit            *int    `pulumi:"limit"`
	Offset           *int    `pulumi:"offset"`
	ResultOutputFile *string `pulumi:"resultOutputFile"`
	// Topic list.
	TopicLists []GetTopicTopicList `pulumi:"topicLists"`
	// Topic name.
	TopicName      *string  `pulumi:"topicName"`
	TopicNameLists []string `pulumi:"topicNameLists"`
}

A collection of values returned by getTopic.

func LookupTopic 

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

Use this data source to query detailed information of tcmq topic

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-tencentcloud/sdk/go/tencentcloud/Tcmq"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/tencentcloudstack/pulumi-tencentcloud/sdk/go/tencentcloud/Tcmq"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := Tcmq.GetTopic(ctx, &tcmq.GetTopicArgs{
			TopicName: pulumi.StringRef("topic_name"),
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type LookupTopicResultOutput 

type LookupTopicResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getTopic.

func LookupTopicOutput 

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

func (LookupTopicResultOutput) ElementType 

func (LookupTopicResultOutput) ElementType() reflect.Type

func (LookupTopicResultOutput) Filters 

func (o LookupTopicResultOutput) Filters() GetTopicFilterArrayOutput

func (LookupTopicResultOutput) Id 

func (o LookupTopicResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (LookupTopicResultOutput) IsTagFilter 

func (o LookupTopicResultOutput) IsTagFilter() pulumi.BoolPtrOutput

func (LookupTopicResultOutput) Limit 

func (o LookupTopicResultOutput) Limit() pulumi.IntPtrOutput

func (LookupTopicResultOutput) Offset 

func (o LookupTopicResultOutput) Offset() pulumi.IntPtrOutput

func (LookupTopicResultOutput) ResultOutputFile 

func (o LookupTopicResultOutput) ResultOutputFile() pulumi.StringPtrOutput

func (LookupTopicResultOutput) ToLookupTopicResultOutput 

func (o LookupTopicResultOutput) ToLookupTopicResultOutput() LookupTopicResultOutput

func (LookupTopicResultOutput) ToLookupTopicResultOutputWithContext 

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

func (LookupTopicResultOutput) TopicLists 

func (o LookupTopicResultOutput) TopicLists() GetTopicTopicListArrayOutput

Topic list.

func (LookupTopicResultOutput) TopicName 

func (o LookupTopicResultOutput) TopicName() pulumi.StringPtrOutput

Topic name.

func (LookupTopicResultOutput) TopicNameLists 

func (o LookupTopicResultOutput) TopicNameLists() pulumi.StringArrayOutput

type Queue 

type Queue struct {
	pulumi.CustomResourceState

	// Dead letter queue name.
	DeadLetterQueueName pulumi.StringPtrOutput `pulumi:"deadLetterQueueName"`
	// First lookback interval.
	FirstQueryInterval pulumi.IntPtrOutput `pulumi:"firstQueryInterval"`
	// Maximum number of heaped messages. The value range is 1,000,000-10,000,000 during the beta test and can be 1,000,000-1,000,000,000 after the product is officially released. The default value is 10,000,000 during the beta test and will be 100,000,000 after the product is officially released.
	MaxMsgHeapNum pulumi.IntPtrOutput `pulumi:"maxMsgHeapNum"`
	// Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.
	MaxMsgSize pulumi.IntPtrOutput `pulumi:"maxMsgSize"`
	// Maximum number of lookbacks.
	MaxQueryCount pulumi.IntPtrOutput `pulumi:"maxQueryCount"`
	// Maximum receipt times. Value range: 1-1000.
	MaxReceiveCount pulumi.IntPtrOutput `pulumi:"maxReceiveCount"`
	// Maximum period in seconds before an unconsumed message expires, which is required if `policy` is 1. Value range: 300-43200. This value should be smaller than `msgRetentionSeconds` (maximum message retention period).
	MaxTimeToLive pulumi.IntPtrOutput `pulumi:"maxTimeToLive"`
	// The max period during which a message is retained before it is automatically acknowledged. Value range: 30-43,200 seconds (30 seconds to 12 hours). Default value: 3600 seconds (1 hour).
	MsgRetentionSeconds pulumi.IntPtrOutput `pulumi:"msgRetentionSeconds"`
	// Dead letter policy. 0: message has been consumed multiple times but not deleted; 1: `Time-To-Live` has elapsed.
	Policy pulumi.IntPtrOutput `pulumi:"policy"`
	// Long polling wait time for message reception. Value range: 0-30 seconds. Default value: 0.
	PollingWaitSeconds pulumi.IntPtrOutput `pulumi:"pollingWaitSeconds"`
	// Queue name, which must be unique under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	QueueName pulumi.StringOutput `pulumi:"queueName"`
	// Queue storage space configured for message rewind. Value range: 10,240-512,000 MB (if message rewind is enabled). The value `0` indicates that message rewind is not enabled.
	RetentionSizeInMb pulumi.IntPtrOutput `pulumi:"retentionSizeInMb"`
	// Rewindable time of messages in the queue. Value range: 0-1,296,000s (if message rewind is enabled). The value `0` indicates that message rewind is not enabled.
	RewindSeconds pulumi.IntPtrOutput `pulumi:"rewindSeconds"`
	// Whether to enable message trace. true: yes; false: no. If this field is not configured, the feature will not be enabled.
	Trace pulumi.BoolPtrOutput `pulumi:"trace"`
	// 1: transaction queue; 0: general queue.
	Transaction pulumi.IntPtrOutput `pulumi:"transaction"`
	// Message visibility timeout period. Value range: 1-43200 seconds (i.e., 12 hours). Default value: 30.
	VisibilityTimeout pulumi.IntPtrOutput `pulumi:"visibilityTimeout"`
}

Provides a resource to create a tcmq queue

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/tencentcloudstack/pulumi-tencentcloud/sdk/go/tencentcloud/Tcmq"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := Tcmq.NewQueue(ctx, "queue", &Tcmq.QueueArgs{
			QueueName: pulumi.String("queue_name"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

tcmq queue can be imported using the id, e.g.

```sh 

$ pulumi import tencentcloud:Tcmq/queue:Queue queue queue_id

```

func GetQueue 

func GetQueue(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *QueueState, opts ...pulumi.ResourceOption) (*Queue, error)

GetQueue gets an existing Queue 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 NewQueue 

func NewQueue(ctx *pulumi.Context,
	name string, args *QueueArgs, opts ...pulumi.ResourceOption) (*Queue, error)

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

func (*Queue) ElementType 

func (*Queue) ElementType() reflect.Type

func (*Queue) ToQueueOutput 

func (i *Queue) ToQueueOutput() QueueOutput

func (*Queue) ToQueueOutputWithContext 

func (i *Queue) ToQueueOutputWithContext(ctx context.Context) QueueOutput

type QueueArgs 

type QueueArgs struct {
	// Dead letter queue name.
	DeadLetterQueueName pulumi.StringPtrInput
	// First lookback interval.
	FirstQueryInterval pulumi.IntPtrInput
	// Maximum number of heaped messages. The value range is 1,000,000-10,000,000 during the beta test and can be 1,000,000-1,000,000,000 after the product is officially released. The default value is 10,000,000 during the beta test and will be 100,000,000 after the product is officially released.
	MaxMsgHeapNum pulumi.IntPtrInput
	// Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.
	MaxMsgSize pulumi.IntPtrInput
	// Maximum number of lookbacks.
	MaxQueryCount pulumi.IntPtrInput
	// Maximum receipt times. Value range: 1-1000.
	MaxReceiveCount pulumi.IntPtrInput
	// Maximum period in seconds before an unconsumed message expires, which is required if `policy` is 1. Value range: 300-43200. This value should be smaller than `msgRetentionSeconds` (maximum message retention period).
	MaxTimeToLive pulumi.IntPtrInput
	// The max period during which a message is retained before it is automatically acknowledged. Value range: 30-43,200 seconds (30 seconds to 12 hours). Default value: 3600 seconds (1 hour).
	MsgRetentionSeconds pulumi.IntPtrInput
	// Dead letter policy. 0: message has been consumed multiple times but not deleted; 1: `Time-To-Live` has elapsed.
	Policy pulumi.IntPtrInput
	// Long polling wait time for message reception. Value range: 0-30 seconds. Default value: 0.
	PollingWaitSeconds pulumi.IntPtrInput
	// Queue name, which must be unique under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	QueueName pulumi.StringInput
	// Queue storage space configured for message rewind. Value range: 10,240-512,000 MB (if message rewind is enabled). The value `0` indicates that message rewind is not enabled.
	RetentionSizeInMb pulumi.IntPtrInput
	// Rewindable time of messages in the queue. Value range: 0-1,296,000s (if message rewind is enabled). The value `0` indicates that message rewind is not enabled.
	RewindSeconds pulumi.IntPtrInput
	// Whether to enable message trace. true: yes; false: no. If this field is not configured, the feature will not be enabled.
	Trace pulumi.BoolPtrInput
	// 1: transaction queue; 0: general queue.
	Transaction pulumi.IntPtrInput
	// Message visibility timeout period. Value range: 1-43200 seconds (i.e., 12 hours). Default value: 30.
	VisibilityTimeout pulumi.IntPtrInput
}

The set of arguments for constructing a Queue resource.

func (QueueArgs) ElementType 

func (QueueArgs) ElementType() reflect.Type

type QueueArray 

type QueueArray []QueueInput

func (QueueArray) ElementType 

func (QueueArray) ElementType() reflect.Type

func (QueueArray) ToQueueArrayOutput 

func (i QueueArray) ToQueueArrayOutput() QueueArrayOutput

func (QueueArray) ToQueueArrayOutputWithContext 

func (i QueueArray) ToQueueArrayOutputWithContext(ctx context.Context) QueueArrayOutput

type QueueArrayInput 

type QueueArrayInput interface {
	pulumi.Input

	ToQueueArrayOutput() QueueArrayOutput
	ToQueueArrayOutputWithContext(context.Context) QueueArrayOutput
}

QueueArrayInput is an input type that accepts QueueArray and QueueArrayOutput values. You can construct a concrete instance of `QueueArrayInput` via: 

QueueArray{ QueueArgs{...} }

type QueueArrayOutput 

type QueueArrayOutput struct{ *pulumi.OutputState }

func (QueueArrayOutput) ElementType 

func (QueueArrayOutput) ElementType() reflect.Type

func (QueueArrayOutput) Index 

func (o QueueArrayOutput) Index(i pulumi.IntInput) QueueOutput

func (QueueArrayOutput) ToQueueArrayOutput 

func (o QueueArrayOutput) ToQueueArrayOutput() QueueArrayOutput

func (QueueArrayOutput) ToQueueArrayOutputWithContext 

func (o QueueArrayOutput) ToQueueArrayOutputWithContext(ctx context.Context) QueueArrayOutput

type QueueInput 

type QueueInput interface {
	pulumi.Input

	ToQueueOutput() QueueOutput
	ToQueueOutputWithContext(ctx context.Context) QueueOutput
}

type QueueMap 

type QueueMap map[string]QueueInput

func (QueueMap) ElementType 

func (QueueMap) ElementType() reflect.Type

func (QueueMap) ToQueueMapOutput 

func (i QueueMap) ToQueueMapOutput() QueueMapOutput

func (QueueMap) ToQueueMapOutputWithContext 

func (i QueueMap) ToQueueMapOutputWithContext(ctx context.Context) QueueMapOutput

type QueueMapInput 

type QueueMapInput interface {
	pulumi.Input

	ToQueueMapOutput() QueueMapOutput
	ToQueueMapOutputWithContext(context.Context) QueueMapOutput
}

QueueMapInput is an input type that accepts QueueMap and QueueMapOutput values. You can construct a concrete instance of `QueueMapInput` via: 

QueueMap{ "key": QueueArgs{...} }

type QueueMapOutput 

type QueueMapOutput struct{ *pulumi.OutputState }

func (QueueMapOutput) ElementType 

func (QueueMapOutput) ElementType() reflect.Type

func (QueueMapOutput) MapIndex 

func (o QueueMapOutput) MapIndex(k pulumi.StringInput) QueueOutput

func (QueueMapOutput) ToQueueMapOutput 

func (o QueueMapOutput) ToQueueMapOutput() QueueMapOutput

func (QueueMapOutput) ToQueueMapOutputWithContext 

func (o QueueMapOutput) ToQueueMapOutputWithContext(ctx context.Context) QueueMapOutput

type QueueOutput 

type QueueOutput struct{ *pulumi.OutputState }

func (QueueOutput) DeadLetterQueueName 

func (o QueueOutput) DeadLetterQueueName() pulumi.StringPtrOutput

Dead letter queue name.

func (QueueOutput) ElementType 

func (QueueOutput) ElementType() reflect.Type

func (QueueOutput) FirstQueryInterval 

func (o QueueOutput) FirstQueryInterval() pulumi.IntPtrOutput

First lookback interval.

func (QueueOutput) MaxMsgHeapNum 

func (o QueueOutput) MaxMsgHeapNum() pulumi.IntPtrOutput

Maximum number of heaped messages. The value range is 1,000,000-10,000,000 during the beta test and can be 1,000,000-1,000,000,000 after the product is officially released. The default value is 10,000,000 during the beta test and will be 100,000,000 after the product is officially released.

func (QueueOutput) MaxMsgSize 

func (o QueueOutput) MaxMsgSize() pulumi.IntPtrOutput

Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.

func (QueueOutput) MaxQueryCount 

func (o QueueOutput) MaxQueryCount() pulumi.IntPtrOutput

Maximum number of lookbacks.

func (QueueOutput) MaxReceiveCount 

func (o QueueOutput) MaxReceiveCount() pulumi.IntPtrOutput

Maximum receipt times. Value range: 1-1000.

func (QueueOutput) MaxTimeToLive 

func (o QueueOutput) MaxTimeToLive() pulumi.IntPtrOutput

Maximum period in seconds before an unconsumed message expires, which is required if `policy` is 1. Value range: 300-43200. This value should be smaller than `msgRetentionSeconds` (maximum message retention period).

func (QueueOutput) MsgRetentionSeconds 

func (o QueueOutput) MsgRetentionSeconds() pulumi.IntPtrOutput

The max period during which a message is retained before it is automatically acknowledged. Value range: 30-43,200 seconds (30 seconds to 12 hours). Default value: 3600 seconds (1 hour).

func (QueueOutput) Policy 

func (o QueueOutput) Policy() pulumi.IntPtrOutput

Dead letter policy. 0: message has been consumed multiple times but not deleted; 1: `Time-To-Live` has elapsed.

func (QueueOutput) PollingWaitSeconds 

func (o QueueOutput) PollingWaitSeconds() pulumi.IntPtrOutput

Long polling wait time for message reception. Value range: 0-30 seconds. Default value: 0.

func (QueueOutput) QueueName 

func (o QueueOutput) QueueName() pulumi.StringOutput

Queue name, which must be unique under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.

func (QueueOutput) RetentionSizeInMb 

func (o QueueOutput) RetentionSizeInMb() pulumi.IntPtrOutput

Queue storage space configured for message rewind. Value range: 10,240-512,000 MB (if message rewind is enabled). The value `0` indicates that message rewind is not enabled.

func (QueueOutput) RewindSeconds 

func (o QueueOutput) RewindSeconds() pulumi.IntPtrOutput

Rewindable time of messages in the queue. Value range: 0-1,296,000s (if message rewind is enabled). The value `0` indicates that message rewind is not enabled.

func (QueueOutput) ToQueueOutput 

func (o QueueOutput) ToQueueOutput() QueueOutput

func (QueueOutput) ToQueueOutputWithContext 

func (o QueueOutput) ToQueueOutputWithContext(ctx context.Context) QueueOutput

func (QueueOutput) Trace 

func (o QueueOutput) Trace() pulumi.BoolPtrOutput

Whether to enable message trace. true: yes; false: no. If this field is not configured, the feature will not be enabled.

func (QueueOutput) Transaction 

func (o QueueOutput) Transaction() pulumi.IntPtrOutput

1: transaction queue; 0: general queue.

func (QueueOutput) VisibilityTimeout 

func (o QueueOutput) VisibilityTimeout() pulumi.IntPtrOutput

Message visibility timeout period. Value range: 1-43200 seconds (i.e., 12 hours). Default value: 30.

type QueueState 

type QueueState struct {
	// Dead letter queue name.
	DeadLetterQueueName pulumi.StringPtrInput
	// First lookback interval.
	FirstQueryInterval pulumi.IntPtrInput
	// Maximum number of heaped messages. The value range is 1,000,000-10,000,000 during the beta test and can be 1,000,000-1,000,000,000 after the product is officially released. The default value is 10,000,000 during the beta test and will be 100,000,000 after the product is officially released.
	MaxMsgHeapNum pulumi.IntPtrInput
	// Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.
	MaxMsgSize pulumi.IntPtrInput
	// Maximum number of lookbacks.
	MaxQueryCount pulumi.IntPtrInput
	// Maximum receipt times. Value range: 1-1000.
	MaxReceiveCount pulumi.IntPtrInput
	// Maximum period in seconds before an unconsumed message expires, which is required if `policy` is 1. Value range: 300-43200. This value should be smaller than `msgRetentionSeconds` (maximum message retention period).
	MaxTimeToLive pulumi.IntPtrInput
	// The max period during which a message is retained before it is automatically acknowledged. Value range: 30-43,200 seconds (30 seconds to 12 hours). Default value: 3600 seconds (1 hour).
	MsgRetentionSeconds pulumi.IntPtrInput
	// Dead letter policy. 0: message has been consumed multiple times but not deleted; 1: `Time-To-Live` has elapsed.
	Policy pulumi.IntPtrInput
	// Long polling wait time for message reception. Value range: 0-30 seconds. Default value: 0.
	PollingWaitSeconds pulumi.IntPtrInput
	// Queue name, which must be unique under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	QueueName pulumi.StringPtrInput
	// Queue storage space configured for message rewind. Value range: 10,240-512,000 MB (if message rewind is enabled). The value `0` indicates that message rewind is not enabled.
	RetentionSizeInMb pulumi.IntPtrInput
	// Rewindable time of messages in the queue. Value range: 0-1,296,000s (if message rewind is enabled). The value `0` indicates that message rewind is not enabled.
	RewindSeconds pulumi.IntPtrInput
	// Whether to enable message trace. true: yes; false: no. If this field is not configured, the feature will not be enabled.
	Trace pulumi.BoolPtrInput
	// 1: transaction queue; 0: general queue.
	Transaction pulumi.IntPtrInput
	// Message visibility timeout period. Value range: 1-43200 seconds (i.e., 12 hours). Default value: 30.
	VisibilityTimeout pulumi.IntPtrInput
}

func (QueueState) ElementType 

func (QueueState) ElementType() reflect.Type

type Subscribe 

type Subscribe struct {
	pulumi.CustomResourceState

	// The number of `BindingKey` cannot exceed 5, and the length of each `BindingKey` cannot exceed 64 bytes. This field indicates the filtering policy for subscribing to and receiving messages. Each `BindingKey` includes up to 15 dots (namely up to 16 segments).
	BindingKeys pulumi.StringArrayOutput `pulumi:"bindingKeys"`
	// `Endpoint` for notification receipt, which is distinguished by `Protocol`. For `http`, `Endpoint` must begin with `http://` and `host` can be a domain name or IP. For `Queue`, enter `QueueName`. Note that currently the push service cannot push messages to a VPC; therefore, if a VPC domain name or address is entered for `Endpoint`, pushed messages will not be received. Currently, messages can be pushed only to the public network and classic network.
	Endpoint pulumi.StringOutput `pulumi:"endpoint"`
	// Message body tag (used for message filtering). The number of tags cannot exceed 5, and each tag can contain up to 16 characters. It is used in conjunction with the `MsgTag` parameter of `(Batch)PublishMessage`. Rules: 1. If `FilterTag` is not configured, no matter whether `MsgTag` is configured, the subscription will receive all messages published to the topic; 2. If the array of `FilterTag` values has a value, only when at least one of the values in the array also exists in the array of `MsgTag` values (i.e., `FilterTag` and `MsgTag` have an intersection) can the subscription receive messages published to the topic; 3. If the array of `FilterTag` values has a value, but `MsgTag` is not configured, then no message published to the topic will be received, which can be considered as a special case of rule 2 as `FilterTag` and `MsgTag` do not intersect in this case. The overall design idea of rules is based on the intention of the subscriber.
	FilterTags pulumi.StringArrayOutput `pulumi:"filterTags"`
	// Push content format. Valid values: 1. JSON; 2. SIMPLIFIED, i.e., the raw format. If `Protocol` is `queue`, this value must be `SIMPLIFIED`. If `Protocol` is `http`, both options are acceptable, and the default value is `JSON`.
	NotifyContentFormat pulumi.StringPtrOutput `pulumi:"notifyContentFormat"`
	// CMQ push server retry policy in case an error occurs while pushing a message to `Endpoint`. Valid values: 1. `BACKOFF_RETRY`: backoff retry, which is to retry at a fixed interval, discard the message after a certain number of retries, and continue to push the next message; 2. `EXPONENTIAL_DECAY_RETRY`: exponential decay retry, which is to retry at an exponentially increasing interval, such as 1s, 2s, 4s, 8s, and so on. As a message can be retained in a topic for one day, failed messages will be discarded at most after one day of retry. Default value: `EXPONENTIAL_DECAY_RETRY`.
	NotifyStrategy pulumi.StringPtrOutput `pulumi:"notifyStrategy"`
	// ubscription protocol. Currently, two protocols are supported: `http` and `queue`. To use the `http` protocol, you need to build your own web server to receive messages. With the `queue` protocol, messages are automatically pushed to a CMQ queue and you can pull them concurrently.
	Protocol pulumi.StringOutput `pulumi:"protocol"`
	// Subscription name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	SubscriptionName pulumi.StringOutput `pulumi:"subscriptionName"`
	// Tag description list.
	Tags pulumi.MapOutput `pulumi:"tags"`
	// Topic name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	TopicName pulumi.StringOutput `pulumi:"topicName"`
}

Provides a resource to create a tcmq subscribe

## Import

tcmq subscribe can be imported using the id, e.g.

```sh 

$ pulumi import tencentcloud:Tcmq/subscribe:Subscribe subscribe subscribe_id

```

func GetSubscribe 

func GetSubscribe(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *SubscribeState, opts ...pulumi.ResourceOption) (*Subscribe, error)

GetSubscribe gets an existing Subscribe 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 NewSubscribe 

func NewSubscribe(ctx *pulumi.Context,
	name string, args *SubscribeArgs, opts ...pulumi.ResourceOption) (*Subscribe, error)

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

func (*Subscribe) ElementType 

func (*Subscribe) ElementType() reflect.Type

func (*Subscribe) ToSubscribeOutput 

func (i *Subscribe) ToSubscribeOutput() SubscribeOutput

func (*Subscribe) ToSubscribeOutputWithContext 

func (i *Subscribe) ToSubscribeOutputWithContext(ctx context.Context) SubscribeOutput

type SubscribeArgs 

type SubscribeArgs struct {
	// The number of `BindingKey` cannot exceed 5, and the length of each `BindingKey` cannot exceed 64 bytes. This field indicates the filtering policy for subscribing to and receiving messages. Each `BindingKey` includes up to 15 dots (namely up to 16 segments).
	BindingKeys pulumi.StringArrayInput
	// `Endpoint` for notification receipt, which is distinguished by `Protocol`. For `http`, `Endpoint` must begin with `http://` and `host` can be a domain name or IP. For `Queue`, enter `QueueName`. Note that currently the push service cannot push messages to a VPC; therefore, if a VPC domain name or address is entered for `Endpoint`, pushed messages will not be received. Currently, messages can be pushed only to the public network and classic network.
	Endpoint pulumi.StringInput
	// Message body tag (used for message filtering). The number of tags cannot exceed 5, and each tag can contain up to 16 characters. It is used in conjunction with the `MsgTag` parameter of `(Batch)PublishMessage`. Rules: 1. If `FilterTag` is not configured, no matter whether `MsgTag` is configured, the subscription will receive all messages published to the topic; 2. If the array of `FilterTag` values has a value, only when at least one of the values in the array also exists in the array of `MsgTag` values (i.e., `FilterTag` and `MsgTag` have an intersection) can the subscription receive messages published to the topic; 3. If the array of `FilterTag` values has a value, but `MsgTag` is not configured, then no message published to the topic will be received, which can be considered as a special case of rule 2 as `FilterTag` and `MsgTag` do not intersect in this case. The overall design idea of rules is based on the intention of the subscriber.
	FilterTags pulumi.StringArrayInput
	// Push content format. Valid values: 1. JSON; 2. SIMPLIFIED, i.e., the raw format. If `Protocol` is `queue`, this value must be `SIMPLIFIED`. If `Protocol` is `http`, both options are acceptable, and the default value is `JSON`.
	NotifyContentFormat pulumi.StringPtrInput
	// CMQ push server retry policy in case an error occurs while pushing a message to `Endpoint`. Valid values: 1. `BACKOFF_RETRY`: backoff retry, which is to retry at a fixed interval, discard the message after a certain number of retries, and continue to push the next message; 2. `EXPONENTIAL_DECAY_RETRY`: exponential decay retry, which is to retry at an exponentially increasing interval, such as 1s, 2s, 4s, 8s, and so on. As a message can be retained in a topic for one day, failed messages will be discarded at most after one day of retry. Default value: `EXPONENTIAL_DECAY_RETRY`.
	NotifyStrategy pulumi.StringPtrInput
	// ubscription protocol. Currently, two protocols are supported: `http` and `queue`. To use the `http` protocol, you need to build your own web server to receive messages. With the `queue` protocol, messages are automatically pushed to a CMQ queue and you can pull them concurrently.
	Protocol pulumi.StringInput
	// Subscription name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	SubscriptionName pulumi.StringInput
	// Tag description list.
	Tags pulumi.MapInput
	// Topic name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	TopicName pulumi.StringInput
}

The set of arguments for constructing a Subscribe resource.

func (SubscribeArgs) ElementType 

func (SubscribeArgs) ElementType() reflect.Type

type SubscribeArray 

type SubscribeArray []SubscribeInput

func (SubscribeArray) ElementType 

func (SubscribeArray) ElementType() reflect.Type

func (SubscribeArray) ToSubscribeArrayOutput 

func (i SubscribeArray) ToSubscribeArrayOutput() SubscribeArrayOutput

func (SubscribeArray) ToSubscribeArrayOutputWithContext 

func (i SubscribeArray) ToSubscribeArrayOutputWithContext(ctx context.Context) SubscribeArrayOutput

type SubscribeArrayInput 

type SubscribeArrayInput interface {
	pulumi.Input

	ToSubscribeArrayOutput() SubscribeArrayOutput
	ToSubscribeArrayOutputWithContext(context.Context) SubscribeArrayOutput
}

SubscribeArrayInput is an input type that accepts SubscribeArray and SubscribeArrayOutput values. You can construct a concrete instance of `SubscribeArrayInput` via: 

SubscribeArray{ SubscribeArgs{...} }

type SubscribeArrayOutput 

type SubscribeArrayOutput struct{ *pulumi.OutputState }

func (SubscribeArrayOutput) ElementType 

func (SubscribeArrayOutput) ElementType() reflect.Type

func (SubscribeArrayOutput) Index 

func (o SubscribeArrayOutput) Index(i pulumi.IntInput) SubscribeOutput

func (SubscribeArrayOutput) ToSubscribeArrayOutput 

func (o SubscribeArrayOutput) ToSubscribeArrayOutput() SubscribeArrayOutput

func (SubscribeArrayOutput) ToSubscribeArrayOutputWithContext 

func (o SubscribeArrayOutput) ToSubscribeArrayOutputWithContext(ctx context.Context) SubscribeArrayOutput

type SubscribeInput 

type SubscribeInput interface {
	pulumi.Input

	ToSubscribeOutput() SubscribeOutput
	ToSubscribeOutputWithContext(ctx context.Context) SubscribeOutput
}

type SubscribeMap 

type SubscribeMap map[string]SubscribeInput

func (SubscribeMap) ElementType 

func (SubscribeMap) ElementType() reflect.Type

func (SubscribeMap) ToSubscribeMapOutput 

func (i SubscribeMap) ToSubscribeMapOutput() SubscribeMapOutput

func (SubscribeMap) ToSubscribeMapOutputWithContext 

func (i SubscribeMap) ToSubscribeMapOutputWithContext(ctx context.Context) SubscribeMapOutput

type SubscribeMapInput 

type SubscribeMapInput interface {
	pulumi.Input

	ToSubscribeMapOutput() SubscribeMapOutput
	ToSubscribeMapOutputWithContext(context.Context) SubscribeMapOutput
}

SubscribeMapInput is an input type that accepts SubscribeMap and SubscribeMapOutput values. You can construct a concrete instance of `SubscribeMapInput` via: 

SubscribeMap{ "key": SubscribeArgs{...} }

type SubscribeMapOutput 

type SubscribeMapOutput struct{ *pulumi.OutputState }

func (SubscribeMapOutput) ElementType 

func (SubscribeMapOutput) ElementType() reflect.Type

func (SubscribeMapOutput) MapIndex 

func (o SubscribeMapOutput) MapIndex(k pulumi.StringInput) SubscribeOutput

func (SubscribeMapOutput) ToSubscribeMapOutput 

func (o SubscribeMapOutput) ToSubscribeMapOutput() SubscribeMapOutput

func (SubscribeMapOutput) ToSubscribeMapOutputWithContext 

func (o SubscribeMapOutput) ToSubscribeMapOutputWithContext(ctx context.Context) SubscribeMapOutput

type SubscribeOutput 

type SubscribeOutput struct{ *pulumi.OutputState }

func (SubscribeOutput) BindingKeys 

func (o SubscribeOutput) BindingKeys() pulumi.StringArrayOutput

The number of `BindingKey` cannot exceed 5, and the length of each `BindingKey` cannot exceed 64 bytes. This field indicates the filtering policy for subscribing to and receiving messages. Each `BindingKey` includes up to 15 dots (namely up to 16 segments).

func (SubscribeOutput) ElementType 

func (SubscribeOutput) ElementType() reflect.Type

func (SubscribeOutput) Endpoint 

func (o SubscribeOutput) Endpoint() pulumi.StringOutput

`Endpoint` for notification receipt, which is distinguished by `Protocol`. For `http`, `Endpoint` must begin with `http://` and `host` can be a domain name or IP. For `Queue`, enter `QueueName`. Note that currently the push service cannot push messages to a VPC; therefore, if a VPC domain name or address is entered for `Endpoint`, pushed messages will not be received. Currently, messages can be pushed only to the public network and classic network.

func (SubscribeOutput) FilterTags 

func (o SubscribeOutput) FilterTags() pulumi.StringArrayOutput

Message body tag (used for message filtering). The number of tags cannot exceed 5, and each tag can contain up to 16 characters. It is used in conjunction with the `MsgTag` parameter of `(Batch)PublishMessage`. Rules: 1. If `FilterTag` is not configured, no matter whether `MsgTag` is configured, the subscription will receive all messages published to the topic; 2. If the array of `FilterTag` values has a value, only when at least one of the values in the array also exists in the array of `MsgTag` values (i.e., `FilterTag` and `MsgTag` have an intersection) can the subscription receive messages published to the topic; 3. If the array of `FilterTag` values has a value, but `MsgTag` is not configured, then no message published to the topic will be received, which can be considered as a special case of rule 2 as `FilterTag` and `MsgTag` do not intersect in this case. The overall design idea of rules is based on the intention of the subscriber.

func (SubscribeOutput) NotifyContentFormat 

func (o SubscribeOutput) NotifyContentFormat() pulumi.StringPtrOutput

Push content format. Valid values: 1. JSON; 2. SIMPLIFIED, i.e., the raw format. If `Protocol` is `queue`, this value must be `SIMPLIFIED`. If `Protocol` is `http`, both options are acceptable, and the default value is `JSON`.

func (SubscribeOutput) NotifyStrategy 

func (o SubscribeOutput) NotifyStrategy() pulumi.StringPtrOutput

CMQ push server retry policy in case an error occurs while pushing a message to `Endpoint`. Valid values: 1. `BACKOFF_RETRY`: backoff retry, which is to retry at a fixed interval, discard the message after a certain number of retries, and continue to push the next message; 2. `EXPONENTIAL_DECAY_RETRY`: exponential decay retry, which is to retry at an exponentially increasing interval, such as 1s, 2s, 4s, 8s, and so on. As a message can be retained in a topic for one day, failed messages will be discarded at most after one day of retry. Default value: `EXPONENTIAL_DECAY_RETRY`.

func (SubscribeOutput) Protocol 

func (o SubscribeOutput) Protocol() pulumi.StringOutput

ubscription protocol. Currently, two protocols are supported: `http` and `queue`. To use the `http` protocol, you need to build your own web server to receive messages. With the `queue` protocol, messages are automatically pushed to a CMQ queue and you can pull them concurrently.

func (SubscribeOutput) SubscriptionName 

func (o SubscribeOutput) SubscriptionName() pulumi.StringOutput

Subscription name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.

func (SubscribeOutput) Tags 

func (o SubscribeOutput) Tags() pulumi.MapOutput

Tag description list.

func (SubscribeOutput) ToSubscribeOutput 

func (o SubscribeOutput) ToSubscribeOutput() SubscribeOutput

func (SubscribeOutput) ToSubscribeOutputWithContext 

func (o SubscribeOutput) ToSubscribeOutputWithContext(ctx context.Context) SubscribeOutput

func (SubscribeOutput) TopicName 

func (o SubscribeOutput) TopicName() pulumi.StringOutput

Topic name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.

type SubscribeState 

type SubscribeState struct {
	// The number of `BindingKey` cannot exceed 5, and the length of each `BindingKey` cannot exceed 64 bytes. This field indicates the filtering policy for subscribing to and receiving messages. Each `BindingKey` includes up to 15 dots (namely up to 16 segments).
	BindingKeys pulumi.StringArrayInput
	// `Endpoint` for notification receipt, which is distinguished by `Protocol`. For `http`, `Endpoint` must begin with `http://` and `host` can be a domain name or IP. For `Queue`, enter `QueueName`. Note that currently the push service cannot push messages to a VPC; therefore, if a VPC domain name or address is entered for `Endpoint`, pushed messages will not be received. Currently, messages can be pushed only to the public network and classic network.
	Endpoint pulumi.StringPtrInput
	// Message body tag (used for message filtering). The number of tags cannot exceed 5, and each tag can contain up to 16 characters. It is used in conjunction with the `MsgTag` parameter of `(Batch)PublishMessage`. Rules: 1. If `FilterTag` is not configured, no matter whether `MsgTag` is configured, the subscription will receive all messages published to the topic; 2. If the array of `FilterTag` values has a value, only when at least one of the values in the array also exists in the array of `MsgTag` values (i.e., `FilterTag` and `MsgTag` have an intersection) can the subscription receive messages published to the topic; 3. If the array of `FilterTag` values has a value, but `MsgTag` is not configured, then no message published to the topic will be received, which can be considered as a special case of rule 2 as `FilterTag` and `MsgTag` do not intersect in this case. The overall design idea of rules is based on the intention of the subscriber.
	FilterTags pulumi.StringArrayInput
	// Push content format. Valid values: 1. JSON; 2. SIMPLIFIED, i.e., the raw format. If `Protocol` is `queue`, this value must be `SIMPLIFIED`. If `Protocol` is `http`, both options are acceptable, and the default value is `JSON`.
	NotifyContentFormat pulumi.StringPtrInput
	// CMQ push server retry policy in case an error occurs while pushing a message to `Endpoint`. Valid values: 1. `BACKOFF_RETRY`: backoff retry, which is to retry at a fixed interval, discard the message after a certain number of retries, and continue to push the next message; 2. `EXPONENTIAL_DECAY_RETRY`: exponential decay retry, which is to retry at an exponentially increasing interval, such as 1s, 2s, 4s, 8s, and so on. As a message can be retained in a topic for one day, failed messages will be discarded at most after one day of retry. Default value: `EXPONENTIAL_DECAY_RETRY`.
	NotifyStrategy pulumi.StringPtrInput
	// ubscription protocol. Currently, two protocols are supported: `http` and `queue`. To use the `http` protocol, you need to build your own web server to receive messages. With the `queue` protocol, messages are automatically pushed to a CMQ queue and you can pull them concurrently.
	Protocol pulumi.StringPtrInput
	// Subscription name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	SubscriptionName pulumi.StringPtrInput
	// Tag description list.
	Tags pulumi.MapInput
	// Topic name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	TopicName pulumi.StringPtrInput
}

func (SubscribeState) ElementType 

func (SubscribeState) ElementType() reflect.Type

type Topic 

type Topic struct {
	pulumi.CustomResourceState

	// Used to specify the message match policy for the topic. `1`: tag match policy (default value); `2`: routing match policy.
	FilterType pulumi.IntPtrOutput `pulumi:"filterType"`
	// Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.
	MaxMsgSize pulumi.IntPtrOutput `pulumi:"maxMsgSize"`
	// Message retention period. Value range: 60-86400 seconds (i.e., 1 minute-1 day). Default value: 86400.
	MsgRetentionSeconds pulumi.IntPtrOutput `pulumi:"msgRetentionSeconds"`
	// Topic name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	TopicName pulumi.StringOutput `pulumi:"topicName"`
	// Whether to enable message trace. true: yes; false: no. If this field is left empty, the feature will not be enabled.
	Trace pulumi.BoolPtrOutput `pulumi:"trace"`
}

Provides a resource to create a tcmq topic

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/tencentcloudstack/pulumi-tencentcloud/sdk/go/tencentcloud/Tcmq"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := Tcmq.NewTopic(ctx, "topic", &Tcmq.TopicArgs{
			TopicName: pulumi.String("topic_name"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

tcmq topic can be imported using the id, e.g.

```sh 

$ pulumi import tencentcloud:Tcmq/topic:Topic topic topic_id

```

func GetTopic 

func GetTopic(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *TopicState, opts ...pulumi.ResourceOption) (*Topic, error)

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

func NewTopic 

func NewTopic(ctx *pulumi.Context,
	name string, args *TopicArgs, opts ...pulumi.ResourceOption) (*Topic, error)

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

func (*Topic) ElementType 

func (*Topic) ElementType() reflect.Type

func (*Topic) ToTopicOutput 

func (i *Topic) ToTopicOutput() TopicOutput

func (*Topic) ToTopicOutputWithContext 

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

type TopicArgs 

type TopicArgs struct {
	// Used to specify the message match policy for the topic. `1`: tag match policy (default value); `2`: routing match policy.
	FilterType pulumi.IntPtrInput
	// Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.
	MaxMsgSize pulumi.IntPtrInput
	// Message retention period. Value range: 60-86400 seconds (i.e., 1 minute-1 day). Default value: 86400.
	MsgRetentionSeconds pulumi.IntPtrInput
	// Topic name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	TopicName pulumi.StringInput
	// Whether to enable message trace. true: yes; false: no. If this field is left empty, the feature will not be enabled.
	Trace pulumi.BoolPtrInput
}

The set of arguments for constructing a Topic resource.

func (TopicArgs) ElementType 

func (TopicArgs) ElementType() reflect.Type

type TopicArray 

type TopicArray []TopicInput

func (TopicArray) ElementType 

func (TopicArray) ElementType() reflect.Type

func (TopicArray) ToTopicArrayOutput 

func (i TopicArray) ToTopicArrayOutput() TopicArrayOutput

func (TopicArray) ToTopicArrayOutputWithContext 

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

type TopicArrayInput 

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 

type TopicArrayOutput struct{ *pulumi.OutputState }

func (TopicArrayOutput) ElementType 

func (TopicArrayOutput) ElementType() reflect.Type

func (TopicArrayOutput) Index 

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

func (TopicArrayOutput) ToTopicArrayOutput 

func (o TopicArrayOutput) ToTopicArrayOutput() TopicArrayOutput

func (TopicArrayOutput) ToTopicArrayOutputWithContext 

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

type TopicInput 

type TopicInput interface {
	pulumi.Input

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

type TopicMap 

type TopicMap map[string]TopicInput

func (TopicMap) ElementType 

func (TopicMap) ElementType() reflect.Type

func (TopicMap) ToTopicMapOutput 

func (i TopicMap) ToTopicMapOutput() TopicMapOutput

func (TopicMap) ToTopicMapOutputWithContext 

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

type TopicMapInput 

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 

type TopicMapOutput struct{ *pulumi.OutputState }

func (TopicMapOutput) ElementType 

func (TopicMapOutput) ElementType() reflect.Type

func (TopicMapOutput) MapIndex 

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

func (TopicMapOutput) ToTopicMapOutput 

func (o TopicMapOutput) ToTopicMapOutput() TopicMapOutput

func (TopicMapOutput) ToTopicMapOutputWithContext 

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

type TopicOutput 

type TopicOutput struct{ *pulumi.OutputState }

func (TopicOutput) ElementType 

func (TopicOutput) ElementType() reflect.Type

func (TopicOutput) FilterType 

func (o TopicOutput) FilterType() pulumi.IntPtrOutput

Used to specify the message match policy for the topic. `1`: tag match policy (default value); `2`: routing match policy.

func (TopicOutput) MaxMsgSize 

func (o TopicOutput) MaxMsgSize() pulumi.IntPtrOutput

Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.

func (TopicOutput) MsgRetentionSeconds 

func (o TopicOutput) MsgRetentionSeconds() pulumi.IntPtrOutput

Message retention period. Value range: 60-86400 seconds (i.e., 1 minute-1 day). Default value: 86400.

func (TopicOutput) ToTopicOutput 

func (o TopicOutput) ToTopicOutput() TopicOutput

func (TopicOutput) ToTopicOutputWithContext 

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

func (TopicOutput) TopicName 

func (o TopicOutput) TopicName() pulumi.StringOutput

Topic name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.

func (TopicOutput) Trace 

func (o TopicOutput) Trace() pulumi.BoolPtrOutput

Whether to enable message trace. true: yes; false: no. If this field is left empty, the feature will not be enabled.

type TopicState 

type TopicState struct {
	// Used to specify the message match policy for the topic. `1`: tag match policy (default value); `2`: routing match policy.
	FilterType pulumi.IntPtrInput
	// Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.
	MaxMsgSize pulumi.IntPtrInput
	// Message retention period. Value range: 60-86400 seconds (i.e., 1 minute-1 day). Default value: 86400.
	MsgRetentionSeconds pulumi.IntPtrInput
	// Topic name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	TopicName pulumi.StringPtrInput
	// Whether to enable message trace. true: yes; false: no. If this field is left empty, the feature will not be enabled.
	Trace pulumi.BoolPtrInput
}

func (TopicState) ElementType 

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.