workers

Oct 19, 2023

Changes in this version

+ type NamedTask interface

+ Name func() (name string)

Mar 22, 2023

Changes in this version

+ var ErrLongTaskNormalClosed = errors.New("normal closed")

+ var ErrLongTaskTimeout = errors.New("timeout")

+ var ErrNoHeartbeatInLongTask = errors.New("no heartbeat")

+ var ErrNoTimeoutInLongTask = errors.New("no timeout")

+ type AbstractLongTask struct

+ func NewAbstractLongTask(initialTimeout time.Duration) *AbstractLongTask

+ func (task *AbstractLongTask) Aborted() (ok bool, cause error)

+ func (task *AbstractLongTask) Close()

+ func (task *AbstractLongTask) Heartbeat() (initialTimeout time.Duration, ch <-chan time.Duration)

+ func (task *AbstractLongTask) OnAbort(cause error)

+ func (task *AbstractLongTask) Touch(nextAliveTimeout time.Duration)

+ type LongTask interface

+ Heartbeat func() (initialTimeout time.Duration, ch <-chan time.Duration)

+ OnAbort func(cause error)

Feb 19, 2023

Changes in this version

+ var TimeoutErr = fmt.Errorf("workers execute timeout")

+ type Group interface

+ Add func(key string, task GroupTask)

+ Run func(ctx context.Context) (future GroupFuture)

+ type GroupFuture interface

+ Wait func(ctx context.Context) (result GroupResult, err error)

+ type GroupResult interface

+ Errors func() (err map[string]error)

+ Results func() (results map[string]interface{})

+ Succeed func() (ok bool)

+ type GroupTask interface

+ Execute func(ctx context.Context) (result interface{}, err error)

type Workers

+ Group func() (group Group)

Jun 7, 2022

Changes in this version

type Option

+ func MaxIdleWorkerDuration(d time.Duration) Option

+ func MaxWorkers(max int) Option

type Options

+ MaxIdleWorkerDuration time.Duration

+ MaxWorkers int

+ type Task interface

+ Execute func()

type Workers

+ Dispatch func(task Task) (ok bool)

+ MustDispatch func(task Task)

Jun 7, 2022

Changes in this version

+ type Handler interface

+ Handle func(payload interface{})

type Option

+ func Concurrency(concurrency int) Option

+ func WorkerMaxIdleDuration(d time.Duration) Option

type Options

+ WorkerMaxIdleDuration time.Duration

type Workers

+ Close func()

Aug 21, 2021

Changes in this version

type Workers

+ func New(handler UnitHandler, options ...Option) (w Workers, err error)

+ Execute func(action string, payload interface{}) (ok bool)

Aug 20, 2021

Changes in this version

+ const DefaultConcurrency

+ const DefaultMaxIdleTime

type Option

+ func WithConcurrency(concurrency int) Option

+ func WithMaxIdleTime(maxIdleTime time.Duration) Option

+ type Options struct

+ Concurrency int

+ MaxIdleTime time.Duration

+ type UnitHandler interface

+ Handle func(action string, payload interface{})

Jul 18, 2021

Changes in this version

+ type Execute func(v interface{}, meta map[string]string)

+ type Option struct

+ CommandBufferSize int

+ CommandTimeout time.Duration

+ Fn Execute

+ MaxIdleTime time.Duration

+ MaxWorkerNum int

+ type Unit struct

+ type Workers struct

+ func NewWorkers(option Option) (w *Workers)

+ func (w *Workers) Command(v interface{}, metaKvs ...string) (ok bool)

+ func (w *Workers) Start()

+ func (w *Workers) Stop()

+ func (w *Workers) Sync()