cmq

package
v1.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 7, 2018 License: Apache-2.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DefaultClient = CmqClient{Client: *core.NewClient()}

Functions

func DoAction 

func DoAction(action string, options ...string) ([]byte, error)

Types

type BatchDeleteMessageResp added in v1.3.0 

type BatchDeleteMessageResp struct {
	ClientRequestID int64  `json:"clientRequestId"`
	Code            int64  `json:"code"`
	Message         string `json:"message"`
	RequestID       string `json:"requestId"`
}

func BatchDeleteMessage added in v1.3.0 

func BatchDeleteMessage(options ...string) (*BatchDeleteMessageResp, error)

func (*BatchDeleteMessageResp) String added in v1.3.0 

func (r *BatchDeleteMessageResp) String(args ...interface{}) (string, error)

type BatchReceiveMessageResp added in v1.3.0 

type BatchReceiveMessageResp struct {
	ClientRequestID int64  `json:"clientRequestId"`
	Code            int64  `json:"code"`
	Message         string `json:"message"`
	MsgInfoList     []struct {
		DequeueCount         int64  `json:"dequeueCount"`
		EnqueueTime          int64  `json:"enqueueTime"`
		FirstDequeueTime     int64  `json:"firstDequeueTime"`
		MsgBody              string `json:"msgBody"`
		MsgID                string `json:"msgId"`
		NextVisibleTime      int64  `json:"nextVisibleTime"`
		OriginalDeQueueCount int64  `json:"originalDeQueueCount"`
		OriginalEnQueueTime  int64  `json:"originalEnQueueTime"`
		OriginalQueueID      string `json:"originalQueueId"`
		ReceiptHandle        string `json:"receiptHandle"`
	} `json:"msgInfoList"`
	RequestID string `json:"requestId"`
}

func BatchReceiveMessage added in v1.3.0 

func BatchReceiveMessage(options ...string) (*BatchReceiveMessageResp, error)

func (*BatchReceiveMessageResp) String added in v1.3.0 

func (r *BatchReceiveMessageResp) String(args ...interface{}) (string, error)

type BatchSendMessageResp added in v1.3.0 

type BatchSendMessageResp struct {
	ClientRequestID int64  `json:"clientRequestId"`
	Code            int64  `json:"code"`
	Message         string `json:"message"`
	MsgList         []struct {
		MsgID string `json:"msgId"`
	} `json:"msgList"`
	RequestID string `json:"requestId"`
}

func BatchSendMessage added in v1.3.0 

func BatchSendMessage(options ...string) (*BatchSendMessageResp, error)

func (*BatchSendMessageResp) String added in v1.3.0 

func (r *BatchSendMessageResp) String(args ...interface{}) (string, error)

type CmqClient added in v1.3.0 

type CmqClient struct {
	core.Client
}

func NewClient added in v1.3.0 

func NewClient() *CmqClient

func (*CmqClient) BatchDeleteMessage added in v1.3.0 

func (c *CmqClient) BatchDeleteMessage(options ...string) (*BatchDeleteMessageResp, error)

Implement https://cloud.tencent.com/document/api/406/5841

func (*CmqClient) BatchReceiveMessage added in v1.3.0 

func (c *CmqClient) BatchReceiveMessage(options ...string) (*BatchReceiveMessageResp, error)

Implement https://cloud.tencent.com/document/api/406/5924

func (*CmqClient) BatchSendMessage added in v1.3.0 

func (c *CmqClient) BatchSendMessage(options ...string) (*BatchSendMessageResp, error)

Implement https://cloud.tencent.com/document/api/406/5838

func (*CmqClient) CreateQueue added in v1.3.0 

func (c *CmqClient) CreateQueue(options ...string) (*CreateQueueResp, error)

Implement https://cloud.tencent.com/document/api/406/5832

func (*CmqClient) CreateTopic added in v1.3.0 

func (c *CmqClient) CreateTopic(options ...string) (*CreateTopicResp, error)

Implement https://cloud.tencent.com/document/api/406/7405

func (*CmqClient) DeleteMessage added in v1.3.0 

func (c *CmqClient) DeleteMessage(options ...string) (*DeleteMessageResp, error)

Implement https://cloud.tencent.com/document/api/406/5840

