taskqueue

Documentation

Index

• type BaseTaskQueue
  • func NewBaseTaskQueue() *BaseTaskQueue
  • func (btq *BaseTaskQueue) Add(task QueueTask)
  • func (btq *BaseTaskQueue) Start()
• type QueueTask
• type TaskQueue

Types

type BaseTaskQueue

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

func NewBaseTaskQueue

func NewBaseTaskQueue() *BaseTaskQueue

func (*BaseTaskQueue) Add

func (btq *BaseTaskQueue) Add(task QueueTask)

func (*BaseTaskQueue) Start

func (btq *BaseTaskQueue) Start()

type QueueTask

type QueueTask interface {
	Execute() error
}

type TaskQueue

type TaskQueue interface {
	Start()
	Add(task QueueTask)
	// contains filtered or unexported methods
}