worker

Documentation

Index

• type RetryPolicy
• type WorkerConfiguration
• type WorkerConfigurer
  • 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
  • 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

Types

type RetryPolicy

type RetryPolicy string

const RETRY_POLICY_BACKOFF RetryPolicy = "BACKOFF"

const RETRY_POLICY_FIXED RetryPolicy = "FIXED"

type WorkerConfiguration

type WorkerConfiguration struct {
	ServerUrl                string
	PollInterval             int
	MaxRetryBeforeResultPush int
	RetryIntervalSecond      int
}

type WorkerConfigurer

type WorkerConfigurer struct {
	// contains filtered or unexported fields
}

func NewWorkerConfigurer

func NewWorkerConfigurer(conf WorkerConfiguration) *WorkerConfigurer

func (*WorkerConfigurer) RegisterWorker

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

func (*WorkerConfigurer) Start

func (wc *WorkerConfigurer) Start()

func (*WorkerConfigurer) Stop

func (wc *WorkerConfigurer) Stop()

type WorkerWrapper

type WorkerWrapper struct {
	// contains filtered or unexported fields
}

func NewDefaultWorker

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

func (*WorkerWrapper) WithRetryCount

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

func (*WorkerWrapper) WithRetryInterval

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

func (*WorkerWrapper) WithRetryPolicy

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

func (*WorkerWrapper) WithTimeoutSeconds

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