aqueue

Documentation

Index

• type Queue
  • func New() *Queue
  • func (queue *Queue) Publish(channel string, message interface{}) (int64, error)
  • func (queue *Queue) Subscribe(channel string, callback callable, v interface{})

Types

type Queue

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

func New

func New() *Queue

New 虚拟构造 /**

func (*Queue) Publish

func (queue *Queue) Publish(channel string, message interface{}) (int64, error)

Publish 发布消息 /**

func (*Queue) Subscribe

func (queue *Queue) Subscribe(channel string, callback callable, v interface{})

Subscribe 订阅消息 /**