worker

Dec 26, 2022

Changes in this version

+ type RetryPolicy string

+ const RETRY_POLICY_BACKOFF

+ const RETRY_POLICY_FIXED

+ type WorkerConfiguration struct

+ MaxRetryBeforeResultPush int

+ RetryIntervalSecond int

+ ServerUrl string

+ type WorkerConfigurer struct

+ func NewWorkerConfigurer(conf WorkerConfiguration) *WorkerConfigurer

+ func (wc *WorkerConfigurer) RegisterWorker(w *WorkerWrapper, name string, pollInterval time.Duration, batchSize int, ...) error

+ func (wc *WorkerConfigurer) Start()

+ func (wc *WorkerConfigurer) Stop()

+ type WorkerWrapper struct

+ func NewDefaultWorker(w func(map[string]any) (map[string]any, error)) *WorkerWrapper

+ func (w *WorkerWrapper) WithRetryCount(count int) *WorkerWrapper

+ func (w *WorkerWrapper) WithRetryInterval(retryInterval int) *WorkerWrapper

+ func (w *WorkerWrapper) WithRetryPolicy(policy string) *WorkerWrapper

+ func (w *WorkerWrapper) WithTimeoutSeconds(timeout int) *WorkerWrapper