mq_http_sdk

package module

Go to main page

Versions in this module

v1

v1.0.3

Jan 5, 2021

Changes in this version

+ const SHARDING

type AliyunMQConsumer

+ func (p *AliyunMQConsumer) ConsumeMessageOrderly(respChan chan ConsumeMessageResponse, errChan chan error, numOfMessages int32, ...)

type ConsumeMessageEntry

+ ShardingKey string

type ConsumeMessageResponse

+ func (r *ConsumeMessageResponse) Responses() []*MessageResponse

type MQClient

+ func NewAliyunMQClientWithTimeout(endpoint, accessKeyId, accessKeySecret, securityToken string, ...) MQClient

type MQConsumer

+ ConsumeMessageOrderly func(respChan chan ConsumeMessageResponse, errChan chan error, numOfMessages int32, ...)

+ type MessageResponder interface

+ Responses func() []*MessageResponse

type PublishMessageRequest

+ ShardingKey string

type PublishMessageResponse

+ func (r *PublishMessageResponse) Responses() []*MessageResponse

v1.0.1

Jun 10, 2019

Changes in this version

+ const Keys

+ const StartDeliverTime

+ const TransCheckImmunityTime

+ var ErrMessageProperty = errors.TN(ALIYUN_MQ_ERR_NS, 4, ...)

+ func CommitOrRollback(p *AliyunMQTransProducer, receiptHandle string, trans string) (err error)

+ func ConstructPubMessage(pubMsgReq *PublishMessageRequest) (err error)

+ func ConstructRecMessage(entries *[]ConsumeMessageEntry)

+ func ContainsSpecialChar(input string) (result bool)

type AliyunMQClient

+ func (p *AliyunMQClient) GetTransProducer(instanceId string, topicName string, groupId string) MQTransProducer

+ type AliyunMQTransProducer struct

+ func (p *AliyunMQTransProducer) Commit(receiptHandle string) (err error)

+ func (p *AliyunMQTransProducer) ConsumeHalfMessage(respChan chan ConsumeMessageResponse, errChan chan error, numOfMessages int32, ...)

+ func (p *AliyunMQTransProducer) GroupId() string

+ func (p *AliyunMQTransProducer) InstanceId() string

+ func (p *AliyunMQTransProducer) PublishMessage(message PublishMessageRequest) (resp PublishMessageResponse, err error)

+ func (p *AliyunMQTransProducer) Rollback(receiptHandle string) (err error)

+ func (p *AliyunMQTransProducer) TopicName() string

type ConsumeMessageEntry

+ MessageKey string

+ PropInner string

+ Properties map[string]string

+ StartDeliverTime int64

+ TransCheckImmunityTime int

type MQClient

+ GetTransProducer func(instanceId string, topicName string, groupId string) MQTransProducer

+ type MQTransProducer interface

+ Commit func(receiptHandle string) (err error)

+ ConsumeHalfMessage func(respChan chan ConsumeMessageResponse, errChan chan error, numOfMessages int32, ...)

+ GroupId func() string

+ InstanceId func() string

+ PublishMessage func(message PublishMessageRequest) (resp PublishMessageResponse, err error)

+ Rollback func(receiptHandle string) (err error)

+ TopicName func() string

type PublishMessageRequest

+ MessageKey string

+ Properties map[string]string

+ StartDeliverTime int64

+ TransCheckImmunityTime int

type PublishMessageResponse

+ ReceiptHandle string

v1.0.0

Jan 2, 2019

Changes in this version

+ const ALIYUN_MQ_ERR_NS

+ const ALIYUN_MQ_ERR_TEMPSTR

+ const AUTHORIZATION

+ const CONTENT_MD5

+ const CONTENT_TYPE

+ const ClientName

+ const ClientVersion

+ const DATE

+ const DELETE

+ const DefaultTimeout

+ const GET

+ const HOST

+ const KEEP_ALIVE

+ const MQ_VERSION

+ const POST

+ const SECURITY_TOKEN

+ var DefaultNumOfMessages int32 = 16

+ var ErrAckMessage = errors.TN(ALIYUN_MQ_ERR_NS, 102, ...)

+ var ErrGeneralAuthHeaderFailed = errors.TN(ALIYUN_MQ_ERR_NS, 3, "general auth header failed, {{.err}}")

+ var ErrMarshalMessageFailed = errors.TN(ALIYUN_MQ_ERR_NS, 2, "marshal message filed, {{.err}}")

+ var ErrMqServer = errors.TN(ALIYUN_MQ_ERR_NS, 101, ALIYUN_MQ_ERR_TEMPSTR)

+ var ErrSendRequestFailed = errors.TN(ALIYUN_MQ_ERR_NS, 5, "send request failed, {{.err}}")

+ var ErrSignMessageFailed = errors.TN(ALIYUN_MQ_ERR_NS, 1, "sign message failed, {{.err}}")

+ var ErrUnmarshalErrorResponseFailed = errors.TN(ALIYUN_MQ_ERR_NS, 7, ...)

+ var ErrUnmarshalResponseFailed = errors.TN(ALIYUN_MQ_ERR_NS, 8, "unmarshal response failed, {{.err}}")

+ func ParseError(resp ErrorResponse, resource string) (err error)

