models

type BatchDeleteMessageReq struct {
	*Request
	QueueName     string   `name:"queueName"`
	ReceiptHandle []string `name:"receiptHandle"`
}

type BatchDeleteMessageResp struct {
	*Response
	ErrorList []DelError `json:"errorList"`
}

type BatchPublishMessageReq struct {
	*Request
	TopicName  string    `name:"topicName"`
	MsgBody    []string  `name:"msgBody"`
	MsgTag     *[]string `name:"msgTag"`
	RoutingKey *string   `name:"routingKey"`
}

type BatchPublishMessageResp struct {
	*Response
	MsgList []*PublishMsgId `json:"msgList"`
}

type BatchReceiveMessageReq struct {
	*Request
	QueueName          string `name:"queueName"`
	NumOfMsg           int    `name:"numOfMsg"`
	PollingWaitSeconds *int   `name:"pollingWaitSeconds"`
}

type BatchReceiveMessageResp struct {
	*Response
	MsgInfoList []*MsgInfo `json:"msgInfoList"`
}

type BatchSendMessageReq struct {
	*Request
	QueueName    string   `name:"queueName"`
	MsgBody      []string `name:"msgBody"`
	DelaySeconds *int     `name:"delaySeconds"`
}

type BatchSendMessageResp struct {
	*Response
	MsgList []*SendMsgId `json:"msgList"`
}

type ClearSubscriptionFilterTagsReq struct {
	*Request
	TopicName        string `name:"topicName"`
	SubscriptionName string `name:"subscriptionName"`
}

type ClearSubscriptionFilterTagsResp struct {
	*Response
}

type CmqErr struct {
	Code      int
	Message   string
	RequestId string
}

type CreateTopicReq struct {
	*Request
	TopicName  string `name:"topicName"`
	MaxMsgSize int    `name:"maxMsgSize"`
	FilterType *int   `name:"maxMsgSize"`
}

type CreateTopicResp struct {
	*Response
	TopicId string `json:"topicId"`
}

type DeadLetterPolicy struct {
	DeadLetterQueue string `json:"deadLetterQueue"`
	Policy          int    `json:"policy"`
	MaxReceiveCount *int   `json:"maxReceiveCount"`
	MaxTimeToLive   *int   `json:"maxTimeToLive"`
}

type DelError struct {
	Code          int    `json:"code"`
	Message       string `json:"message"`
	ReceiptHandle string `json:"receiptHandle"`
}

type DeleteMessageReq struct {
	*Request
	QueueName     string `name:"queueName"`
	ReceiptHandle string `name:"receiptHandle"`
}

type DeleteMessageResp struct {
	*Response
}

type DeleteQueueReq struct {
	*Request
	QueueName string `name:"queueName"`
}

type DeleteQueueResp struct {
	*Response
}

type DeleteTopicReq struct {
	*Request
	TopicName string `name:"topicName"`
}

type DeleteTopicResp struct {
	*Response
}

type GetQueueAttributesReq struct {
	*Request
	QueueName string `name:"queueName"`
}

type GetQueueAttributesResp struct {
	*Response
	MaxMsgHeapNum       int `json:"maxMsgHeapNum"`
	PollingWaitSeconds  int `json:"pollingWaitSeconds"`
	VisibilityTimeout   int `json:"visibilityTimeout"`
	MaxMsgSize          int `json:"maxMsgSize"`
	MsgRetentionSeconds int `json:"msgRetentionSeconds"`
	CreateTime          int `json:"createTime"`
	LastModifyTime      int `json:"lastModifyTime"`
	ActiveMsgNum        int `json:"activeMsgNum"`
	InactiveMsgNum      int `json:"inactiveMsgNum"`
	RewindSeconds       int `json:"rewindSeconds"`
	RewindMsgNum        int `json:"rewindmsgNum"`
	MinMsgTime          int `json:"minMsgTime"`
}

type GetSubscriptionAttributesReq struct {
	*Request
	TopicName        string `name:"topicName"`
	SubscriptionName string `name:"subscriptionName"`
}

