runners

Feb 12, 2023

Changes in this version

+ type Processable func() error

+ type Processor struct

+ func (p *Processor) Process(proc Processable) (err error)

type Service

+ func (svc *Service) RunWait(fn func(context.Context)) bool

type WorkerPool

+ func (pool *WorkerPool) MustEnqueueCtx(ctx context.Context, fn WorkerFunc) (ok bool)

Feb 4, 2023

Changes in this version

+ func CtxWithCancel() (context.Context, context.CancelFunc)

+ type CancelCtx (<-chan struct{})

+ func (CancelCtx) Deadline() (time.Time, bool)

+ func (CancelCtx) Value(key interface{}) interface{}

+ func (ctx CancelCtx) Done() <-chan struct{}

+ func (ctx CancelCtx) Err() error

+ func (ctx CancelCtx) GoString() string

+ func (ctx CancelCtx) String() string

type WorkerPool

+ func (pool *WorkerPool) Done() <-chan struct{}

Jan 5, 2023

Changes in this version

+ func Closed() context.Context

type Service

+ func (svc *Service) While(fn func())

Sep 1, 2022

Changes in this version

type Service

+ func (svc *Service) GoRun(fn func(context.Context)) bool

type WorkerPool

+ func (pool *WorkerPool) EnqueueCtx(ctx context.Context, fn WorkerFunc)

+ func (pool *WorkerPool) EnqueueNow(fn WorkerFunc) bool

Jan 2, 2022

Changes in this version

+ type WorkerFunc func(context.Context)

+ type WorkerPool struct

+ func NewWorkerPool(workers int, queue int) WorkerPool

+ func (pool *WorkerPool) Enqueue(fn WorkerFunc)

+ func (pool *WorkerPool) EnqueueNoBlock(fn WorkerFunc) bool

+ func (pool *WorkerPool) Queue() int

+ func (pool *WorkerPool) Running() bool

+ func (pool *WorkerPool) Start() bool

+ func (pool *WorkerPool) Stop() bool

+ func (pool *WorkerPool) Workers() int

Nov 12, 2021

Changes in this version

+ func ContextWithCancel() (context.Context, context.CancelFunc)

+ func GoRun(handOff time.Duration, fn func(ctx context.Context) error, ...) (func(), bool)

+ func RetryGoRun(retries int, handOff time.Duration, fn func(ctx context.Context) error, ...) (func(), bool)

+ func Run(fn func() error) (err error)

+ type FuncRunner struct

+ ErrorHandler func(err error) error

+ HandOff time.Duration

+ func (r *FuncRunner) Err() error

+ func (r *FuncRunner) Go(fn func(ctx context.Context) error) bool

+ func (r *FuncRunner) Stop() bool

Oct 31, 2021

Changes in this version

+ type Service struct

+ func (svc *Service) Done() <-chan struct{}

+ func (svc *Service) Run(fn func(context.Context)) bool

+ func (svc *Service) Running() bool

+ func (svc *Service) Stop(fn func()) bool

+ func (svc *Service) Stopping() bool