func (*CmqClient) DeleteQueue added in v1.3.0 

func (c *CmqClient) DeleteQueue(options ...string) (*DeleteQueueResp, error)

Implement https://cloud.tencent.com/document/api/406/5836

func (*CmqClient) DeleteTopic added in v1.3.0 

func (c *CmqClient) DeleteTopic(options ...string) (*DeleteTopicResp, error)

Implement https://cloud.tencent.com/document/api/406/7409

func (*CmqClient) DoAction added in v1.3.0 

func (client *CmqClient) DoAction(action string, options ...string) ([]byte, error)

func (*CmqClient) GetQueueAttributes added in v1.3.0 

func (c *CmqClient) GetQueueAttributes(options ...string) (*GetQueueAttributesResp, error)

Implement https://cloud.tencent.com/document/api/406/5834

func (*CmqClient) GetSubscriptionAttributes added in v1.3.0 

func (c *CmqClient) GetSubscriptionAttributes(options ...string) (*GetSubscriptionAttributesResp, error)

Implement https://cloud.tencent.com/document/api/406/7418

func (*CmqClient) GetTopicAttributes added in v1.3.0 

func (c *CmqClient) GetTopicAttributes(options ...string) (*GetTopicAttributesResp, error)

Implement https://cloud.tencent.com/document/api/406/7408

func (*CmqClient) ListQueue added in v1.3.0 

func (c *CmqClient) ListQueue(options ...string) (*ListQueueResp, error)

Implement https://cloud.tencent.com/document/api/406/5833

func (*CmqClient) ListSubscriptionByTopic added in v1.3.0 

func (c *CmqClient) ListSubscriptionByTopic(options ...string) (*ListSubscriptionByTopicResp, error)

Implement https://cloud.tencent.com/document/api/406/7415

func (*CmqClient) ListTopic added in v1.3.0 

func (c *CmqClient) ListTopic(options ...string) (*ListTopicResp, error)

Implement https://cloud.tencent.com/document/api/406/7407

func (*CmqClient) PublishMessage added in v1.3.0 

func (c *CmqClient) PublishMessage(options ...string) (*PublishMessageResp, error)

Implement https://cloud.tencent.com/document/api/406/7411

func (*CmqClient) ReceiveMessage added in v1.3.0 

func (c *CmqClient) ReceiveMessage(options ...string) (*ReceiveMessageResp, error)

Implement https://cloud.tencent.com/document/api/406/5839

func (*CmqClient) SendMessage added in v1.3.0 

func (c *CmqClient) SendMessage(options ...string) (*SendMessageResp, error)

Implement https://cloud.tencent.com/document/api/406/5837

func (*CmqClient) SetQueueAttributes added in v1.3.0 

func (c *CmqClient) SetQueueAttributes(options ...string) (*SetQueueAttributesResp, error)

Implement https://cloud.tencent.com/document/api/406/5835

func (*CmqClient) SetSubscriptionAttributes added in v1.3.0 

func (c *CmqClient) SetSubscriptionAttributes(options ...string) (*SetSubscriptionAttributesResp, error)

Implement https://cloud.tencent.com/document/api/406/7416

func (*CmqClient) SetTopicAttributes added in v1.3.0 

func (c *CmqClient) SetTopicAttributes(options ...string) (*SetTopicAttributesResp, error)

Implement https://cloud.tencent.com/document/api/406/7406

func (*CmqClient) Subscribe added in v1.3.0 

func (c *CmqClient) Subscribe(options ...string) (*SubscribeResp, error)

Implement https://cloud.tencent.com/document/api/406/7414

func (*CmqClient) Unsubscribe added in v1.3.0 

func (c *CmqClient) Unsubscribe(options ...string) (*UnsubscribeResp, error)

Implement https://cloud.tencent.com/document/api/406/7417

type CreateQueueResp 

type CreateQueueResp struct {
	ClientRequestID int64  `json:"clientRequestId"`
	Code            int64  `json:"code"`
	Message         string `json:"message"`
	QueueID         string `json:"queueId"`
	RequestID       string `json:"requestId"`
}

func CreateQueue 

func CreateQueue(options ...string) (*CreateQueueResp, error)

func (*CreateQueueResp) String added in v1.1.0 

