workers

Documentation

Index

• type Config
  • func (c *Config) BuildWorkers() (*Workers, error)
• type Logger
• type Worker
• type Workers
  • func (ws *Workers) AddOneWorker()
  • func (ws *Workers) Start()
  • func (ws *Workers) State() map[string]*Worker
  • func (ws *Workers) Stop()
  • func (ws *Workers) StopAllWorkers()
  • func (ws *Workers) StopOneWorker()

Types

type Config

type Config struct {
	PoolSize int `cfg:"pool_size"`
	Model    sdk.Model
	Runner   sdk.Runner
	Logger   Logger
}

func (*Config) BuildWorkers

func (c *Config) BuildWorkers() (*Workers, error)

type Logger

type Logger interface {
	zombie.Logger
	Info(msg string, kv ...interface{})
	Warning(msg string, kv ...interface{})
	Error(msg string, kv ...interface{})
}

type Worker

type Worker struct {
	Jobs         int
	Busy         bool
	JobID        string
	JobNamespace string
	JobType      string
	StartedAt    time.Time
}

type Workers

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

func (*Workers) AddOneWorker

func (ws *Workers) AddOneWorker()

func (*Workers) Start

func (ws *Workers) Start()

func (*Workers) State

func (ws *Workers) State() map[string]*Worker

func (*Workers) Stop

func (ws *Workers) Stop()

func (*Workers) StopAllWorkers

func (ws *Workers) StopAllWorkers()

func (*Workers) StopOneWorker

func (ws *Workers) StopOneWorker()