queue

Documentation

Index

• type CallBackFunc
• type Queue
  • func NewQueue(capacity, worker int, workFunc WorkFunc, onSuccess, onFail CallBackFunc, ...) *Queue
  • func (q *Queue) Push(key string, value interface{})
  • func (q *Queue) PushAfter(key string, value interface{}, after time.Duration)
  • func (q *Queue) Run()
• type WorkFunc

Types

type CallBackFunc

type CallBackFunc func(obj interface{})

type Queue

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

func NewQueue

func NewQueue(capacity, worker int, workFunc WorkFunc, onSuccess, onFail CallBackFunc, stopCh <-chan struct{}) *Queue

func (*Queue) Push

func (q *Queue) Push(key string, value interface{})

func (*Queue) PushAfter

func (q *Queue) PushAfter(key string, value interface{}, after time.Duration)

func (*Queue) Run

func (q *Queue) Run()

type WorkFunc

type WorkFunc func(obj interface{}) error