workqueue

Documentation

Index

• type ProcessType
• type ProcessingQueue
  • func (p *ProcessingQueue) Process(f func(item interface{}) error) error
• type Queue
  • func NewQueue() *Queue
  • func (n *Queue) Add(item interface{})
  • func (n *Queue) Close()
  • func (n *Queue) Done(item interface{})
  • func (n *Queue) Get() (item interface{}, quit bool)
  • func (n *Queue) Len() int
  • func (n *Queue) Remove(item interface{})
• type QueueAddType
• type QueueType

Types

type ProcessType

type ProcessType interface {
	Process(func(item interface{}) error)
}

type ProcessingQueue

type ProcessingQueue struct {
	*Queue
}

func (*ProcessingQueue) Process

func (p *ProcessingQueue) Process(f func(item interface{}) error) error

type Queue

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

func NewQueue

func NewQueue() *Queue

func (*Queue) Add

func (n *Queue) Add(item interface{})

func (*Queue) Close

func (n *Queue) Close()

func (*Queue) Done

func (n *Queue) Done(item interface{})

func (*Queue) Get

func (n *Queue) Get() (item interface{}, quit bool)

func (*Queue) Len

func (n *Queue) Len() int

func (*Queue) Remove

func (n *Queue) Remove(item interface{})

Remove will prevent item from being processed

type QueueAddType

type QueueAddType interface {
	Add(interface{})
}

type QueueType

type QueueType interface {
	QueueAddType
	Get() (interface{}, bool)
	Done(interface{})
	Remove(interface{})
	Close()
	Len() int
}