mqs

Documentation

Index

• Variables
• func MustNewQueue(topic string, handler ConsumeHandler) queue.MessageQueue
• func NewQueue(topic string, handler ConsumeHandler) (queue.MessageQueue, error)
• type AiQueue
  • func NewAiMq(ctx context.Context, svcCtx *svc.ServiceContext) *AiQueue
  • func (l *AiQueue) Consume(val string) error
• type Beta
  • func (b *Beta) Add(item interface{})
  • func (b *Beta) Done(item interface{})
  • func (b *Beta) Get() (item interface{})
• type CloudMq
  • func NewCloudMq(ctx context.Context, svcCtx *svc.ServiceContext) *CloudMq
  • func (l *CloudMq) Consume(val string) error
• type ConsumeHandle
• type ConsumeHandler
• type HpcMq
  • func NewHpcMq(ctx context.Context, svcCtx *svc.ServiceContext) *HpcMq
  • func (l *HpcMq) Consume(val string) error

Variables

var InsQueue *workQueue

Functions

func MustNewQueue

func MustNewQueue(topic string, handler ConsumeHandler) queue.MessageQueue

func NewQueue

func NewQueue(topic string, handler ConsumeHandler) (queue.MessageQueue, error)

Types

type AiQueue

type AiQueue struct {
	// contains filtered or unexported fields
}

* Listening to the payment flow status change notification message queue

func NewAiMq

func NewAiMq(ctx context.Context, svcCtx *svc.ServiceContext) *AiQueue

func (*AiQueue) Consume

func (l *AiQueue) Consume(val string) error

type Beta

type Beta struct {
	// contains filtered or unexported fields
}

func (*Beta) Add

func (b *Beta) Add(item interface{})

func (*Beta) Done

func (b *Beta) Done(item interface{})

func (*Beta) Get

func (b *Beta) Get() (item interface{})

type CloudMq

type CloudMq struct {
	// contains filtered or unexported fields
}

*

func NewCloudMq

func NewCloudMq(ctx context.Context, svcCtx *svc.ServiceContext) *CloudMq

func (*CloudMq) Consume

func (l *CloudMq) Consume(val string) error

type ConsumeHandle

type ConsumeHandle func(v string) error

type ConsumeHandler

type ConsumeHandler interface {
	Consume(value string) error
}

type HpcMq

type HpcMq struct {
	// contains filtered or unexported fields
}

* Listening to the payment flow status change notification message queue

func NewHpcMq

func NewHpcMq(ctx context.Context, svcCtx *svc.ServiceContext) *HpcMq

func (*HpcMq) Consume

func (l *HpcMq) Consume(val string) error