tcmq

package
v0.0.0-...-9153d0a Latest Latest
Warning

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

Go to latest
Published: Sep 8, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type GetQueueFilter

type GetQueueFilter struct {
	Name   *string  `pulumi:"name"`
	Values []string `pulumi:"values"`
}

type GetQueueFilterArgs

type GetQueueFilterArgs struct {
	Name   pulumi.StringPtrInput   `pulumi:"name"`
	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 (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 (GetQueueFilterOutput) ToGetQueueFilterOutput

func (o GetQueueFilterOutput) ToGetQueueFilterOutput() GetQueueFilterOutput

func (GetQueueFilterOutput) ToGetQueueFilterOutputWithContext

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

func (GetQueueFilterOutput) Values

type GetQueueQueueList

type GetQueueQueueList struct {
	ActiveMsgNum        int                                  `pulumi:"activeMsgNum"`
	Bps                 int                                  `pulumi:"bps"`
	CreateTime          int                                  `pulumi:"createTime"`
	CreateUin           int                                  `pulumi:"createUin"`
	DeadLetterPolicies  []GetQueueQueueListDeadLetterPolicy  `pulumi:"deadLetterPolicies"`
	DeadLetterSources   []GetQueueQueueListDeadLetterSource  `pulumi:"deadLetterSources"`
	DelayMsgNum         int                                  `pulumi:"delayMsgNum"`
	InactiveMsgNum      int                                  `pulumi:"inactiveMsgNum"`
	LastModifyTime      int                                  `pulumi:"lastModifyTime"`
	MaxDelaySeconds     int                                  `pulumi:"maxDelaySeconds"`
	MaxMsgBacklogSize   int                                  `pulumi:"maxMsgBacklogSize"`
	MaxMsgHeapNum       int                                  `pulumi:"maxMsgHeapNum"`
	MaxMsgSize          int                                  `pulumi:"maxMsgSize"`
	MaxUnackedMsgNum    int                                  `pulumi:"maxUnackedMsgNum"`
	MinMsgTime          int                                  `pulumi:"minMsgTime"`
	MsgRetentionSeconds int                                  `pulumi:"msgRetentionSeconds"`
	NamespaceName       string                               `pulumi:"namespaceName"`
	PollingWaitSeconds  int                                  `pulumi:"pollingWaitSeconds"`
	Qps                 int                                  `pulumi:"qps"`
	QueueId             string                               `pulumi:"queueId"`
	QueueName           string                               `pulumi:"queueName"`
	RetentionSizeInMb   int                                  `pulumi:"retentionSizeInMb"`
	RewindMsgNum        int                                  `pulumi:"rewindMsgNum"`
	RewindSeconds       int                                  `pulumi:"rewindSeconds"`
	Status              int                                  `pulumi:"status"`
	Tags                []GetQueueQueueListTag               `pulumi:"tags"`
	TenantId            string                               `pulumi:"tenantId"`
	Trace               bool                                 `pulumi:"trace"`
	Transaction         bool                                 `pulumi:"transaction"`
	TransactionPolicies []GetQueueQueueListTransactionPolicy `pulumi:"transactionPolicies"`
	VisibilityTimeout   int                                  `pulumi:"visibilityTimeout"`
}

type GetQueueQueueListArgs

type GetQueueQueueListArgs struct {
	ActiveMsgNum        pulumi.IntInput                              `pulumi:"activeMsgNum"`
	Bps                 pulumi.IntInput                              `pulumi:"bps"`
	CreateTime          pulumi.IntInput                              `pulumi:"createTime"`
	CreateUin           pulumi.IntInput                              `pulumi:"createUin"`
	DeadLetterPolicies  GetQueueQueueListDeadLetterPolicyArrayInput  `pulumi:"deadLetterPolicies"`
	DeadLetterSources   GetQueueQueueListDeadLetterSourceArrayInput  `pulumi:"deadLetterSources"`
	DelayMsgNum         pulumi.IntInput                              `pulumi:"delayMsgNum"`
	InactiveMsgNum      pulumi.IntInput                              `pulumi:"inactiveMsgNum"`
	LastModifyTime      pulumi.IntInput                              `pulumi:"lastModifyTime"`
	MaxDelaySeconds     pulumi.IntInput                              `pulumi:"maxDelaySeconds"`
	MaxMsgBacklogSize   pulumi.IntInput                              `pulumi:"maxMsgBacklogSize"`
	MaxMsgHeapNum       pulumi.IntInput                              `pulumi:"maxMsgHeapNum"`
	MaxMsgSize          pulumi.IntInput                              `pulumi:"maxMsgSize"`
	MaxUnackedMsgNum    pulumi.IntInput                              `pulumi:"maxUnackedMsgNum"`
	MinMsgTime          pulumi.IntInput                              `pulumi:"minMsgTime"`
	MsgRetentionSeconds pulumi.IntInput                              `pulumi:"msgRetentionSeconds"`
	NamespaceName       pulumi.StringInput                           `pulumi:"namespaceName"`
	PollingWaitSeconds  pulumi.IntInput                              `pulumi:"pollingWaitSeconds"`
	Qps                 pulumi.IntInput                              `pulumi:"qps"`
	QueueId             pulumi.StringInput                           `pulumi:"queueId"`
	QueueName           pulumi.StringInput                           `pulumi:"queueName"`
	RetentionSizeInMb   pulumi.IntInput                              `pulumi:"retentionSizeInMb"`
	RewindMsgNum        pulumi.IntInput                              `pulumi:"rewindMsgNum"`
	RewindSeconds       pulumi.IntInput                              `pulumi:"rewindSeconds"`
	Status              pulumi.IntInput                              `pulumi:"status"`
	Tags                GetQueueQueueListTagArrayInput               `pulumi:"tags"`
	TenantId            pulumi.StringInput                           `pulumi:"tenantId"`
	Trace               pulumi.BoolInput                             `pulumi:"trace"`
	Transaction         pulumi.BoolInput                             `pulumi:"transaction"`
	TransactionPolicies GetQueueQueueListTransactionPolicyArrayInput `pulumi:"transactionPolicies"`
	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) Index

func (GetQueueQueueListArrayOutput) ToGetQueueQueueListArrayOutput

func (o GetQueueQueueListArrayOutput) ToGetQueueQueueListArrayOutput() GetQueueQueueListArrayOutput

func (GetQueueQueueListArrayOutput) ToGetQueueQueueListArrayOutputWithContext

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

type GetQueueQueueListDeadLetterPolicy

type GetQueueQueueListDeadLetterPolicy struct {
	DeadLetterQueue string `pulumi:"deadLetterQueue"`
	MaxReceiveCount int    `pulumi:"maxReceiveCount"`
	MaxTimeToLive   int    `pulumi:"maxTimeToLive"`
	Policy          int    `pulumi:"policy"`
}

type GetQueueQueueListDeadLetterPolicyArgs

type GetQueueQueueListDeadLetterPolicyArgs struct {
	DeadLetterQueue pulumi.StringInput `pulumi:"deadLetterQueue"`
	MaxReceiveCount pulumi.IntInput    `pulumi:"maxReceiveCount"`
	MaxTimeToLive   pulumi.IntInput    `pulumi:"maxTimeToLive"`
	Policy          pulumi.IntInput    `pulumi:"policy"`
}

func (GetQueueQueueListDeadLetterPolicyArgs) ElementType

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) 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) Index

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 (GetQueueQueueListDeadLetterPolicyOutput) ElementType

