worker

Documentation

Index

• type Config
• type ReconcileFunc
• type Worker
  • func New(cfg *Config, l *zap.Logger, clock clock.WithTicker, reconcile ReconcileFunc) *Worker
  • func (w *Worker) Enqueue(item interface{})
  • func (w *Worker) EnqueueAfter(item interface{}, duration time.Duration)
  • func (w *Worker) Start(interrupt <-chan struct{})

Types

type Config

type Config struct {
	Name        string
	Retries     int
	Threadiness int
}

type ReconcileFunc

type ReconcileFunc func(key interface{}) error

type Worker

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

func New

func New(
	cfg *Config,
	l *zap.Logger,
	clock clock.WithTicker,
	reconcile ReconcileFunc,
) *Worker

func (*Worker) Enqueue

func (w *Worker) Enqueue(item interface{})

func (*Worker) EnqueueAfter

func (w *Worker) EnqueueAfter(item interface{}, duration time.Duration)

func (*Worker) Start

func (w *Worker) Start(interrupt <-chan struct{})