manager

type Config struct {
	ID           string
	Input        core.Input
	Processors   []core.Processor
	Outputs      []core.Output
	SaveState    core.SaveStateFunc
	LoadState    core.LoadStateFunc
	ErrorHandler core.ErrorHandler
}

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

type Status struct {
	Running                   bool      `json:"running"`
	Errors                    []error   `json:"errors"`
	LastSuccessfulRun         time.Time `json:"last_successful_run"`
	LastSuccessfulResultCount int       `json:"last_successful_result_count"`
	HasErrors                 bool      `json:"has_errors"`
	ErrorsSinceSuccessfulRun  int       `json:"errors_since_successful_run"`
}

type StatusHandler func(status Status)