+ type AckMessageErrorEntry struct

+ ErrorCode string

+ ErrorMessage string

+ ReceiptHandle string

+ XMLName xml.Name

+ type AckMessageErrorResponse struct

+ FailedMessages []AckMessageErrorEntry

+ XMLName xml.Name

+ type AliyunMQAckMsgDecoder struct

+ func (p *AliyunMQAckMsgDecoder) Decode(reader io.Reader, v interface{}) (err error)

+ func (p *AliyunMQAckMsgDecoder) DecodeError(bodyBytes []byte, resource string, requestId string) (decodedError error, err error)

+ type AliyunMQClient struct

+ func (p *AliyunMQClient) GetConsumer(instanceId string, topicName string, consumer string, messageTag string) MQConsumer

+ func (p *AliyunMQClient) GetCredential() Credential

+ func (p *AliyunMQClient) GetEndpoint() string

+ func (p *AliyunMQClient) GetProducer(instanceId string, topicName string) MQProducer

+ func (p *AliyunMQClient) Send(decoder MQDecoder, method Method, headers map[string]string, ...) (statusCode int, err error)

+ func (p *AliyunMQClient) Send0(method Method, headers map[string]string, message interface{}, resource string) (*fasthttp.Response, error)

+ type AliyunMQConsumer struct

+ func (p *AliyunMQConsumer) AckMessage(receiptHandles []string) (err error)

+ func (p *AliyunMQConsumer) ConsumeMessage(respChan chan ConsumeMessageResponse, errChan chan error, numOfMessages int32, ...)

+ func (p *AliyunMQConsumer) Consumer() string

+ func (p *AliyunMQConsumer) InstanceId() string

+ func (p *AliyunMQConsumer) MessageTag() string

+ func (p *AliyunMQConsumer) TopicName() string

+ type AliyunMQDecoder struct

+ func (p *AliyunMQDecoder) Decode(reader io.Reader, v interface{}) (err error)

+ func (p *AliyunMQDecoder) DecodeError(bodyBytes []byte, resource string, requestId string) (decodedError error, err error)

+ type AliyunMQProducer struct

+ func (p *AliyunMQProducer) InstanceId() string

+ func (p *AliyunMQProducer) PublishMessage(message PublishMessageRequest) (resp PublishMessageResponse, err error)

+ func (p *AliyunMQProducer) TopicName() string

+ type ConsumeMessageEntry struct

+ ConsumedTimes int64

+ FirstConsumeTime int64

+ MessageBody string

+ MessageBodyMD5 string

+ MessageId string

+ MessageTag string

+ NextConsumeTime int64

+ PublishTime int64

+ ReceiptHandle string

+ type ConsumeMessageResponse struct

+ Messages []ConsumeMessageEntry

+ XMLName xml.Name

+ type Credential interface

+ AccessKeyId func() string

+ AccessKeySecret func() string

+ SecurityToken func() string

+ Signature func(method Method, headers map[string]string, resource string) (signature string, err error)

+ type ErrAckItem struct

+ ErrorCode string

+ ErrorHandle string

+ ErrorMsg string

+ type ErrorResponse struct

+ Code string

+ HostId string

+ Message string

+ RequestId string

+ XMLName xml.Name

+ type MQClient interface

+ GetConsumer func(instanceId string, topicName string, consumer string, messageTag string) MQConsumer

+ GetCredential func() Credential

+ GetEndpoint func() string

+ GetProducer func(instanceId string, topicName string) MQProducer

+ func NewAliyunMQClient(endpoint, accessKeyId, accessKeySecret, securityToken string) MQClient

+ type MQConsumer interface

+ AckMessage func(receiptHandles []string) (err error)

+ ConsumeMessage func(respChan chan ConsumeMessageResponse, errChan chan error, numOfMessages int32, ...)

+ Consumer func() string

+ InstanceId func() string

+ MessageTag func() string

+ TopicName func() string

+ type MQCredential struct

+ func NewMQCredential(accessKeyId string, accessKeySecret string, securityToken string) *MQCredential

+ func (p *MQCredential) AccessKeyId() string

+ func (p *MQCredential) AccessKeySecret() string

+ func (p *MQCredential) SecurityToken() string

+ func (p *MQCredential) Signature(method Method, headers map[string]string, resource string) (signature string, err error)

+ type MQDecoder interface

+ Decode func(reader io.Reader, v interface{}) (err error)

+ DecodeError func(bodyBytes []byte, resource string, requestId string) (decodedError error, err error)

+ func NewAliyunMQAckMsgDecoder() MQDecoder

+ func NewAliyunMQDecoder() MQDecoder

+ type MQProducer interface

+ InstanceId func() string

+ PublishMessage func(message PublishMessageRequest) (resp PublishMessageResponse, err error)

+ TopicName func() string

+ type MessageResponse struct

+ Code string

+ HostId string

+ Message string

+ RequestId string

+ XMLName xml.Name

+ type Method string

+ type PublishMessageRequest struct

+ MessageBody string

+ MessageTag string

+ XMLName xml.Name

+ type PublishMessageResponse struct

+ MessageBodyMD5 string

+ MessageId string

+ type ReceiptHandles struct

+ ReceiptHandles []string

+ XMLName xml.Name

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL