Documentation

Index

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

Constants

This section is empty.

Variables

var DequeueNumber float64 = 0

DequeueNumber dequeue number

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