message

package
v3.54.0 Latest Latest
Warning

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

Go to latest
Published: Apr 24, 2024 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 GetServiceQueuesArgs

type GetServiceQueuesArgs struct {
	// A list of Queue IDs. Its element value is same as Queue Name.
	Ids []string `pulumi:"ids"`
	// A regex string to filter results by Queue name.
	NameRegex *string `pulumi:"nameRegex"`
	// File name where to save data source results (after running `pulumi preview`).
	OutputFile *string `pulumi:"outputFile"`
	PageNumber *int    `pulumi:"pageNumber"`
	PageSize   *int    `pulumi:"pageSize"`
	// The name of the queue.
	QueueName *string `pulumi:"queueName"`
}

A collection of arguments for invoking getServiceQueues.

type GetServiceQueuesOutputArgs

type GetServiceQueuesOutputArgs struct {
	// A list of Queue IDs. Its element value is same as Queue Name.
	Ids pulumi.StringArrayInput `pulumi:"ids"`
	// A regex string to filter results by Queue name.
	NameRegex pulumi.StringPtrInput `pulumi:"nameRegex"`
	// File name where to save data source results (after running `pulumi preview`).
	OutputFile pulumi.StringPtrInput `pulumi:"outputFile"`
	PageNumber pulumi.IntPtrInput    `pulumi:"pageNumber"`
	PageSize   pulumi.IntPtrInput    `pulumi:"pageSize"`
	// The name of the queue.
	QueueName pulumi.StringPtrInput `pulumi:"queueName"`
}

A collection of arguments for invoking getServiceQueues.

func (GetServiceQueuesOutputArgs) ElementType

func (GetServiceQueuesOutputArgs) ElementType() reflect.Type

type GetServiceQueuesQueue

type GetServiceQueuesQueue struct {
	// The total number of messages that are in the Active state in the queue. The value is an approximate number.
	ActiveMessages int `pulumi:"activeMessages"`
	// The time when the queue was created. This value is a UNIX timestamp representing the number of milliseconds that have elapsed since the epoch time January 1, 1970, 00:00:00 UTC.
	CreateTime int `pulumi:"createTime"`
	// The total number of the messages that are in the Delayed state in the queue. The value is an approximate number.
	DelayMessages int `pulumi:"delayMessages"`
	// The delay period after which all messages that are sent to the queue can be consumed. Unit: seconds.
	DelaySeconds int `pulumi:"delaySeconds"`
	// The ID of the Queue. Its value is same as Queue Name.
	Id string `pulumi:"id"`
	// The total number of the messages that are in the Inactive state in the queue. The value is an approximate number.
	InactiveMessages int `pulumi:"inactiveMessages"`
	// The time when the queue was last modified. This value is a UNIX timestamp representing the number of milliseconds that have elapsed since the epoch time January 1, 1970, 00:00:00 UTC.
	LastModifyTime int `pulumi:"lastModifyTime"`
	// Indicates whether the log management feature is enabled for the queue.
	LoggingEnabled bool `pulumi:"loggingEnabled"`
	// The maximum size of a message body that can be sent to the queue. Unit: bytes.
	MaximumMessageSize int `pulumi:"maximumMessageSize"`
	// The maximum period for which a message can be retained in the queue. A message that is sent to the queue can be retained for a specified period. After the specified period ends, the message is deleted no matter whether it is consumed. Unit: seconds.
	MessageRetentionPeriod int `pulumi:"messageRetentionPeriod"`
	// The maximum period for which a ReceiveMessage request waits if no message is available in the queue. Unit: seconds.
	PollingWaitSeconds int `pulumi:"pollingWaitSeconds"`
	// The internal url of the queue.
	QueueInternalUrl string `pulumi:"queueInternalUrl"`
	// The name of the queue.
	QueueName string `pulumi:"queueName"`
	// The url of the queue.
	QueueUrl string `pulumi:"queueUrl"`
	// The invisibility period for which the received message remains the Inactive state. Unit: seconds.
	VisibilityTimeout int `pulumi:"visibilityTimeout"`
}

type GetServiceQueuesQueueArgs

type GetServiceQueuesQueueArgs struct {
	// The total number of messages that are in the Active state in the queue. The value is an approximate number.
	ActiveMessages pulumi.IntInput `pulumi:"activeMessages"`
	// The time when the queue was created. This value is a UNIX timestamp representing the number of milliseconds that have elapsed since the epoch time January 1, 1970, 00:00:00 UTC.
	CreateTime pulumi.IntInput `pulumi:"createTime"`
	// The total number of the messages that are in the Delayed state in the queue. The value is an approximate number.
	DelayMessages pulumi.IntInput `pulumi:"delayMessages"`
	// The delay period after which all messages that are sent to the queue can be consumed. Unit: seconds.
	DelaySeconds pulumi.IntInput `pulumi:"delaySeconds"`
	// The ID of the Queue. Its value is same as Queue Name.
	Id pulumi.StringInput `pulumi:"id"`
	// The total number of the messages that are in the Inactive state in the queue. The value is an approximate number.
	InactiveMessages pulumi.IntInput `pulumi:"inactiveMessages"`
	// The time when the queue was last modified. This value is a UNIX timestamp representing the number of milliseconds that have elapsed since the epoch time January 1, 1970, 00:00:00 UTC.
	LastModifyTime pulumi.IntInput `pulumi:"lastModifyTime"`
	// Indicates whether the log management feature is enabled for the queue.
	LoggingEnabled pulumi.BoolInput `pulumi:"loggingEnabled"`
	// The maximum size of a message body that can be sent to the queue. Unit: bytes.
	MaximumMessageSize pulumi.IntInput `pulumi:"maximumMessageSize"`
	// The maximum period for which a message can be retained in the queue. A message that is sent to the queue can be retained for a specified period. After the specified period ends, the message is deleted no matter whether it is consumed. Unit: seconds.
	MessageRetentionPeriod pulumi.IntInput `pulumi:"messageRetentionPeriod"`
	// The maximum period for which a ReceiveMessage request waits if no message is available in the queue. Unit: seconds.
	PollingWaitSeconds pulumi.IntInput `pulumi:"pollingWaitSeconds"`
	// The internal url of the queue.
	QueueInternalUrl pulumi.StringInput `pulumi:"queueInternalUrl"`
	// The name of the queue.
	QueueName pulumi.StringInput `pulumi:"queueName"`
	// The url of the queue.
	QueueUrl pulumi.StringInput `pulumi:"queueUrl"`
	// The invisibility period for which the received message remains the Inactive state. Unit: seconds.
	VisibilityTimeout pulumi.IntInput `pulumi:"visibilityTimeout"`
}

func (GetServiceQueuesQueueArgs) ElementType

func (GetServiceQueuesQueueArgs) ElementType() reflect.Type

func (GetServiceQueuesQueueArgs) ToGetServiceQueuesQueueOutput

func (i GetServiceQueuesQueueArgs) ToGetServiceQueuesQueueOutput() GetServiceQueuesQueueOutput

func (GetServiceQueuesQueueArgs) ToGetServiceQueuesQueueOutputWithContext

func (i GetServiceQueuesQueueArgs) ToGetServiceQueuesQueueOutputWithContext(ctx context.Context) GetServiceQueuesQueueOutput

type GetServiceQueuesQueueArray

type GetServiceQueuesQueueArray []GetServiceQueuesQueueInput

func (GetServiceQueuesQueueArray) ElementType

func (GetServiceQueuesQueueArray) ElementType() reflect.Type

func (GetServiceQueuesQueueArray) ToGetServiceQueuesQueueArrayOutput

func (i GetServiceQueuesQueueArray) ToGetServiceQueuesQueueArrayOutput() GetServiceQueuesQueueArrayOutput

func (GetServiceQueuesQueueArray) ToGetServiceQueuesQueueArrayOutputWithContext

func (i GetServiceQueuesQueueArray) ToGetServiceQueuesQueueArrayOutputWithContext(ctx context.Context) GetServiceQueuesQueueArrayOutput

type GetServiceQueuesQueueArrayInput

type GetServiceQueuesQueueArrayInput interface {
	pulumi.Input

	ToGetServiceQueuesQueueArrayOutput() GetServiceQueuesQueueArrayOutput
	ToGetServiceQueuesQueueArrayOutputWithContext(context.Context) GetServiceQueuesQueueArrayOutput
}

GetServiceQueuesQueueArrayInput is an input type that accepts GetServiceQueuesQueueArray and GetServiceQueuesQueueArrayOutput values. You can construct a concrete instance of `GetServiceQueuesQueueArrayInput` via:

GetServiceQueuesQueueArray{ GetServiceQueuesQueueArgs{...} }

type GetServiceQueuesQueueArrayOutput

type GetServiceQueuesQueueArrayOutput struct{ *pulumi.OutputState }

func (GetServiceQueuesQueueArrayOutput) ElementType

func (GetServiceQueuesQueueArrayOutput) Index

func (GetServiceQueuesQueueArrayOutput) ToGetServiceQueuesQueueArrayOutput

func (o GetServiceQueuesQueueArrayOutput) ToGetServiceQueuesQueueArrayOutput() GetServiceQueuesQueueArrayOutput

func (GetServiceQueuesQueueArrayOutput) ToGetServiceQueuesQueueArrayOutputWithContext

func (o GetServiceQueuesQueueArrayOutput) ToGetServiceQueuesQueueArrayOutputWithContext(ctx context.Context) GetServiceQueuesQueueArrayOutput

type GetServiceQueuesQueueInput

type GetServiceQueuesQueueInput interface {
	pulumi.Input

	ToGetServiceQueuesQueueOutput() GetServiceQueuesQueueOutput
	ToGetServiceQueuesQueueOutputWithContext(context.Context) GetServiceQueuesQueueOutput
}

