mns

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Dec 21, 2022 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func PkgVersion added in v0.0.1 

func PkgVersion() (semver.Version, error)

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

Types

type GetQueuesArgs 

type GetQueuesArgs struct {
	// A string to filter resulting queues by their name prefixs.
	NamePrefix *string `pulumi:"namePrefix"`
	OutputFile *string `pulumi:"outputFile"`
}

A collection of arguments for invoking getQueues.

type GetQueuesOutputArgs 

type GetQueuesOutputArgs struct {
	// A string to filter resulting queues by their name prefixs.
	NamePrefix pulumi.StringPtrInput `pulumi:"namePrefix"`
	OutputFile pulumi.StringPtrInput `pulumi:"outputFile"`
}

A collection of arguments for invoking getQueues.

func (GetQueuesOutputArgs) ElementType 

func (GetQueuesOutputArgs) ElementType() reflect.Type

type GetQueuesQueue 

type GetQueuesQueue struct {
	// This attribute defines the length of time, in seconds, after which every message sent to the queue is dequeued.
	DelaySeconds int `pulumi:"delaySeconds"`
	// The id of the queue, The value is set to `name`.
	Id string `pulumi:"id"`
	// This indicates the maximum length, in bytes, of any message body sent to the queue.
	MaximumMessageSize int `pulumi:"maximumMessageSize"`
	// Messages are deleted from the queue after a specified length of time, whether they have been activated or not. This attribute defines the viability period, in seconds, for every message in the queue.
	MessageRetentionPeriod int `pulumi:"messageRetentionPeriod"`
	// The name of the queue
	Name string `pulumi:"name"`
	// Long polling is measured in seconds. When this attribute is set to 0, long polling is disabled. When it is not set to 0, long polling is enabled and message dequeue requests will be processed only when valid messages are received or when long polling times out.
	PollingWaitSeconds int `pulumi:"pollingWaitSeconds"`
	// Dequeued messages change from active (visible) status to inactive (invisible) status. This attribute defines the length of time, in seconds, that messages remain invisible. Messages return to active status after the set period.
	VisibilityTimeouts int `pulumi:"visibilityTimeouts"`
}

type GetQueuesQueueArgs 

type GetQueuesQueueArgs struct {
	// This attribute defines the length of time, in seconds, after which every message sent to the queue is dequeued.
	DelaySeconds pulumi.IntInput `pulumi:"delaySeconds"`
	// The id of the queue, The value is set to `name`.
	Id pulumi.StringInput `pulumi:"id"`
	// This indicates the maximum length, in bytes, of any message body sent to the queue.
	MaximumMessageSize pulumi.IntInput `pulumi:"maximumMessageSize"`
	// Messages are deleted from the queue after a specified length of time, whether they have been activated or not. This attribute defines the viability period, in seconds, for every message in the queue.
	MessageRetentionPeriod pulumi.IntInput `pulumi:"messageRetentionPeriod"`
	// The name of the queue
	Name pulumi.StringInput `pulumi:"name"`
	// Long polling is measured in seconds. When this attribute is set to 0, long polling is disabled. When it is not set to 0, long polling is enabled and message dequeue requests will be processed only when valid messages are received or when long polling times out.
	PollingWaitSeconds pulumi.IntInput `pulumi:"pollingWaitSeconds"`
	// Dequeued messages change from active (visible) status to inactive (invisible) status. This attribute defines the length of time, in seconds, that messages remain invisible. Messages return to active status after the set period.
	VisibilityTimeouts pulumi.IntInput `pulumi:"visibilityTimeouts"`
}

func (GetQueuesQueueArgs) ElementType 

func (GetQueuesQueueArgs) ElementType() reflect.Type

func (GetQueuesQueueArgs) ToGetQueuesQueueOutput 

func (i GetQueuesQueueArgs) ToGetQueuesQueueOutput() GetQueuesQueueOutput

func (GetQueuesQueueArgs) ToGetQueuesQueueOutputWithContext 

func (i GetQueuesQueueArgs) ToGetQueuesQueueOutputWithContext(ctx context.Context) GetQueuesQueueOutput

type GetQueuesQueueArray 

type GetQueuesQueueArray []GetQueuesQueueInput

func (GetQueuesQueueArray) ElementType 

func (GetQueuesQueueArray) ElementType() reflect.Type

func (GetQueuesQueueArray) ToGetQueuesQueueArrayOutput 

func (i GetQueuesQueueArray) ToGetQueuesQueueArrayOutput() GetQueuesQueueArrayOutput

func (GetQueuesQueueArray) ToGetQueuesQueueArrayOutputWithContext 

func (i GetQueuesQueueArray) ToGetQueuesQueueArrayOutputWithContext(ctx context.Context) GetQueuesQueueArrayOutput

type GetQueuesQueueArrayInput 

type GetQueuesQueueArrayInput interface {
	pulumi.Input

	ToGetQueuesQueueArrayOutput() GetQueuesQueueArrayOutput
	ToGetQueuesQueueArrayOutputWithContext(context.Context) GetQueuesQueueArrayOutput
}

GetQueuesQueueArrayInput is an input type that accepts GetQueuesQueueArray and GetQueuesQueueArrayOutput values. You can construct a concrete instance of `GetQueuesQueueArrayInput` via: 

GetQueuesQueueArray{ GetQueuesQueueArgs{...} }

type GetQueuesQueueArrayOutput 

type GetQueuesQueueArrayOutput struct{ *pulumi.OutputState }

func (GetQueuesQueueArrayOutput) ElementType 

func (GetQueuesQueueArrayOutput) ElementType() reflect.Type

func (GetQueuesQueueArrayOutput) Index 

func (o GetQueuesQueueArrayOutput) Index(i pulumi.IntInput) GetQueuesQueueOutput

func (GetQueuesQueueArrayOutput) ToGetQueuesQueueArrayOutput 

func (o GetQueuesQueueArrayOutput) ToGetQueuesQueueArrayOutput() GetQueuesQueueArrayOutput

func (GetQueuesQueueArrayOutput) ToGetQueuesQueueArrayOutputWithContext 

func (o GetQueuesQueueArrayOutput) ToGetQueuesQueueArrayOutputWithContext(ctx context.Context) GetQueuesQueueArrayOutput

type GetQueuesQueueInput 

type GetQueuesQueueInput interface {
	pulumi.Input

	ToGetQueuesQueueOutput() GetQueuesQueueOutput
	ToGetQueuesQueueOutputWithContext(context.Context) GetQueuesQueueOutput
}

GetQueuesQueueInput is an input type that accepts GetQueuesQueueArgs and GetQueuesQueueOutput values. You can construct a concrete instance of `GetQueuesQueueInput` via: 

GetQueuesQueueArgs{...}

type GetQueuesQueueOutput 

type GetQueuesQueueOutput struct{ *pulumi.OutputState }

func (GetQueuesQueueOutput) DelaySeconds 

func (o GetQueuesQueueOutput) DelaySeconds() pulumi.IntOutput

This attribute defines the length of time, in seconds, after which every message sent to the queue is dequeued.

func (GetQueuesQueueOutput) ElementType 

func (GetQueuesQueueOutput) ElementType() reflect.Type

func (GetQueuesQueueOutput) Id 

func (o GetQueuesQueueOutput) Id() pulumi.StringOutput

The id of the queue, The value is set to `name`.

func (GetQueuesQueueOutput) MaximumMessageSize 

func (o GetQueuesQueueOutput) MaximumMessageSize() pulumi.IntOutput

This indicates the maximum length, in bytes, of any message body sent to the queue.

func (GetQueuesQueueOutput) MessageRetentionPeriod 

func (o GetQueuesQueueOutput) MessageRetentionPeriod() pulumi.IntOutput

Messages are deleted from the queue after a specified length of time, whether they have been activated or not. This attribute defines the viability period, in seconds, for every message in the queue.

func (GetQueuesQueueOutput) Name 

func (o GetQueuesQueueOutput) Name() pulumi.StringOutput

The name of the queue

func (GetQueuesQueueOutput) PollingWaitSeconds 

func (o GetQueuesQueueOutput) PollingWaitSeconds() pulumi.IntOutput

Long polling is measured in seconds. When this attribute is set to 0, long polling is disabled. When it is not set to 0, long polling is enabled and message dequeue requests will be processed only when valid messages are received or when long polling times out.

func (GetQueuesQueueOutput) ToGetQueuesQueueOutput 

func (o GetQueuesQueueOutput) ToGetQueuesQueueOutput() GetQueuesQueueOutput

