fqueue

Documentation

Index

• type FunctionCall
• type FunctionQueue
  • func NewFunctionQueue(name string) *FunctionQueue
  • func NewFunctionQueueWithSize(name string, size int) *FunctionQueue
  • func (fq *FunctionQueue) Enqueue(fn FunctionCall)
  • func (fq *FunctionQueue) Execute()
  • func (fq *FunctionQueue) RegisterCallback(callback chan error)

Types

type FunctionCall

type FunctionCall func() error

type FunctionQueue

type FunctionQueue struct {
	Name             string
	CallbackChannels []chan error
	DropCount        int
	// contains filtered or unexported fields
}

func NewFunctionQueue

func NewFunctionQueue(name string) *FunctionQueue

func NewFunctionQueueWithSize

func NewFunctionQueueWithSize(name string, size int) *FunctionQueue

func (*FunctionQueue) Enqueue

func (fq *FunctionQueue) Enqueue(fn FunctionCall)

func (*FunctionQueue) Execute

func (fq *FunctionQueue) Execute()

func (*FunctionQueue) RegisterCallback

func (fq *FunctionQueue) RegisterCallback(callback chan error)