workers

Sep 18, 2019

Changes in this version

+ const ErrEmptyConfig

+ const ErrEmptyJob

+ const ErrEmptyLocker

+ const ErrEmptyWorkers

+ type LockerSettings interface

+ Apply func(key string, v *viper.Viper) (worker.Locker, error)

type Params

+ Locker worker.Locker

Apr 25, 2019

Changes in this version

+ const ErrMissingKey

+ const ErrRedisClientNil

+ type Error string

+ func (e Error) Error() string

Jul 22, 2018

Changes in this version

+ var Module = module.Module

+ func NewWorkersGroup(wrks []*worker.Worker) *worker.Group

+ type Params struct

+ Config *viper.Viper

+ Jobs map[string]worker.Job

+ Logger *zap.SugaredLogger

+ Redis *redis.Client

+ type Result struct

+ Workers []*worker.Worker

+ func NewWorkers(p Params) (Result, error)