async

Jan 30, 2024

Changes in this version

type AtomicGroup

+ func (d *AtomicGroup) Name() string

+ func (d *AtomicGroup) SetName(name string)

+ type AtomicGroupKey string

+ type ErrorCounter struct

+ func NewErrorCounter(maxErrors int, msg string) *ErrorCounter

+ func (ec *ErrorCounter) Error() error

+ func (ec *ErrorCounter) MaxErrors() int

+ func (ec *ErrorCounter) SetError(err error) bool

+ type FiniteCommandWithErrorCounter struct

+ func (c FiniteCommandWithErrorCounter) Run(ctx context.Context) error

+ type Runner interface

+ Run func(context.Context) error

Oct 13, 2023

Changes in this version

+ type SingleShotCommand struct

+ Init func(context.Context) error

+ Interval time.Duration

+ Runable func(context.Context) error

+ func (c SingleShotCommand) Run(ctx context.Context) error

Aug 22, 2023

Changes in this version

+ type MultiClientScheduler struct

+ func NewMultiClientScheduler() *MultiClientScheduler

+ func (s *MultiClientScheduler) Enqueue(requestID int32, taskType TaskType, taskFn taskFunction, resFn resultFunction) (ignored bool)

+ func (s *MultiClientScheduler) Stop()

Aug 1, 2023

Changes in this version

+ var ErrTaskOverwritten = errors.New("task overwritten")

+ type ReplacementPolicy = int

+ const ReplacementPolicyCancelOld

+ const ReplacementPolicyIgnoreNew

+ type Scheduler struct

+ func NewScheduler() *Scheduler

+ func (s *Scheduler) Enqueue(taskType TaskType, taskFn taskFunction, resFn resultFunction) (ignored bool)

+ func (s *Scheduler) Stop()

+ type TaskType struct

+ ID int64

+ Policy ReplacementPolicy

May 8, 2023

Changes in this version

+ type Commander interface

+ Command func() Command

+ type QueuedAtomicGroup struct

+ func NewQueuedAtomicGroup(parent context.Context, limit uint32) *QueuedAtomicGroup

+ func (d *QueuedAtomicGroup) Add(cmd Command)

Sep 15, 2021

Changes in this version

+ type AtomicGroup struct

+ func NewAtomicGroup(parent context.Context) *AtomicGroup

+ func (d *AtomicGroup) Add(cmd Command)

+ func (d *AtomicGroup) Error() error

+ func (d *AtomicGroup) Stop()

+ func (d *AtomicGroup) Wait()

+ func (d *AtomicGroup) WaitAsync() <-chan struct{}

+ type Command func(context.Context) error

+ type FiniteCommand struct

+ Interval time.Duration

+ Runable func(context.Context) error

+ func (c FiniteCommand) Run(ctx context.Context) error

+ type Group struct

+ func NewGroup(parent context.Context) *Group

+ func (g *Group) Add(cmd Command)

+ func (g *Group) Stop()

+ func (g *Group) Wait()

+ func (g *Group) WaitAsync() <-chan struct{}

+ type InfiniteCommand struct

+ Interval time.Duration

+ Runable func(context.Context) error

+ func (c InfiniteCommand) Run(ctx context.Context) error