func (GetQueueQueueListDeadLetterPolicyOutput) MaxReceiveCount

func (GetQueueQueueListDeadLetterPolicyOutput) MaxTimeToLive

func (GetQueueQueueListDeadLetterPolicyOutput) 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 {
	QueueId   string `pulumi:"queueId"`
	QueueName string `pulumi:"queueName"`
}

type GetQueueQueueListDeadLetterSourceArgs

type GetQueueQueueListDeadLetterSourceArgs struct {
	QueueId   pulumi.StringInput `pulumi:"queueId"`
	QueueName pulumi.StringInput `pulumi:"queueName"`
}

func (GetQueueQueueListDeadLetterSourceArgs) ElementType

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) 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) Index

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) QueueId

func (GetQueueQueueListDeadLetterSourceOutput) 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

func (GetQueueQueueListOutput) Bps

func (GetQueueQueueListOutput) CreateTime

func (o GetQueueQueueListOutput) CreateTime() pulumi.IntOutput

func (GetQueueQueueListOutput) CreateUin

func (GetQueueQueueListOutput) DeadLetterPolicies

func (GetQueueQueueListOutput) DeadLetterSources

func (GetQueueQueueListOutput) DelayMsgNum

func (o GetQueueQueueListOutput) DelayMsgNum() pulumi.IntOutput

