Documentation ¶
Index ¶
- Constants
- func GetCurrentMillisecond() int64
- func GetCurrentUnixMicro() int64
- func HamSha1(data string, key []byte) string
- func Md5(byteMessage []byte) string
- func Sha1(data string) string
- type Client
- type Error
- type Message
- type MsgReceive
- type MsgReceives
- type MsgSend
- type Queue
- func (queue *Queue) Delete(receiptHandle string, errChan chan error)
- func (queue *Queue) DeleteBatch(errChan chan error, receiptHandles ...string)
- func (queue *Queue) Receive(messageChan chan []*MsgReceive, errChan chan error)
- func (queue *Queue) Send(time int64, message []byte) (msg MsgSend, err error)
- type ReceiptHandles
Constants ¶
View Source
const HeaderMNSPrefix = "x-mns-"
View Source
const (
MNSAPIVersion = "2015-06-06"
)
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Client ¶
type Client struct { AccessKeyId string AccessKeySecret string Endpoint string Version string SecurityToken string // contains filtered or unexported fields }
type MsgReceive ¶
type MsgReceive struct { MessageId string `xml:"MessageId"` MessageBodyMD5 string `xml:"MessageBodyMD5"` MessageBody string `xml:"MessageBody"` ReceiptHandle string `xml:"ReceiptHandle"` EnqueueTime int64 `xml:"EnqueueTime"` NextVisibleTime int64 `xml:"NextVisibleTime"` DequeueCount int `xml:"DequeueCount"` Priority int `xml:"Priority"` }
type MsgReceives ¶
type MsgReceives struct {
Message []*MsgReceive `xml:"Message"`
}
type Queue ¶
func (*Queue) DeleteBatch ¶
删除队列消息
func (*Queue) Receive ¶
func (queue *Queue) Receive(messageChan chan []*MsgReceive, errChan chan error)
消费队列消息
type ReceiptHandles ¶
Click to show internal directories.
Click to hide internal directories.