workers

Documentation

Index

• Constants
• Variables
• func NewWorkersGroup(wrks []*worker.Worker) *worker.Group
• type Error
  • func (e Error) Error() string
• type Params
• type Result
  • func NewWorkers(p Params) (Result, error)

Constants

const (
	// ErrMissingKey when config key for worker is missing
	ErrMissingKey = Error("missing worker key")

	// ErrRedisClientNil when redis client not provided
	ErrRedisClientNil = Error("gotten nil redis client for exclusive worker")
)

Variables

var Module = module.Module{
	{Constructor: NewWorkersGroup},
	{Constructor: NewWorkers},
}

Module of workers

Functions

func NewWorkersGroup

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

NewWorkersGroup returns workers group with injected workers

Types

type Error

type Error string

Error is constant error

func (Error) Error

func (e Error) Error() string

Error converts constant error from string

type Params

type Params struct {
	dig.In

	Config *viper.Viper
	Logger *zap.Logger
	Redis  *redis.Client `optional:"true"`
	Jobs   map[string]worker.Job
}

Params is dependencies for create workers slice

type Result

type Result struct {
	dig.Out
	Workers []*worker.Worker
}

Result returns wrapped workers group for di

func NewWorkers

func NewWorkers(p Params) (Result, error)

NewWorkers returns wrapped workers slice builded by config settings