runner

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

type Processor interface {
	Start() error
	Stop() error
	GetDoneChan() <-chan struct{}
	GetBackoff() time.Duration
	SetBackoff(d time.Duration)
	GetLastLogTime() time.Time
	SetLastLogTime(t time.Time)
	GetLogger() *logger.Logger
	IsRunning() bool
	GetPID() int
}

type WatchOption func(*watchOptions)