taskpoll

Documentation

Index

• type TaskPollController
  • func NewTaskPollController(name string, concurrency uint, interval time.Duration, emptyWait time.Duration) *TaskPollController
  • func (tpc *TaskPollController) AwaitingCount() int
  • func (tpc *TaskPollController) Name() string
  • func (tpc *TaskPollController) Push(item TaskPollItem) TaskPollItem
  • func (tpc *TaskPollController) Remove(id string, exitCode TaskPollExitCode)
  • func (tpc *TaskPollController) Start()
• type TaskPollExitCode
• type TaskPollItem

Types

type TaskPollController

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

func NewTaskPollController

func NewTaskPollController(name string, concurrency uint, interval time.Duration, emptyWait time.Duration) *TaskPollController

func (*TaskPollController) AwaitingCount

func (tpc *TaskPollController) AwaitingCount() int

func (*TaskPollController) Name

func (tpc *TaskPollController) Name() string

func (*TaskPollController) Push

func (tpc *TaskPollController) Push(item TaskPollItem) TaskPollItem

func (*TaskPollController) Remove

func (tpc *TaskPollController) Remove(id string, exitCode TaskPollExitCode)

func (*TaskPollController) Start

func (tpc *TaskPollController) Start()

type TaskPollExitCode

type TaskPollExitCode uint

const (
	TPExitSuccess TaskPollExitCode = iota
	TPExitError
	TPExitInterrupt
)

type TaskPollItem

type TaskPollItem interface {
	ID() string
	TaskName() string
	Weight() uint
	Count() int

	Yield(i int, tpc *TaskPollController)
	OnExit(exitCode TaskPollExitCode)
	Init() TaskPollItem
}