queue

Documentation

Index

• type InnerChanTaskQueue
  • func (q *InnerChanTaskQueue) Append(task meta.TaskSpecInterface)
  • func (q *InnerChanTaskQueue) Pop() (meta.TaskSpecInterface, bool)
• type TaskQueue

Types

type InnerChanTaskQueue

type InnerChanTaskQueue struct {
	Ch chan meta.TaskSpecInterface
}

func (*InnerChanTaskQueue) Append

func (q *InnerChanTaskQueue) Append(task meta.TaskSpecInterface)

func (*InnerChanTaskQueue) Pop

func (q *InnerChanTaskQueue) Pop() (meta.TaskSpecInterface, bool)

type TaskQueue

type TaskQueue interface {
	Append(meta.TaskSpec)
	Pop() meta.TaskSpec
}