alimns

package module

Go to main page

Versions in this module

v2

v2.1.11

Jun 26, 2021

Changes in this version

type M

+ MessageID string

v2.1.10

Oct 28, 2020

v2.1.9

Sep 28, 2020

v2.1.8

Aug 5, 2020

v2.1.7

Jul 1, 2020

v2.1.6

Jun 17, 2020

v2.1.5

Jun 11, 2020

v2.1.4

Jun 11, 2020

v2.1.3

Jun 4, 2020

Changes in this version

+ func HandleErrFrom(ctx context.Context) error

v2.1.2

Jun 4, 2020

Changes in this version

type Client

+ func (c *Client) SetAfter(after After)

+ func (c *Client) SetBefore(before Before)

v2.1.1

Jun 4, 2020

Changes in this version

+ type After func(ctx context.Context)

+ type Before func(m *M) (context.Context, error)

v2.1.0

May 29, 2020

Changes in this version

type Queue

+ PullWait bool

v2.0.6

May 25, 2020

Changes in this version

+ func DefaultHook(callback func(entryJson string, fieldsJson string)) func(entry Entry) error

+ func Hooks(hooks ...func(entry Entry) error) zap.Option

+ func NewLogger() (logger *zap.Logger, err error)

+ type Entry struct

+ Caller string

+ Err error

+ ErrStr string

+ Fields []zap.Field

+ FieldsJSON string

+ Level zapcore.Level

+ LevelStr string

+ LoggerName string

+ Message string

+ Stack string

+ func NewEntryFromZapEntry(ent zapcore.Entry) Entry

v2.0.5

May 20, 2020

v2.0.4

May 18, 2020

v2.0.3

May 14, 2020

v2.0.2

May 9, 2020

v2.0.1

May 9, 2020

v2.0.0

May 9, 2020

Changes in this version

+ const BackOffRetryStrategy

+ const ExponentialDecayRetryStrategy

+ const JSONNotifyFormat

+ const SimplifiedNotifyFormat

+ const XMLNotifyFormat

+ func Base64Md5(s string) (string, error)

+ func ErrFrom(ctx context.Context) error

+ func IsBase64(s string) bool

+ func IsCreateQueueConflict(err error) bool

+ func IsCreateQueueNoContent(err error) bool

+ func IsHandleCrash(err error) bool

+ func IsInternalError(err error) bool

+ func IsMessageBodyLimit(err error) bool

+ func IsMessageDelaySecondsOutOfRange(err error) bool

+ func IsSendMessageTimeout(err error) bool

+ func IsUnknown(err error) bool

+ func IsVisibilityTimeout(err error) bool

+ func Md5(s string) ([]byte, error)

+ func Parallel() int

+ func TimestampInMs() int64

+ type Backoff interface

+ Backoff func() int

+ type BackoffError struct

+ Err error

+ N int

+ func (err BackoffError) Backoff() int

+ func (err BackoffError) Error() string

+ func (err BackoffError) Unwrap() error

+ type BatchPeekMessageResponse struct

+ PeekMessages []*PeekMessage

+ XMLName xml.Name

+ XMLNs string

+ type BatchReceiveMessageResponse struct

+ ReceiveMessages []*ReceiveMessage

+ XMLName xml.Name

+ XMLNs string

+ type BatchSendMessageResponse struct

+ SendMessages []*SendMessage

+ XMLName xml.Name

+ XMLNs string

+ type Builder interface

+ Handle func(ctx context.Context) error

+ type ChangeVisibilityTimeoutResponse struct

+ NextVisibleTime int64

+ ReceiptHandle string

+ XMLName xml.Name

+ XMLNs string

+ type Clean func(ctx context.Context)

+ type Client struct

+ func NewClient(config Config) (*Client, error)

+ func (c *Client) AddLogHook(f LogHook)

+ func (c *Client) BatchPeekMessage(name string) (*BatchPeekMessageResponse, error)

+ func (c *Client) BatchReceiveMessage(name string, setters ...ReceiveMessageParamSetter) (*BatchReceiveMessageResponse, error)

+ func (c *Client) BatchSendMessage(name string, messageList ...*Message) (*BatchSendMessageResponse, error)

+ func (c *Client) ChangeVisibilityTimeout(name, receiptHandle string, visibilityTimeout int) (*ChangeVisibilityTimeoutResponse, error)

+ func (c *Client) CreateQueue(name string, setters ...QueueAttributeSetter) (string, error)

+ func (c *Client) CreateTopic(name string, setters ...TopicAttributeSetter) error

