worker

Documentation

Index

• type KeyedWorkQueue
  • func NewKeyedWorkQueue(log *logrus.Entry, buffer int) KeyedWorkQueue
  • func (d KeyedWorkQueue) Close()
  • func (d KeyedWorkQueue) Dispatch(key string, work Work)
  • func (d KeyedWorkQueue) Wait()
• type Work

Types

type KeyedWorkQueue

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

func NewKeyedWorkQueue

func NewKeyedWorkQueue(log *logrus.Entry, buffer int) KeyedWorkQueue

func (KeyedWorkQueue) Close

func (d KeyedWorkQueue) Close()

func (KeyedWorkQueue) Dispatch

func (d KeyedWorkQueue) Dispatch(key string, work Work)

func (KeyedWorkQueue) Wait

func (d KeyedWorkQueue) Wait()

type Work

type Work func()