rainbond: github.com/goodrain/rainbond/mq/api/mq Index | Files

package mq

import "github.com/goodrain/rainbond/mq/api/mq"

Index

Package Files

mq.go

Variables

var DequeueNumber float64 = 0
var EnqueueNumber float64 = 0

type ActionMQ Uses

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 Uses

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

NewActionMQ new etcd mq

Package mq imports 10 packages (graph) and is imported by 4 packages. Updated 2019-02-19. Refresh now. Tools for package owners.