workers

Documentation

Index

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

Variables

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

Functions

func NewWorkersGroup

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

NewWorkersGroup returns workers group with injected workers

Types

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