engine

Documentation

Index

• func Kill(pid int) error
• type DailyLimits
  • func (dtl DailyLimits) MarshalJSON() ([]byte, error)
  • func (dtl *DailyLimits) UnmarshalJSON(data []byte) error
• type ProcessGroupDailyBalance
• type ProcessGroupDailyLimit
• type ProcessHunter
  • func NewProcessHunter(checkPeriod time.Duration, balancePath string, savePeriod time.Duration, ...) *ProcessHunter
  • func (ph *ProcessHunter) GetLatestPGroupsBalance() []ProcessGroupDailyBalance
  • func (ph *ProcessHunter) GetLatestProcessesBalance() TimeBalance
  • func (ph *ProcessHunter) GetLimits() ([]ProcessGroupDailyLimit, 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
• type TimeBalance
  • func (tb TimeBalance) MarshalJSON() ([]byte, error)
  • func (tb *TimeBalance) UnmarshalJSON(data []byte) error

Functions

func Kill

func Kill(pid int) error

Kill kills process pid

Types

type DailyLimits

type DailyLimits map[string]time.Duration

DailyLimits maps days of the week to time limit The key can be "*" (meaing 'any day of the week') or space separated string of three-letter abbreviations of the days of week, i.e. Mon Tue Wed Thu Fri Sat Sun

func (DailyLimits) MarshalJSON

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

MarshalJSON marshals dtl using 12h35m46s duration format

func (*DailyLimits) UnmarshalJSON

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

UnmarshalJSON unmarshals dtl, lowercasing the key and using 12h35m46s duration format

type ProcessGroupDailyBalance

type ProcessGroupDailyBalance struct {
	PG []string       `json:"processes"`
	L  prettyDuration `json:"limit"`
	B  prettyDuration `json:"balance"`
}

ProcessGroupDailyBalance describes daily limit L and balance B of process group PG

type ProcessGroupDailyLimit

type ProcessGroupDailyLimit struct {
	PG []string    `json:"processes"`
	DL DailyLimits `json:"limits"`
}

ProcessGroupDailyLimit specifies daily time limit DL for one or more processes in PG

type ProcessHunter

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

ProcessHunter is monitoring and killing processes that go overtime for particular day

func NewProcessHunter

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

NewProcessHunter initializes and returns a new ProcessHunter

func (*ProcessHunter) GetLatestPGroupsBalance

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

GetLatestPGroupsBalance returns pgroups

func (*ProcessHunter) GetLatestProcessesBalance

func (ph *ProcessHunter) GetLatestProcessesBalance() TimeBalance

GetLatestProcessesBalance returns processes

func (*ProcessHunter) GetLimits

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

GetLimits returns current daily limits (which are normally loaded from a config file) and its hash

func (*ProcessHunter) LoadBalance

func (ph *ProcessHunter) LoadBalance() error

LoadBalance loads the balance from provided path

func (*ProcessHunter) LoadConfig

func (ph *ProcessHunter) LoadConfig() error

LoadConfig loads ProcessHunder configuration from path

func (*ProcessHunter) Run

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

Run is a goroutine that periodically checks running processes

func (*ProcessHunter) SaveBalance

func (ph *ProcessHunter) SaveBalance() error

SaveBalance saves balance to provided path

type TimeBalance

type TimeBalance map[string]time.Duration

TimeBalance maps process name to running time

func (TimeBalance) MarshalJSON

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

MarshalJSON marshals tb using 12h35m46s duration format

func (*TimeBalance) UnmarshalJSON

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

UnmarshalJSON unmarshals dtl using 12h35m46s duration format