Versions in this module Expand all Collapse all v1 v1.0.3 May 3, 2025 Changes in this version + type ErrorHandler func(error) + type Keeper interface + AddTask func(ctx context.Context, task Task) error + UnProcessedTaskSize func() int + 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
Go to main page