func (GetQueuesQueueOutput) ToGetQueuesQueueOutputWithContext 

func (o GetQueuesQueueOutput) ToGetQueuesQueueOutputWithContext(ctx context.Context) GetQueuesQueueOutput

func (GetQueuesQueueOutput) VisibilityTimeouts 

func (o GetQueuesQueueOutput) VisibilityTimeouts() pulumi.IntOutput

Dequeued messages change from active (visible) status to inactive (invisible) status. This attribute defines the length of time, in seconds, that messages remain invisible. Messages return to active status after the set period.

type GetQueuesResult 

type GetQueuesResult struct {
	// The provider-assigned unique ID for this managed resource.
	Id         string  `pulumi:"id"`
	NamePrefix *string `pulumi:"namePrefix"`
	// A list of queue names.
	Names      []string `pulumi:"names"`
	OutputFile *string  `pulumi:"outputFile"`
	// A list of queues. Each element contains the following attributes:
	Queues []GetQueuesQueue `pulumi:"queues"`
}

A collection of values returned by getQueues.

func GetQueues 

func GetQueues(ctx *pulumi.Context, args *GetQueuesArgs, opts ...pulumi.InvokeOption) (*GetQueuesResult, error)

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-alicloud/sdk/go/alicloud/mns"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/rhysmdnz/pulumi-alicloud/sdk/go/alicloud/mns"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		queues, err := mns.GetQueues(ctx, &mns.GetQueuesArgs{
			NamePrefix: pulumi.StringRef("tf-"),
		}, nil)
		if err != nil {
			return err
		}
		ctx.Export("firstQueueId", queues.Queues[0].Id)
		return nil
	})
}

```

type GetQueuesResultOutput 

type GetQueuesResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getQueues.

func GetQueuesOutput 

func GetQueuesOutput(ctx *pulumi.Context, args GetQueuesOutputArgs, opts ...pulumi.InvokeOption) GetQueuesResultOutput

func (GetQueuesResultOutput) ElementType 

func (GetQueuesResultOutput) ElementType() reflect.Type

func (GetQueuesResultOutput) Id 

func (o GetQueuesResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (GetQueuesResultOutput) NamePrefix 

func (o GetQueuesResultOutput) NamePrefix() pulumi.StringPtrOutput

func (GetQueuesResultOutput) Names 

func (o GetQueuesResultOutput) Names() pulumi.StringArrayOutput

A list of queue names.

func (GetQueuesResultOutput) OutputFile 

func (o GetQueuesResultOutput) OutputFile() pulumi.StringPtrOutput

func (GetQueuesResultOutput) Queues 

func (o GetQueuesResultOutput) Queues() GetQueuesQueueArrayOutput

A list of queues. Each element contains the following attributes:

func (GetQueuesResultOutput) ToGetQueuesResultOutput 

func (o GetQueuesResultOutput) ToGetQueuesResultOutput() GetQueuesResultOutput

func (GetQueuesResultOutput) ToGetQueuesResultOutputWithContext 

func (o GetQueuesResultOutput) ToGetQueuesResultOutputWithContext(ctx context.Context) GetQueuesResultOutput

type GetServiceArgs 

type GetServiceArgs struct {
	// Setting the value to `On` to enable the service. If has been enabled, return the result. Valid values: "On" or "Off". Default to "Off".
	Enable *string `pulumi:"enable"`
}

A collection of arguments for invoking getService.

type GetServiceOutputArgs 

type GetServiceOutputArgs struct {
	// Setting the value to `On` to enable the service. If has been enabled, return the result. Valid values: "On" or "Off". Default to "Off".
	Enable pulumi.StringPtrInput `pulumi:"enable"`
}

A collection of arguments for invoking getService.

func (GetServiceOutputArgs) ElementType 

func (GetServiceOutputArgs) ElementType() reflect.Type

type GetServiceResult 

type GetServiceResult struct {
	Enable *string `pulumi:"enable"`
	// The provider-assigned unique ID for this managed resource.
	Id string `pulumi:"id"`
	// The current service enable status.
	Status string `pulumi:"status"`
}

A collection of values returned by getService.

func GetService 

func GetService(ctx *pulumi.Context, args *GetServiceArgs, opts ...pulumi.InvokeOption) (*GetServiceResult, error)

Using this data source can open MNS service automatically. If the service has been opened, it will return opened.

For information about MNS and how to use it, see [What is MNS](https://www.alibabacloud.com/help/en/product/27412.htm).

> **NOTE:** Available in v1.118.0+

> **NOTE:** The MNS service is not support in the international site.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-alicloud/sdk/go/alicloud/mns"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/rhysmdnz/pulumi-alicloud/sdk/go/alicloud/mns"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := mns.GetService(ctx, &mns.GetServiceArgs{
			Enable: pulumi.StringRef("On"),
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type GetServiceResultOutput 

type GetServiceResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getService.

func GetServiceOutput 

func GetServiceOutput(ctx *pulumi.Context, args GetServiceOutputArgs, opts ...pulumi.InvokeOption) GetServiceResultOutput

func (GetServiceResultOutput) ElementType 

func (GetServiceResultOutput) ElementType() reflect.Type

func (GetServiceResultOutput) Enable 

func (o GetServiceResultOutput) Enable() pulumi.StringPtrOutput

func (GetServiceResultOutput) Id 

func (o GetServiceResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (GetServiceResultOutput) Status 

func (o GetServiceResultOutput) Status() pulumi.StringOutput

The current service enable status.

func (GetServiceResultOutput) ToGetServiceResultOutput 

func (o GetServiceResultOutput) ToGetServiceResultOutput() GetServiceResultOutput

func (GetServiceResultOutput) ToGetServiceResultOutputWithContext 

func (o GetServiceResultOutput) ToGetServiceResultOutputWithContext(ctx context.Context) GetServiceResultOutput

type GetTopicSubscriptionsArgs 

type GetTopicSubscriptionsArgs struct {
	// A string to filter resulting subscriptions of the topic by their name prefixs.
	NamePrefix *string `pulumi:"namePrefix"`
	OutputFile *string `pulumi:"outputFile"`
	// Two topics on a single account in the same region cannot have the same name. A topic name must start with an English letter or a digit, and can contain English letters, digits, and hyphens, with the length not exceeding 256 characters.
	TopicName string `pulumi:"topicName"`
}

A collection of arguments for invoking getTopicSubscriptions.

type GetTopicSubscriptionsOutputArgs 

type GetTopicSubscriptionsOutputArgs struct {
	// A string to filter resulting subscriptions of the topic by their name prefixs.
	NamePrefix pulumi.StringPtrInput `pulumi:"namePrefix"`
	OutputFile pulumi.StringPtrInput `pulumi:"outputFile"`
	// Two topics on a single account in the same region cannot have the same name. A topic name must start with an English letter or a digit, and can contain English letters, digits, and hyphens, with the length not exceeding 256 characters.
	TopicName pulumi.StringInput `pulumi:"topicName"`
}

A collection of arguments for invoking getTopicSubscriptions.

func (GetTopicSubscriptionsOutputArgs) ElementType 

func (GetTopicSubscriptionsOutputArgs) ElementType() reflect.Type

type GetTopicSubscriptionsResult 

type GetTopicSubscriptionsResult struct {
	// The provider-assigned unique ID for this managed resource.
	Id         string  `pulumi:"id"`
	NamePrefix *string `pulumi:"namePrefix"`
	// A list of subscription names.
	Names      []string `pulumi:"names"`
	OutputFile *string  `pulumi:"outputFile"`
	// A list of subscriptions. Each element contains the following attributes:
	Subscriptions []GetTopicSubscriptionsSubscription `pulumi:"subscriptions"`
	TopicName     string                              `pulumi:"topicName"`
}

A collection of values returned by getTopicSubscriptions.

func GetTopicSubscriptions 

func GetTopicSubscriptions(ctx *pulumi.Context, args *GetTopicSubscriptionsArgs, opts ...pulumi.InvokeOption) (*GetTopicSubscriptionsResult, error)

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-alicloud/sdk/go/alicloud/mns"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/rhysmdnz/pulumi-alicloud/sdk/go/alicloud/mns"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		subscriptions, err := mns.GetTopicSubscriptions(ctx, &mns.GetTopicSubscriptionsArgs{
			NamePrefix: pulumi.StringRef("tf-"),
			TopicName:  "topic_name",
		}, nil)
		if err != nil {
			return err
		}
		ctx.Export("firstTopicSubscriptionId", subscriptions.Subscriptions[0].Id)
		return nil
	})
}

```

