Documentation

Index

Constants

This section is empty.

Variables

View Source
var DequeueNumber float64 = 0

DequeueNumber dequeue number

View Source
var EnqueueNumber float64 = 0

EnqueueNumber enqueue number

Functions

This section is empty.

Types

type ActionMQ

type ActionMQ interface {
	Enqueue(context.Context, string, string) error
	Dequeue(context.Context, string) (string, error)
	TopicIsExist(string) bool
	GetAllTopics() []string
	Start() error
	Stop() error
}

ActionMQ 队列操作

func NewActionMQ

func NewActionMQ(ctx context.Context, c option.Config) ActionMQ

NewActionMQ new etcd mq

Source Files