GetServiceQueuesQueueInput is an input type that accepts GetServiceQueuesQueueArgs and GetServiceQueuesQueueOutput values. You can construct a concrete instance of `GetServiceQueuesQueueInput` via:

GetServiceQueuesQueueArgs{...}

type GetServiceQueuesQueueOutput

type GetServiceQueuesQueueOutput struct{ *pulumi.OutputState }

func (GetServiceQueuesQueueOutput) ActiveMessages

func (o GetServiceQueuesQueueOutput) ActiveMessages() pulumi.IntOutput

The total number of messages that are in the Active state in the queue. The value is an approximate number.

func (GetServiceQueuesQueueOutput) CreateTime

The time when the queue was created. This value is a UNIX timestamp representing the number of milliseconds that have elapsed since the epoch time January 1, 1970, 00:00:00 UTC.

func (GetServiceQueuesQueueOutput) DelayMessages

func (o GetServiceQueuesQueueOutput) DelayMessages() pulumi.IntOutput

The total number of the messages that are in the Delayed state in the queue. The value is an approximate number.

func (GetServiceQueuesQueueOutput) DelaySeconds

func (o GetServiceQueuesQueueOutput) DelaySeconds() pulumi.IntOutput

The delay period after which all messages that are sent to the queue can be consumed. Unit: seconds.

func (GetServiceQueuesQueueOutput) ElementType

func (GetServiceQueuesQueueOutput) Id

The ID of the Queue. Its value is same as Queue Name.

func (GetServiceQueuesQueueOutput) InactiveMessages

func (o GetServiceQueuesQueueOutput) InactiveMessages() pulumi.IntOutput

The total number of the messages that are in the Inactive state in the queue. The value is an approximate number.

func (GetServiceQueuesQueueOutput) LastModifyTime

func (o GetServiceQueuesQueueOutput) LastModifyTime() pulumi.IntOutput

The time when the queue was last modified. This value is a UNIX timestamp representing the number of milliseconds that have elapsed since the epoch time January 1, 1970, 00:00:00 UTC.

func (GetServiceQueuesQueueOutput) LoggingEnabled

func (o GetServiceQueuesQueueOutput) LoggingEnabled() pulumi.BoolOutput

Indicates whether the log management feature is enabled for the queue.

func (GetServiceQueuesQueueOutput) MaximumMessageSize

func (o GetServiceQueuesQueueOutput) MaximumMessageSize() pulumi.IntOutput

The maximum size of a message body that can be sent to the queue. Unit: bytes.

func (GetServiceQueuesQueueOutput) MessageRetentionPeriod

func (o GetServiceQueuesQueueOutput) MessageRetentionPeriod() pulumi.IntOutput

The maximum period for which a message can be retained in the queue. A message that is sent to the queue can be retained for a specified period. After the specified period ends, the message is deleted no matter whether it is consumed. Unit: seconds.

func (GetServiceQueuesQueueOutput) PollingWaitSeconds

func (o GetServiceQueuesQueueOutput) PollingWaitSeconds() pulumi.IntOutput

The maximum period for which a ReceiveMessage request waits if no message is available in the queue. Unit: seconds.

func (GetServiceQueuesQueueOutput) QueueInternalUrl

func (o GetServiceQueuesQueueOutput) QueueInternalUrl() pulumi.StringOutput

The internal url of the queue.

func (GetServiceQueuesQueueOutput) QueueName

The name of the queue.

func (GetServiceQueuesQueueOutput) QueueUrl

The url of the queue.

func (GetServiceQueuesQueueOutput) ToGetServiceQueuesQueueOutput

func (o GetServiceQueuesQueueOutput) ToGetServiceQueuesQueueOutput() GetServiceQueuesQueueOutput

func (GetServiceQueuesQueueOutput) ToGetServiceQueuesQueueOutputWithContext

func (o GetServiceQueuesQueueOutput) ToGetServiceQueuesQueueOutputWithContext(ctx context.Context) GetServiceQueuesQueueOutput

func (GetServiceQueuesQueueOutput) VisibilityTimeout

func (o GetServiceQueuesQueueOutput) VisibilityTimeout() pulumi.IntOutput

The invisibility period for which the received message remains the Inactive state. Unit: seconds.

type GetServiceQueuesResult

type GetServiceQueuesResult struct {
	// The provider-assigned unique ID for this managed resource.
	Id        string   `pulumi:"id"`
	Ids       []string `pulumi:"ids"`
	NameRegex *string  `pulumi:"nameRegex"`
	// A list of Queue names.
	Names      []string `pulumi:"names"`
	OutputFile *string  `pulumi:"outputFile"`
	PageNumber *int     `pulumi:"pageNumber"`
	PageSize   *int     `pulumi:"pageSize"`
	// The name of the queue.
	QueueName *string `pulumi:"queueName"`
	// A list of Queues. Each element contains the following attributes:
	Queues []GetServiceQueuesQueue `pulumi:"queues"`
}

A collection of values returned by getServiceQueues.

func GetServiceQueues

func GetServiceQueues(ctx *pulumi.Context, args *GetServiceQueuesArgs, opts ...pulumi.InvokeOption) (*GetServiceQueuesResult, error)

This data source provides the Message Notification Service Queues of the current Alibaba Cloud user.

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

## Example Usage

```go package main

import (

"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/message"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		ids, err := message.GetServiceQueues(ctx, &message.GetServiceQueuesArgs{
			Ids: []string{
				"example_id",
			},
		}, nil)
		if err != nil {
			return err
		}
		ctx.Export("queueId1", ids.Queues[0].Id)
		name, err := message.GetServiceQueues(ctx, &message.GetServiceQueuesArgs{
			QueueName: pulumi.StringRef("tf-example"),
		}, nil)
		if err != nil {
			return err
		}
		ctx.Export("queueId2", name.Queues[0].Id)
		return nil
	})
}

```

type GetServiceQueuesResultOutput

type GetServiceQueuesResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getServiceQueues.

func (GetServiceQueuesResultOutput) ElementType

func (GetServiceQueuesResultOutput) Id

The provider-assigned unique ID for this managed resource.

func (GetServiceQueuesResultOutput) Ids

func (GetServiceQueuesResultOutput) NameRegex

func (GetServiceQueuesResultOutput) Names

A list of Queue names.

func (GetServiceQueuesResultOutput) OutputFile

func (GetServiceQueuesResultOutput) PageNumber

func (GetServiceQueuesResultOutput) PageSize

func (GetServiceQueuesResultOutput) QueueName

The name of the queue.

func (GetServiceQueuesResultOutput) Queues

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

func (GetServiceQueuesResultOutput) ToGetServiceQueuesResultOutput

func (o GetServiceQueuesResultOutput) ToGetServiceQueuesResultOutput() GetServiceQueuesResultOutput

func (GetServiceQueuesResultOutput) ToGetServiceQueuesResultOutputWithContext

func (o GetServiceQueuesResultOutput) ToGetServiceQueuesResultOutputWithContext(ctx context.Context) GetServiceQueuesResultOutput

type GetServiceSubscriptionsArgs

type GetServiceSubscriptionsArgs struct {
	// A list of Subscription IDs.
	Ids []string `pulumi:"ids"`
	// A regex string to filter results by Subscription name.
	NameRegex *string `pulumi:"nameRegex"`
	// File name where to save data source results (after running `pulumi preview`).
	OutputFile *string `pulumi:"outputFile"`
	PageNumber *int    `pulumi:"pageNumber"`
	PageSize   *int    `pulumi:"pageSize"`
	// The name of the subscription.
	SubscriptionName *string `pulumi:"subscriptionName"`
	// The name of the topic.
	TopicName string `pulumi:"topicName"`
}

A collection of arguments for invoking getServiceSubscriptions.

type GetServiceSubscriptionsOutputArgs

type GetServiceSubscriptionsOutputArgs struct {
	// A list of Subscription IDs.
	Ids pulumi.StringArrayInput `pulumi:"ids"`
	// A regex string to filter results by Subscription name.
	NameRegex pulumi.StringPtrInput `pulumi:"nameRegex"`
	// File name where to save data source results (after running `pulumi preview`).
	OutputFile pulumi.StringPtrInput `pulumi:"outputFile"`
	PageNumber pulumi.IntPtrInput    `pulumi:"pageNumber"`
	PageSize   pulumi.IntPtrInput    `pulumi:"pageSize"`
	// The name of the subscription.
	SubscriptionName pulumi.StringPtrInput `pulumi:"subscriptionName"`
	// The name of the topic.
	TopicName pulumi.StringInput `pulumi:"topicName"`
}

A collection of arguments for invoking getServiceSubscriptions.

func (GetServiceSubscriptionsOutputArgs) ElementType

type GetServiceSubscriptionsResult

type GetServiceSubscriptionsResult struct {
	// The provider-assigned unique ID for this managed resource.
	Id        string   `pulumi:"id"`
	Ids       []string `pulumi:"ids"`
	NameRegex *string  `pulumi:"nameRegex"`
	// A list of Subscription names.
	Names      []string `pulumi:"names"`
	OutputFile *string  `pulumi:"outputFile"`
	PageNumber *int     `pulumi:"pageNumber"`
	PageSize   *int     `pulumi:"pageSize"`
	// The name of the subscription.
	SubscriptionName *string `pulumi:"subscriptionName"`
	// A list of Subscriptions. Each element contains the following attributes:
	Subscriptions []GetServiceSubscriptionsSubscription `pulumi:"subscriptions"`
	// The name of the topic.
	TopicName string `pulumi:"topicName"`
}

A collection of values returned by getServiceSubscriptions.

func GetServiceSubscriptions

func GetServiceSubscriptions(ctx *pulumi.Context, args *GetServiceSubscriptionsArgs, opts ...pulumi.InvokeOption) (*GetServiceSubscriptionsResult, error)

This data source provides the Message Notification Service Subscriptions of the current Alibaba Cloud user.

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

## Example Usage

```go package main

import (

"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/message"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		ids, err := message.GetServiceSubscriptions(ctx, &message.GetServiceSubscriptionsArgs{
			Ids: []string{
				"example_id",
			},
			TopicName: "tf-example",
		}, nil)
		if err != nil {
			return err
		}
		ctx.Export("subscriptionId1", ids.Subscriptions[0].Id)
		name, err := message.GetServiceSubscriptions(ctx, &message.GetServiceSubscriptionsArgs{
			TopicName: "tf-example",
		}, nil)
		if err != nil {
			return err
		}
		ctx.Export("subscriptionId2", name.Subscriptions[0].Id)
		return nil
	})
}

```

type GetServiceSubscriptionsResultOutput

type GetServiceSubscriptionsResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getServiceSubscriptions.

func (GetServiceSubscriptionsResultOutput) ElementType

func (GetServiceSubscriptionsResultOutput) Id

The provider-assigned unique ID for this managed resource.

func (GetServiceSubscriptionsResultOutput) Ids

func (GetServiceSubscriptionsResultOutput) NameRegex

func (GetServiceSubscriptionsResultOutput) Names

A list of Subscription names.

func (GetServiceSubscriptionsResultOutput) OutputFile

func (GetServiceSubscriptionsResultOutput) PageNumber

func (GetServiceSubscriptionsResultOutput) PageSize

func (GetServiceSubscriptionsResultOutput) SubscriptionName

The name of the subscription.

func (GetServiceSubscriptionsResultOutput) Subscriptions

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

func (GetServiceSubscriptionsResultOutput) ToGetServiceSubscriptionsResultOutput

func (o GetServiceSubscriptionsResultOutput) ToGetServiceSubscriptionsResultOutput() GetServiceSubscriptionsResultOutput

func (GetServiceSubscriptionsResultOutput) ToGetServiceSubscriptionsResultOutputWithContext

func (o GetServiceSubscriptionsResultOutput) ToGetServiceSubscriptionsResultOutputWithContext(ctx context.Context) GetServiceSubscriptionsResultOutput

func (GetServiceSubscriptionsResultOutput) TopicName

The name of the topic.

type GetServiceSubscriptionsSubscription

type GetServiceSubscriptionsSubscription struct {
	// The time when the subscription was created. This value is a UNIX timestamp representing the number of milliseconds that have elapsed since the epoch time January 1, 1970, 00:00:00 UTC.
	CreateTime int `pulumi:"createTime"`
	// The endpoint to which the messages are pushed.
	Endpoint string `pulumi:"endpoint"`
	// The tag that is used to filter messages. Only the messages that are attached with the specified tag can be pushed.
	FilterTag string `pulumi:"filterTag"`
	// The id of the Subscription.
	Id string `pulumi:"id"`
	// The time when the subscription was last modified. This value is a UNIX timestamp representing the number of milliseconds that have elapsed since the epoch time January 1, 1970, 00:00:00 UTC.
	LastModifyTime int `pulumi:"lastModifyTime"`
	// The content format of the messages that are pushed to the endpoint.
	NotifyContentFormat string `pulumi:"notifyContentFormat"`
	// The retry policy that is applied if an error occurs when MNS pushes messages to the endpoint.
	NotifyStrategy string `pulumi:"notifyStrategy"`
	// The name of the subscription.
	SubscriptionName string `pulumi:"subscriptionName"`
	// The url of the subscription.
	SubscriptionUrl string `pulumi:"subscriptionUrl"`
	// The name of the topic.
	TopicName string `pulumi:"topicName"`
	// The account ID of the topic owner.
	TopicOwner string `pulumi:"topicOwner"`
}

type GetServiceSubscriptionsSubscriptionArgs

type GetServiceSubscriptionsSubscriptionArgs struct {
	// The time when the subscription was created. This value is a UNIX timestamp representing the number of milliseconds that have elapsed since the epoch time January 1, 1970, 00:00:00 UTC.
	CreateTime pulumi.IntInput `pulumi:"createTime"`
	// The endpoint to which the messages are pushed.
	Endpoint pulumi.StringInput `pulumi:"endpoint"`
	// The tag that is used to filter messages. Only the messages that are attached with the specified tag can be pushed.
	FilterTag pulumi.StringInput `pulumi:"filterTag"`
	// The id of the Subscription.
	Id pulumi.StringInput `pulumi:"id"`
	// The time when the subscription was last modified. This value is a UNIX timestamp representing the number of milliseconds that have elapsed since the epoch time January 1, 1970, 00:00:00 UTC.
	LastModifyTime pulumi.IntInput `pulumi:"lastModifyTime"`
	// The content format of the messages that are pushed to the endpoint.
	NotifyContentFormat pulumi.StringInput `pulumi:"notifyContentFormat"`
	// The retry policy that is applied if an error occurs when MNS pushes messages to the endpoint.
	NotifyStrategy pulumi.StringInput `pulumi:"notifyStrategy"`
	// The name of the subscription.
	SubscriptionName pulumi.StringInput `pulumi:"subscriptionName"`
	// The url of the subscription.
	SubscriptionUrl pulumi.StringInput `pulumi:"subscriptionUrl"`
	// The name of the topic.
	TopicName pulumi.StringInput `pulumi:"topicName"`
	// The account ID of the topic owner.
	TopicOwner pulumi.StringInput `pulumi:"topicOwner"`
}

func (GetServiceSubscriptionsSubscriptionArgs) ElementType

func (GetServiceSubscriptionsSubscriptionArgs) ToGetServiceSubscriptionsSubscriptionOutput

func (i GetServiceSubscriptionsSubscriptionArgs) ToGetServiceSubscriptionsSubscriptionOutput() GetServiceSubscriptionsSubscriptionOutput

func (GetServiceSubscriptionsSubscriptionArgs) ToGetServiceSubscriptionsSubscriptionOutputWithContext

func (i GetServiceSubscriptionsSubscriptionArgs) ToGetServiceSubscriptionsSubscriptionOutputWithContext(ctx context.Context) GetServiceSubscriptionsSubscriptionOutput

type GetServiceSubscriptionsSubscriptionArray

type GetServiceSubscriptionsSubscriptionArray []GetServiceSubscriptionsSubscriptionInput

func (GetServiceSubscriptionsSubscriptionArray) ElementType

func (GetServiceSubscriptionsSubscriptionArray) ToGetServiceSubscriptionsSubscriptionArrayOutput

func (i GetServiceSubscriptionsSubscriptionArray) ToGetServiceSubscriptionsSubscriptionArrayOutput() GetServiceSubscriptionsSubscriptionArrayOutput

func (GetServiceSubscriptionsSubscriptionArray) ToGetServiceSubscriptionsSubscriptionArrayOutputWithContext

func (i GetServiceSubscriptionsSubscriptionArray) ToGetServiceSubscriptionsSubscriptionArrayOutputWithContext(ctx context.Context) GetServiceSubscriptionsSubscriptionArrayOutput

type GetServiceSubscriptionsSubscriptionArrayInput

type GetServiceSubscriptionsSubscriptionArrayInput interface {
	pulumi.Input

	ToGetServiceSubscriptionsSubscriptionArrayOutput() GetServiceSubscriptionsSubscriptionArrayOutput
	ToGetServiceSubscriptionsSubscriptionArrayOutputWithContext(context.Context) GetServiceSubscriptionsSubscriptionArrayOutput
}

GetServiceSubscriptionsSubscriptionArrayInput is an input type that accepts GetServiceSubscriptionsSubscriptionArray and GetServiceSubscriptionsSubscriptionArrayOutput values. You can construct a concrete instance of `GetServiceSubscriptionsSubscriptionArrayInput` via:

GetServiceSubscriptionsSubscriptionArray{ GetServiceSubscriptionsSubscriptionArgs{...} }

type GetServiceSubscriptionsSubscriptionArrayOutput

type GetServiceSubscriptionsSubscriptionArrayOutput struct{ *pulumi.OutputState }

func (GetServiceSubscriptionsSubscriptionArrayOutput) ElementType

func (GetServiceSubscriptionsSubscriptionArrayOutput) Index

func (GetServiceSubscriptionsSubscriptionArrayOutput) ToGetServiceSubscriptionsSubscriptionArrayOutput

func (o GetServiceSubscriptionsSubscriptionArrayOutput) ToGetServiceSubscriptionsSubscriptionArrayOutput() GetServiceSubscriptionsSubscriptionArrayOutput

func (GetServiceSubscriptionsSubscriptionArrayOutput) ToGetServiceSubscriptionsSubscriptionArrayOutputWithContext

func (o GetServiceSubscriptionsSubscriptionArrayOutput) ToGetServiceSubscriptionsSubscriptionArrayOutputWithContext(ctx context.Context) GetServiceSubscriptionsSubscriptionArrayOutput

type GetServiceSubscriptionsSubscriptionInput

type GetServiceSubscriptionsSubscriptionInput interface {
	pulumi.Input

	ToGetServiceSubscriptionsSubscriptionOutput() GetServiceSubscriptionsSubscriptionOutput
	ToGetServiceSubscriptionsSubscriptionOutputWithContext(context.Context) GetServiceSubscriptionsSubscriptionOutput
}

GetServiceSubscriptionsSubscriptionInput is an input type that accepts GetServiceSubscriptionsSubscriptionArgs and GetServiceSubscriptionsSubscriptionOutput values. You can construct a concrete instance of `GetServiceSubscriptionsSubscriptionInput` via:

GetServiceSubscriptionsSubscriptionArgs{...}

type GetServiceSubscriptionsSubscriptionOutput

type GetServiceSubscriptionsSubscriptionOutput struct{ *pulumi.OutputState }

func (GetServiceSubscriptionsSubscriptionOutput) CreateTime

The time when the subscription was created. This value is a UNIX timestamp representing the number of milliseconds that have elapsed since the epoch time January 1, 1970, 00:00:00 UTC.

func (GetServiceSubscriptionsSubscriptionOutput) ElementType

func (GetServiceSubscriptionsSubscriptionOutput) Endpoint

The endpoint to which the messages are pushed.

func (GetServiceSubscriptionsSubscriptionOutput) FilterTag

The tag that is used to filter messages. Only the messages that are attached with the specified tag can be pushed.

func (GetServiceSubscriptionsSubscriptionOutput) Id

The id of the Subscription.

func (GetServiceSubscriptionsSubscriptionOutput) LastModifyTime

The time when the subscription was last modified. This value is a UNIX timestamp representing the number of milliseconds that have elapsed since the epoch time January 1, 1970, 00:00:00 UTC.

func (GetServiceSubscriptionsSubscriptionOutput) NotifyContentFormat

The content format of the messages that are pushed to the endpoint.

func (GetServiceSubscriptionsSubscriptionOutput) NotifyStrategy

The retry policy that is applied if an error occurs when MNS pushes messages to the endpoint.

func (GetServiceSubscriptionsSubscriptionOutput) SubscriptionName

The name of the subscription.

func (GetServiceSubscriptionsSubscriptionOutput) SubscriptionUrl

The url of the subscription.

func (GetServiceSubscriptionsSubscriptionOutput) ToGetServiceSubscriptionsSubscriptionOutput

func (o GetServiceSubscriptionsSubscriptionOutput) ToGetServiceSubscriptionsSubscriptionOutput() GetServiceSubscriptionsSubscriptionOutput

func (GetServiceSubscriptionsSubscriptionOutput) ToGetServiceSubscriptionsSubscriptionOutputWithContext

func (o GetServiceSubscriptionsSubscriptionOutput) ToGetServiceSubscriptionsSubscriptionOutputWithContext(ctx context.Context) GetServiceSubscriptionsSubscriptionOutput

func (GetServiceSubscriptionsSubscriptionOutput) TopicName

The name of the topic.

func (GetServiceSubscriptionsSubscriptionOutput) TopicOwner

The account ID of the topic owner.

type GetServiceTopicsArgs

type GetServiceTopicsArgs struct {
	// A list of Topic IDs. Its element value is same as Topic Name.
	Ids []string `pulumi:"ids"`
	// A regex string to filter results by Topic name.
	NameRegex *string `pulumi:"nameRegex"`
	// File name where to save data source results (after running `pulumi preview`).
	OutputFile *string `pulumi:"outputFile"`
	PageNumber *int    `pulumi:"pageNumber"`
	PageSize   *int    `pulumi:"pageSize"`
	// The name of the topic.
	TopicName *string `pulumi:"topicName"`
}

A collection of arguments for invoking getServiceTopics.

type GetServiceTopicsOutputArgs

type GetServiceTopicsOutputArgs struct {
	// A list of Topic IDs. Its element value is same as Topic Name.
	Ids pulumi.StringArrayInput `pulumi:"ids"`
	// A regex string to filter results by Topic name.
	NameRegex pulumi.StringPtrInput `pulumi:"nameRegex"`
	// File name where to save data source results (after running `pulumi preview`).
	OutputFile pulumi.StringPtrInput `pulumi:"outputFile"`
	PageNumber pulumi.IntPtrInput    `pulumi:"pageNumber"`
	PageSize   pulumi.IntPtrInput    `pulumi:"pageSize"`
	// The name of the topic.
	TopicName pulumi.StringPtrInput `pulumi:"topicName"`
}

A collection of arguments for invoking getServiceTopics.

func (GetServiceTopicsOutputArgs) ElementType

func (GetServiceTopicsOutputArgs) ElementType() reflect.Type

type GetServiceTopicsResult

type GetServiceTopicsResult struct {
	// The provider-assigned unique ID for this managed resource.
	Id        string   `pulumi:"id"`
	Ids       []string `pulumi:"ids"`
	NameRegex *string  `pulumi:"nameRegex"`
	// A list of Topic names.
	Names      []string `pulumi:"names"`
	OutputFile *string  `pulumi:"outputFile"`
	PageNumber *int     `pulumi:"pageNumber"`
	PageSize   *int     `pulumi:"pageSize"`
	// The name of the topic.
	TopicName *string `pulumi:"topicName"`
	// A list of Topics. Each element contains the following attributes:
	Topics []GetServiceTopicsTopic `pulumi:"topics"`
}

A collection of values returned by getServiceTopics.

func GetServiceTopics

func GetServiceTopics(ctx *pulumi.Context, args *GetServiceTopicsArgs, opts ...pulumi.InvokeOption) (*GetServiceTopicsResult, error)

This data source provides the Message Notification Service Topics of the current Alibaba Cloud user.

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

## Example Usage

```go package main

import (

"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/message"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		ids, err := message.GetServiceTopics(ctx, &message.GetServiceTopicsArgs{
			Ids: []string{
				"example_id",
			},
		}, nil)
		if err != nil {
			return err
		}
		ctx.Export("topicId1", ids.Topics[0].Id)
		name, err := message.GetServiceTopics(ctx, &message.GetServiceTopicsArgs{
			TopicName: pulumi.StringRef("tf-example"),
		}, nil)
		if err != nil {
			return err
		}
		ctx.Export("topicId2", name.Topics[0].Id)
		return nil
	})
}

```

type GetServiceTopicsResultOutput

type GetServiceTopicsResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getServiceTopics.

func (GetServiceTopicsResultOutput) ElementType

func (GetServiceTopicsResultOutput) Id

The provider-assigned unique ID for this managed resource.

func (GetServiceTopicsResultOutput) Ids

func (GetServiceTopicsResultOutput) NameRegex

func (GetServiceTopicsResultOutput) Names

A list of Topic names.

func (GetServiceTopicsResultOutput) OutputFile

func (GetServiceTopicsResultOutput) PageNumber

func (GetServiceTopicsResultOutput) PageSize

func (GetServiceTopicsResultOutput) ToGetServiceTopicsResultOutput

func (o GetServiceTopicsResultOutput) ToGetServiceTopicsResultOutput() GetServiceTopicsResultOutput

func (GetServiceTopicsResultOutput) ToGetServiceTopicsResultOutputWithContext

func (o GetServiceTopicsResultOutput) ToGetServiceTopicsResultOutputWithContext(ctx context.Context) GetServiceTopicsResultOutput

func (GetServiceTopicsResultOutput) TopicName

The name of the topic.

func (GetServiceTopicsResultOutput) Topics

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

type GetServiceTopicsTopic

type GetServiceTopicsTopic struct {
	// The time when the topic was created. This value is a UNIX timestamp representing the number of milliseconds that have elapsed since the epoch time January 1, 1970, 00:00:00 UTC.
	CreateTime int `pulumi:"createTime"`
	// The id of the Topic. Its value is same as Topic Name.
	Id string `pulumi:"id"`
	// The time when the topic was last modified. This value is a UNIX timestamp representing the number of milliseconds that have elapsed since the epoch time January 1, 1970, 00:00:00 UTC.
	LastModifyTime int `pulumi:"lastModifyTime"`
	// Indicates whether the log management feature is enabled.
	LoggingEnabled bool `pulumi:"loggingEnabled"`
	// The maximum size of a message body that can be sent to the topic. Unit: bytes.
	MaxMessageSize int `pulumi:"maxMessageSize"`
	// The number of messages in the topic.
	MessageCount int `pulumi:"messageCount"`
	// The maximum period for which a message can be retained in the topic. A message that is sent to the topic can be retained for a specified period. After the specified period ends, the message is deleted no matter whether it is pushed to the specified endpoints. Unit: seconds.
	MessageRetentionPeriod int `pulumi:"messageRetentionPeriod"`
	// The inner url of the topic.
	TopicInnerUrl string `pulumi:"topicInnerUrl"`
	// The name of the topic.
	TopicName string `pulumi:"topicName"`
	// The url of the topic.
	TopicUrl string `pulumi:"topicUrl"`
}

type GetServiceTopicsTopicArgs

type GetServiceTopicsTopicArgs struct {
	// The time when the topic was created. This value is a UNIX timestamp representing the number of milliseconds that have elapsed since the epoch time January 1, 1970, 00:00:00 UTC.
	CreateTime pulumi.IntInput `pulumi:"createTime"`
	// The id of the Topic. Its value is same as Topic Name.
	Id pulumi.StringInput `pulumi:"id"`
	// The time when the topic was last modified. This value is a UNIX timestamp representing the number of milliseconds that have elapsed since the epoch time January 1, 1970, 00:00:00 UTC.
	LastModifyTime pulumi.IntInput `pulumi:"lastModifyTime"`
	// Indicates whether the log management feature is enabled.
	LoggingEnabled pulumi.BoolInput `pulumi:"loggingEnabled"`
	// The maximum size of a message body that can be sent to the topic. Unit: bytes.
	MaxMessageSize pulumi.IntInput `pulumi:"maxMessageSize"`
	// The number of messages in the topic.
	MessageCount pulumi.IntInput `pulumi:"messageCount"`
	// The maximum period for which a message can be retained in the topic. A message that is sent to the topic can be retained for a specified period. After the specified period ends, the message is deleted no matter whether it is pushed to the specified endpoints. Unit: seconds.
	MessageRetentionPeriod pulumi.IntInput `pulumi:"messageRetentionPeriod"`
	// The inner url of the topic.
	TopicInnerUrl pulumi.StringInput `pulumi:"topicInnerUrl"`
	// The name of the topic.
	TopicName pulumi.StringInput `pulumi:"topicName"`
	// The url of the topic.
	TopicUrl pulumi.StringInput `pulumi:"topicUrl"`
}

