mqs

package

v0.1.19 Latest Latest Go to latest Published: Jan 5, 2024 License: MulanPSL-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var InsQueue *workQueue

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

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

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

* Listening to the payment flow status change notification message queue

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

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

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

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

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

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

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

*

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

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

type ConsumeHandle func(v string) error

type ConsumeHandler interface {
	Consume(value string) error
}

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

* Listening to the payment flow status change notification message queue

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

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