redis

Documentation

Index

• type ReliableQueue
  • func NewReliableQueue(key string) ReliableQueue
  • func (r ReliableQueue) Push(msg ...interface{}) error
  • func (r ReliableQueue) Subscribe(f func(val string))

Types

type ReliableQueue

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

可靠队列

func NewReliableQueue

func NewReliableQueue(key string) ReliableQueue

func (ReliableQueue) Push

func (r ReliableQueue) Push(msg ...interface{}) error

func (ReliableQueue) Subscribe

func (r ReliableQueue) Subscribe(f func(val string))