type GetTopicSubscriptionsResultOutput 

type GetTopicSubscriptionsResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getTopicSubscriptions.

func GetTopicSubscriptionsOutput 

func GetTopicSubscriptionsOutput(ctx *pulumi.Context, args GetTopicSubscriptionsOutputArgs, opts ...pulumi.InvokeOption) GetTopicSubscriptionsResultOutput

func (GetTopicSubscriptionsResultOutput) ElementType 

func (GetTopicSubscriptionsResultOutput) ElementType() reflect.Type

func (GetTopicSubscriptionsResultOutput) Id 

func (o GetTopicSubscriptionsResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (GetTopicSubscriptionsResultOutput) NamePrefix 

func (o GetTopicSubscriptionsResultOutput) NamePrefix() pulumi.StringPtrOutput

func (GetTopicSubscriptionsResultOutput) Names 

func (o GetTopicSubscriptionsResultOutput) Names() pulumi.StringArrayOutput

A list of subscription names.

func (GetTopicSubscriptionsResultOutput) OutputFile 

func (o GetTopicSubscriptionsResultOutput) OutputFile() pulumi.StringPtrOutput

func (GetTopicSubscriptionsResultOutput) Subscriptions 

func (o GetTopicSubscriptionsResultOutput) Subscriptions() GetTopicSubscriptionsSubscriptionArrayOutput

A list of subscriptions. Each element contains the following attributes:

func (GetTopicSubscriptionsResultOutput) ToGetTopicSubscriptionsResultOutput 

func (o GetTopicSubscriptionsResultOutput) ToGetTopicSubscriptionsResultOutput() GetTopicSubscriptionsResultOutput

func (GetTopicSubscriptionsResultOutput) ToGetTopicSubscriptionsResultOutputWithContext 

func (o GetTopicSubscriptionsResultOutput) ToGetTopicSubscriptionsResultOutputWithContext(ctx context.Context) GetTopicSubscriptionsResultOutput

func (GetTopicSubscriptionsResultOutput) TopicName 

func (o GetTopicSubscriptionsResultOutput) TopicName() pulumi.StringOutput

type GetTopicSubscriptionsSubscription 

type GetTopicSubscriptionsSubscription struct {
	// Describe the terminal address of the message received in this subscription.
	// * `filterTag`- A string to filter resulting messages of the topic by their message tag.
	Endpoint  string `pulumi:"endpoint"`
	FilterTag string `pulumi:"filterTag"`
	// The ID of the topic subscription. The value is set to `name`.
	Id string `pulumi:"id"`
	// The name of the subscription.
	// * `topicName`- The topic which The subscription belongs to was named with the name.
	Name string `pulumi:"name"`
	// The NotifyContentFormat attribute of Subscription. This attribute specifies the content format of the messages pushed to users.
	NotifyContentFormat string `pulumi:"notifyContentFormat"`
	// The NotifyStrategy attribute of Subscription. This attribute specifies the retry strategy when message sending fails.
	NotifyStrategy string `pulumi:"notifyStrategy"`
	// Two topics on a single account in the same region cannot have the same name. A topic name must start with an English letter or a digit, and can contain English letters, digits, and hyphens, with the length not exceeding 256 characters.
	TopicName string `pulumi:"topicName"`
}

type GetTopicSubscriptionsSubscriptionArgs 

type GetTopicSubscriptionsSubscriptionArgs struct {
	// Describe the terminal address of the message received in this subscription.
	// * `filterTag`- A string to filter resulting messages of the topic by their message tag.
	Endpoint  pulumi.StringInput `pulumi:"endpoint"`
	FilterTag pulumi.StringInput `pulumi:"filterTag"`
	// The ID of the topic subscription. The value is set to `name`.
	Id pulumi.StringInput `pulumi:"id"`
	// The name of the subscription.
	// * `topicName`- The topic which The subscription belongs to was named with the name.
	Name pulumi.StringInput `pulumi:"name"`
	// The NotifyContentFormat attribute of Subscription. This attribute specifies the content format of the messages pushed to users.
	NotifyContentFormat pulumi.StringInput `pulumi:"notifyContentFormat"`
	// The NotifyStrategy attribute of Subscription. This attribute specifies the retry strategy when message sending fails.
	NotifyStrategy pulumi.StringInput `pulumi:"notifyStrategy"`
	// Two topics on a single account in the same region cannot have the same name. A topic name must start with an English letter or a digit, and can contain English letters, digits, and hyphens, with the length not exceeding 256 characters.
	TopicName pulumi.StringInput `pulumi:"topicName"`
}

func (GetTopicSubscriptionsSubscriptionArgs) ElementType 

func (GetTopicSubscriptionsSubscriptionArgs) ElementType() reflect.Type

func (GetTopicSubscriptionsSubscriptionArgs) ToGetTopicSubscriptionsSubscriptionOutput 

func (i GetTopicSubscriptionsSubscriptionArgs) ToGetTopicSubscriptionsSubscriptionOutput() GetTopicSubscriptionsSubscriptionOutput

func (GetTopicSubscriptionsSubscriptionArgs) ToGetTopicSubscriptionsSubscriptionOutputWithContext 

func (i GetTopicSubscriptionsSubscriptionArgs) ToGetTopicSubscriptionsSubscriptionOutputWithContext(ctx context.Context) GetTopicSubscriptionsSubscriptionOutput

type GetTopicSubscriptionsSubscriptionArray 

type GetTopicSubscriptionsSubscriptionArray []GetTopicSubscriptionsSubscriptionInput

func (GetTopicSubscriptionsSubscriptionArray) ElementType 

func (GetTopicSubscriptionsSubscriptionArray) ElementType() reflect.Type

func (GetTopicSubscriptionsSubscriptionArray) ToGetTopicSubscriptionsSubscriptionArrayOutput 

func (i GetTopicSubscriptionsSubscriptionArray) ToGetTopicSubscriptionsSubscriptionArrayOutput() GetTopicSubscriptionsSubscriptionArrayOutput

func (GetTopicSubscriptionsSubscriptionArray) ToGetTopicSubscriptionsSubscriptionArrayOutputWithContext 

func (i GetTopicSubscriptionsSubscriptionArray) ToGetTopicSubscriptionsSubscriptionArrayOutputWithContext(ctx context.Context) GetTopicSubscriptionsSubscriptionArrayOutput

type GetTopicSubscriptionsSubscriptionArrayInput 

type GetTopicSubscriptionsSubscriptionArrayInput interface {
	pulumi.Input

	ToGetTopicSubscriptionsSubscriptionArrayOutput() GetTopicSubscriptionsSubscriptionArrayOutput
	ToGetTopicSubscriptionsSubscriptionArrayOutputWithContext(context.Context) GetTopicSubscriptionsSubscriptionArrayOutput
}

GetTopicSubscriptionsSubscriptionArrayInput is an input type that accepts GetTopicSubscriptionsSubscriptionArray and GetTopicSubscriptionsSubscriptionArrayOutput values. You can construct a concrete instance of `GetTopicSubscriptionsSubscriptionArrayInput` via: 

GetTopicSubscriptionsSubscriptionArray{ GetTopicSubscriptionsSubscriptionArgs{...} }

type GetTopicSubscriptionsSubscriptionArrayOutput 

type GetTopicSubscriptionsSubscriptionArrayOutput struct{ *pulumi.OutputState }

func (GetTopicSubscriptionsSubscriptionArrayOutput) ElementType 

func (GetTopicSubscriptionsSubscriptionArrayOutput) ElementType() reflect.Type

func (GetTopicSubscriptionsSubscriptionArrayOutput) Index 

func (o GetTopicSubscriptionsSubscriptionArrayOutput) Index(i pulumi.IntInput) GetTopicSubscriptionsSubscriptionOutput

func (GetTopicSubscriptionsSubscriptionArrayOutput) ToGetTopicSubscriptionsSubscriptionArrayOutput 

func (o GetTopicSubscriptionsSubscriptionArrayOutput) ToGetTopicSubscriptionsSubscriptionArrayOutput() GetTopicSubscriptionsSubscriptionArrayOutput

func (GetTopicSubscriptionsSubscriptionArrayOutput) ToGetTopicSubscriptionsSubscriptionArrayOutputWithContext 

func (o GetTopicSubscriptionsSubscriptionArrayOutput) ToGetTopicSubscriptionsSubscriptionArrayOutputWithContext(ctx context.Context) GetTopicSubscriptionsSubscriptionArrayOutput

type GetTopicSubscriptionsSubscriptionInput 

type GetTopicSubscriptionsSubscriptionInput interface {
	pulumi.Input

	ToGetTopicSubscriptionsSubscriptionOutput() GetTopicSubscriptionsSubscriptionOutput
	ToGetTopicSubscriptionsSubscriptionOutputWithContext(context.Context) GetTopicSubscriptionsSubscriptionOutput
}

GetTopicSubscriptionsSubscriptionInput is an input type that accepts GetTopicSubscriptionsSubscriptionArgs and GetTopicSubscriptionsSubscriptionOutput values. You can construct a concrete instance of `GetTopicSubscriptionsSubscriptionInput` via: 

GetTopicSubscriptionsSubscriptionArgs{...}

type GetTopicSubscriptionsSubscriptionOutput 

type GetTopicSubscriptionsSubscriptionOutput struct{ *pulumi.OutputState }

func (GetTopicSubscriptionsSubscriptionOutput) ElementType 

func (GetTopicSubscriptionsSubscriptionOutput) ElementType() reflect.Type

func (GetTopicSubscriptionsSubscriptionOutput) Endpoint 

func (o GetTopicSubscriptionsSubscriptionOutput) Endpoint() pulumi.StringOutput

Describe the terminal address of the message received in this subscription. * `filterTag`- A string to filter resulting messages of the topic by their message tag.

func (GetTopicSubscriptionsSubscriptionOutput) FilterTag 

func (o GetTopicSubscriptionsSubscriptionOutput) FilterTag() pulumi.StringOutput

func (GetTopicSubscriptionsSubscriptionOutput) Id 

func (o GetTopicSubscriptionsSubscriptionOutput) Id() pulumi.StringOutput

The ID of the topic subscription. The value is set to `name`.

func (GetTopicSubscriptionsSubscriptionOutput) Name 

func (o GetTopicSubscriptionsSubscriptionOutput) Name() pulumi.StringOutput

The name of the subscription. * `topicName`- The topic which The subscription belongs to was named with the name.

func (GetTopicSubscriptionsSubscriptionOutput) NotifyContentFormat 

func (o GetTopicSubscriptionsSubscriptionOutput) NotifyContentFormat() pulumi.StringOutput

The NotifyContentFormat attribute of Subscription. This attribute specifies the content format of the messages pushed to users.

func (GetTopicSubscriptionsSubscriptionOutput) NotifyStrategy 

func (o GetTopicSubscriptionsSubscriptionOutput) NotifyStrategy() pulumi.StringOutput

The NotifyStrategy attribute of Subscription. This attribute specifies the retry strategy when message sending fails.

func (GetTopicSubscriptionsSubscriptionOutput) ToGetTopicSubscriptionsSubscriptionOutput 

func (o GetTopicSubscriptionsSubscriptionOutput) ToGetTopicSubscriptionsSubscriptionOutput() GetTopicSubscriptionsSubscriptionOutput

func (GetTopicSubscriptionsSubscriptionOutput) ToGetTopicSubscriptionsSubscriptionOutputWithContext 

func (o GetTopicSubscriptionsSubscriptionOutput) ToGetTopicSubscriptionsSubscriptionOutputWithContext(ctx context.Context) GetTopicSubscriptionsSubscriptionOutput

func (GetTopicSubscriptionsSubscriptionOutput) TopicName 

func (o GetTopicSubscriptionsSubscriptionOutput) TopicName() pulumi.StringOutput

Two topics on a single account in the same region cannot have the same name. A topic name must start with an English letter or a digit, and can contain English letters, digits, and hyphens, with the length not exceeding 256 characters.

type GetTopicsArgs 

type GetTopicsArgs struct {
	// A string to filter resulting topics by their name prefixs.
	NamePrefix *string `pulumi:"namePrefix"`
	OutputFile *string `pulumi:"outputFile"`
}

A collection of arguments for invoking getTopics.

type GetTopicsOutputArgs 

type GetTopicsOutputArgs struct {
	// A string to filter resulting topics by their name prefixs.
	NamePrefix pulumi.StringPtrInput `pulumi:"namePrefix"`
	OutputFile pulumi.StringPtrInput `pulumi:"outputFile"`
}

A collection of arguments for invoking getTopics.

func (GetTopicsOutputArgs) ElementType 

func (GetTopicsOutputArgs) ElementType() reflect.Type

type GetTopicsResult 

type GetTopicsResult struct {
	// The provider-assigned unique ID for this managed resource.
	Id         string  `pulumi:"id"`
	NamePrefix *string `pulumi:"namePrefix"`
	// A list of topic names.
	Names      []string `pulumi:"names"`
	OutputFile *string  `pulumi:"outputFile"`
	// A list of topics. Each element contains the following attributes:
	Topics []GetTopicsTopic `pulumi:"topics"`
}

A collection of values returned by getTopics.

func GetTopics 

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

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-alicloud/sdk/go/alicloud/mns"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/rhysmdnz/pulumi-alicloud/sdk/go/alicloud/mns"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		topics, err := mns.GetTopics(ctx, &mns.GetTopicsArgs{
			NamePrefix: pulumi.StringRef("tf-"),
		}, nil)
		if err != nil {
			return err
		}
		ctx.Export("firstTopicId", topics.Topics[0].Id)
		return nil
	})
}

