Versions in this module Expand all Collapse all v1 v1.0.1 Nov 2, 2020 Changes in this version type Keeper + UnProcessedTaskSize func() int v1.0.0 Jul 13, 2020 Changes in this version + type ErrorHandler func(error) + type Keeper interface + AddTask func(ctx context.Context, task Task) error + func NewAsyncTask(opts ...Option) (Keeper, error) + type Option interface + type OptionFunc func(k *keeper) + func WithErrorHandlerOption(f ErrorHandler) OptionFunc + func WithQueueSizeOption(size int) OptionFunc + func WithTimeoutOption(timeout time.Duration) OptionFunc + func WithWorkerSizeOption(size int) OptionFunc + type Task interface + Process func(ctx context.Context) error