func (GetServiceTopicsTopicArgs) ElementType

func (GetServiceTopicsTopicArgs) ElementType() reflect.Type

func (GetServiceTopicsTopicArgs) ToGetServiceTopicsTopicOutput

func (i GetServiceTopicsTopicArgs) ToGetServiceTopicsTopicOutput() GetServiceTopicsTopicOutput

func (GetServiceTopicsTopicArgs) ToGetServiceTopicsTopicOutputWithContext

func (i GetServiceTopicsTopicArgs) ToGetServiceTopicsTopicOutputWithContext(ctx context.Context) GetServiceTopicsTopicOutput

type GetServiceTopicsTopicArray

type GetServiceTopicsTopicArray []GetServiceTopicsTopicInput

func (GetServiceTopicsTopicArray) ElementType

func (GetServiceTopicsTopicArray) ElementType() reflect.Type

func (GetServiceTopicsTopicArray) ToGetServiceTopicsTopicArrayOutput

func (i GetServiceTopicsTopicArray) ToGetServiceTopicsTopicArrayOutput() GetServiceTopicsTopicArrayOutput

func (GetServiceTopicsTopicArray) ToGetServiceTopicsTopicArrayOutputWithContext

func (i GetServiceTopicsTopicArray) ToGetServiceTopicsTopicArrayOutputWithContext(ctx context.Context) GetServiceTopicsTopicArrayOutput

type GetServiceTopicsTopicArrayInput

type GetServiceTopicsTopicArrayInput interface {
	pulumi.Input

	ToGetServiceTopicsTopicArrayOutput() GetServiceTopicsTopicArrayOutput
	ToGetServiceTopicsTopicArrayOutputWithContext(context.Context) GetServiceTopicsTopicArrayOutput
}

GetServiceTopicsTopicArrayInput is an input type that accepts GetServiceTopicsTopicArray and GetServiceTopicsTopicArrayOutput values. You can construct a concrete instance of `GetServiceTopicsTopicArrayInput` via:

GetServiceTopicsTopicArray{ GetServiceTopicsTopicArgs{...} }

type GetServiceTopicsTopicArrayOutput

type GetServiceTopicsTopicArrayOutput struct{ *pulumi.OutputState }

func (GetServiceTopicsTopicArrayOutput) ElementType

func (GetServiceTopicsTopicArrayOutput) Index

func (GetServiceTopicsTopicArrayOutput) ToGetServiceTopicsTopicArrayOutput

func (o GetServiceTopicsTopicArrayOutput) ToGetServiceTopicsTopicArrayOutput() GetServiceTopicsTopicArrayOutput

func (GetServiceTopicsTopicArrayOutput) ToGetServiceTopicsTopicArrayOutputWithContext

func (o GetServiceTopicsTopicArrayOutput) ToGetServiceTopicsTopicArrayOutputWithContext(ctx context.Context) GetServiceTopicsTopicArrayOutput

type GetServiceTopicsTopicInput

type GetServiceTopicsTopicInput interface {
	pulumi.Input

	ToGetServiceTopicsTopicOutput() GetServiceTopicsTopicOutput
	ToGetServiceTopicsTopicOutputWithContext(context.Context) GetServiceTopicsTopicOutput
}

GetServiceTopicsTopicInput is an input type that accepts GetServiceTopicsTopicArgs and GetServiceTopicsTopicOutput values. You can construct a concrete instance of `GetServiceTopicsTopicInput` via:

GetServiceTopicsTopicArgs{...}

type GetServiceTopicsTopicOutput

type GetServiceTopicsTopicOutput struct{ *pulumi.OutputState }

func (GetServiceTopicsTopicOutput) CreateTime

The time when the topic was created. This value is a UNIX timestamp representing the number of milliseconds that have elapsed since the epoch time January 1, 1970, 00:00:00 UTC.

func (GetServiceTopicsTopicOutput) ElementType

func (GetServiceTopicsTopicOutput) Id

The id of the Topic. Its value is same as Topic Name.

func (GetServiceTopicsTopicOutput) LastModifyTime

func (o GetServiceTopicsTopicOutput) LastModifyTime() pulumi.IntOutput

The time when the topic was last modified. This value is a UNIX timestamp representing the number of milliseconds that have elapsed since the epoch time January 1, 1970, 00:00:00 UTC.

func (GetServiceTopicsTopicOutput) LoggingEnabled

func (o GetServiceTopicsTopicOutput) LoggingEnabled() pulumi.BoolOutput

Indicates whether the log management feature is enabled.

func (GetServiceTopicsTopicOutput) MaxMessageSize

func (o GetServiceTopicsTopicOutput) MaxMessageSize() pulumi.IntOutput

The maximum size of a message body that can be sent to the topic. Unit: bytes.

func (GetServiceTopicsTopicOutput) MessageCount

func (o GetServiceTopicsTopicOutput) MessageCount() pulumi.IntOutput

The number of messages in the topic.

func (GetServiceTopicsTopicOutput) MessageRetentionPeriod

func (o GetServiceTopicsTopicOutput) MessageRetentionPeriod() pulumi.IntOutput

The maximum period for which a message can be retained in the topic. A message that is sent to the topic can be retained for a specified period. After the specified period ends, the message is deleted no matter whether it is pushed to the specified endpoints. Unit: seconds.

func (GetServiceTopicsTopicOutput) ToGetServiceTopicsTopicOutput

func (o GetServiceTopicsTopicOutput) ToGetServiceTopicsTopicOutput() GetServiceTopicsTopicOutput

func (GetServiceTopicsTopicOutput) ToGetServiceTopicsTopicOutputWithContext

func (o GetServiceTopicsTopicOutput) ToGetServiceTopicsTopicOutputWithContext(ctx context.Context) GetServiceTopicsTopicOutput

func (GetServiceTopicsTopicOutput) TopicInnerUrl

The inner url of the topic.

func (GetServiceTopicsTopicOutput) TopicName

The name of the topic.

func (GetServiceTopicsTopicOutput) TopicUrl

The url of the topic.

type ServiceQueue

type ServiceQueue struct {
	pulumi.CustomResourceState

	// The delay period after which a message sent to the queue can be consumed. Unit: seconds. Valid values: 0-604800 seconds. Default value: 0.
	DelaySeconds pulumi.IntOutput `pulumi:"delaySeconds"`
	// Specifies whether to enable the log management feature. Default value: false. Valid values:
	LoggingEnabled pulumi.BoolPtrOutput `pulumi:"loggingEnabled"`
	// The maximum size of a message body that can be sent to the queue. Unit: bytes. Valid value range: 1024-65536. Default value: 65536.
	MaximumMessageSize pulumi.IntOutput `pulumi:"maximumMessageSize"`
	// The maximum period for which a message can be retained in the queue. After the specified period, the message is deleted no matter whether the message is consumed. Unit: seconds. Valid values: 60-604800. Default value: 345600.
	MessageRetentionPeriod pulumi.IntOutput `pulumi:"messageRetentionPeriod"`
	// The maximum period for which a ReceiveMessage request waits if no message is available in the queue. Unit: seconds. Valid values: 0-30. Default value: 0.
	PollingWaitSeconds pulumi.IntOutput `pulumi:"pollingWaitSeconds"`
	// 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 120 characters.
	QueueName pulumi.StringOutput `pulumi:"queueName"`
	// The invisibility period for which the received message remains the Inactive state. Unit: seconds. Valid values: 1-43200. Default value: 30.
	VisibilityTimeout pulumi.IntOutput `pulumi:"visibilityTimeout"`
}

Provides a Message Notification Service Queue resource.