```

type GetTopicsResultOutput 

type GetTopicsResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getTopics.

func GetTopicsOutput 

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

func (GetTopicsResultOutput) ElementType 

func (GetTopicsResultOutput) ElementType() reflect.Type

func (GetTopicsResultOutput) Id 

func (o GetTopicsResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (GetTopicsResultOutput) NamePrefix 

func (o GetTopicsResultOutput) NamePrefix() pulumi.StringPtrOutput

func (GetTopicsResultOutput) Names 

func (o GetTopicsResultOutput) Names() pulumi.StringArrayOutput

A list of topic names.

func (GetTopicsResultOutput) OutputFile 

func (o GetTopicsResultOutput) OutputFile() pulumi.StringPtrOutput

func (GetTopicsResultOutput) ToGetTopicsResultOutput 

func (o GetTopicsResultOutput) ToGetTopicsResultOutput() GetTopicsResultOutput

func (GetTopicsResultOutput) ToGetTopicsResultOutputWithContext 

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

func (GetTopicsResultOutput) Topics 

func (o GetTopicsResultOutput) Topics() GetTopicsTopicArrayOutput

A list of topics. Each element contains the following attributes:

type GetTopicsTopic 

type GetTopicsTopic struct {
	// The id of the topic. The value is set to `name`.
	Id string `pulumi:"id"`
	// Whether to enable logging.
	LoggingEnabled bool `pulumi:"loggingEnabled"`
	// This indicates the maximum length, in bytes, of any message body sent to the topic.
	MaximumMessageSize int `pulumi:"maximumMessageSize"`
	// The name of the topic.
	Name string `pulumi:"name"`
}

type GetTopicsTopicArgs 

type GetTopicsTopicArgs struct {
	// The id of the topic. The value is set to `name`.
	Id pulumi.StringInput `pulumi:"id"`
	// Whether to enable logging.
	LoggingEnabled pulumi.BoolInput `pulumi:"loggingEnabled"`
	// This indicates the maximum length, in bytes, of any message body sent to the topic.
	MaximumMessageSize pulumi.IntInput `pulumi:"maximumMessageSize"`
	// The name of the topic.
	Name pulumi.StringInput `pulumi:"name"`
}

func (GetTopicsTopicArgs) ElementType 

func (GetTopicsTopicArgs) ElementType() reflect.Type

func (GetTopicsTopicArgs) ToGetTopicsTopicOutput 

func (i GetTopicsTopicArgs) ToGetTopicsTopicOutput() GetTopicsTopicOutput

func (GetTopicsTopicArgs) ToGetTopicsTopicOutputWithContext 

func (i GetTopicsTopicArgs) ToGetTopicsTopicOutputWithContext(ctx context.Context) GetTopicsTopicOutput

type GetTopicsTopicArray 

type GetTopicsTopicArray []GetTopicsTopicInput

func (GetTopicsTopicArray) ElementType 

func (GetTopicsTopicArray) ElementType() reflect.Type

func (GetTopicsTopicArray) ToGetTopicsTopicArrayOutput 

func (i GetTopicsTopicArray) ToGetTopicsTopicArrayOutput() GetTopicsTopicArrayOutput

func (GetTopicsTopicArray) ToGetTopicsTopicArrayOutputWithContext 

func (i GetTopicsTopicArray) ToGetTopicsTopicArrayOutputWithContext(ctx context.Context) GetTopicsTopicArrayOutput

type GetTopicsTopicArrayInput 

type GetTopicsTopicArrayInput interface {
	pulumi.Input

	ToGetTopicsTopicArrayOutput() GetTopicsTopicArrayOutput
	ToGetTopicsTopicArrayOutputWithContext(context.Context) GetTopicsTopicArrayOutput
}

GetTopicsTopicArrayInput is an input type that accepts GetTopicsTopicArray and GetTopicsTopicArrayOutput values. You can construct a concrete instance of `GetTopicsTopicArrayInput` via: 

GetTopicsTopicArray{ GetTopicsTopicArgs{...} }

type GetTopicsTopicArrayOutput 

type GetTopicsTopicArrayOutput struct{ *pulumi.OutputState }

func (GetTopicsTopicArrayOutput) ElementType 

func (GetTopicsTopicArrayOutput) ElementType() reflect.Type

func (GetTopicsTopicArrayOutput) Index 

func (o GetTopicsTopicArrayOutput) Index(i pulumi.IntInput) GetTopicsTopicOutput

func (GetTopicsTopicArrayOutput) ToGetTopicsTopicArrayOutput 

func (o GetTopicsTopicArrayOutput) ToGetTopicsTopicArrayOutput() GetTopicsTopicArrayOutput

func (GetTopicsTopicArrayOutput) ToGetTopicsTopicArrayOutputWithContext 

func (o GetTopicsTopicArrayOutput) ToGetTopicsTopicArrayOutputWithContext(ctx context.Context) GetTopicsTopicArrayOutput

type GetTopicsTopicInput 

type GetTopicsTopicInput interface {
	pulumi.Input

	ToGetTopicsTopicOutput() GetTopicsTopicOutput
	ToGetTopicsTopicOutputWithContext(context.Context) GetTopicsTopicOutput
}

GetTopicsTopicInput is an input type that accepts GetTopicsTopicArgs and GetTopicsTopicOutput values. You can construct a concrete instance of `GetTopicsTopicInput` via: 

GetTopicsTopicArgs{...}

type GetTopicsTopicOutput 

type GetTopicsTopicOutput struct{ *pulumi.OutputState }

func (GetTopicsTopicOutput) ElementType 

func (GetTopicsTopicOutput) ElementType() reflect.Type

func (GetTopicsTopicOutput) Id 

func (o GetTopicsTopicOutput) Id() pulumi.StringOutput

The id of the topic. The value is set to `name`.

func (GetTopicsTopicOutput) LoggingEnabled 

func (o GetTopicsTopicOutput) LoggingEnabled() pulumi.BoolOutput

Whether to enable logging.

func (GetTopicsTopicOutput) MaximumMessageSize 

func (o GetTopicsTopicOutput) MaximumMessageSize() pulumi.IntOutput

This indicates the maximum length, in bytes, of any message body sent to the topic.

func (GetTopicsTopicOutput) Name 

func (o GetTopicsTopicOutput) Name() pulumi.StringOutput

The name of the topic.

func (GetTopicsTopicOutput) ToGetTopicsTopicOutput 

func (o GetTopicsTopicOutput) ToGetTopicsTopicOutput() GetTopicsTopicOutput

func (GetTopicsTopicOutput) ToGetTopicsTopicOutputWithContext 

func (o GetTopicsTopicOutput) ToGetTopicsTopicOutputWithContext(ctx context.Context) GetTopicsTopicOutput

type Queue 

type Queue struct {
	pulumi.CustomResourceState

	// This attribute defines the length of time, in seconds, after which every message sent to the queue is dequeued. Valid value range: 0-604800 seconds, i.e., 0 to 7 days. Default value to 0.
	DelaySeconds pulumi.IntPtrOutput `pulumi:"delaySeconds"`
	// This indicates the maximum length, in bytes, of any message body sent to the queue. Valid value range: 1024-65536, i.e., 1K to 64K. Default value to 65536.
	MaximumMessageSize pulumi.IntPtrOutput `pulumi:"maximumMessageSize"`
	// Messages are deleted from the queue after a specified length of time, whether they have been activated or not. This attribute defines the viability period, in seconds, for every message in the queue. Valid value range: 60-604800 seconds, i.e., 1 minutes to 7 days. Default value to 345600.
	MessageRetentionPeriod pulumi.IntPtrOutput `pulumi:"messageRetentionPeriod"`
	// Two queues on a single account in the same region cannot have the same name. A queue name must start with an English letter or a digit, and can contain English letters, digits, and hyphens, with the length not exceeding 256 characters .
	Name pulumi.StringOutput `pulumi:"name"`
	// Long polling is measured in seconds. When this attribute is set to 0, long polling is disabled. When it is not set to 0, long polling is enabled and message dequeue requests will be processed only when valid messages are received or when long polling times out. Valid value range: 0-30 seconds. Default value to 0.
	PollingWaitSeconds pulumi.IntPtrOutput `pulumi:"pollingWaitSeconds"`
	// The VisibilityTimeout attribute of the queue. A dequeued messages will change from active (visible) status to inactive (invisible) status, and this attribute defines the length of time, in seconds, that messages remain invisible. Messages return to active status after the set period. Valid value range: 1-43200 seconds, i.e., 1 seconds to 12 hours. Default value to 30.
	VisibilityTimeout pulumi.IntPtrOutput `pulumi:"visibilityTimeout"`
}

## Example Usage

Basic Usage

```go package main

