subworker

Documentation

Index

• type Orchestrator
  • func NewOrchestrator(baseWorker svc.Worker) *Orchestrator
  • func (s *Orchestrator) AddSubWorker(name string, w svc.Worker) error
  • func (s *Orchestrator) Init(l *zap.Logger) error
  • func (s *Orchestrator) Run() error
  • func (s *Orchestrator) Terminate() error

Types

type Orchestrator

type Orchestrator struct {
	svc.Worker

	TerminationGracePeriod time.Duration
	TerminationWaitPeriod  time.Duration
	// contains filtered or unexported fields
}

Orchestrator is a subclass of Nullworker which allows this worker to take on child workers and initialize them much like SVC does but in a slightly simpler way. The base worker is initialized and run last and shutdown first.

func NewOrchestrator

func NewOrchestrator(baseWorker svc.Worker) *Orchestrator

func (*Orchestrator) AddSubWorker

func (s *Orchestrator) AddSubWorker(name string, w svc.Worker) error

func (*Orchestrator) Init

func (s *Orchestrator) Init(l *zap.Logger) error

func (*Orchestrator) Run

func (s *Orchestrator) Run() error

func (*Orchestrator) Terminate

func (s *Orchestrator) Terminate() error