controllerqueue

Documentation

Index

• func MaxRetries(n int) option
• func NumWorkers(n int) option
• func Period(d time.Duration) option
• type Queue
  • func New(name string, f QueueFunc, opts ...option) *Queue
  • func (cq *Queue) Add(item interface{})
  • func (cq *Queue) Get() (interface{}, bool)
  • func (cq *Queue) Len() int
  • func (cq *Queue) Start(quit <-chan struct{})
• type QueueFunc

Functions

func MaxRetries

func MaxRetries(n int) option

func NumWorkers

func NumWorkers(n int) option

func Period

func Period(d time.Duration) option

Types

type Queue

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

func New

func New(name string, f QueueFunc, opts ...option) *Queue

func (*Queue) Add

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

func (*Queue) Get

func (cq *Queue) Get() (interface{}, bool)

func (*Queue) Len

func (cq *Queue) Len() int

func (*Queue) Start

func (cq *Queue) Start(quit <-chan struct{})

type QueueFunc

type QueueFunc func(interface{}) error