subworker

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(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