mq

Documentation

Index

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

Variables

var DequeueNumber float64 = 0

var EnqueueNumber float64 = 0

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