func (r *CreateQueueResp) String(args ...interface{}) (string, error)

type CreateTopicResp added in v1.3.0 

type CreateTopicResp struct {
	Code      int64  `json:"code"`
	Message   string `json:"message"`
	RequestID string `json:"requestId"`
	TopicID   string `json:"topicId"`
}

func CreateTopic added in v1.3.0 

func CreateTopic(options ...string) (*CreateTopicResp, error)

func (*CreateTopicResp) String added in v1.3.0 

func (r *CreateTopicResp) String(args ...interface{}) (string, error)

type DeleteMessageResp added in v1.3.0 

type DeleteMessageResp struct {
	ClientRequestID int64  `json:"clientRequestId"`
	Code            int64  `json:"code"`
	Message         string `json:"message"`
	RequestID       string `json:"requestId"`
}

func DeleteMessage added in v1.3.0 

func DeleteMessage(options ...string) (*DeleteMessageResp, error)

func (*DeleteMessageResp) String added in v1.3.0 

func (r *DeleteMessageResp) String(args ...interface{}) (string, error)

type DeleteQueueResp 

type DeleteQueueResp struct {
	ClientRequestID int64  `json:"clientRequestId"`
	Code            int64  `json:"code"`
	Message         string `json:"message"`
	RequestID       string `json:"requestId"`
}

func DeleteQueue 

func DeleteQueue(options ...string) (*DeleteQueueResp, error)

func (*DeleteQueueResp) String added in v1.1.0 

func (r *DeleteQueueResp) String(args ...interface{}) (string, error)

type DeleteTopicResp added in v1.3.0 

type DeleteTopicResp struct {
	Code      int64  `json:"code"`
	Message   string `json:"message"`
	RequestID string `json:"requestId"`
}

func DeleteTopic added in v1.3.0 

func DeleteTopic(options ...string) (*DeleteTopicResp, error)

func (*DeleteTopicResp) String added in v1.3.0 

func (r *DeleteTopicResp) String(args ...interface{}) (string, error)

type GetQueueAttributesResp added in v1.3.0 

type GetQueueAttributesResp struct {
	ActiveMsgNum        int64  `json:"activeMsgNum"`
	ClientRequestID     int64  `json:"clientRequestId"`
	Code                int64  `json:"code"`
	CreateTime          int64  `json:"createTime"`
	DelayMsgNum         int64  `json:"delayMsgNum"`
	InactiveMsgNum      int64  `json:"inactiveMsgNum"`
	LastModifyTime      int64  `json:"lastModifyTime"`
	MaxMsgHeapNum       int64  `json:"maxMsgHeapNum"`
	MaxMsgSize          int64  `json:"maxMsgSize"`
	Message             string `json:"message"`
	MinMsgTime          int64  `json:"minMsgTime"`
	MsgRetentionSeconds int64  `json:"msgRetentionSeconds"`
	PollingWaitSeconds  int64  `json:"pollingWaitSeconds"`
	RequestID           string `json:"requestId"`
	RewindMsgNum        int64  `json:"rewindMsgNum"`
	RewindSeconds       int64  `json:"rewindSeconds"`
	VisibilityTimeout   int64  `json:"visibilityTimeout"`
}

func GetQueueAttributes added in v1.3.0 

func GetQueueAttributes(options ...string) (*GetQueueAttributesResp, error)

func (*GetQueueAttributesResp) String added in v1.3.0 

func (r *GetQueueAttributesResp) String(args ...interface{}) (string, error)

type GetSubscriptionAttributesResp added in v1.3.0 

type GetSubscriptionAttributesResp struct {
	BindingKey          []interface{} `json:"bindingKey"`
	Code                int64         `json:"code"`
	CreateTime          int64         `json:"createTime"`
	Endpoint            string        `json:"endpoint"`
	FilterTags          []interface{} `json:"filterTags"`
	LastModifyTime      int64         `json:"lastModifyTime"`
	Message             string        `json:"message"`
	MsgCount            int64         `json:"msgCount"`
	NotifyContentFormat string        `json:"notifyContentFormat"`
	NotifyStrategy      string        `json:"notifyStrategy"`
	Protocol            string        `json:"protocol"`
	RequestID           string        `json:"requestId"`
	TopicOwner          string        `json:"topicOwner"`
}

