pool

Dec 13, 2022

Changes in this version

+ type Pool struct

+ func New(minRoutines int, maxRoutines int, timeout time.Duration, logger *logr.Logger) *Pool

+ func (p *Pool) Dispatch(task Task) string

+ func (p *Pool) GetResult() *[]TaskStatus

+ func (p *Pool) Shutdown()

+ type Task interface

+ GetName func() string

+ Run func(workRoutine int) (interface{}, error)

+ type TaskStatus struct

+ AssignTime time.Time

+ Data interface{}

+ Duration time.Duration

+ Err error

+ Executor string

+ ID string

+ Name string

+ StartTime time.Time