executor

Documentation

Index

• type LocalExecutor
  • func NewLocalExecutor(maxParallelism, maxQueueSize int) *LocalExecutor
  • func (ex *LocalExecutor) Close() error
  • func (ex *LocalExecutor) GetGroupTasks(groupID interface{}) int
  • func (ex *LocalExecutor) Start()
  • func (ex *LocalExecutor) Submit(t *Task) bool
  • func (ex *LocalExecutor) SubmitAfter(t *Task, after time.Duration) bool
• type Task
  • func (t *Task) ID() interface{}

Types

type LocalExecutor

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

func NewLocalExecutor

func NewLocalExecutor(maxParallelism, maxQueueSize int) *LocalExecutor

func (*LocalExecutor) Close

func (ex *LocalExecutor) Close() error

func (*LocalExecutor) GetGroupTasks

func (ex *LocalExecutor) GetGroupTasks(groupID interface{}) int

func (*LocalExecutor) Start

func (ex *LocalExecutor) Start()

func (*LocalExecutor) Submit

func (ex *LocalExecutor) Submit(t *Task) bool

func (*LocalExecutor) SubmitAfter

func (ex *LocalExecutor) SubmitAfter(t *Task, after time.Duration) bool

type Task

type Task struct {
	// TaskID is used to ensure that there is only one instance of this task
	TaskID interface{}

	// GroupID is used to group together tasks.
	GroupID interface{}

	// Apply is the work that the task comprises.
	Apply func() error
}

Task is the unit of execution that the executor will execute.

func (*Task) ID

func (t *Task) ID() interface{}