queue

Documentation

Index

• type Queue
  • func NewQueue() *Queue
  • func (q *Queue) AddAction(Action func())
  • func (q *Queue) Addactions(actions map[string]func())
• type Worker
  • func NewWorker(queue *Queue) *Worker
  • func (w *Worker) Execute() bool

Types

type Queue

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

Queue holds name, list of actions and context with cancel.

func NewQueue

func NewQueue() *Queue

NewQueue instantiates new queue.

func (*Queue) AddAction

func (q *Queue) AddAction(Action func())

AddAction sends Action to the channel.

func (*Queue) Addactions

func (q *Queue) Addactions(actions map[string]func())

Addactions adds actions to the queue and cancels channel.

type Worker

type Worker struct {
	Queue *Queue
}

Worker responsible for queue serving.

func NewWorker

func NewWorker(queue *Queue) *Worker

NewWorker initializes a new Worker.

func (*Worker) Execute

func (w *Worker) Execute() bool

Execute processes actions from the queue (actions channel).