+ func (c *Client) DeleteMessage(name, receiptHandle string) error

+ func (c *Client) DeleteQueue(name string) error

+ func (c *Client) DeleteTopic(name string) error

+ func (c *Client) EnableDebug()

+ func (c *Client) GetQueueAttributes(name string) (*QueueAttributeResponse, error)

+ func (c *Client) ListQueue(request *ListQueueRequest) (*ListQueueResponse, error)

+ func (c *Client) PeekMessage(name string) (*PeekMessageResponse, error)

+ func (c *Client) PublishMessage(topic, message string, setters ...PublishMessageParamSetter) (string, error)

+ func (c *Client) QueueMetaOverride(name string, setters ...QueueAttributeSetter) error

+ func (c *Client) ReceiveMessage(name string, setters ...ReceiveMessageParamSetter) (*ReceiveMessageResponse, error)

+ func (c *Client) SendBase64EncodedJSONMessage(name string, messageBody interface{}, setters ...MessageSetter) (*SendMessageResponse, error)

+ func (c *Client) SetClean(clean Clean)

+ func (c *Client) SetMakeContext(makeContext MakeContext)

+ func (c *Client) SetQueuePrefix(prefix string)

+ func (c *Client) SetTopicAttributes(topic string, setters ...TopicAttributeSetter) error

+ func (c *Client) Subscribe(topic, subscription string, endpoint EndPointer, ...) error

+ func (c *Client) Unsubscribe(topic, subscription string) error

+ type Cmdable interface

+ Eval func(script string, keys []string, args ...interface{}) *redis.Cmd

+ Expire func(key string, expiration time.Duration) *redis.BoolCmd

+ LRem func(key string, count int64, value interface{}) *redis.IntCmd

+ Pipeline func() redis.Pipeliner

+ RPush func(key string, values ...interface{}) *redis.IntCmd

+ SetNX func(key string, value interface{}, expiration time.Duration) *redis.BoolCmd

+ type Codec interface

+ Decode func([]byte, interface{}) error

+ Encode func(interface{}) ([]byte, error)

+ type Config struct

+ AccessKeyID string

+ AccessKeySecret string

+ Endpoint string

+ QueuePrefix string

+ type Consumer struct

+ func NewConsumer(client *Client) *Consumer

+ func (c *Consumer) AddQueue(q *Queue) error

+ func (c *Consumer) BatchListQueue() error

+ func (c *Consumer) ConsumeQueueMessage(queue *Queue)

+ func (c *Consumer) CreateQueueList(fetchQueueReady chan struct{}) chan struct{}

+ func (c *Consumer) LongPollQueueMessage(queue *Queue)

+ func (c *Consumer) OnReceive(queue *Queue, receiveMsg *ReceiveMessage)

+ func (c *Consumer) PeriodicallyFetchQueues() chan struct{}

+ func (c *Consumer) PopCount() int32

+ func (c *Consumer) Run()

+ func (c *Consumer) Schedule(createQueueReady chan struct{})

+ type EndPointer interface

+ EndPoint func() (string, error)

+ type HTTPEndPoint string

+ func (ep HTTPEndPoint) EndPoint() (string, error)

+ type Handle func(ctx context.Context) error

+ type JSONCodec struct

+ func (codec JSONCodec) Decode(data []byte, value interface{}) error

+ func (codec JSONCodec) Encode(value interface{}) ([]byte, error)

+ type ListQueueRequest struct

+ Marker string

+ Prefix string

+ RetNumber string

+ type ListQueueResponse struct

+ NextMarker string

+ Queues []*QueueData

+ XMLName xml.Name

+ XMLNs string

+ type LogHook func(entry zapcore.Entry)

+ type M struct

+ EnqueueTime int64

+ MessageBody string

+ QueueName string

+ ReceiptHandle string

+ func MFrom(ctx context.Context) *M

+ func (m *M) Decode(v interface{}) error

+ type MakeContext func(m *M) (context.Context, error)

+ type Message struct

+ DelaySeconds int

+ MessageBody string

+ Priority int

+ XMLName xml.Name

+ XMLNs string

+ func DefaultMessage() Message

+ type MessageSetter func(msg *Message) error

+ func WithMessageDelaySeconds(delay int) MessageSetter

+ func WithMessagePriority(priority int) MessageSetter

+ type MnsError string

+ func (e MnsError) Error() string

+ type ModifiedAttribute struct

+ DelaySeconds *int

+ LoggingEnabled *bool

+ MaximumMessageSize int

+ MessageRetentionPeriod int

