taskpool

Documentation

Overview

Package taskpool wraps execution task pool and cancel task pool

Index

• type Manager
  • func (m Manager) HasJob(jobID string) bool
  • func (m Manager) ShutdownAndWait(timeout time.Duration)
  • func (m Manager) Submit(log log.T, jobID string, job task.Job) error
• type T
  • func NewTaskPool(log log.T, documentWorkersLimit int, ...) T

Types

type Manager

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

Manager contains execution pool and cancel pool

func (Manager) HasJob

func (m Manager) HasJob(jobID string) bool

HasJob returns if execution pool has specified job

func (Manager) ShutdownAndWait

func (m Manager) ShutdownAndWait(timeout time.Duration)

ShutdownAndWait wait and shutdown the task pool

func (Manager) Submit

func (m Manager) Submit(log log.T, jobID string, job task.Job) error

Submit submits the task to the execution pool

type T

type T interface {
	Submit(log log.T, jobID string, job task.Job) error
	ShutdownAndWait(timeout time.Duration)
	HasJob(jobID string) bool
}

T represents the interface for taskpool

func NewTaskPool

func NewTaskPool(log log.T, documentWorkersLimit int, cancelWaitDurationMillisecond time.Duration) T

NewTaskPool creates a new instance of Manager