For information about Message Notification Service Queue and how to use it, see [What is Queue](https://www.alibabacloud.com/help/en/message-service/latest/createqueue).

> **NOTE:** Available since v1.188.0.

## Example Usage

Basic Usage

```go package main

import (

"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/message"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi/config"

)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		cfg := config.New(ctx, "")
		name := "tf-example"
		if param := cfg.Get("name"); param != "" {
			name = param
		}
		_, err := message.NewServiceQueue(ctx, "queue", &message.ServiceQueueArgs{
			QueueName:              pulumi.String(name),
			DelaySeconds:           pulumi.Int(60478),
			MaximumMessageSize:     pulumi.Int(12357),
			MessageRetentionPeriod: pulumi.Int(256000),
			VisibilityTimeout:      pulumi.Int(30),
			PollingWaitSeconds:     pulumi.Int(3),
			LoggingEnabled:         pulumi.Bool(true),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

Message Notification Service Queue can be imported using the id or queue_name, e.g.

```sh $ pulumi import alicloud:message/serviceQueue:ServiceQueue example <queue_name> ```

func GetServiceQueue

func GetServiceQueue(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *ServiceQueueState, opts ...pulumi.ResourceOption) (*ServiceQueue, error)

GetServiceQueue gets an existing ServiceQueue 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 NewServiceQueue

func NewServiceQueue(ctx *pulumi.Context,
	name string, args *ServiceQueueArgs, opts ...pulumi.ResourceOption) (*ServiceQueue, error)

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

func (*ServiceQueue) ElementType

func (*ServiceQueue) ElementType() reflect.Type

func (*ServiceQueue) ToServiceQueueOutput

func (i *ServiceQueue) ToServiceQueueOutput() ServiceQueueOutput

func (*ServiceQueue) ToServiceQueueOutputWithContext

func (i *ServiceQueue) ToServiceQueueOutputWithContext(ctx context.Context) ServiceQueueOutput

type ServiceQueueArgs

type ServiceQueueArgs struct {
	// The delay period after which a message sent to the queue can be consumed. Unit: seconds. Valid values: 0-604800 seconds. Default value: 0.
	DelaySeconds pulumi.IntPtrInput
	// Specifies whether to enable the log management feature. Default value: false. Valid values:
	LoggingEnabled pulumi.BoolPtrInput
	// The maximum size of a message body that can be sent to the queue. Unit: bytes. Valid value range: 1024-65536. Default value: 65536.
	MaximumMessageSize pulumi.IntPtrInput
	// The maximum period for which a message can be retained in the queue. After the specified period, the message is deleted no matter whether the message is consumed. Unit: seconds. Valid values: 60-604800. Default value: 345600.
	MessageRetentionPeriod pulumi.IntPtrInput
	// The maximum period for which a ReceiveMessage request waits if no message is available in the queue. Unit: seconds. Valid values: 0-30. Default value: 0.
	PollingWaitSeconds 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 120 characters.
	QueueName pulumi.StringInput
	// The invisibility period for which the received message remains the Inactive state. Unit: seconds. Valid values: 1-43200. Default value: 30.
	VisibilityTimeout pulumi.IntPtrInput
}

The set of arguments for constructing a ServiceQueue resource.

func (ServiceQueueArgs) ElementType

func (ServiceQueueArgs) ElementType() reflect.Type

type ServiceQueueArray

type ServiceQueueArray []ServiceQueueInput

func (ServiceQueueArray) ElementType

func (ServiceQueueArray) ElementType() reflect.Type

func (ServiceQueueArray) ToServiceQueueArrayOutput

func (i ServiceQueueArray) ToServiceQueueArrayOutput() ServiceQueueArrayOutput

func (ServiceQueueArray) ToServiceQueueArrayOutputWithContext

func (i ServiceQueueArray) ToServiceQueueArrayOutputWithContext(ctx context.Context) ServiceQueueArrayOutput

type ServiceQueueArrayInput

type ServiceQueueArrayInput interface {
	pulumi.Input

	ToServiceQueueArrayOutput() ServiceQueueArrayOutput
	ToServiceQueueArrayOutputWithContext(context.Context) ServiceQueueArrayOutput
}

ServiceQueueArrayInput is an input type that accepts ServiceQueueArray and ServiceQueueArrayOutput values. You can construct a concrete instance of `ServiceQueueArrayInput` via:

ServiceQueueArray{ ServiceQueueArgs{...} }

type ServiceQueueArrayOutput

type ServiceQueueArrayOutput struct{ *pulumi.OutputState }

func (ServiceQueueArrayOutput) ElementType

func (ServiceQueueArrayOutput) ElementType() reflect.Type

func (ServiceQueueArrayOutput) Index

func (ServiceQueueArrayOutput) ToServiceQueueArrayOutput

func (o ServiceQueueArrayOutput) ToServiceQueueArrayOutput() ServiceQueueArrayOutput

func (ServiceQueueArrayOutput) ToServiceQueueArrayOutputWithContext

func (o ServiceQueueArrayOutput) ToServiceQueueArrayOutputWithContext(ctx context.Context) ServiceQueueArrayOutput

type ServiceQueueInput

type ServiceQueueInput interface {
	pulumi.Input

	ToServiceQueueOutput() ServiceQueueOutput
	ToServiceQueueOutputWithContext(ctx context.Context) ServiceQueueOutput
}

type ServiceQueueMap

type ServiceQueueMap map[string]ServiceQueueInput

func (ServiceQueueMap) ElementType

func (ServiceQueueMap) ElementType() reflect.Type

func (ServiceQueueMap) ToServiceQueueMapOutput

func (i ServiceQueueMap) ToServiceQueueMapOutput() ServiceQueueMapOutput

func (ServiceQueueMap) ToServiceQueueMapOutputWithContext

func (i ServiceQueueMap) ToServiceQueueMapOutputWithContext(ctx context.Context) ServiceQueueMapOutput

type ServiceQueueMapInput

type ServiceQueueMapInput interface {
	pulumi.Input

	ToServiceQueueMapOutput() ServiceQueueMapOutput
	ToServiceQueueMapOutputWithContext(context.Context) ServiceQueueMapOutput
}

ServiceQueueMapInput is an input type that accepts ServiceQueueMap and ServiceQueueMapOutput values. You can construct a concrete instance of `ServiceQueueMapInput` via:

ServiceQueueMap{ "key": ServiceQueueArgs{...} }

type ServiceQueueMapOutput

type ServiceQueueMapOutput struct{ *pulumi.OutputState }

func (ServiceQueueMapOutput) ElementType

func (ServiceQueueMapOutput) ElementType() reflect.Type

func (ServiceQueueMapOutput) MapIndex

func (ServiceQueueMapOutput) ToServiceQueueMapOutput

func (o ServiceQueueMapOutput) ToServiceQueueMapOutput() ServiceQueueMapOutput

func (ServiceQueueMapOutput) ToServiceQueueMapOutputWithContext

func (o ServiceQueueMapOutput) ToServiceQueueMapOutputWithContext(ctx context.Context) ServiceQueueMapOutput

type ServiceQueueOutput

type ServiceQueueOutput struct{ *pulumi.OutputState }

func (ServiceQueueOutput) DelaySeconds

func (o ServiceQueueOutput) DelaySeconds() pulumi.IntOutput

The delay period after which a message sent to the queue can be consumed. Unit: seconds. Valid values: 0-604800 seconds. Default value: 0.

func (ServiceQueueOutput) ElementType

func (ServiceQueueOutput) ElementType() reflect.Type

func (ServiceQueueOutput) LoggingEnabled

func (o ServiceQueueOutput) LoggingEnabled() pulumi.BoolPtrOutput

Specifies whether to enable the log management feature. Default value: false. Valid values:

func (ServiceQueueOutput) MaximumMessageSize

func (o ServiceQueueOutput) MaximumMessageSize() pulumi.IntOutput

The maximum size of a message body that can be sent to the queue. Unit: bytes. Valid value range: 1024-65536. Default value: 65536.

func (ServiceQueueOutput) MessageRetentionPeriod

func (o ServiceQueueOutput) MessageRetentionPeriod() pulumi.IntOutput

The maximum period for which a message can be retained in the queue. After the specified period, the message is deleted no matter whether the message is consumed. Unit: seconds. Valid values: 60-604800. Default value: 345600.

func (ServiceQueueOutput) PollingWaitSeconds

func (o ServiceQueueOutput) PollingWaitSeconds() pulumi.IntOutput

The maximum period for which a ReceiveMessage request waits if no message is available in the queue. Unit: seconds. Valid values: 0-30. Default value: 0.

func (ServiceQueueOutput) QueueName

func (o ServiceQueueOutput) QueueName() 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 120 characters.

func (ServiceQueueOutput) ToServiceQueueOutput

func (o ServiceQueueOutput) ToServiceQueueOutput() ServiceQueueOutput

func (ServiceQueueOutput) ToServiceQueueOutputWithContext

func (o ServiceQueueOutput) ToServiceQueueOutputWithContext(ctx context.Context) ServiceQueueOutput

func (ServiceQueueOutput) VisibilityTimeout

func (o ServiceQueueOutput) VisibilityTimeout() pulumi.IntOutput

The invisibility period for which the received message remains the Inactive state. Unit: seconds. Valid values: 1-43200. Default value: 30.

type ServiceQueueState

type ServiceQueueState struct {
	// The delay period after which a message sent to the queue can be consumed. Unit: seconds. Valid values: 0-604800 seconds. Default value: 0.
	DelaySeconds pulumi.IntPtrInput
	// Specifies whether to enable the log management feature. Default value: false. Valid values:
	LoggingEnabled pulumi.BoolPtrInput
	// The maximum size of a message body that can be sent to the queue. Unit: bytes. Valid value range: 1024-65536. Default value: 65536.
	MaximumMessageSize pulumi.IntPtrInput
	// The maximum period for which a message can be retained in the queue. After the specified period, the message is deleted no matter whether the message is consumed. Unit: seconds. Valid values: 60-604800. Default value: 345600.
	MessageRetentionPeriod pulumi.IntPtrInput
	// The maximum period for which a ReceiveMessage request waits if no message is available in the queue. Unit: seconds. Valid values: 0-30. Default value: 0.
	PollingWaitSeconds 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 120 characters.
	QueueName pulumi.StringPtrInput
	// The invisibility period for which the received message remains the Inactive state. Unit: seconds. Valid values: 1-43200. Default value: 30.
	VisibilityTimeout pulumi.IntPtrInput
}

func (ServiceQueueState) ElementType

func (ServiceQueueState) ElementType() reflect.Type

type ServiceSubscription

type ServiceSubscription 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 tag that is used to filter messages. Only the messages that have the same tag can be pushed. A tag is a string that can be up to 16 characters in length. By default, no tag is specified to filter messages.
	FilterTag pulumi.StringPtrOutput `pulumi:"filterTag"`
	// The NotifyContentFormat attribute of Subscription. This attribute specifies the content format of the messages pushed to users. Valid values: `XML`, `JSON` and `SIMPLIFIED`. Default value: `XML`.
	NotifyContentFormat pulumi.StringOutput `pulumi:"notifyContentFormat"`
	// The NotifyStrategy attribute of Subscription. This attribute specifies the retry strategy when message sending fails. Default value: `BACKOFF_RETRY`. Valid values:
	NotifyStrategy pulumi.StringOutput `pulumi:"notifyStrategy"`
	// The Push type of Subscription. The Valid values: `http`, `queue`, `mpush`, `alisms` and `email`.
	PushType pulumi.StringOutput `pulumi:"pushType"`
	// 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 255 characters.
	SubscriptionName pulumi.StringOutput `pulumi:"subscriptionName"`
	// 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 255 characters.
	TopicName pulumi.StringOutput `pulumi:"topicName"`
}

Provides a Message Notification Service Subscription resource.

For information about Message Notification Service Subscription and how to use it, see [What is Subscription](https://www.alibabacloud.com/help/en/message-service/latest/subscribe-1).

> **NOTE:** Available since v1.188.0.

## Example Usage

Basic Usage

```go package main

import (

"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/message"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi/config"

)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		cfg := config.New(ctx, "")
		name := "tf-example"
		if param := cfg.Get("name"); param != "" {
			name = param
		}
		_, err := message.NewServiceTopic(ctx, "default", &message.ServiceTopicArgs{
			TopicName:      pulumi.String(name),
			MaxMessageSize: pulumi.Int(12357),
			LoggingEnabled: pulumi.Bool(true),
		})
		if err != nil {
			return err
		}
		_, err = message.NewServiceSubscription(ctx, "default", &message.ServiceSubscriptionArgs{
			TopicName:           _default.TopicName,
			SubscriptionName:    pulumi.String(name),
			Endpoint:            pulumi.String("http://example.com"),
			PushType:            pulumi.String("http"),
			FilterTag:           pulumi.String("tf-example"),
			NotifyContentFormat: pulumi.String("XML"),
			NotifyStrategy:      pulumi.String("BACKOFF_RETRY"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

Message Notification Service Subscription can be imported using the id, e.g.

```sh $ pulumi import alicloud:message/serviceSubscription:ServiceSubscription example <topic_name>:<subscription_name> ```

func GetServiceSubscription

func GetServiceSubscription(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *ServiceSubscriptionState, opts ...pulumi.ResourceOption) (*ServiceSubscription, error)

GetServiceSubscription gets an existing ServiceSubscription 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 NewServiceSubscription

func NewServiceSubscription(ctx *pulumi.Context,
	name string, args *ServiceSubscriptionArgs, opts ...pulumi.ResourceOption) (*ServiceSubscription, error)

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

func (*ServiceSubscription) ElementType

func (*ServiceSubscription) ElementType() reflect.Type

func (*ServiceSubscription) ToServiceSubscriptionOutput

func (i *ServiceSubscription) ToServiceSubscriptionOutput() ServiceSubscriptionOutput

func (*ServiceSubscription) ToServiceSubscriptionOutputWithContext

func (i *ServiceSubscription) ToServiceSubscriptionOutputWithContext(ctx context.Context) ServiceSubscriptionOutput

type ServiceSubscriptionArgs

type ServiceSubscriptionArgs 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 tag that is used to filter messages. Only the messages that have the same tag can be pushed. A tag is a string that can be up to 16 characters in length. By default, no tag is specified to filter messages.
	FilterTag pulumi.StringPtrInput
	// The NotifyContentFormat attribute of Subscription. This attribute specifies the content format of the messages pushed to users. Valid values: `XML`, `JSON` and `SIMPLIFIED`. Default value: `XML`.
	NotifyContentFormat pulumi.StringPtrInput
	// The NotifyStrategy attribute of Subscription. This attribute specifies the retry strategy when message sending fails. Default value: `BACKOFF_RETRY`. Valid values:
	NotifyStrategy pulumi.StringPtrInput
	// The Push type of Subscription. The Valid values: `http`, `queue`, `mpush`, `alisms` and `email`.
	PushType pulumi.StringInput
	// 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 255 characters.
	SubscriptionName pulumi.StringInput
	// 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 255 characters.
	TopicName pulumi.StringInput
}

The set of arguments for constructing a ServiceSubscription resource.

func (ServiceSubscriptionArgs) ElementType

func (ServiceSubscriptionArgs) ElementType() reflect.Type

type ServiceSubscriptionArray

type ServiceSubscriptionArray []ServiceSubscriptionInput

func (ServiceSubscriptionArray) ElementType

func (ServiceSubscriptionArray) ElementType() reflect.Type

func (ServiceSubscriptionArray) ToServiceSubscriptionArrayOutput

func (i ServiceSubscriptionArray) ToServiceSubscriptionArrayOutput() ServiceSubscriptionArrayOutput

func (ServiceSubscriptionArray) ToServiceSubscriptionArrayOutputWithContext

func (i ServiceSubscriptionArray) ToServiceSubscriptionArrayOutputWithContext(ctx context.Context) ServiceSubscriptionArrayOutput

type ServiceSubscriptionArrayInput

type ServiceSubscriptionArrayInput interface {
	pulumi.Input

	ToServiceSubscriptionArrayOutput() ServiceSubscriptionArrayOutput
	ToServiceSubscriptionArrayOutputWithContext(context.Context) ServiceSubscriptionArrayOutput
}

ServiceSubscriptionArrayInput is an input type that accepts ServiceSubscriptionArray and ServiceSubscriptionArrayOutput values. You can construct a concrete instance of `ServiceSubscriptionArrayInput` via:

ServiceSubscriptionArray{ ServiceSubscriptionArgs{...} }

type ServiceSubscriptionArrayOutput

type ServiceSubscriptionArrayOutput struct{ *pulumi.OutputState }

func (ServiceSubscriptionArrayOutput) ElementType

func (ServiceSubscriptionArrayOutput) Index

func (ServiceSubscriptionArrayOutput) ToServiceSubscriptionArrayOutput

func (o ServiceSubscriptionArrayOutput) ToServiceSubscriptionArrayOutput() ServiceSubscriptionArrayOutput

func (ServiceSubscriptionArrayOutput) ToServiceSubscriptionArrayOutputWithContext

func (o ServiceSubscriptionArrayOutput) ToServiceSubscriptionArrayOutputWithContext(ctx context.Context) ServiceSubscriptionArrayOutput

type ServiceSubscriptionInput

type ServiceSubscriptionInput interface {
	pulumi.Input

	ToServiceSubscriptionOutput() ServiceSubscriptionOutput
	ToServiceSubscriptionOutputWithContext(ctx context.Context) ServiceSubscriptionOutput
}

type ServiceSubscriptionMap

type ServiceSubscriptionMap map[string]ServiceSubscriptionInput

func (ServiceSubscriptionMap) ElementType

func (ServiceSubscriptionMap) ElementType() reflect.Type

func (ServiceSubscriptionMap) ToServiceSubscriptionMapOutput

func (i ServiceSubscriptionMap) ToServiceSubscriptionMapOutput() ServiceSubscriptionMapOutput

func (ServiceSubscriptionMap) ToServiceSubscriptionMapOutputWithContext

func (i ServiceSubscriptionMap) ToServiceSubscriptionMapOutputWithContext(ctx context.Context) ServiceSubscriptionMapOutput

type ServiceSubscriptionMapInput

type ServiceSubscriptionMapInput interface {
	pulumi.Input

	ToServiceSubscriptionMapOutput() ServiceSubscriptionMapOutput
	ToServiceSubscriptionMapOutputWithContext(context.Context) ServiceSubscriptionMapOutput
}

ServiceSubscriptionMapInput is an input type that accepts ServiceSubscriptionMap and ServiceSubscriptionMapOutput values. You can construct a concrete instance of `ServiceSubscriptionMapInput` via:

ServiceSubscriptionMap{ "key": ServiceSubscriptionArgs{...} }

type ServiceSubscriptionMapOutput

type ServiceSubscriptionMapOutput struct{ *pulumi.OutputState }

func (ServiceSubscriptionMapOutput) ElementType

func (ServiceSubscriptionMapOutput) MapIndex

func (ServiceSubscriptionMapOutput) ToServiceSubscriptionMapOutput

func (o ServiceSubscriptionMapOutput) ToServiceSubscriptionMapOutput() ServiceSubscriptionMapOutput

func (ServiceSubscriptionMapOutput) ToServiceSubscriptionMapOutputWithContext

func (o ServiceSubscriptionMapOutput) ToServiceSubscriptionMapOutputWithContext(ctx context.Context) ServiceSubscriptionMapOutput

type ServiceSubscriptionOutput

type ServiceSubscriptionOutput struct{ *pulumi.OutputState }

func (ServiceSubscriptionOutput) ElementType

func (ServiceSubscriptionOutput) ElementType() reflect.Type

func (ServiceSubscriptionOutput) Endpoint

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 (ServiceSubscriptionOutput) FilterTag

The tag that is used to filter messages. Only the messages that have the same tag can be pushed. A tag is a string that can be up to 16 characters in length. By default, no tag is specified to filter messages.

func (ServiceSubscriptionOutput) NotifyContentFormat

func (o ServiceSubscriptionOutput) NotifyContentFormat() pulumi.StringOutput

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

func (ServiceSubscriptionOutput) NotifyStrategy

func (o ServiceSubscriptionOutput) NotifyStrategy() pulumi.StringOutput

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

func (ServiceSubscriptionOutput) PushType

The Push type of Subscription. The Valid values: `http`, `queue`, `mpush`, `alisms` and `email`.

func (ServiceSubscriptionOutput) SubscriptionName

func (o ServiceSubscriptionOutput) SubscriptionName() 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 255 characters.

func (ServiceSubscriptionOutput) ToServiceSubscriptionOutput

func (o ServiceSubscriptionOutput) ToServiceSubscriptionOutput() ServiceSubscriptionOutput

func (ServiceSubscriptionOutput) ToServiceSubscriptionOutputWithContext

func (o ServiceSubscriptionOutput) ToServiceSubscriptionOutputWithContext(ctx context.Context) ServiceSubscriptionOutput

func (ServiceSubscriptionOutput) TopicName

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 255 characters.

type ServiceSubscriptionState

type ServiceSubscriptionState 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 tag that is used to filter messages. Only the messages that have the same tag can be pushed. A tag is a string that can be up to 16 characters in length. By default, no tag is specified to filter messages.
	FilterTag pulumi.StringPtrInput
	// The NotifyContentFormat attribute of Subscription. This attribute specifies the content format of the messages pushed to users. Valid values: `XML`, `JSON` and `SIMPLIFIED`. Default value: `XML`.
	NotifyContentFormat pulumi.StringPtrInput
	// The NotifyStrategy attribute of Subscription. This attribute specifies the retry strategy when message sending fails. Default value: `BACKOFF_RETRY`. Valid values:
	NotifyStrategy pulumi.StringPtrInput
	// The Push type of Subscription. The Valid values: `http`, `queue`, `mpush`, `alisms` and `email`.
	PushType 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 255 characters.
	SubscriptionName 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 255 characters.
	TopicName pulumi.StringPtrInput
}

func (ServiceSubscriptionState) ElementType

func (ServiceSubscriptionState) ElementType() reflect.Type

type ServiceTopic

type ServiceTopic struct {
	pulumi.CustomResourceState

	// Specifies whether to enable the log management feature. Default value: false. Valid values:
	LoggingEnabled pulumi.BoolPtrOutput `pulumi:"loggingEnabled"`
	// The maximum size of a message body that can be sent to the topic. Unit: bytes. Valid values: 1024-65536. Default value: 65536.
	MaxMessageSize pulumi.IntOutput `pulumi:"maxMessageSize"`
	// 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 255 characters.
	TopicName pulumi.StringOutput `pulumi:"topicName"`
}

Provides a Message Notification Service Topic resource.

For information about Message Notification Service Topic and how to use it, see [What is Topic](https://www.alibabacloud.com/help/en/message-service/latest/createtopic).

> **NOTE:** Available since v1.188.0.

## Example Usage

Basic Usage

```go package main

import (

"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/message"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi/config"

)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		cfg := config.New(ctx, "")
		name := "tf-example"
		if param := cfg.Get("name"); param != "" {
			name = param
		}
		_, err := message.NewServiceTopic(ctx, "default", &message.ServiceTopicArgs{
			TopicName:      pulumi.String(name),
			MaxMessageSize: pulumi.Int(12357),
			LoggingEnabled: pulumi.Bool(true),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

Message Notification Service Topic can be imported using the id or topic_name, e.g.

```sh $ pulumi import alicloud:message/serviceTopic:ServiceTopic example <topic_name> ```

func GetServiceTopic

func GetServiceTopic(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *ServiceTopicState, opts ...pulumi.ResourceOption) (*ServiceTopic, error)

GetServiceTopic gets an existing ServiceTopic 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 NewServiceTopic

func NewServiceTopic(ctx *pulumi.Context,
	name string, args *ServiceTopicArgs, opts ...pulumi.ResourceOption) (*ServiceTopic, error)

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

func (*ServiceTopic) ElementType

func (*ServiceTopic) ElementType() reflect.Type

func (*ServiceTopic) ToServiceTopicOutput

func (i *ServiceTopic) ToServiceTopicOutput() ServiceTopicOutput

func (*ServiceTopic) ToServiceTopicOutputWithContext

func (i *ServiceTopic) ToServiceTopicOutputWithContext(ctx context.Context) ServiceTopicOutput

type ServiceTopicArgs

type ServiceTopicArgs struct {
	// Specifies whether to enable the log management feature. Default value: false. Valid values:
	LoggingEnabled pulumi.BoolPtrInput
	// The maximum size of a message body that can be sent to the topic. Unit: bytes. Valid values: 1024-65536. Default value: 65536.
	MaxMessageSize 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 255 characters.
	TopicName pulumi.StringInput
}

The set of arguments for constructing a ServiceTopic resource.

func (ServiceTopicArgs) ElementType

func (ServiceTopicArgs) ElementType() reflect.Type

type ServiceTopicArray

type ServiceTopicArray []ServiceTopicInput

func (ServiceTopicArray) ElementType

func (ServiceTopicArray) ElementType() reflect.Type

func (ServiceTopicArray) ToServiceTopicArrayOutput

func (i ServiceTopicArray) ToServiceTopicArrayOutput() ServiceTopicArrayOutput

func (ServiceTopicArray) ToServiceTopicArrayOutputWithContext

func (i ServiceTopicArray) ToServiceTopicArrayOutputWithContext(ctx context.Context) ServiceTopicArrayOutput

type ServiceTopicArrayInput

type ServiceTopicArrayInput interface {
	pulumi.Input

	ToServiceTopicArrayOutput() ServiceTopicArrayOutput
	ToServiceTopicArrayOutputWithContext(context.Context) ServiceTopicArrayOutput
}

ServiceTopicArrayInput is an input type that accepts ServiceTopicArray and ServiceTopicArrayOutput values. You can construct a concrete instance of `ServiceTopicArrayInput` via:

ServiceTopicArray{ ServiceTopicArgs{...} }

type ServiceTopicArrayOutput

type ServiceTopicArrayOutput struct{ *pulumi.OutputState }

func (ServiceTopicArrayOutput) ElementType

func (ServiceTopicArrayOutput) ElementType() reflect.Type

func (ServiceTopicArrayOutput) Index

func (ServiceTopicArrayOutput) ToServiceTopicArrayOutput

func (o ServiceTopicArrayOutput) ToServiceTopicArrayOutput() ServiceTopicArrayOutput

func (ServiceTopicArrayOutput) ToServiceTopicArrayOutputWithContext

func (o ServiceTopicArrayOutput) ToServiceTopicArrayOutputWithContext(ctx context.Context) ServiceTopicArrayOutput

type ServiceTopicInput

type ServiceTopicInput interface {
	pulumi.Input

	ToServiceTopicOutput() ServiceTopicOutput
	ToServiceTopicOutputWithContext(ctx context.Context) ServiceTopicOutput
}

type ServiceTopicMap

type ServiceTopicMap map[string]ServiceTopicInput

func (ServiceTopicMap) ElementType

func (ServiceTopicMap) ElementType() reflect.Type

func (ServiceTopicMap) ToServiceTopicMapOutput

func (i ServiceTopicMap) ToServiceTopicMapOutput() ServiceTopicMapOutput

func (ServiceTopicMap) ToServiceTopicMapOutputWithContext

func (i ServiceTopicMap) ToServiceTopicMapOutputWithContext(ctx context.Context) ServiceTopicMapOutput

type ServiceTopicMapInput

type ServiceTopicMapInput interface {
	pulumi.Input

	ToServiceTopicMapOutput() ServiceTopicMapOutput
	ToServiceTopicMapOutputWithContext(context.Context) ServiceTopicMapOutput
}

ServiceTopicMapInput is an input type that accepts ServiceTopicMap and ServiceTopicMapOutput values. You can construct a concrete instance of `ServiceTopicMapInput` via:

ServiceTopicMap{ "key": ServiceTopicArgs{...} }

type ServiceTopicMapOutput

type ServiceTopicMapOutput struct{ *pulumi.OutputState }

func (ServiceTopicMapOutput) ElementType

func (ServiceTopicMapOutput) ElementType() reflect.Type

func (ServiceTopicMapOutput) MapIndex

func (ServiceTopicMapOutput) ToServiceTopicMapOutput

func (o ServiceTopicMapOutput) ToServiceTopicMapOutput() ServiceTopicMapOutput

func (ServiceTopicMapOutput) ToServiceTopicMapOutputWithContext

func (o ServiceTopicMapOutput) ToServiceTopicMapOutputWithContext(ctx context.Context) ServiceTopicMapOutput

type ServiceTopicOutput

type ServiceTopicOutput struct{ *pulumi.OutputState }

func (ServiceTopicOutput) ElementType

func (ServiceTopicOutput) ElementType() reflect.Type

func (ServiceTopicOutput) LoggingEnabled

func (o ServiceTopicOutput) LoggingEnabled() pulumi.BoolPtrOutput

Specifies whether to enable the log management feature. Default value: false. Valid values:

func (ServiceTopicOutput) MaxMessageSize

func (o ServiceTopicOutput) MaxMessageSize() pulumi.IntOutput

The maximum size of a message body that can be sent to the topic. Unit: bytes. Valid values: 1024-65536. Default value: 65536.

func (ServiceTopicOutput) ToServiceTopicOutput

func (o ServiceTopicOutput) ToServiceTopicOutput() ServiceTopicOutput

func (ServiceTopicOutput) ToServiceTopicOutputWithContext

func (o ServiceTopicOutput) ToServiceTopicOutputWithContext(ctx context.Context) ServiceTopicOutput

func (ServiceTopicOutput) TopicName

func (o ServiceTopicOutput) 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 255 characters.

type ServiceTopicState

type ServiceTopicState struct {
	// Specifies whether to enable the log management feature. Default value: false. Valid values:
	LoggingEnabled pulumi.BoolPtrInput
	// The maximum size of a message body that can be sent to the topic. Unit: bytes. Valid values: 1024-65536. Default value: 65536.
	MaxMessageSize 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 255 characters.
	TopicName pulumi.StringPtrInput
}

func (ServiceTopicState) ElementType

func (ServiceTopicState) ElementType() reflect.Type

Jump to

Keyboard shortcuts

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