+ PollingWaitSeconds *int

+ VisibilityTimeout int

+ XMLName xml.Name

+ func DefaultQueueAttri() ModifiedAttribute

+ type PeekMessage struct

+ DequeueCount int

+ EnqueueTime int64

+ FirstDequeueTime int64

+ MessageBody string

+ MessageBodyMD5 string

+ MessageID string

+ Priority int

+ type PeekMessageResponse struct

+ type Producer struct

+ func NewProducer(client *Client) *Producer

+ type PublishMessageParam struct

+ MessageAttributes string

+ MessageBody string

+ MessageTag string

+ XMLName xml.Name

+ type PublishMessageParamSetter func(attri *PublishMessageParam) error

+ func WithMessageTag(filterTag string) PublishMessageParamSetter

+ type Queue struct

+ AttributeSetters []QueueAttributeSetter

+ Name string

+ Parallel int

+ func (q *Queue) Stop()

+ type QueueAttributeResponse struct

+ Activemessages string

+ CreateTime string

+ DelayMessages string

+ DelaySeconds int

+ InactiveMessages string

+ LastModifyTime string

+ LoggingEnabled bool

+ MaximumMessageSize int

+ MessageRetentionPeriod int

+ PollingWaitSeconds int

+ QueueName string

+ VisibilityTimeout int

+ XMLName xml.Name

+ type QueueAttributeSetter func(attri *ModifiedAttribute) error

+ func WithDelaySeconds(s int) QueueAttributeSetter

+ func WithLoggingEnabled(flag bool) QueueAttributeSetter

+ func WithMaximumMessageSize(size int) QueueAttributeSetter

+ func WithMessageRetentionPeriod(s int) QueueAttributeSetter

+ func WithPollingWaitSeconds(s int) QueueAttributeSetter

+ func WithVisibilityTimeout(s int) QueueAttributeSetter

+ type QueueData struct

+ QueueURL string

+ type QueueEndPoint struct

+ AccountID string

+ QueueName string

+ Region string

+ func (ep QueueEndPoint) EndPoint() (string, error)

+ type ReceiveMessage struct

+ DequeueCount int

+ EnqueueTime int64

+ FirstDequeueTime int64

+ MessageBody string

+ MessageBodyMD5 string

+ MessageID string

+ NextVisibleTime int64

+ Priority int

+ ReceiptHandle string

+ XMLName xml.Name

+ XMLNs string

+ type ReceiveMessageParam struct

+ NumOfMessages int

+ WaitSeconds *int

+ func DefaultBatchReceiveMessage() ReceiveMessageParam

+ func DefaultReceiveMessage() ReceiveMessageParam

+ type ReceiveMessageParamSetter func(*ReceiveMessageParam) error

+ func WithReceiveMessageNumOfMessages(num int) ReceiveMessageParamSetter

+ func WithReceiveMessageWaitSeconds(s int) ReceiveMessageParamSetter

+ type ReceiveMessageResponse struct

+ type RespErr struct

+ Code string

+ HostID string

+ Message string

+ RequestID string

+ XMLName xml.Name

+ XMLNs string

+ type SendMessage struct

+ ErrorCode string

+ ErrorMessage string

+ MessageBodyMD5 string

+ MessageID string

+ ReceiptHandle string

+ XMLName xml.Name

+ XMLNs string

+ type SendMessageResponse struct

+ type SubscribeParam struct

+ EndPoint string

+ FilterTag string

+ NotifyContentFormat string

+ NotifyStrategy string

+ XMLName xml.Name

+ type SubscribeParamSetter func(attri *SubscribeParam) error

+ func WithFilterTag(filterTag string) SubscribeParamSetter

+ func WithNotifyContentFormat(s string) SubscribeParamSetter

+ func WithNotifyStrategy(ns string) SubscribeParamSetter

+ type TopicAttribute struct

+ LoggingEnabled bool

+ MaximumMessageSize int

+ XMLName xml.Name

+ func DefaultTopicAttr() TopicAttribute

+ type TopicAttributeSetter func(attri *TopicAttribute) error

+ func TopicWithLoggingEnabled(flag bool) TopicAttributeSetter

+ func TopicWithMaximumMessageSize(size int) TopicAttributeSetter

+ type Transient interface

+ Transient func() bool

+ type TransientError struct

+ Err error

+ func (err TransientError) Error() string

+ func (err TransientError) Transient() bool

+ func (err TransientError) Unwrap() error

Other modules containing this package

github.com/xiaojiaoyu100/aliyun-mns

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