func GetSubscriptionAttributes added in v1.3.0 

func GetSubscriptionAttributes(options ...string) (*GetSubscriptionAttributesResp, error)

func (*GetSubscriptionAttributesResp) String added in v1.3.0 

func (r *GetSubscriptionAttributesResp) String(args ...interface{}) (string, error)

type GetTopicAttributesResp added in v1.3.0 

type GetTopicAttributesResp struct {
	Code                int64  `json:"code"`
	CreateTime          int64  `json:"createTime"`
	FilterType          int64  `json:"filterType"`
	LastModifyTime      int64  `json:"lastModifyTime"`
	MaxMsgSize          int64  `json:"maxMsgSize"`
	Message             string `json:"message"`
	MsgCount            int64  `json:"msgCount"`
	MsgRetentionSeconds int64  `json:"msgRetentionSeconds"`
	RequestID           string `json:"requestId"`
	TopicID             string `json:"topicId"`
	TopicName           string `json:"topicName"`
}

func GetTopicAttributes added in v1.3.0 

func GetTopicAttributes(options ...string) (*GetTopicAttributesResp, error)

func (*GetTopicAttributesResp) String added in v1.3.0 

func (r *GetTopicAttributesResp) String(args ...interface{}) (string, error)

type ListQueueResp 

type ListQueueResp struct {
	ClientRequestID int64  `json:"clientRequestId"`
	Code            int64  `json:"code"`
	Message         string `json:"message"`
	QueueList       []struct {
		QueueID   string `json:"queueId"`
		QueueName string `json:"queueName"`
	} `json:"queueList"`
	RequestID  string `json:"requestId"`
	TotalCount int64  `json:"totalCount"`
}

func ListQueue 

func ListQueue(options ...string) (*ListQueueResp, error)

func (*ListQueueResp) String added in v1.1.0 

func (r *ListQueueResp) String(args ...interface{}) (string, error)

type ListSubscriptionByTopicResp added in v1.3.0 

type ListSubscriptionByTopicResp struct {
	Code             int64  `json:"code"`
	Message          string `json:"message"`
	RequestID        string `json:"requestId"`
	SubscriptionList []struct {
		Endpoint         string `json:"endpoint"`
		Protocol         string `json:"protocol"`
		SubscriptionID   string `json:"subscriptionId"`
		SubscriptionName string `json:"subscriptionName"`
	} `json:"subscriptionList"`
	TotalCount int64 `json:"totalCount"`
}

func ListSubscriptionByTopic added in v1.3.0 

func ListSubscriptionByTopic(options ...string) (*ListSubscriptionByTopicResp, error)

func (*ListSubscriptionByTopicResp) String added in v1.3.0 

func (r *ListSubscriptionByTopicResp) String(args ...interface{}) (string, error)

type ListTopicResp added in v1.3.0 

type ListTopicResp struct {
	Code      int64  `json:"code"`
	Message   string `json:"message"`
	RequestID string `json:"requestId"`
	TopicList []struct {
		TopicID   string `json:"topicId"`
		TopicName string `json:"topicName"`
	} `json:"topicList"`
	TotalCount int64 `json:"totalCount"`
}

func ListTopic added in v1.3.0 

func ListTopic(options ...string) (*ListTopicResp, error)

func (*ListTopicResp) String added in v1.3.0 

func (r *ListTopicResp) String(args ...interface{}) (string, error)

type PublishMessageResp added in v1.3.0 

type PublishMessageResp struct {
	Code      int64  `json:"code"`
	Message   string `json:"message"`
	MsgID     string `json:"msgId"`
	RequestID string `json:"requestId"`
}

func PublishMessage added in v1.3.0 

func PublishMessage(options ...string) (*PublishMessageResp, error)

func (*PublishMessageResp) String added in v1.3.0 

func (r *PublishMessageResp) String(args ...interface{}) (string, error)

type ReceiveMessageResp added in v1.3.0 

type ReceiveMessageResp struct {
	ClientRequestID      int64  `json:"clientRequestId"`
	Code                 int64  `json:"code"`
	DequeueCount         int64  `json:"dequeueCount"`
	EnqueueTime          int64  `json:"enqueueTime"`
	FirstDequeueTime     int64  `json:"firstDequeueTime"`
	Message              string `json:"message"`
	MsgBody              string `json:"msgBody"`
	MsgID                string `json:"msgId"`
	NextVisibleTime      int64  `json:"nextVisibleTime"`
	OriginalDeQueueCount int64  `json:"originalDeQueueCount"`
	OriginalEnQueueTime  int64  `json:"originalEnQueueTime"`
	OriginalQueueID      string `json:"originalQueueId"`
	ReceiptHandle        string `json:"receiptHandle"`
	RequestID            string `json:"requestId"`
}

func ReceiveMessage added in v1.3.0 

func ReceiveMessage(options ...string) (*ReceiveMessageResp, error)

func (*ReceiveMessageResp) String added in v1.3.0 

func (r *ReceiveMessageResp) String(args ...interface{}) (string, error)

type SendMessageResp added in v1.3.0 

type SendMessageResp struct {
	ClientRequestID int64  `json:"clientRequestId"`
	Code            int64  `json:"code"`
	Message         string `json:"message"`
	MsgID           string `json:"msgId"`
	RequestID       string `json:"requestId"`
}

func SendMessage added in v1.3.0 

func SendMessage(options ...string) (*SendMessageResp, error)

func (*SendMessageResp) String added in v1.3.0 

func (r *SendMessageResp) String(args ...interface{}) (string, error)

type SetQueueAttributesResp added in v1.3.0 

type SetQueueAttributesResp struct {
	ClientRequestID     int64  `json:"clientRequestId"`
	Code                int64  `json:"code"`
	MaxMsgHeapNum       int64  `json:"maxMsgHeapNum"`
	MaxMsgSize          int64  `json:"maxMsgSize"`
	Message             string `json:"message"`
	MsgRetentionSeconds int64  `json:"msgRetentionSeconds"`
	PollingWaitSeconds  int64  `json:"pollingWaitSeconds"`
	RequestID           string `json:"requestId"`
	VisibilityTimeout   int64  `json:"visibilityTimeout"`
}

func SetQueueAttributes added in v1.3.0 

func SetQueueAttributes(options ...string) (*SetQueueAttributesResp, error)

func (*SetQueueAttributesResp) String added in v1.3.0 

func (r *SetQueueAttributesResp) String(args ...interface{}) (string, error)

type SetSubscriptionAttributesResp added in v1.3.0 

type SetSubscriptionAttributesResp struct {
	Code      int64  `json:"code"`
	Message   string `json:"message"`
	RequestID string `json:"requestId"`
}

func SetSubscriptionAttributes added in v1.3.0 

func SetSubscriptionAttributes(options ...string) (*SetSubscriptionAttributesResp, error)

func (*SetSubscriptionAttributesResp) String added in v1.3.0 

func (r *SetSubscriptionAttributesResp) String(args ...interface{}) (string, error)

type SetTopicAttributesResp added in v1.3.0 

type SetTopicAttributesResp struct {
	Code      int64  `json:"code"`
	Message   string `json:"message"`
	RequestID string `json:"requestId"`
}

func SetTopicAttributes added in v1.3.0 

func SetTopicAttributes(options ...string) (*SetTopicAttributesResp, error)

func (*SetTopicAttributesResp) String added in v1.3.0 

func (r *SetTopicAttributesResp) String(args ...interface{}) (string, error)

type SubscribeResp added in v1.3.0 

type SubscribeResp struct {
	Code           int64  `json:"code"`
	Message        string `json:"message"`
	RequestID      string `json:"requestId"`
	SubscriptionID string `json:"subscriptionId"`
}

func Subscribe added in v1.3.0 

func Subscribe(options ...string) (*SubscribeResp, error)

func (*SubscribeResp) String added in v1.3.0 

func (r *SubscribeResp) String(args ...interface{}) (string, error)

type UnsubscribeResp added in v1.3.0 

type UnsubscribeResp struct {
	Code      int64  `json:"code"`
	Message   string `json:"message"`
	RequestID string `json:"requestId"`
}

func Unsubscribe added in v1.3.0 

func Unsubscribe(options ...string) (*UnsubscribeResp, error)

func (*UnsubscribeResp) String added in v1.3.0 

func (r *UnsubscribeResp) String(args ...interface{}) (string, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.