workerb

Documentation

Index

• type WorkerB
  • func (s *WorkerB) DoWork()
  • func (s *WorkerB) Init() error
  • func (s *WorkerB) IsDisabled() bool
  • func (s *WorkerB) Run(ctx context.Context) error
  • func (s *WorkerB) Status() string

Types

type WorkerB

type WorkerB struct {
	Cfg         *cfg.Cfg                        `inject:""`
	WorkerPool  *components.WorkerPool          `inject:""`
	PController *components.ProcessorController `inject:""`
	// contains filtered or unexported fields
}

func (*WorkerB) DoWork

func (s *WorkerB) DoWork()

func (*WorkerB) Init

func (s *WorkerB) Init() error

func (*WorkerB) IsDisabled

func (s *WorkerB) IsDisabled() bool

func (*WorkerB) Run

func (s *WorkerB) Run(ctx context.Context) error

func (*WorkerB) Status

func (s *WorkerB) Status() string