import ( 

"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/rhysmdnz/pulumi-alicloud/sdk/go/alicloud/mns"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := mns.NewQueue(ctx, "queue", &mns.QueueArgs{
			DelaySeconds:           pulumi.Int(0),
			MaximumMessageSize:     pulumi.Int(65536),
			MessageRetentionPeriod: pulumi.Int(345600),
			PollingWaitSeconds:     pulumi.Int(0),
			VisibilityTimeout:      pulumi.Int(30),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

MNS QUEUE can be imported using the id or name, e.g.

```sh 

$ pulumi import alicloud:mns/queue:Queue queue queuename

```

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 {
	// This attribute defines the length of time, in seconds, after which every message sent to the queue is dequeued. Valid value range: 0-604800 seconds, i.e., 0 to 7 days. Default value to 0.
	DelaySeconds pulumi.IntPtrInput
	// This indicates the maximum length, in bytes, of any message body sent to the queue. Valid value range: 1024-65536, i.e., 1K to 64K. Default value to 65536.
	MaximumMessageSize pulumi.IntPtrInput
	// Messages are deleted from the queue after a specified length of time, whether they have been activated or not. This attribute defines the viability period, in seconds, for every message in the queue. Valid value range: 60-604800 seconds, i.e., 1 minutes to 7 days. Default value to 345600.
	MessageRetentionPeriod pulumi.IntPtrInput
	// Two queues on a single account in the same region cannot have the same name. A queue name must start with an English letter or a digit, and can contain English letters, digits, and hyphens, with the length not exceeding 256 characters .
	Name pulumi.StringPtrInput
	// Long polling is measured in seconds. When this attribute is set to 0, long polling is disabled. When it is not set to 0, long polling is enabled and message dequeue requests will be processed only when valid messages are received or when long polling times out. Valid value range: 0-30 seconds. Default value to 0.
	PollingWaitSeconds pulumi.IntPtrInput
	// The VisibilityTimeout attribute of the queue. A dequeued messages will change from active (visible) status to inactive (invisible) status, and this attribute defines the length of time, in seconds, that messages remain invisible. Messages return to active status after the set period. Valid value range: 1-43200 seconds, i.e., 1 seconds to 12 hours. Default value to 30.
	VisibilityTimeout pulumi.IntPtrInput
}

The set of arguments for constructing a Queue resource.

func (QueueArgs) ElementType 

func (QueueArgs) ElementType() reflect.Type

type QueueArray 

type QueueArray []QueueInput

func (QueueArray) ElementType 

func (QueueArray) ElementType() reflect.Type

func (QueueArray) ToQueueArrayOutput 

func (i QueueArray) ToQueueArrayOutput() QueueArrayOutput

func (QueueArray) ToQueueArrayOutputWithContext 

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

type QueueArrayInput 

type QueueArrayInput interface {
	pulumi.Input

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

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

QueueArray{ QueueArgs{...} }

type QueueArrayOutput 

type QueueArrayOutput struct{ *pulumi.OutputState }

func (QueueArrayOutput) ElementType 

func (QueueArrayOutput) ElementType() reflect.Type

func (QueueArrayOutput) Index 

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

func (QueueArrayOutput) ToQueueArrayOutput 

func (o QueueArrayOutput) ToQueueArrayOutput() QueueArrayOutput

func (QueueArrayOutput) ToQueueArrayOutputWithContext 

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

type QueueInput 

type QueueInput interface {
	pulumi.Input

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

type QueueMap 

type QueueMap map[string]QueueInput

func (QueueMap) ElementType 

func (QueueMap) ElementType() reflect.Type

func (QueueMap) ToQueueMapOutput 

func (i QueueMap) ToQueueMapOutput() QueueMapOutput

func (QueueMap) ToQueueMapOutputWithContext 

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

type QueueMapInput 

type QueueMapInput interface {
	pulumi.Input

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

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

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

type QueueMapOutput 

type QueueMapOutput struct{ *pulumi.OutputState }

func (QueueMapOutput) ElementType 

func (QueueMapOutput) ElementType() reflect.Type

func (QueueMapOutput) MapIndex 

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

func (QueueMapOutput) ToQueueMapOutput 

func (o QueueMapOutput) ToQueueMapOutput() QueueMapOutput

func (QueueMapOutput) ToQueueMapOutputWithContext 

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

type QueueOutput 

type QueueOutput struct{ *pulumi.OutputState }

func (QueueOutput) DelaySeconds 

func (o QueueOutput) DelaySeconds() pulumi.IntPtrOutput

This attribute defines the length of time, in seconds, after which every message sent to the queue is dequeued. Valid value range: 0-604800 seconds, i.e., 0 to 7 days. Default value to 0.

func (QueueOutput) ElementType 

func (QueueOutput) ElementType() reflect.Type

func (QueueOutput) MaximumMessageSize 

func (o QueueOutput) MaximumMessageSize() pulumi.IntPtrOutput

This indicates the maximum length, in bytes, of any message body sent to the queue. Valid value range: 1024-65536, i.e., 1K to 64K. Default value to 65536.

func (QueueOutput) MessageRetentionPeriod 

func (o QueueOutput) MessageRetentionPeriod() pulumi.IntPtrOutput

Messages are deleted from the queue after a specified length of time, whether they have been activated or not. This attribute defines the viability period, in seconds, for every message in the queue. Valid value range: 60-604800 seconds, i.e., 1 minutes to 7 days. Default value to 345600.

func (QueueOutput) Name 

func (o QueueOutput) Name() pulumi.StringOutput

Two queues on a single account in the same region cannot have the same name. A queue name must start with an English letter or a digit, and can contain English letters, digits, and hyphens, with the length not exceeding 256 characters .

func (QueueOutput) PollingWaitSeconds 

func (o QueueOutput) PollingWaitSeconds() pulumi.IntPtrOutput

Long polling is measured in seconds. When this attribute is set to 0, long polling is disabled. When it is not set to 0, long polling is enabled and message dequeue requests will be processed only when valid messages are received or when long polling times out. Valid value range: 0-30 seconds. Default value to 0.

func (QueueOutput) ToQueueOutput 

func (o QueueOutput) ToQueueOutput() QueueOutput

func (QueueOutput) ToQueueOutputWithContext 

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

func (QueueOutput) VisibilityTimeout 

func (o QueueOutput) VisibilityTimeout() pulumi.IntPtrOutput

The VisibilityTimeout attribute of the queue. A dequeued messages will change from active (visible) status to inactive (invisible) status, and this attribute defines the length of time, in seconds, that messages remain invisible. Messages return to active status after the set period. Valid value range: 1-43200 seconds, i.e., 1 seconds to 12 hours. Default value to 30.

type QueueState 

type QueueState struct {
	// This attribute defines the length of time, in seconds, after which every message sent to the queue is dequeued. Valid value range: 0-604800 seconds, i.e., 0 to 7 days. Default value to 0.
	DelaySeconds pulumi.IntPtrInput
	// This indicates the maximum length, in bytes, of any message body sent to the queue. Valid value range: 1024-65536, i.e., 1K to 64K. Default value to 65536.
	MaximumMessageSize pulumi.IntPtrInput
	// Messages are deleted from the queue after a specified length of time, whether they have been activated or not. This attribute defines the viability period, in seconds, for every message in the queue. Valid value range: 60-604800 seconds, i.e., 1 minutes to 7 days. Default value to 345600.
	MessageRetentionPeriod pulumi.IntPtrInput
	// Two queues on a single account in the same region cannot have the same name. A queue name must start with an English letter or a digit, and can contain English letters, digits, and hyphens, with the length not exceeding 256 characters .
	Name pulumi.StringPtrInput
	// Long polling is measured in seconds. When this attribute is set to 0, long polling is disabled. When it is not set to 0, long polling is enabled and message dequeue requests will be processed only when valid messages are received or when long polling times out. Valid value range: 0-30 seconds. Default value to 0.
	PollingWaitSeconds pulumi.IntPtrInput
	// The VisibilityTimeout attribute of the queue. A dequeued messages will change from active (visible) status to inactive (invisible) status, and this attribute defines the length of time, in seconds, that messages remain invisible. Messages return to active status after the set period. Valid value range: 1-43200 seconds, i.e., 1 seconds to 12 hours. Default value to 30.
	VisibilityTimeout pulumi.IntPtrInput
}

func (QueueState) ElementType 

func (QueueState) ElementType() reflect.Type

type Topic 

type Topic struct {
	pulumi.CustomResourceState

	// Is logging enabled? true or false. Default value to false.
	LoggingEnabled pulumi.BoolPtrOutput `pulumi:"loggingEnabled"`
	// This indicates the maximum length, in bytes, of any message body sent to the topic. Valid value range: 1024-65536, i.e., 1K to 64K. Default value to 65536.
	MaximumMessageSize pulumi.IntPtrOutput `pulumi:"maximumMessageSize"`
	// Two topics on a single account in the same region cannot have the same name. A topic name must start with an English letter or a digit, and can contain English letters, digits, and hyphens, with the length not exceeding 256 characters.
	Name pulumi.StringOutput `pulumi:"name"`
}

## Example Usage

Basic Usage

```go package main

import ( 

"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/rhysmdnz/pulumi-alicloud/sdk/go/alicloud/mns"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := mns.NewTopic(ctx, "topic", &mns.TopicArgs{
			LoggingEnabled:     pulumi.Bool(false),
			MaximumMessageSize: pulumi.Int(65536),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

MNS Topic can be imported using the id or name, e.g.

```sh 

$ pulumi import alicloud:mns/topic:Topic topic topicName

```

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 {
	// Is logging enabled? true or false. Default value to false.
	LoggingEnabled pulumi.BoolPtrInput
	// This indicates the maximum length, in bytes, of any message body sent to the topic. Valid value range: 1024-65536, i.e., 1K to 64K. Default value to 65536.
	MaximumMessageSize pulumi.IntPtrInput
	// Two topics on a single account in the same region cannot have the same name. A topic name must start with an English letter or a digit, and can contain English letters, digits, and hyphens, with the length not exceeding 256 characters.
	Name pulumi.StringPtrInput
}

The set of arguments for constructing a Topic resource.

func (TopicArgs) ElementType 

func (TopicArgs) ElementType() reflect.Type

type TopicArray 

type TopicArray []TopicInput

func (TopicArray) ElementType 

func (TopicArray) ElementType() reflect.Type

func (TopicArray) ToTopicArrayOutput 

func (i TopicArray) ToTopicArrayOutput() TopicArrayOutput

func (TopicArray) ToTopicArrayOutputWithContext 

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

type TopicArrayInput 

type TopicArrayInput interface {
	pulumi.Input

	ToTopicArrayOutput() TopicArrayOutput
	ToTopicArrayOutputWithContext(context.Context) TopicArrayOutput
}

TopicArrayInput is an input type that accepts TopicArray and TopicArrayOutput values. You can construct a concrete instance of `TopicArrayInput` via: 

TopicArray{ TopicArgs{...} }

type TopicArrayOutput 

type TopicArrayOutput struct{ *pulumi.OutputState }

func (TopicArrayOutput) ElementType 

func (TopicArrayOutput) ElementType() reflect.Type

func (TopicArrayOutput) Index 

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

func (TopicArrayOutput) ToTopicArrayOutput 

func (o TopicArrayOutput) ToTopicArrayOutput() TopicArrayOutput

func (TopicArrayOutput) ToTopicArrayOutputWithContext 

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

type TopicInput 

type TopicInput interface {
	pulumi.Input

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

type TopicMap 

type TopicMap map[string]TopicInput

func (TopicMap) ElementType 

func (TopicMap) ElementType() reflect.Type

func (TopicMap) ToTopicMapOutput 

func (i TopicMap) ToTopicMapOutput() TopicMapOutput

func (TopicMap) ToTopicMapOutputWithContext 

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

type TopicMapInput 

type TopicMapInput interface {
	pulumi.Input

	ToTopicMapOutput() TopicMapOutput
	ToTopicMapOutputWithContext(context.Context) TopicMapOutput
}

TopicMapInput is an input type that accepts TopicMap and TopicMapOutput values. You can construct a concrete instance of `TopicMapInput` via: 

TopicMap{ "key": TopicArgs{...} }

type TopicMapOutput 

type TopicMapOutput struct{ *pulumi.OutputState }

func (TopicMapOutput) ElementType 

func (TopicMapOutput) ElementType() reflect.Type

func (TopicMapOutput) MapIndex 

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

func (TopicMapOutput) ToTopicMapOutput 

func (o TopicMapOutput) ToTopicMapOutput() TopicMapOutput

func (TopicMapOutput) ToTopicMapOutputWithContext 

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

type TopicOutput 

type TopicOutput struct{ *pulumi.OutputState }

func (TopicOutput) ElementType 

func (TopicOutput) ElementType() reflect.Type

func (TopicOutput) LoggingEnabled 

func (o TopicOutput) LoggingEnabled() pulumi.BoolPtrOutput

Is logging enabled? true or false. Default value to false.

func (TopicOutput) MaximumMessageSize 

func (o TopicOutput) MaximumMessageSize() pulumi.IntPtrOutput

This indicates the maximum length, in bytes, of any message body sent to the topic. Valid value range: 1024-65536, i.e., 1K to 64K. Default value to 65536.

func (TopicOutput) Name 

func (o TopicOutput) Name() pulumi.StringOutput

Two topics on a single account in the same region cannot have the same name. A topic name must start with an English letter or a digit, and can contain English letters, digits, and hyphens, with the length not exceeding 256 characters.

func (TopicOutput) ToTopicOutput 

func (o TopicOutput) ToTopicOutput() TopicOutput

func (TopicOutput) ToTopicOutputWithContext 

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

type TopicState 

type TopicState struct {
	// Is logging enabled? true or false. Default value to false.
	LoggingEnabled pulumi.BoolPtrInput
	// This indicates the maximum length, in bytes, of any message body sent to the topic. Valid value range: 1024-65536, i.e., 1K to 64K. Default value to 65536.
	MaximumMessageSize pulumi.IntPtrInput
	// Two topics on a single account in the same region cannot have the same name. A topic name must start with an English letter or a digit, and can contain English letters, digits, and hyphens, with the length not exceeding 256 characters.
	Name pulumi.StringPtrInput
}

func (TopicState) ElementType 

func (TopicState) ElementType() reflect.Type

type TopicSubscription 

type TopicSubscription struct {
	pulumi.CustomResourceState

	// The endpoint has three format. Available values format:
	// - `HTTP Format`: http://xxx.com/xxx
	// - `Queue Format`: acs:mns:{REGION}:{AccountID}:queues/{QueueName}
	// - `Email Format`: mail:directmail:{MailAddress}
	Endpoint pulumi.StringOutput `pulumi:"endpoint"`
	// The length should be shorter than 16.
	FilterTag pulumi.StringPtrOutput `pulumi:"filterTag"`
	// Two topics subscription on a single account in the same topic cannot have the same name. A topic subscription name must start with an English letter or a digit, and can contain English letters, digits, and hyphens, with the length not exceeding 256 characters.
	Name pulumi.StringOutput `pulumi:"name"`
	// The NotifyContentFormat attribute of Subscription. This attribute specifies the content format of the messages pushed to users. The valid values: `SIMPLIFIED`, `XML` and `JSON`. Default to `SIMPLIFIED`.
	NotifyContentFormat pulumi.StringPtrOutput `pulumi:"notifyContentFormat"`
	// The NotifyStrategy attribute of Subscription. This attribute specifies the retry strategy when message sending fails. The Valid values: `EXPONENTIAL_DECAY_RETRY` and `BACKOFF_RETRY`. Default value to `BACKOFF_RETRY` .
	NotifyStrategy pulumi.StringPtrOutput `pulumi:"notifyStrategy"`
	// The topic which The subscription belongs to was named with the name.A topic name must start with an English letter or a digit, and can contain English letters, digits, and hyphens, with the length not exceeding 256 characters.
	TopicName pulumi.StringOutput `pulumi:"topicName"`
}

## Example Usage

Basic Usage

```go package main

import ( 

"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/rhysmdnz/pulumi-alicloud/sdk/go/alicloud/mns"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := mns.NewTopic(ctx, "topic", &mns.TopicArgs{
			LoggingEnabled:     pulumi.Bool(false),
			MaximumMessageSize: pulumi.Int(65536),
		})
		if err != nil {
			return err
		}
		_, err = mns.NewTopicSubscription(ctx, "subscription", &mns.TopicSubscriptionArgs{
			Endpoint:            pulumi.String("http://www.xxx.com/xxx"),
			FilterTag:           pulumi.String("test"),
			NotifyContentFormat: pulumi.String("XML"),
			NotifyStrategy:      pulumi.String("BACKOFF_RETRY"),
			TopicName:           pulumi.String("tf-example-mnstopic"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

MNS Topic subscription can be imported using the id, e.g.

```sh 

$ pulumi import alicloud:mns/topicSubscription:TopicSubscription subscription tf-example-mnstopic:tf-example-mnstopic-sub

```

func GetTopicSubscription 

func GetTopicSubscription(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *TopicSubscriptionState, opts ...pulumi.ResourceOption) (*TopicSubscription, error)

GetTopicSubscription gets an existing TopicSubscription 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 NewTopicSubscription 

func NewTopicSubscription(ctx *pulumi.Context,
	name string, args *TopicSubscriptionArgs, opts ...pulumi.ResourceOption) (*TopicSubscription, error)

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

func (*TopicSubscription) ElementType 

func (*TopicSubscription) ElementType() reflect.Type

func (*TopicSubscription) ToTopicSubscriptionOutput 

func (i *TopicSubscription) ToTopicSubscriptionOutput() TopicSubscriptionOutput

func (*TopicSubscription) ToTopicSubscriptionOutputWithContext 

func (i *TopicSubscription) ToTopicSubscriptionOutputWithContext(ctx context.Context) TopicSubscriptionOutput

type TopicSubscriptionArgs 

type TopicSubscriptionArgs struct {
	// The endpoint has three format. Available values format:
	// - `HTTP Format`: http://xxx.com/xxx
	// - `Queue Format`: acs:mns:{REGION}:{AccountID}:queues/{QueueName}
	// - `Email Format`: mail:directmail:{MailAddress}
	Endpoint pulumi.StringInput
	// The length should be shorter than 16.
	FilterTag pulumi.StringPtrInput
	// Two topics subscription on a single account in the same topic cannot have the same name. A topic subscription name must start with an English letter or a digit, and can contain English letters, digits, and hyphens, with the length not exceeding 256 characters.
	Name pulumi.StringPtrInput
	// The NotifyContentFormat attribute of Subscription. This attribute specifies the content format of the messages pushed to users. The valid values: `SIMPLIFIED`, `XML` and `JSON`. Default to `SIMPLIFIED`.
	NotifyContentFormat pulumi.StringPtrInput
	// The NotifyStrategy attribute of Subscription. This attribute specifies the retry strategy when message sending fails. The Valid values: `EXPONENTIAL_DECAY_RETRY` and `BACKOFF_RETRY`. Default value to `BACKOFF_RETRY` .
	NotifyStrategy pulumi.StringPtrInput
	// The topic which The subscription belongs to was named with the name.A topic name must start with an English letter or a digit, and can contain English letters, digits, and hyphens, with the length not exceeding 256 characters.
	TopicName pulumi.StringInput
}

The set of arguments for constructing a TopicSubscription resource.

func (TopicSubscriptionArgs) ElementType 

func (TopicSubscriptionArgs) ElementType() reflect.Type

type TopicSubscriptionArray 

type TopicSubscriptionArray []TopicSubscriptionInput

func (TopicSubscriptionArray) ElementType 

func (TopicSubscriptionArray) ElementType() reflect.Type

func (TopicSubscriptionArray) ToTopicSubscriptionArrayOutput 

func (i TopicSubscriptionArray) ToTopicSubscriptionArrayOutput() TopicSubscriptionArrayOutput

func (TopicSubscriptionArray) ToTopicSubscriptionArrayOutputWithContext 

func (i TopicSubscriptionArray) ToTopicSubscriptionArrayOutputWithContext(ctx context.Context) TopicSubscriptionArrayOutput

type TopicSubscriptionArrayInput 

type TopicSubscriptionArrayInput interface {
	pulumi.Input

	ToTopicSubscriptionArrayOutput() TopicSubscriptionArrayOutput
	ToTopicSubscriptionArrayOutputWithContext(context.Context) TopicSubscriptionArrayOutput
}

TopicSubscriptionArrayInput is an input type that accepts TopicSubscriptionArray and TopicSubscriptionArrayOutput values. You can construct a concrete instance of `TopicSubscriptionArrayInput` via: 

TopicSubscriptionArray{ TopicSubscriptionArgs{...} }

type TopicSubscriptionArrayOutput 

type TopicSubscriptionArrayOutput struct{ *pulumi.OutputState }

func (TopicSubscriptionArrayOutput) ElementType 

func (TopicSubscriptionArrayOutput) ElementType() reflect.Type

func (TopicSubscriptionArrayOutput) Index 

func (o TopicSubscriptionArrayOutput) Index(i pulumi.IntInput) TopicSubscriptionOutput

func (TopicSubscriptionArrayOutput) ToTopicSubscriptionArrayOutput 

func (o TopicSubscriptionArrayOutput) ToTopicSubscriptionArrayOutput() TopicSubscriptionArrayOutput

func (TopicSubscriptionArrayOutput) ToTopicSubscriptionArrayOutputWithContext 

func (o TopicSubscriptionArrayOutput) ToTopicSubscriptionArrayOutputWithContext(ctx context.Context) TopicSubscriptionArrayOutput

type TopicSubscriptionInput 

type TopicSubscriptionInput interface {
	pulumi.Input

	ToTopicSubscriptionOutput() TopicSubscriptionOutput
	ToTopicSubscriptionOutputWithContext(ctx context.Context) TopicSubscriptionOutput
}

type TopicSubscriptionMap 

type TopicSubscriptionMap map[string]TopicSubscriptionInput

func (TopicSubscriptionMap) ElementType 

func (TopicSubscriptionMap) ElementType() reflect.Type

func (TopicSubscriptionMap) ToTopicSubscriptionMapOutput 

func (i TopicSubscriptionMap) ToTopicSubscriptionMapOutput() TopicSubscriptionMapOutput

func (TopicSubscriptionMap) ToTopicSubscriptionMapOutputWithContext 

func (i TopicSubscriptionMap) ToTopicSubscriptionMapOutputWithContext(ctx context.Context) TopicSubscriptionMapOutput

type TopicSubscriptionMapInput 

type TopicSubscriptionMapInput interface {
	pulumi.Input

	ToTopicSubscriptionMapOutput() TopicSubscriptionMapOutput
	ToTopicSubscriptionMapOutputWithContext(context.Context) TopicSubscriptionMapOutput
}

TopicSubscriptionMapInput is an input type that accepts TopicSubscriptionMap and TopicSubscriptionMapOutput values. You can construct a concrete instance of `TopicSubscriptionMapInput` via: 

TopicSubscriptionMap{ "key": TopicSubscriptionArgs{...} }

type TopicSubscriptionMapOutput 

type TopicSubscriptionMapOutput struct{ *pulumi.OutputState }

func (TopicSubscriptionMapOutput) ElementType 

func (TopicSubscriptionMapOutput) ElementType() reflect.Type

func (TopicSubscriptionMapOutput) MapIndex 

func (o TopicSubscriptionMapOutput) MapIndex(k pulumi.StringInput) TopicSubscriptionOutput

func (TopicSubscriptionMapOutput) ToTopicSubscriptionMapOutput 

func (o TopicSubscriptionMapOutput) ToTopicSubscriptionMapOutput() TopicSubscriptionMapOutput

func (TopicSubscriptionMapOutput) ToTopicSubscriptionMapOutputWithContext 

func (o TopicSubscriptionMapOutput) ToTopicSubscriptionMapOutputWithContext(ctx context.Context) TopicSubscriptionMapOutput

type TopicSubscriptionOutput 

type TopicSubscriptionOutput struct{ *pulumi.OutputState }

func (TopicSubscriptionOutput) ElementType 

func (TopicSubscriptionOutput) ElementType() reflect.Type

func (TopicSubscriptionOutput) Endpoint 

func (o TopicSubscriptionOutput) Endpoint() pulumi.StringOutput

The endpoint has three format. Available values format: - `HTTP Format`: http://xxx.com/xxx - `Queue Format`: acs:mns:{REGION}:{AccountID}:queues/{QueueName} - `Email Format`: mail:directmail:{MailAddress}

func (TopicSubscriptionOutput) FilterTag 

func (o TopicSubscriptionOutput) FilterTag() pulumi.StringPtrOutput

The length should be shorter than 16.

func (TopicSubscriptionOutput) Name 

func (o TopicSubscriptionOutput) Name() pulumi.StringOutput

Two topics subscription on a single account in the same topic cannot have the same name. A topic subscription name must start with an English letter or a digit, and can contain English letters, digits, and hyphens, with the length not exceeding 256 characters.

func (TopicSubscriptionOutput) NotifyContentFormat 

func (o TopicSubscriptionOutput) NotifyContentFormat() pulumi.StringPtrOutput

The NotifyContentFormat attribute of Subscription. This attribute specifies the content format of the messages pushed to users. The valid values: `SIMPLIFIED`, `XML` and `JSON`. Default to `SIMPLIFIED`.

func (TopicSubscriptionOutput) NotifyStrategy 

func (o TopicSubscriptionOutput) NotifyStrategy() pulumi.StringPtrOutput

The NotifyStrategy attribute of Subscription. This attribute specifies the retry strategy when message sending fails. The Valid values: `EXPONENTIAL_DECAY_RETRY` and `BACKOFF_RETRY`. Default value to `BACKOFF_RETRY` .

func (TopicSubscriptionOutput) ToTopicSubscriptionOutput 

func (o TopicSubscriptionOutput) ToTopicSubscriptionOutput() TopicSubscriptionOutput

func (TopicSubscriptionOutput) ToTopicSubscriptionOutputWithContext 

func (o TopicSubscriptionOutput) ToTopicSubscriptionOutputWithContext(ctx context.Context) TopicSubscriptionOutput

func (TopicSubscriptionOutput) TopicName 

func (o TopicSubscriptionOutput) TopicName() pulumi.StringOutput

The topic which The subscription belongs to was named with the name.A topic name must start with an English letter or a digit, and can contain English letters, digits, and hyphens, with the length not exceeding 256 characters.

type TopicSubscriptionState 

type TopicSubscriptionState struct {
	// The endpoint has three format. Available values format:
	// - `HTTP Format`: http://xxx.com/xxx
	// - `Queue Format`: acs:mns:{REGION}:{AccountID}:queues/{QueueName}
	// - `Email Format`: mail:directmail:{MailAddress}
	Endpoint pulumi.StringPtrInput
	// The length should be shorter than 16.
	FilterTag pulumi.StringPtrInput
	// Two topics subscription on a single account in the same topic cannot have the same name. A topic subscription name must start with an English letter or a digit, and can contain English letters, digits, and hyphens, with the length not exceeding 256 characters.
	Name pulumi.StringPtrInput
	// The NotifyContentFormat attribute of Subscription. This attribute specifies the content format of the messages pushed to users. The valid values: `SIMPLIFIED`, `XML` and `JSON`. Default to `SIMPLIFIED`.
	NotifyContentFormat pulumi.StringPtrInput
	// The NotifyStrategy attribute of Subscription. This attribute specifies the retry strategy when message sending fails. The Valid values: `EXPONENTIAL_DECAY_RETRY` and `BACKOFF_RETRY`. Default value to `BACKOFF_RETRY` .
	NotifyStrategy pulumi.StringPtrInput
	// The topic which The subscription belongs to was named with the name.A topic name must start with an English letter or a digit, and can contain English letters, digits, and hyphens, with the length not exceeding 256 characters.
	TopicName pulumi.StringPtrInput
}

func (TopicSubscriptionState) ElementType 

func (TopicSubscriptionState) ElementType() reflect.Type

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.