type GetSubscriptionAttributesResp struct {
	*Response
	TopicOwner          string `json:"topicOwner"`
	MsgCount            int    `json:"msgCount"`
	Protocol            string `json:"protocol"`
	Endpoint            string `json:"endpoint"`
	NotifyStrategy      string `json:"notifyStrategy"`
	NotifyContentFormat string `json:"notifyContentFormat"`
	CreateTime          int    `json:"createTime"`
	LastModifyTime      int    `json:"lastModifyTime"`
	BindingKey          string `json:"bindingKey"`
}

type GetTopicAttributesReq struct {
	*Request
	TopicName string `name:"topicName"`
}

type GetTopicAttributesResp struct {
	*Response
	MsgCount            int `json:"msgCount"`
	MaxMsgSize          int `json:"maxMsgSize"`
	MsgRetentionSeconds int `json:"msgRetentionSeconds"`
	CreateTime          int `json:"createTime"`
	LastModifyTime      int `json:"lastModifyTime"`
	FilterType          int `json:"filterType"`
}

type IRequest interface {
	GetParams() map[string]string
	GetAction() string
	GetBodyReader() io.Reader
	GetType() string
	GetHttpMethod() string
}

type IResponse interface {
	GetCode() int
	GetMessage() string
	GetRequestId() string
}

type ListQueueReq struct {
	*Request
	SearchWord string `name:"searchWord"`
	Offset     *int   `name:"offset"`
	Limit      *int   `name:"limit"`
}

type ListQueueResp struct {
	*Response
	TotalCount int      `json:"totalCount"`
	QueueList  []*Queue `json:"queueList"`
}

type ListSubscriptionByTopicReq struct {
	*Request
	TopicName  string `name:"topicName"`
	SearchWord string `name:"searchWord"`
	Offset     *int   `name:"offset"`
	Limit      *int   `name:"limit"`
}

type ListSubscriptionByTopicResp struct {
	*Response
	TotalCount       int          `json:"totalCount"`
	SubscriptionList []*TopicList `json:"subscriptionList"`
}

type ListTopicReq struct {
	*Request
	SearchWord *string `name:"searchWord"`
	Offset     *int    `name:"offset"`
	Limit      *int    `name:"limit"`
}

type ListTopicResp struct {
	*Response
	TotalCount int      `json:"totalCount"`
	TopicList  []*Topic `json:"topicList"`
}

type MsgInfo struct {
	MsgBody          string `json:"msgBody"`
	MsgId            string `json:"msgId"`
	ReceiptHandle    string `json:"receiptHandle"`
	EnqueueTime      int    `json:"enqueueTime"`
	FirstDequeueTime int    `json:"firstDequeueTime"`
	NextVisibleTime  int    `json:"nextVisibleTime"`
	DequeueCount     int    `json:"dequeueCount"`
}

type PublishMessageReq struct {
	*Request
	TopicName  string    `name:"topicName"`
	MsgBody    string    `name:"msgBody"`
	MsgTag     *[]string `name:"msgTag"`
	RoutingKey *string   `name:"routingKey"`
}

type PublishMessageResp struct {
	*Response
}

type PublishMsgId struct {
	MsgId string `json:"msgId"`
}

type Queue struct {
	QueueId   string `json:"queueId"`
	QueueName string `json:"queueName"`
}

type QueueCreateReq struct {
	*Request
	QueueName           string            `name:"queueName"`
	MaxMsgHeapNum       *int              `name:"maxMsgHeapNum"`
	PollingWaitSeconds  *int              `name:"pollingWaitSeconds"`
	VisibilityTimeout   *int              `name:"visibilityTimeout"`
	MaxMsgSize          *int              `name:"maxMsgSize"`
	MsgRetentionSeconds *int              `name:"msgRetentionSeconds"`
	RewindSeconds       *int              `name:"rewindSeconds"`
	DeadLetterPolicy    *DeadLetterPolicy `name:"deadLetterPolicy"`
}

type QueueCreateResp struct {
	*Response
	QueueId string `json:"queueId"`
}

type ReceiveMessageReq struct {
	*Request
	QueueName          string `name:"queueName"`
	PollingWaitSeconds *int   `name:"pollingWaitSeconds"`
}

type ReceiveMessageResp struct {
	*Response
	MsgBody          string `json:"msgBody"`
	ReceiptHandle    string `json:"receiptHandle"`
	EnqueueTime      int    `json:"enqueueTime"`
	FirstDequeueTime int    `json:"firstDequeueTime"`
	NextVisibleTime  int    `json:"nextVisibleTime"`
	DequeueCount     int    `json:"dequeueCount"`
}

type Request struct {
	Action          string `name:"Action"`
	Region          string `name:"Region"`
	Timestamp       uint64 `name:"Timestamp"`
	Nonce           uint64 `name:"Nonce"`
	SecretId        string `name:"SecretId"`
	Signature       string `name:"Signature"`
	SignatureMethod string `name:"SignatureMethod"`
	Token           string `name:"Token"`
	// contains filtered or unexported fields
}

type Response struct {
	Code      int    `json:"code"`
	Message   string `json:"message"`
	RequestId string `json:"requestId"`
	MsgId     string `json:"msgId"`
}

type RewindQueueReq struct {
	*Request
	QueueName        string `name:"queueName"`
	StartConsumeTime int    `name:"startConsumeTime"` // Unix时间戳
}

type RewindQueueResp struct {
	*Response
}

type SendMessageReq struct {
	*Request
	QueueName    string `name:"queueName"`
	MsgBody      string `name:"msgBody"`
	DelaySeconds *int   `name:"delaySeconds"`
}

type SendMessageResp struct {
	*Response
}

type SendMsgId struct {
	MsgId string `json:"msgId"`
}

type SetQueueAttributesReq struct {
	*Request
	QueueName           string `name:"queueName"`
	MaxMsgHeapNum       *int   `name:"maxMsgHeapNum"`
	PollingWaitSeconds  *int   `name:"pollingWaitSeconds"`
	VisibilityTimeout   *int   `name:"visibilityTimeout"`
	MaxMsgSize          *int   `name:"maxMsgSize"`
	MsgRetentionSeconds *int   `name:"msgRetentionSeconds"`
	RewindSeconds       *int   `name:"rewindSeconds"`
}

type SetQueueAttributesResp struct {
	*Response
	MaxMsgHeapNum       int `json:"maxMsgHeapNum"`
	PollingWaitSeconds  int `json:"pollingWaitSeconds"`
	VisibilityTimeout   int `json:"visibilityTimeout"`
	MaxMsgSize          int `json:"maxMsgSize"`
	MsgRetentionSeconds int `json:"msgRetentionSeconds"`
	RewindSeconds       int `json:"rewindSeconds"`
}

type SetSubscriptionAttributesReq struct {
	*Request
	TopicName           string    `name:"topicName"`
	SubscriptionName    string    `name:"subscriptionName"`
	NotifyStrategy      *string   `name:"notifyStrategy"`
	NotifyContentFormat *string   `name:"notifyContentFormat"`
	FilterTag           *[]string `name:"filterTag"`
	BindingKey          []string  `name:"bindingKey"`
}

type SetSubscriptionAttributesResp struct {
	*Response
}

type SetTopicAttributesReq struct {
	*Request
	TopicName  string `name:"topicName"`
	MaxMsgSize *int   `name:"maxMsgSize"`
}

type SetTopicAttributesResp struct {
	*Response
}

type SubscribeReq struct {
	*Request
	TopicName           string    `name:"topicName"`
	SubscriptionName    string    `name:"subscriptionName"`
	Protocol            string    `name:"protocol"`
	Endpoint            string    `name:"endpoint"`
	NotifyStrategy      *string   `name:"notifyStrategy"`
	NotifyContentFormat *string   `name:"notifyContentFormat"`
	FilterTag           *[]string `name:"filterTag"`
	BindingKey          []string  `name:"bindingKey"`
}

type SubscribeResp struct {
	*Response
}

type Topic struct {
	TopicId   string `json:"topicId"`
	TopicName string `json:"topicName"`
}

type TopicList struct {
	SubscriptionId   string `json:"subscriptionId"`
	SubscriptionName string `json:"subscriptionName"`
	Protocol         string `json:"protocol"`
	Endpoint         string `json:"endpoint"`
}

type UnsubscribeReq struct {
	*Request
	TopicName        string `name:"topicName"`
	SubscriptionName string `name:"subscriptionName"`
}

type UnsubscribeResp struct {
	*Response
}