func (GetQueueQueueListOutput) ElementType

func (GetQueueQueueListOutput) ElementType() reflect.Type

func (GetQueueQueueListOutput) InactiveMsgNum

func (o GetQueueQueueListOutput) InactiveMsgNum() pulumi.IntOutput

func (GetQueueQueueListOutput) LastModifyTime

func (o GetQueueQueueListOutput) LastModifyTime() pulumi.IntOutput

func (GetQueueQueueListOutput) MaxDelaySeconds

func (o GetQueueQueueListOutput) MaxDelaySeconds() pulumi.IntOutput

func (GetQueueQueueListOutput) MaxMsgBacklogSize

func (o GetQueueQueueListOutput) MaxMsgBacklogSize() pulumi.IntOutput

func (GetQueueQueueListOutput) MaxMsgHeapNum

func (o GetQueueQueueListOutput) MaxMsgHeapNum() pulumi.IntOutput

func (GetQueueQueueListOutput) MaxMsgSize

func (o GetQueueQueueListOutput) MaxMsgSize() pulumi.IntOutput

func (GetQueueQueueListOutput) MaxUnackedMsgNum

func (o GetQueueQueueListOutput) MaxUnackedMsgNum() pulumi.IntOutput

func (GetQueueQueueListOutput) MinMsgTime

func (o GetQueueQueueListOutput) MinMsgTime() pulumi.IntOutput

func (GetQueueQueueListOutput) MsgRetentionSeconds

func (o GetQueueQueueListOutput) MsgRetentionSeconds() pulumi.IntOutput

func (GetQueueQueueListOutput) NamespaceName

func (o GetQueueQueueListOutput) NamespaceName() pulumi.StringOutput

func (GetQueueQueueListOutput) PollingWaitSeconds

func (o GetQueueQueueListOutput) PollingWaitSeconds() pulumi.IntOutput

func (GetQueueQueueListOutput) Qps

func (GetQueueQueueListOutput) QueueId

func (GetQueueQueueListOutput) QueueName

func (GetQueueQueueListOutput) RetentionSizeInMb

func (o GetQueueQueueListOutput) RetentionSizeInMb() pulumi.IntOutput

func (GetQueueQueueListOutput) RewindMsgNum

func (o GetQueueQueueListOutput) RewindMsgNum() pulumi.IntOutput

func (GetQueueQueueListOutput) RewindSeconds

func (o GetQueueQueueListOutput) RewindSeconds() pulumi.IntOutput

func (GetQueueQueueListOutput) Status

func (GetQueueQueueListOutput) Tags

func (GetQueueQueueListOutput) TenantId

func (GetQueueQueueListOutput) ToGetQueueQueueListOutput

func (o GetQueueQueueListOutput) ToGetQueueQueueListOutput() GetQueueQueueListOutput

func (GetQueueQueueListOutput) ToGetQueueQueueListOutputWithContext

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

func (GetQueueQueueListOutput) Trace

func (GetQueueQueueListOutput) Transaction

func (o GetQueueQueueListOutput) Transaction() pulumi.BoolOutput

func (GetQueueQueueListOutput) TransactionPolicies

func (GetQueueQueueListOutput) VisibilityTimeout

func (o GetQueueQueueListOutput) VisibilityTimeout() pulumi.IntOutput

type GetQueueQueueListTag

type GetQueueQueueListTag struct {
	TagKey   string `pulumi:"tagKey"`
	TagValue string `pulumi:"tagValue"`
}

type GetQueueQueueListTagArgs

type GetQueueQueueListTagArgs struct {
	TagKey   pulumi.StringInput `pulumi:"tagKey"`
	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) Index

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 (GetQueueQueueListTagOutput) TagValue

func (GetQueueQueueListTagOutput) ToGetQueueQueueListTagOutput

func (o GetQueueQueueListTagOutput) ToGetQueueQueueListTagOutput() GetQueueQueueListTagOutput

func (GetQueueQueueListTagOutput) ToGetQueueQueueListTagOutputWithContext

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

type GetQueueQueueListTransactionPolicy

type GetQueueQueueListTransactionPolicy struct {
	FirstQueryInterval int `pulumi:"firstQueryInterval"`
	MaxQueryCount      int `pulumi:"maxQueryCount"`
}

type GetQueueQueueListTransactionPolicyArgs

type GetQueueQueueListTransactionPolicyArgs struct {
	FirstQueryInterval pulumi.IntInput `pulumi:"firstQueryInterval"`
	MaxQueryCount      pulumi.IntInput `pulumi:"maxQueryCount"`
}

func (GetQueueQueueListTransactionPolicyArgs) ElementType

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) 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) Index

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) FirstQueryInterval

func (GetQueueQueueListTransactionPolicyOutput) MaxQueryCount

func (GetQueueQueueListTransactionPolicyOutput) ToGetQueueQueueListTransactionPolicyOutput

func (o GetQueueQueueListTransactionPolicyOutput) ToGetQueueQueueListTransactionPolicyOutput() GetQueueQueueListTransactionPolicyOutput

func (GetQueueQueueListTransactionPolicyOutput) ToGetQueueQueueListTransactionPolicyOutputWithContext

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

type GetSubscribeSubscriptionList

type GetSubscribeSubscriptionList struct {
	BindingKeys         []string `pulumi:"bindingKeys"`
	CreateTime          int      `pulumi:"createTime"`
	Endpoint            string   `pulumi:"endpoint"`
	FilterTags          []string `pulumi:"filterTags"`
	LastModifyTime      int      `pulumi:"lastModifyTime"`
	MsgCount            int      `pulumi:"msgCount"`
	NotifyContentFormat string   `pulumi:"notifyContentFormat"`
	NotifyStrategy      string   `pulumi:"notifyStrategy"`
	Protocol            string   `pulumi:"protocol"`
	SubscriptionId      string   `pulumi:"subscriptionId"`
	SubscriptionName    string   `pulumi:"subscriptionName"`
	TopicOwner          int      `pulumi:"topicOwner"`
}

type GetSubscribeSubscriptionListArgs

type GetSubscribeSubscriptionListArgs struct {
	BindingKeys         pulumi.StringArrayInput `pulumi:"bindingKeys"`
	CreateTime          pulumi.IntInput         `pulumi:"createTime"`
	Endpoint            pulumi.StringInput      `pulumi:"endpoint"`
	FilterTags          pulumi.StringArrayInput `pulumi:"filterTags"`
	LastModifyTime      pulumi.IntInput         `pulumi:"lastModifyTime"`
	MsgCount            pulumi.IntInput         `pulumi:"msgCount"`
	NotifyContentFormat pulumi.StringInput      `pulumi:"notifyContentFormat"`
	NotifyStrategy      pulumi.StringInput      `pulumi:"notifyStrategy"`
	Protocol            pulumi.StringInput      `pulumi:"protocol"`
	SubscriptionId      pulumi.StringInput      `pulumi:"subscriptionId"`
	SubscriptionName    pulumi.StringInput      `pulumi:"subscriptionName"`
	TopicOwner          pulumi.IntInput         `pulumi:"topicOwner"`
}

func (GetSubscribeSubscriptionListArgs) ElementType

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) 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) Index

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 (GetSubscribeSubscriptionListOutput) CreateTime

func (GetSubscribeSubscriptionListOutput) ElementType

func (GetSubscribeSubscriptionListOutput) Endpoint

func (GetSubscribeSubscriptionListOutput) FilterTags

func (GetSubscribeSubscriptionListOutput) LastModifyTime

func (GetSubscribeSubscriptionListOutput) MsgCount

func (GetSubscribeSubscriptionListOutput) NotifyContentFormat

func (o GetSubscribeSubscriptionListOutput) NotifyContentFormat() pulumi.StringOutput

func (GetSubscribeSubscriptionListOutput) NotifyStrategy

func (GetSubscribeSubscriptionListOutput) Protocol

func (GetSubscribeSubscriptionListOutput) SubscriptionId

func (GetSubscribeSubscriptionListOutput) SubscriptionName

func (GetSubscribeSubscriptionListOutput) ToGetSubscribeSubscriptionListOutput

func (o GetSubscribeSubscriptionListOutput) ToGetSubscribeSubscriptionListOutput() GetSubscribeSubscriptionListOutput

func (GetSubscribeSubscriptionListOutput) ToGetSubscribeSubscriptionListOutputWithContext

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

func (GetSubscribeSubscriptionListOutput) TopicOwner

type GetTopicFilter

type GetTopicFilter struct {
	Name   *string  `pulumi:"name"`
	Values []string `pulumi:"values"`
}

type GetTopicFilterArgs

type GetTopicFilterArgs struct {
	Name   pulumi.StringPtrInput   `pulumi:"name"`
	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 (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 (GetTopicFilterOutput) ToGetTopicFilterOutput

func (o GetTopicFilterOutput) ToGetTopicFilterOutput() GetTopicFilterOutput

func (GetTopicFilterOutput) ToGetTopicFilterOutputWithContext

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

func (GetTopicFilterOutput) Values

type GetTopicTopicList

type GetTopicTopicList struct {
	BrokerType          int                    `pulumi:"brokerType"`
	CreateTime          int                    `pulumi:"createTime"`
	CreateUin           int                    `pulumi:"createUin"`
	FilterType          int                    `pulumi:"filterType"`
	LastModifyTime      int                    `pulumi:"lastModifyTime"`
	MaxMsgSize          int                    `pulumi:"maxMsgSize"`
	MsgCount            int                    `pulumi:"msgCount"`
	MsgRetentionSeconds int                    `pulumi:"msgRetentionSeconds"`
	NamespaceName       string                 `pulumi:"namespaceName"`
	Qps                 int                    `pulumi:"qps"`
	Status              int                    `pulumi:"status"`
	Tags                []GetTopicTopicListTag `pulumi:"tags"`
	TenantId            string                 `pulumi:"tenantId"`
	TopicId             string                 `pulumi:"topicId"`
	TopicName           string                 `pulumi:"topicName"`
	Trace               bool                   `pulumi:"trace"`
}

type GetTopicTopicListArgs

type GetTopicTopicListArgs struct {
	BrokerType          pulumi.IntInput                `pulumi:"brokerType"`
	CreateTime          pulumi.IntInput                `pulumi:"createTime"`
	CreateUin           pulumi.IntInput                `pulumi:"createUin"`
	FilterType          pulumi.IntInput                `pulumi:"filterType"`
	LastModifyTime      pulumi.IntInput                `pulumi:"lastModifyTime"`
	MaxMsgSize          pulumi.IntInput                `pulumi:"maxMsgSize"`
	MsgCount            pulumi.IntInput                `pulumi:"msgCount"`
	MsgRetentionSeconds pulumi.IntInput                `pulumi:"msgRetentionSeconds"`
	NamespaceName       pulumi.StringInput             `pulumi:"namespaceName"`
	Qps                 pulumi.IntInput                `pulumi:"qps"`
	Status              pulumi.IntInput                `pulumi:"status"`
	Tags                GetTopicTopicListTagArrayInput `pulumi:"tags"`
	TenantId            pulumi.StringInput             `pulumi:"tenantId"`
	TopicId             pulumi.StringInput             `pulumi:"topicId"`
	TopicName           pulumi.StringInput             `pulumi:"topicName"`
	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) Index

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

func (GetTopicTopicListOutput) CreateTime

func (o GetTopicTopicListOutput) CreateTime() pulumi.IntOutput

func (GetTopicTopicListOutput) CreateUin

func (GetTopicTopicListOutput) ElementType

func (GetTopicTopicListOutput) ElementType() reflect.Type

func (GetTopicTopicListOutput) FilterType

func (o GetTopicTopicListOutput) FilterType() pulumi.IntOutput

func (GetTopicTopicListOutput) LastModifyTime

func (o GetTopicTopicListOutput) LastModifyTime() pulumi.IntOutput

func (GetTopicTopicListOutput) MaxMsgSize

func (o GetTopicTopicListOutput) MaxMsgSize() pulumi.IntOutput

func (GetTopicTopicListOutput) MsgCount

func (GetTopicTopicListOutput) MsgRetentionSeconds

func (o GetTopicTopicListOutput) MsgRetentionSeconds() pulumi.IntOutput

func (GetTopicTopicListOutput) NamespaceName

func (o GetTopicTopicListOutput) NamespaceName() pulumi.StringOutput

func (GetTopicTopicListOutput) Qps

func (GetTopicTopicListOutput) Status

func (GetTopicTopicListOutput) Tags

func (GetTopicTopicListOutput) TenantId

func (GetTopicTopicListOutput) ToGetTopicTopicListOutput

func (o GetTopicTopicListOutput) ToGetTopicTopicListOutput() GetTopicTopicListOutput

func (GetTopicTopicListOutput) ToGetTopicTopicListOutputWithContext

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

func (GetTopicTopicListOutput) TopicId

func (GetTopicTopicListOutput) TopicName

func (GetTopicTopicListOutput) Trace

type GetTopicTopicListTag

type GetTopicTopicListTag struct {
	TagKey   string `pulumi:"tagKey"`
	TagValue string `pulumi:"tagValue"`
}

type GetTopicTopicListTagArgs

type GetTopicTopicListTagArgs struct {
	TagKey   pulumi.StringInput `pulumi:"tagKey"`
	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) Index

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 (GetTopicTopicListTagOutput) TagValue

func (GetTopicTopicListTagOutput) ToGetTopicTopicListTagOutput

func (o GetTopicTopicListTagOutput) ToGetTopicTopicListTagOutput() GetTopicTopicListTagOutput

func (GetTopicTopicListTagOutput) ToGetTopicTopicListTagOutputWithContext

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

type LookupQueueArgs

type LookupQueueArgs struct {
	Filters          []GetQueueFilter `pulumi:"filters"`
	IsTagFilter      *bool            `pulumi:"isTagFilter"`
	Limit            *int             `pulumi:"limit"`
	Offset           *int             `pulumi:"offset"`
	QueueName        *string          `pulumi:"queueName"`
	QueueNameLists   []string         `pulumi:"queueNameLists"`
	ResultOutputFile *string          `pulumi:"resultOutputFile"`
}

A collection of arguments for invoking getQueue.

type LookupQueueOutputArgs

type LookupQueueOutputArgs struct {
	Filters          GetQueueFilterArrayInput `pulumi:"filters"`
	IsTagFilter      pulumi.BoolPtrInput      `pulumi:"isTagFilter"`
	Limit            pulumi.IntPtrInput       `pulumi:"limit"`
	Offset           pulumi.IntPtrInput       `pulumi:"offset"`
	QueueName        pulumi.StringPtrInput    `pulumi:"queueName"`
	QueueNameLists   pulumi.StringArrayInput  `pulumi:"queueNameLists"`
	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"`
	QueueLists       []GetQueueQueueList `pulumi:"queueLists"`
	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)

type LookupQueueResultOutput

type LookupQueueResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getQueue.

func (LookupQueueResultOutput) ElementType

func (LookupQueueResultOutput) ElementType() reflect.Type

func (LookupQueueResultOutput) Filters

func (LookupQueueResultOutput) Id

The provider-assigned unique ID for this managed resource.

func (LookupQueueResultOutput) IsTagFilter

func (LookupQueueResultOutput) Limit

func (LookupQueueResultOutput) Offset

func (LookupQueueResultOutput) QueueLists

func (LookupQueueResultOutput) QueueName

func (LookupQueueResultOutput) QueueNameLists

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 {
	Limit            *int    `pulumi:"limit"`
	Offset           *int    `pulumi:"offset"`
	ResultOutputFile *string `pulumi:"resultOutputFile"`
	SubscriptionName *string `pulumi:"subscriptionName"`
	TopicName        string  `pulumi:"topicName"`
}

A collection of arguments for invoking getSubscribe.

type LookupSubscribeOutputArgs

type LookupSubscribeOutputArgs struct {
	Limit            pulumi.IntPtrInput    `pulumi:"limit"`
	Offset           pulumi.IntPtrInput    `pulumi:"offset"`
	ResultOutputFile pulumi.StringPtrInput `pulumi:"resultOutputFile"`
	SubscriptionName pulumi.StringPtrInput `pulumi:"subscriptionName"`
	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"`
	SubscriptionLists []GetSubscribeSubscriptionList `pulumi:"subscriptionLists"`
	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)

type LookupSubscribeResultOutput

type LookupSubscribeResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getSubscribe.

func (LookupSubscribeResultOutput) ElementType

func (LookupSubscribeResultOutput) Id

The provider-assigned unique ID for this managed resource.

func (LookupSubscribeResultOutput) Limit

func (LookupSubscribeResultOutput) Offset

func (LookupSubscribeResultOutput) ResultOutputFile

func (o LookupSubscribeResultOutput) ResultOutputFile() pulumi.StringPtrOutput

func (LookupSubscribeResultOutput) SubscriptionLists

func (LookupSubscribeResultOutput) SubscriptionName

func (o LookupSubscribeResultOutput) SubscriptionName() pulumi.StringPtrOutput

func (LookupSubscribeResultOutput) ToLookupSubscribeResultOutput

func (o LookupSubscribeResultOutput) ToLookupSubscribeResultOutput() LookupSubscribeResultOutput

func (LookupSubscribeResultOutput) ToLookupSubscribeResultOutputWithContext

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

func (LookupSubscribeResultOutput) TopicName

type LookupTopicArgs

type LookupTopicArgs struct {
	Filters          []GetTopicFilter `pulumi:"filters"`
	IsTagFilter      *bool            `pulumi:"isTagFilter"`
	Limit            *int             `pulumi:"limit"`
	Offset           *int             `pulumi:"offset"`
	ResultOutputFile *string          `pulumi:"resultOutputFile"`
	TopicName        *string          `pulumi:"topicName"`
	TopicNameLists   []string         `pulumi:"topicNameLists"`
}

A collection of arguments for invoking getTopic.

type LookupTopicOutputArgs

type LookupTopicOutputArgs struct {
	Filters          GetTopicFilterArrayInput `pulumi:"filters"`
	IsTagFilter      pulumi.BoolPtrInput      `pulumi:"isTagFilter"`
	Limit            pulumi.IntPtrInput       `pulumi:"limit"`
	Offset           pulumi.IntPtrInput       `pulumi:"offset"`
	ResultOutputFile pulumi.StringPtrInput    `pulumi:"resultOutputFile"`
	TopicName        pulumi.StringPtrInput    `pulumi:"topicName"`
	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"`
	TopicLists       []GetTopicTopicList `pulumi:"topicLists"`
	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)

type LookupTopicResultOutput

type LookupTopicResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getTopic.

func (LookupTopicResultOutput) ElementType

func (LookupTopicResultOutput) ElementType() reflect.Type

func (LookupTopicResultOutput) Filters

func (LookupTopicResultOutput) Id

The provider-assigned unique ID for this managed resource.

func (LookupTopicResultOutput) IsTagFilter

func (LookupTopicResultOutput) Limit

func (LookupTopicResultOutput) Offset

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 (LookupTopicResultOutput) TopicName

func (LookupTopicResultOutput) TopicNameLists

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"`
}

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 (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 (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"`
}

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 (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 (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"`
}

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 (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 (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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL