Versions in this module Expand all Collapse all v1 v1.0.0 Jun 24, 2021 Changes in this version + const MinLogDuration + func NewQueueFramework(q ali_mns.AliMNSQueue, c cl.QueueConfig, h QueueEventHandlerInterface) *queueFramework + type DefaultEventHandler struct + func (d *DefaultEventHandler) AfterChangeVisibility(_ ali_mns.AliMNSQueue, _ *ali_mns.MessageReceiveResponse, ...) + func (d *DefaultEventHandler) AfterLaunch(_ QueueFramework) + func (d *DefaultEventHandler) BeforeChangeVisibility(_ ali_mns.AliMNSQueue, _ *ali_mns.MessageReceiveResponse) + func (d *DefaultEventHandler) BeforeLaunch(qf QueueFramework) + func (d *DefaultEventHandler) ConsumeMessage(_ []byte, _ *ali_mns.MessageReceiveResponse) error + func (d *DefaultEventHandler) OnChangeVisibilityFailed(_ ali_mns.AliMNSQueue, _ *ali_mns.MessageReceiveResponse, ...) + func (d *DefaultEventHandler) OnConsumeFailed(_ error, _ []byte, _ *ali_mns.MessageReceiveResponse) + func (d *DefaultEventHandler) OnError(err error, queue ali_mns.AliMNSQueue, resp *ali_mns.MessageReceiveResponse, ...) + func (d *DefaultEventHandler) OnParseMessageBodyFailed(_ error, _ *ali_mns.MessageReceiveResponse) + func (d *DefaultEventHandler) OnRecoverProcessing(_ QueueFramework) + func (d *DefaultEventHandler) OnWaitingMessage(qf QueueFramework) + func (d *DefaultEventHandler) OnWaitingProcessing(qf QueueFramework) + func (d *DefaultEventHandler) ParseMessageBody(resp *ali_mns.MessageReceiveResponse) ([]byte, error) + type QueueEventHandlerInterface interface + AfterChangeVisibility func(q ali_mns.AliMNSQueue, resp *ali_mns.MessageReceiveResponse, ...) + AfterLaunch func(qf QueueFramework) + BeforeChangeVisibility func(q ali_mns.AliMNSQueue, resp *ali_mns.MessageReceiveResponse) + BeforeLaunch func(qf QueueFramework) + ConsumeMessage func(body []byte, resp *ali_mns.MessageReceiveResponse) error + OnChangeVisibilityFailed func(q ali_mns.AliMNSQueue, resp *ali_mns.MessageReceiveResponse, ...) + OnConsumeFailed func(err error, body []byte, resp *ali_mns.MessageReceiveResponse) + OnError func(err error, q ali_mns.AliMNSQueue, rr *ali_mns.MessageReceiveResponse, ...) + OnParseMessageBodyFailed func(err error, resp *ali_mns.MessageReceiveResponse) + OnRecoverProcessing func(qf QueueFramework) + OnWaitingMessage func(qf QueueFramework) + OnWaitingProcessing func(qf QueueFramework) + ParseMessageBody func(resp *ali_mns.MessageReceiveResponse) ([]byte, error) + type QueueFramework interface + GetConfig func() cl.QueueConfig + GetStatistic func() *Statistic + HasEventHandler func() bool + HasValidQueue func() bool + Launch func() + RegisterBreakQueueOsSingal func(sigs ...os.Signal) + SetEventHandler func(h QueueEventHandlerInterface) + SetQueue func(q ali_mns.AliMNSQueue) + Stop func() + WaitProcessingSeconds func(pop bool) int + type Statistic struct + func (ss *Statistic) Fetch(paramName string) uint64 + func (ss *Statistic) HandleError(count ...uint64) + func (ss *Statistic) HandleSuccess(count ...uint64) + func (ss *Statistic) Loop(count ...uint64) + func (ss *Statistic) MessageReceived(count ...uint64) + func (ss *Statistic) Monitor() bool + func (ss *Statistic) MonitorLog() string + func (ss *Statistic) Performance() string + func (ss *Statistic) QueueError(count ...uint64) + func (ss *Statistic) Start() + func (ss *Statistic) Wait(count ...uint64) + func (ss Statistic) String() string