mns

Documentation

Index

• type BatchDeleteMessageRequest
  • func CreateBatchDeleteMessageRequest() (request *BatchDeleteMessageRequest)
  • func (request *BatchDeleteMessageRequest) SetReceiptHandles(receiptHandles []string)
• type BatchDeleteMessageResponse
  • func CreateBatchDeleteMessageResponse() (response *BatchDeleteMessageResponse)
• type BatchReceiveMessageRequest
  • func CreateBatchReceiveMessageRequest() (request *BatchReceiveMessageRequest)
• type BatchReceiveMessageResponse
  • func CreateBatchReceiveMessageResponse() (response *BatchReceiveMessageResponse)
• type Message
• type Queue
  • func NewClientWithStsToken(regionId, stsAccessKeyId, stsAccessKeySecret, stsToken string) (queue *Queue, err error)
  • func (client *Queue) BatchDeleteMessage(request *BatchDeleteMessageRequest) (response *BatchDeleteMessageResponse, err error)
  • func (client *Queue) BatchReceiveMessage(request *BatchReceiveMessageRequest) (response *BatchReceiveMessageResponse, err error)
  • func (queue *Queue) DoActionWithSigner(request requests.AcsRequest, response responses.AcsResponse) (err error)
  • func (queue *Queue) InitClientConfig() (config *sdk.Config)
  • func (queue *Queue) InitWithOptions(config *sdk.Config, credential auth.Credential) (err error)
  • func (queue *Queue) InitWithStsToken(regionId, stsAccessKeyId, stsAccessKeySecret, stsToken string) (err error)
  • func (queue *Queue) Shutdown()
• type ReceiptHandles

Types

type BatchDeleteMessageRequest

type BatchDeleteMessageRequest struct {
	*requests.RoaRequest
	QueueName string `position:"Path" name:"QueueName"`
}

func CreateBatchDeleteMessageRequest

func CreateBatchDeleteMessageRequest() (request *BatchDeleteMessageRequest)

func (*BatchDeleteMessageRequest) SetReceiptHandles

func (request *BatchDeleteMessageRequest) SetReceiptHandles(receiptHandles []string)

type BatchDeleteMessageResponse

type BatchDeleteMessageResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	Code      string `json:"Code" xml:"Code"`
}

func CreateBatchDeleteMessageResponse

func CreateBatchDeleteMessageResponse() (response *BatchDeleteMessageResponse)

type BatchReceiveMessageRequest

type BatchReceiveMessageRequest struct {
	*requests.RoaRequest
	QueueName     string           `position:"Path" name:"QueueName"`
	NumOfMessages requests.Integer `position:"Query" name:"numOfMessages"`
	WaitSeconds   requests.Integer `position:"Query" name:"waitseconds"`
}

func CreateBatchReceiveMessageRequest

func CreateBatchReceiveMessageRequest() (request *BatchReceiveMessageRequest)

type BatchReceiveMessageResponse

type BatchReceiveMessageResponse struct {
	*responses.BaseResponse
	RequestId string    `json:"RequestId" xml:"RequestId"`
	Code      string    `json:"Code" xml:"Code"`
	Message   []Message `json:"Message" xml:"Message"`
}

func CreateBatchReceiveMessageResponse

func CreateBatchReceiveMessageResponse() (response *BatchReceiveMessageResponse)

type Message

type Message struct {
	MessageId        string `json:"MessageId" xml:"MessageId"`
	MessageBodyMD5   string `json:"MessageBodyMD5" xml:"MessageBodyMD5"`
	MessageBody      string `json:"MessageBody" xml:"MessageBody"`
	ReceiptHandle    string `json:"ReceiptHandle" xml:"ReceiptHandle"`
	EnqueueTime      int    `json:"EnqueueTime" xml:"EnqueueTime"`
	FirstDequeueTime int    `json:"FirstDequeueTime" xml:"FirstDequeueTime"`
	NextVisibleTime  int    `json:"NextVisibleTime" xml:"NextVisibleTime"`
	DequeueCount     int    `json:"DequeueCount" xml:"DequeueCount"`
	Priority         int    `json:"Priority" xml:"Priority"`
}

type Queue

type Queue struct {
	// contains filtered or unexported fields
}

func NewClientWithStsToken

func NewClientWithStsToken(regionId, stsAccessKeyId, stsAccessKeySecret, stsToken string) (queue *Queue, err error)

func (*Queue) BatchDeleteMessage

func (client *Queue) BatchDeleteMessage(request *BatchDeleteMessageRequest) (response *BatchDeleteMessageResponse, err error)

func (*Queue) BatchReceiveMessage

func (client *Queue) BatchReceiveMessage(request *BatchReceiveMessageRequest) (response *BatchReceiveMessageResponse, err error)

func (*Queue) DoActionWithSigner

func (queue *Queue) DoActionWithSigner(request requests.AcsRequest, response responses.AcsResponse) (err error)

func (*Queue) InitClientConfig

func (queue *Queue) InitClientConfig() (config *sdk.Config)

func (*Queue) InitWithOptions

func (queue *Queue) InitWithOptions(config *sdk.Config, credential auth.Credential) (err error)

func (*Queue) InitWithStsToken

func (queue *Queue) InitWithStsToken(regionId, stsAccessKeyId, stsAccessKeySecret, stsToken string) (err error)

func (*Queue) Shutdown

func (queue *Queue) Shutdown()

type ReceiptHandles

type ReceiptHandles struct {
	XMLName xml.Name `xml:"ReceiptHandles"`
	Xmlns   string   `xml:"xmlns,attr"`
	Handles []string `xml:"ReceiptHandle"`
}