mns

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
  • func NewClient(accessKeyId, accessKeySecret, endpoint string) (client *Client)
  • func NewClientForAssumeRole(accessKeyId, accessKeySecret, securityToken, endpoint string) (client *Client)
  • func (client *Client) SetDebug(debug bool)
  • func (client *Client) SignRequest(req *request, payload []byte)
• type Error
  • func (err *Error) Error() string
• type Message
• type MsgReceive
• type MsgSend
• type Queue
  • func (queue *Queue) Delete(receiptHandle string, errChan chan error)
  • func (queue *Queue) Receive(messageChan chan MsgReceive, errChan chan error)
  • func (queue *Queue) Send(time int64, message []byte) (msg MsgSend, err error)

Constants

const HeaderMNSPrefix = "x-mns-"

const (
	MNSAPIVersion = "2015-06-06"
)

Functions

func GetCurrentMillisecond

func GetCurrentMillisecond() int64

获取当前时间戳(毫秒)

func GetCurrentUnixMicro

func GetCurrentUnixMicro() int64

获取当前时间戳(秒)

func HamSha1

func HamSha1(data string, key []byte) string

func Md5

func Md5(byteMessage []byte) string

对数据进行md5计算

func Sha1

func Sha1(data string) string

对字符串进行sha1 计算

Types

type Client

type Client struct {
	AccessKeyId     string
	AccessKeySecret string
	SecurityToken   string
	Endpoint        string
	Version         string
	// contains filtered or unexported fields
}

func NewClient

func NewClient(accessKeyId, accessKeySecret, endpoint string) (client *Client)

func NewClientForAssumeRole

func NewClientForAssumeRole(accessKeyId, accessKeySecret, securityToken, endpoint string) (client *Client)

func (*Client) SetDebug

func (client *Client) SetDebug(debug bool)

func (*Client) SignRequest

func (client *Client) SignRequest(req *request, payload []byte)

授权签名

type Error

type Error struct {
	StatusCode int
	Code       string `xml:"Code"`
	Message    string `xml:"Message"`
}

func (*Error) Error

func (err *Error) Error() string

type Message

type Message struct {
	MessageBody string `xml:"MessageBody"`
}

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 MsgSend

type MsgSend struct {
	MessageId      string `xml:"MessageId"`
	MessageBodyMD5 string `xml:"MessageBodyMD5"`
}

type Queue

type Queue struct {
	*Client
	QueueName string
	Base64    bool
}

func (*Queue) Delete

func (queue *Queue) Delete(receiptHandle string, errChan chan error)

删除队列消息

func (*Queue) Receive

func (queue *Queue) Receive(messageChan chan MsgReceive, errChan chan error)

消费队列消息

func (*Queue) Send

func (queue *Queue) Send(time int64, message []byte) (msg MsgSend, err error)

发送队列消息