executors

package module

Go to main page

Versions in this module

v0

v0.1.4

Sep 28, 2024

Changes in this version

type Executor

+ ExecuteFunc func(fn func(ctx context.Context)) error

type ExecutorService

+ SubmitFunc func(fn func(ctx context.Context) (T, error)) (Future[T], error)

type PoolExecutor

+ func (p *PoolExecutor[T]) ExecuteFunc(fn func(ctx context.Context)) error

+ func (p *PoolExecutor[T]) SubmitFunc(fn func(ctx context.Context) (T, error)) (Future[T], error)

type PoolScheduleExecutor

+ func (p *PoolScheduleExecutor) ScheduleFunc(fn func(ctx context.Context), delay time.Duration) (CancelFunc, error)

+ func (p *PoolScheduleExecutor) ScheduleFuncAtCronRate(fn func(ctx context.Context), rule CRONRule) (CancelFunc, error)

+ func (p *PoolScheduleExecutor) ScheduleFuncAtFixRate(fn func(ctx context.Context), delay time.Duration) (CancelFunc, error)

type ScheduledExecutor

+ ScheduleFunc func(fn func(ctx context.Context), delay time.Duration) (CancelFunc, error)

+ ScheduleFuncAtCronRate func(fn func(ctx context.Context), rule CRONRule) (CancelFunc, error)

+ ScheduleFuncAtFixRate func(fn func(ctx context.Context), delay time.Duration) (CancelFunc, error)

v0.1.3

Nov 1, 2023

v0.1.2

Nov 1, 2023

v0.1.1

Aug 30, 2023

v0.1.0

Aug 13, 2023

Changes in this version

+ var ErrShutdown = errors.New("shutdown")

type DiscardErrorHandler

+ func (d DiscardErrorHandler) CatchError(runnable Runnable, e error)

+ type ErrorHandler interface

+ CatchError func(runnable Runnable, e error)

type ErrorHandlerFunc

+ func (f ErrorHandlerFunc) CatchError(runnable Runnable, e error)

+ type LogErrorHandler struct

+ func (d LogErrorHandler) CatchError(runnable Runnable, e error)

type NoopErrorHandler

+ func (d NoopErrorHandler) CatchError(runnable Runnable, e error)

v0.0.6

Aug 12, 2023

Changes in this version

+ var ErrInvalidCronExpr = errors.New("invalid corn expr")

+ var ErrInvalidCronTimezone = errors.New("invalid corn timezone")

+ func WithLogger(logger *slog.Logger) _PoolExecutorOption

+ type CRONRule struct

+ Expr string

+ Timezone string

type PoolScheduleExecutor

+ func (p *PoolScheduleExecutor) ScheduleAtCronRate(r Runnable, rule CRONRule) (CancelFunc, error)

type ScheduledExecutor

+ ScheduleAtCronRate func(r Runnable, rule CRONRule) (CancelFunc, error)

v0.0.5

Apr 23, 2022

v0.0.4

Apr 23, 2022

Changes in this version

+ type CancelFunc = func()

+ type PoolScheduleExecutor struct

+ func (p *PoolScheduleExecutor) Schedule(r Runnable, delay time.Duration) (CancelFunc, error)

+ func (p *PoolScheduleExecutor) ScheduleAtFixRate(r Runnable, period time.Duration) (CancelFunc, error)

+ func (p *PoolScheduleExecutor) Shutdown(ctx context.Context) error

+ type ScheduledExecutor interface

+ Schedule func(r Runnable, delay time.Duration) (CancelFunc, error)

+ ScheduleAtFixRate func(r Runnable, period time.Duration) (CancelFunc, error)

+ func NewPoolScheduleExecutor(opts ..._PoolExecutorOption) ScheduledExecutor

v0.0.3

Apr 1, 2022

Changes in this version

+ var ErrClosed = errors.New("closed")

+ var ErrFutureCanceled = errors.New("future canceled")

+ var ErrRejectedExecution = errors.New("rejected execution")

+ func WithErrorHandler(handler ExceptionHandler) _PoolExecutorOption

+ func WithExecuteTimeout(ts time.Duration) _PoolExecutorOption

+ func WithMaxBlockingTasks(max int) _PoolExecutorOption

+ func WithMaxConcurrent(concurrent int) _PoolExecutorOption

+ func WithRejectionHandler(handler RejectionHandler) _PoolExecutorOption

+ type Callable interface

+ Call func(ctx context.Context) (T, error)

+ type CallableFunc func(ctx context.Context) (T, error)

+ func (c CallableFunc[T]) Call(ctx context.Context) (T, error)

+ type CallerRunsRejectionPolicy struct

+ func (d CallerRunsRejectionPolicy) RejectExecution(runnable Runnable, e Executor) error

+ type CatchFunction func(err error)

+ type DiscardErrorHandler struct

+ func (d DiscardErrorHandler) CatchException(runnable Runnable, e error)

+ type DiscardRejectionPolicy struct

+ func (d DiscardRejectionPolicy) RejectExecution(runnable Runnable, e Executor) error

+ type ErrInvalidState struct

+ func (e ErrInvalidState) Error() string

+ type ErrPanic struct

+ Cause interface{}

+ func (e ErrPanic) Error() string

+ type ErrorHandlerFunc func(runnable Runnable, e error)

+ func (f ErrorHandlerFunc) CatchException(runnable Runnable, e error)

+ type ExceptionHandler interface

+ CatchException func(runnable Runnable, e error)

+ type Executor interface

+ Execute func(Runnable) error

+ Shutdown func(ctx context.Context) error

+ func NewPoolExecutor(opts ..._PoolExecutorOption) Executor

+ type ExecutorService interface

+ Submit func(callable Callable[T]) (Future[T], error)

+ func NewPoolExecutorService(opts ..._PoolExecutorOption) ExecutorService[T]

+ type Future interface

+ Cancel func() bool

+ Canceled func() bool

+ Catch func(catchFunc CatchFunction) Future[T]

+ Completed func() bool

+ CompletedError func() bool

+ Get func(ctx context.Context) (T, error)

+ Then func(thenFunc ThenFunction[T]) Future[T]

+ type FutureTask struct

+ func NewFutureTask(callable Callable[T]) *FutureTask[T]

+ func (f *FutureTask[T]) Cancel() bool

+ func (f *FutureTask[T]) Canceled() bool

+ func (f *FutureTask[T]) Catch(catchFunc CatchFunction) Future[T]

+ func (f *FutureTask[T]) Completed() bool

+ func (f *FutureTask[T]) CompletedError() bool

+ func (f *FutureTask[T]) Get(ctx context.Context) (T, error)

+ func (f *FutureTask[T]) Run(ctx context.Context)

+ func (f *FutureTask[T]) Then(thenFunc ThenFunction[T]) Future[T]

+ type NoopErrorHandler struct

+ func (d NoopErrorHandler) CatchException(runnable Runnable, e error)

+ type NoopRejectionPolicy struct

+ func (d NoopRejectionPolicy) RejectExecution(runnable Runnable, e Executor) error

+ type PoolExecutor struct

+ func (p *PoolExecutor[T]) Execute(r Runnable) error

+ func (p *PoolExecutor[T]) Shutdown(ctx context.Context) error

+ func (p *PoolExecutor[T]) Submit(callable Callable[T]) (Future[T], error)

+ type RejectionHandler interface

+ RejectExecution func(runnable Runnable, e Executor) error

+ type Runnable interface

+ Run func(ctx context.Context)

+ type RunnableFunc func(ctx context.Context)

+ func (r RunnableFunc) Run(ctx context.Context)

+ type ThenFunction func(val T)

v0.0.2

Mar 5, 2022

v0.0.1

Feb 2, 2022

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL