engine

type DayLimits ¶ added in v0.10.1

type DayLimits map[string]time.Duration

DayLimits maps days to time limit The key (days) can be - "*" (meaing 'any day of the week') - space separated string of three-letter abbreviations of the days of week, i.e. Mon Tue Wed Thu Fri Sat Sun - a concreate date in the format YYYY-MM-DD - space separated list of dates - a combination of all of the above

func (dtl DayLimits) MarshalJSON() ([]byte, error)

func (dtl *DayLimits) UnmarshalJSON(data []byte) error

type Downtime ¶ added in v0.10.1

type Downtime map[string][]string

Downtime maps days to a list of downtime periods See DayLimits for the meaning of the key of this map The values (downtime periods) are strings like this: "12:00..12:30" - for a 30 minutes downtime "..10:00" - downtime up until 10:00 in the morning "18:00.." - downtime after 6:00PM

type ProcessGroupDayBalance ¶ added in v0.10.1

type ProcessGroupDayBalance struct {
	PG           []string       `json:"processes"`
	Limit        prettyDuration `json:"limit"`
	LimitDefined bool           `json:"limit_defined"`
	Balance      prettyDuration `json:"balance"`
	Downtime     []string       `json:"downtime"`
	Blocked      bool           `json:"blocked"`
	TimeStamp    string         `json:"timestamp"`
}

ProcessGroupDayBalance describes day limits and monitored properties of a process group PG

type ProcessGroupDayLimit ¶ added in v0.10.1

type ProcessGroupDayLimit struct {
	PG []string  `json:"processes"`
	DL DayLimits `json:"limits"`
	DT Downtime  `json:"downtime"`
}

ProcessGroupDayLimit specifies day time limit DL and downtime periods DT for one or more processes in PG

type ProcessHunter ¶

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

func NewProcessHunter(
	checkPeriod time.Duration,
	balancePath string,
	savePeriod time.Duration,
	killer func(int) error,
	cfgPath string) *ProcessHunter

func (ph *ProcessHunter) GetBalance() dayTimeBalance

func (ph *ProcessHunter) GetLatestPGroupsBalance() []ProcessGroupDayBalance

func (ph *ProcessHunter) GetLatestProcessesBalance() TimeBalance

func (ph *ProcessHunter) GetLimits() ([]ProcessGroupDayLimit, uint32)

func (ph *ProcessHunter) LoadBalance() error

func (ph *ProcessHunter) LoadConfig() error

func (ph *ProcessHunter) Run(ctx context.Context, wg *sync.WaitGroup)

func (ph *ProcessHunter) SaveBalance() error

func (ph *ProcessHunter) SetConfig(b []byte) error

type TimeBalance ¶ added in v0.6.0

type TimeBalance map[string]time.Duration

TimeBalance maps process name to running time

func (tb TimeBalance) MarshalJSON() ([]byte, error)

func (tb *TimeBalance) UnmarshalJSON(data []byte) error