controller

type ConfigurationStatus struct {
	ErrorRetry    bool
	ShouldBackOff bool
	Interval      string
}

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

type Func struct {
	Function Function
	Params   []FuncParam
	// contains filtered or unexported fields
}

type FuncParam interface{}

type Function interface{}

type Internal struct {
	// DoFunc is the function that will be run until it succeeds and/or
	// using the interval RunInterval if not 0.
	// An unset DoFunc is an error and will be logged as one.
	DoFunc *Func

	// StopFunc is called when the controller stops. It is intended to run any
	// clean-up tasks for the controller (e.g. deallocate/release resources)
	// It is guaranteed that DoFunc is called at least once before StopFunc is
	// called.
	// An unset StopFunc is not an error (and will be a no-op)
	// Note: Since this occurs on controller exit, error counts and tracking may
	// not be checked after StopFunc is run.
	StopFunc *Func

	// If set to any other value than 0, will cause DoFunc to be run in the
	// specified interval. The interval starts from when the DoFunc has
	// returned last
	RunInterval time.Duration

	// ErrorRetryBaseDuration is the initial time to wait to run DoFunc
	// again on return of an error. On each consecutive error, this value
	// is multiplied by the number of consecutive errors to provide a
	// constant back off. The default is 1s.
	ErrorRetryBaseDuration time.Duration

	// Should we have a constant back off for retries during errors.
	RetryBackOff bool

	// NoErrorRetry when set to true, disables retries on errors
	NoErrorRetry bool

	// SkipFirstRun skips the first run of the controller function.
	SkipFirstRun bool
	// contains filtered or unexported fields
}

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

type Map map[string]*Controller

type RunStatus struct {
	SuccessCount     int64
	LastSuccessStamp string

	FailureCount     int64
	LastFailureStamp string

	ConsecutiveFailureCount int64
}

type Scheduler interface {
	// Next returns the time when to run the controller function again.
	Next(time.Time) time.Time
}

type Status struct {
	Name          string
	Configuration ConfigurationStatus

	Status RunStatus
}