Merge branch feature/support_logEnable into release/1.0.8

Title: feat: support configuring the logEnable parameter for queues during creation and attribute setting.

#### 需求实现
实现了在 Go SDK 中支持队列（Queue）的 `LoggingEnabled` 参数配置，以满足客户的请求。

#### 代码实现
通过添加 `LoggingEnabled` 字段到相关结构体，并引入选项模式来设置队列属性，从而支持创建和更新队列时配置日志记录功能。
Link: https://code.alibaba-inc.com/messaging/aliyun-mns-go-sdk/codereview/20337410

Author: Kayne666

CHANGELOG.md

@@ -1,5 +1,8 @@
 # Change log
 
+## 1.0.8
+- Support configuring the logEnable parameter for queues during creation and attribute setting.
+
 ## 1.0.7
 - Add an example of base64 encoding and decoding to queue_example.go.
 - Add support for dynamic credentials.

README-CN.md

@@ -1,6 +1,6 @@
 # Aliyun MNS Go SDK
 
-[![Github version](https://badgen.net/badge/color/1.0.7/green?label=version)](https://badgen.net/badge/color/1.0.7/green?label=version)
+[![Github version](https://badgen.net/badge/color/1.0.8/green?label=version)](https://badgen.net/badge/color/1.0.8/green?label=version)
 
 Aliyun MNS Go SDK 是 MNS 在 Go 编译语言的官方 SDK
 

README.md

@@ -1,6 +1,6 @@
 # Aliyun MNS Go SDK
 
-[![Github version](https://badgen.net/badge/color/1.0.7/green?label=version)](https://badgen.net/badge/color/1.0.7/green?label=version)
+[![Github version](https://badgen.net/badge/color/1.0.8/green?label=version)](https://badgen.net/badge/color/1.0.8/green?label=version)
 
 The Aliyun MNS Go SDK is the official SDK for MNS in the Go programming language
 

example/create_queue_example.go

@@ -0,0 +1,44 @@
+package main
+
+import (
+	"fmt"
+	ali_mns "github.com/aliyun/aliyun-mns-go-sdk"
+	"time"
+)
+
+func main() {
+	// Replace with your own endpoint.
+	endpoint := "http://***.mns.cn-hangzhou.aliyuncs.com"
+	client := ali_mns.NewClient(endpoint)
+	queueManager := ali_mns.NewMNSQueueManager(client)
+	queueName := "test-queue"
+	err := queueManager.CreateQueueWithOptions(queueName,
+		ali_mns.WithDelaySeconds(5),
+		ali_mns.WithMaxMessageSize(1024),
+		ali_mns.WithMessageRetentionPeriod(86400))
+	time.Sleep(time.Duration(2) * time.Second)
+	if err != nil && !ali_mns.ERR_MNS_QUEUE_ALREADY_EXIST_AND_HAVE_SAME_ATTR.IsEqual(err) {
+		fmt.Println("create queue failed: ", err)
+		return
+	}
+
+	attributes, err := queueManager.GetQueueAttributes(queueName)
+	if err != nil {
+		fmt.Println("get queue attributes failed: ", err)
+		return
+	} else {
+		fmt.Println("queue attributes:", attributes)
+	}
+
+	err = queueManager.SetQueueAttributesWithOptions(queueName,
+		ali_mns.WithLoggingEnabled(true),
+		ali_mns.WithMessageRetentionPeriod(7200),
+		ali_mns.WithPollingWaitSeconds(10))
+	attributes, err = queueManager.GetQueueAttributes(queueName)
+	if err != nil {
+		fmt.Println("get queue attributes failed: ", err)
+		return
+	} else {
+		fmt.Println("queue attributes after set:", attributes)
+	}
+}

message.go

@@ -170,6 +170,7 @@ type CreateQueueRequest struct {
 	MessageRetentionPeriod int32    `xml:"MessageRetentionPeriod,omitempty" json:"message_retention_period,omitempty"`
 	VisibilityTimeout      int32    `xml:"VisibilityTimeout,omitempty" json:"visibility_timeout,omitempty"`
 	PollingWaitSeconds     int32    `xml:"PollingWaitSeconds" json:"polling_wait_secods"`
+	LoggingEnabled         bool     `xml:"LoggingEnabled" json:"logging_enabled"`
 }
 
 type CreateTopicRequest struct {
@@ -217,6 +218,7 @@ type QueueAttribute struct {
 	DelayMessages          int64    `xml:"DelayMessages,omitempty" json:"delay_messages,omitempty"`
 	CreateTime             int64    `xml:"CreateTime,omitempty" json:"create_time,omitempty"`
 	LastModifyTime         int64    `xml:"LastModifyTime,omitempty" json:"last_modify_time,omitempty"`
+	LoggingEnabled         bool     `xml:"LoggingEnabled" json:"logging_enabled"`
 }
 
 type TopicAttribute struct {

queue_manager.go

@@ -12,7 +12,9 @@ import (
 type AliQueueManager interface {
 	CreateSimpleQueue(queueName string) (err error)
 	CreateQueue(queueName string, delaySeconds int32, maxMessageSize int32, messageRetentionPeriod int32, visibilityTimeout int32, pollingWaitSeconds int32, slices int32) (err error)
+	CreateQueueWithOptions(queueName string, options ...QueueOption) (err error)
 	SetQueueAttributes(queueName string, delaySeconds int32, maxMessageSize int32, messageRetentionPeriod int32, visibilityTimeout int32, pollingWaitSeconds int32, slices int32) (err error)
+	SetQueueAttributesWithOptions(queueName string, options ...QueueOption) (err error)
 	GetQueueAttributes(queueName string) (attr QueueAttribute, err error)
 	DeleteQueue(queueName string) (err error)
 	ListQueue(nextMarker string, retNumber int32, prefix string) (queues Queues, err error)
@@ -24,6 +26,59 @@ type MNSQueueManager struct {
 	decoder MNSDecoder
 }
 
+type QueueOptions struct {
+	delaySeconds           int32
+	maxMessageSize         int32
+	messageRetentionPeriod int32
+	visibilityTimeout      int32
+	pollingWaitSeconds     int32
+	loggingEnabled         bool
+}
+
+type QueueOption func(*QueueOptions, map[string]bool)
+
+func WithDelaySeconds(delay int32) QueueOption {
+	return func(o *QueueOptions, tracker map[string]bool) {
+		o.delaySeconds = delay
+		tracker["delaySeconds"] = true
+	}
+}
+
+func WithMaxMessageSize(size int32) QueueOption {
+	return func(o *QueueOptions, tracker map[string]bool) {
+		o.maxMessageSize = size
+		tracker["maxMessageSize"] = true
+	}
+}
+
+func WithMessageRetentionPeriod(period int32) QueueOption {
+	return func(o *QueueOptions, tracker map[string]bool) {
+		o.messageRetentionPeriod = period
+		tracker["messageRetentionPeriod"] = true
+	}
+}
+
+func WithVisibilityTimeout(timeout int32) QueueOption {
+	return func(o *QueueOptions, tracker map[string]bool) {
+		o.visibilityTimeout = timeout
+		tracker["visibilityTimeout"] = true
+	}
+}
+
+func WithPollingWaitSeconds(seconds int32) QueueOption {
+	return func(o *QueueOptions, tracker map[string]bool) {
+		o.pollingWaitSeconds = seconds
+		tracker["pollingWaitSeconds"] = true
+	}
+}
+
+func WithLoggingEnabled(enabled bool) QueueOption {
+	return func(o *QueueOptions, tracker map[string]bool) {
+		o.loggingEnabled = enabled
+		tracker["loggingEnabled"] = true
+	}
+}
+
 func checkQueueName(queueName string) (err error) {
 	if len(queueName) > 256 {
 		err = ERR_MNS_QUEUE_NAME_IS_TOO_LONG.New()
@@ -111,6 +166,7 @@ func (p *MNSQueueManager) CreateQueue(queueName string, delaySeconds int32, maxM
 		MessageRetentionPeriod: messageRetentionPeriod,
 		VisibilityTimeout:      visibilityTimeout,
 		PollingWaitSeconds:     pollingWaitSeconds,
+		LoggingEnabled:         false,
 	}
 
 	var code int
@@ -124,6 +180,41 @@ func (p *MNSQueueManager) CreateQueue(queueName string, delaySeconds int32, maxM
 	return
 }
 
+func (p *MNSQueueManager) CreateQueueWithOptions(queueName string, options ...QueueOption) (err error) {
+	queueName = strings.TrimSpace(queueName)
+	if err = checkQueueName(queueName); err != nil {
+		return
+	}
+	opts := defaultQueueOptions()
+	tracker := make(map[string]bool)
+	for _, opt := range options {
+		opt(&opts, tracker)
+	}
+
+	if err = checkAttributes(opts.delaySeconds, opts.messageRetentionPeriod,
+		opts.visibilityTimeout, opts.pollingWaitSeconds); err != nil {
+		return
+	}
+
+	message := CreateQueueRequest{
+		DelaySeconds:           opts.delaySeconds,
+		MaxMessageSize:         opts.maxMessageSize,
+		MessageRetentionPeriod: opts.messageRetentionPeriod,
+		VisibilityTimeout:      opts.visibilityTimeout,
+		PollingWaitSeconds:     opts.pollingWaitSeconds,
+		LoggingEnabled:         opts.loggingEnabled,
+	}
+
+	var code int
+	code, err = send(p.cli, p.decoder, PUT, nil, &message, "queues/"+queueName, nil)
+	if code == http.StatusNoContent {
+		err = ERR_MNS_QUEUE_ALREADY_EXIST_AND_HAVE_SAME_ATTR.New(errors.Params{"name": queueName})
+		return
+	}
+
+	return
+}
+
 func (p *MNSQueueManager) SetQueueAttributes(queueName string, delaySeconds int32, maxMessageSize int32, messageRetentionPeriod int32, visibilityTimeout int32, pollingWaitSeconds int32, slices int32) (err error) {
 	queueName = strings.TrimSpace(queueName)
 
@@ -150,6 +241,58 @@ func (p *MNSQueueManager) SetQueueAttributes(queueName string, delaySeconds int3
 	return
 }
 
+func (p *MNSQueueManager) SetQueueAttributesWithOptions(queueName string, options ...QueueOption) (err error) {
+	queueName = strings.TrimSpace(queueName)
+	if err = checkQueueName(queueName); err != nil {
+		return
+	}
+	opts := QueueOptions{}
+	tracker := make(map[string]bool)
+	for _, opt := range options {
+		opt(&opts, tracker)
+	}
+
+	message := CreateQueueRequest{}
+	if tracker["delaySeconds"] {
+		if err = checkDelaySeconds(opts.delaySeconds); err != nil {
+			return
+		}
+		message.DelaySeconds = opts.delaySeconds
+	}
+
+	if tracker["maxMessageSize"] {
+		message.MaxMessageSize = opts.maxMessageSize
+	}
+
+	if tracker["messageRetentionPeriod"] {
+		if err = checkMessageRetentionPeriod(opts.messageRetentionPeriod); err != nil {
+			return
+		}
+		message.MessageRetentionPeriod = opts.messageRetentionPeriod
+	}
+
+	if tracker["visibilityTimeout"] {
+		if err = checkVisibilityTimeout(opts.visibilityTimeout); err != nil {
+			return
+		}
+		message.VisibilityTimeout = opts.visibilityTimeout
+	}
+
+	if tracker["pollingWaitSeconds"] {
+		if err = checkPollingWaitSeconds(opts.pollingWaitSeconds); err != nil {
+			return
+		}
+		message.PollingWaitSeconds = opts.pollingWaitSeconds
+	}
+
+	if tracker["loggingEnabled"] {
+		message.LoggingEnabled = opts.loggingEnabled
+	}
+
+	_, err = send(p.cli, p.decoder, PUT, nil, &message, fmt.Sprintf("queues/%s?metaoverride=true", queueName), nil)
+	return
+}
+
 func (p *MNSQueueManager) GetQueueAttributes(queueName string) (attr QueueAttribute, err error) {
 	queueName = strings.TrimSpace(queueName)
 
@@ -235,3 +378,14 @@ func (p *MNSQueueManager) ListQueueDetail(nextMarker string, retNumber int32, pr
 
 	return
 }
+
+func defaultQueueOptions() QueueOptions {
+	return QueueOptions{
+		delaySeconds:           0,
+		maxMessageSize:         65536,
+		messageRetentionPeriod: 345600,
+		visibilityTimeout:      30,
+		pollingWaitSeconds:     0,
+		loggingEnabled:         false,
+	}
+}

version.go

@@ -2,5 +2,5 @@ package ali_mns
 
 const (
 	SdkName = "aliyun-sdk-go"
-	Version = "1.0.7"
+	Version = "1.0.8"
 )