cmd

package

Go to main page

Versions in this module

v0

v0.2.2

Apr 26, 2024

Changes in this version

+ const BEST_EFFORT

+ const IDLE

+ const IOPRIO_CLASS_BE

+ const IOPRIO_CLASS_IDLE

+ const IOPRIO_CLASS_NONE

+ const IOPRIO_CLASS_RT

+ const IOPRIO_CLASS_SHIFT

+ const IOPRIO_WHO_PGRP

+ const IOPRIO_WHO_PROCESS

+ const IOPRIO_WHO_USER

+ const NONE

+ const REALTIME

+ const SCHED_BATCH

+ const SCHED_DEADLINE

+ const SCHED_FIFO

+ const SCHED_IDLE

+ const SCHED_ISO

+ const SCHED_OTHER

+ const SCHED_RR

+ var CPUSched map[int]string

+ func Clone[S ~[]E, E any](s S) S

+ func GetCgroup(pid int) (cgroup string, err error)

+ func GetOomScoreAdj(pid int) (score int, err error)

+ func GetResource(pid int, rc string) ([]byte, error)

+ func GetStat(path string) (stat unix.Stat_t, err error)

+ func GetUid(pid int) int

+ func GetUser(uid int) (*user.User, error)

+ func IOPrio_Get(pid int) (int, error)

+ func IOPrio_Split(ioprio int, class, data *int)

+ func Sched_GetParam(pid int) (int, error)

+ func Sched_GetScheduler(pid int) (int, error)

+ type BaseStruct interface

type Command

+ func UserTernaryCommand(shell string, ok string, ko string) Command

+ type FilterAny struct

+ Filter func(p *T, err error) bool

+ Message string

+ type Filterer interface

+ Filter func(p *P, err error) bool

+ String func() string

+ type Formatter func(p *Proc) string

type PresetCache

+ func (pc *PresetCache) FilteredProcs(inputs <-chan []*Proc, outputs chan<- []*Proc, wg *sync.WaitGroup)

type Proc

+ Cgroup string

+ IOPrioClass int

+ IOPrioData int

+ OomScoreAdj int

+ Slice string

+ Uid int

+ Unit string

+ func AllProcs() (result []*Proc)

+ func NewProc(pid int) *Proc

+ func (p *Proc) CPUSchedInfo() string

+ func (p *Proc) GetStringMap() (result map[string]interface{})

+ func (p *Proc) GoString() string

+ func (p *Proc) IOClass() string

+ func (p *Proc) IOSchedInfo() string

+ func (p *Proc) InSystemSlice() bool

+ func (p *Proc) InUserSlice() bool

+ func (p *Proc) Runtime() BaseProfile

+ func (p *Proc) Sched() string

+ func (p *Proc) String() string

+ func (p *Proc) Username() string

+ func (p *Proc) Values() string

+ func (p Proc) Json() (result string)

+ func (p Proc) Raw() string

+ type ProcByPgrp []*Proc

+ func (s ProcByPgrp) ByPgrp() chan []*Proc

+ func (s ProcByPgrp) Len() int

+ func (s ProcByPgrp) Less(i, j int) bool

+ func (s ProcByPgrp) Swap(i, j int)

+ type ProcByPid []*Proc

+ func (s ProcByPid) Len() int

+ func (s ProcByPid) Less(i, j int) bool

+ func (s ProcByPid) Swap(i, j int)

type ProcFilter

+ Scope string

+ func (pf ProcFilter) Filter(p *Proc, err error) bool

+ func (pf ProcFilter) String() string

type ProcGroupJob

+ Jobs []*ProcJob

type ProcJob

+ func NewProcJob(p *Proc) *ProcJob

+ func ProcToProcJob(procs []*Proc) []*ProcJob

+ type ProcStat struct

+ ArgEnd uint

+ ArgStart uint

+ Blocked uint

+ CGuestTime int

+ CMajFlt uint

+ CMinFlt uint

+ CNSwap uint

+ CSTime int

+ CUTime int

+ Comm string

+ DelayAcctBlkIOTicks uint64

+ EndCode uint

+ EndData uint

+ EnvEnd uint

+ EnvStart uint

+ ExitCode int

+ ExitSignal int

+ Flags uint

+ GuestTime uint

+ ITRealValue int

+ KStkEIP uint

+ KStkESP uint

+ MajFlt uint

+ MinFlt uint

+ NSwap uint

+ Nice int

+ NumThreads int

+ Pgrp int

+ Pid int

+ Policy int

+ Ppid int

+ Priority int

+ Processor int

+ RTPrio int

+ Rss int

+ RssLim uint

+ STime uint

+ Session int

+ SigCatch uint

+ SigIgnore uint

+ Signal uint

+ StartBrk uint

+ StartCode uint

+ StartData uint

+ StartStack uint

+ StartTime uint64

+ State string

+ TPGid int

+ TtyNr int

+ UTime uint

+ VSize uint

+ WChan uint

+ func (stat *ProcStat) CPUTime() float64

+ func (stat *ProcStat) GoString() string

+ func (stat *ProcStat) Read(pid int) error

+ func (stat *ProcStat) String() string

+ func (stat *ProcStat) UnmarshalText(buffer []byte) (err error)

type Request

+ func NewRequest(name, path, shell string) *Request

+ type Sched_Param struct

+ Sched_Priority int

+ type SchedulingPolicy struct

+ Class map[int]string

+ High int

+ Low int

+ NeedCredentials []int

+ NeedPriority []int

+ None int

+ var CPU SchedulingPolicy = SchedulingPolicy{ ... }

+ var IO SchedulingPolicy = SchedulingPolicy{ ... }

v0.2.1

Oct 14, 2023

Changes in this version

+ func ChanFirst[T any](ch chan T, f func(T) bool) T

+ func ChanMapFilter[T, U any](in chan T, out chan U, f func(T) (U, bool))

+ func IsNicy(path string) bool

+ func LookAll(file string) chan string

+ func LookPath(file string) string

+ func ValidShell(shell string) (string, error)

+ type BaseRequest struct

+ MaxNice int

+ Name string

+ NumCPU int

+ Path string

+ Preset string

+ Shell string

+ func NewBaseRequest(name, path, shell string) *BaseRequest

type Command

+ func (c *Command) RunJob(shell string) (job *ProcJob, args []string, err error)

+ func (c *Command) Split() (path string, args []string, err error)

type PresetCache

+ RuleFilter FilterProc

+ func (pc *PresetCache) CgroupCandidate(base BaseCgroup) (string, bool)

+ func (pc *PresetCache) DiffReview(job *ProcGroupJob) (count int, err error)

+ func (pc *PresetCache) Expand(rule *Rule) error

+ func (pc *PresetCache) FilteredProcMaps(inputs <-chan []*Proc, outputs chan<- []*ProcMap, wg *sync.WaitGroup)

+ func (pc *PresetCache) GenerateGroupJobs(inputs <-chan []*Proc, output chan<- *ProcGroupJob, wgmain *sync.WaitGroup) (err error)

+ func (pc *PresetCache) GenerateJobs(inputs <-chan *Request, outputs chan<- *ProcJob, wgmain *sync.WaitGroup) (err error)

+ func (pc *PresetCache) GetFilterer(scope string) ProcFilterer

+ func (pc *PresetCache) RawGroupJobs(inputs <-chan []*ProcMap, output chan<- *ProcGroupJob, wg *sync.WaitGroup)

+ func (pc *PresetCache) RawRule(input *Request) (Rule, error)

+ func (pc *PresetCache) RequestJob(input *Request) *ProcJob

+ func (pc *PresetCache) RequestRule(input *Request) Rule

+ func (pc *PresetCache) SliceProperties(rule Rule) (result []string)

type ProcJob

+ func NewMapJob(m *ProcMap) *ProcJob

+ func (job *ProcJob) NicyExec() string

+ func (job *ProcJob) Script(shell string) (result []string, err error)

type ProcMapByPgrp

+ func (s ProcMapByPgrp) ByPgrp() chan []*ProcMap

+ type Request struct

+ CgroupKey string

+ ForceCgroup bool

+ Managed bool

+ Quiet bool

+ Verbosity int

+ func NewPathRequest(path, shell string) *Request

+ func NewRawRequest(name, path, shell string) *Request

+ func (r *Request) MergeFlags()

type Rule

+ func (r Rule) Path() string

v0.2.0

Jun 11, 2023

Changes in this version

+ const EACCESS

+ var FilteredProcs = procfs.FilteredProcs

+ var GetCalling = procfs.GetCalling

+ var GetFormatter = procfs.GetFormatter

+ var GetScopeOnlyFilterer = procfs.GetFilterer

+ var NewProcFromStat = procfs.NewProcFromStat

+ var NewProcScopeFilter = procfs.NewProcScopeFilter

+ func ActivePreset[T Preset](s []T) (elem T)

+ func Diff[T BaseCgroup | BaseProfile](preset T, runtime T) (T, int)

+ func Filter[T any](s []T, f func(T) bool) []T

+ func GetPreset[T Preset](m map[string][]T, key string, kind string) (T, error)

+ func GetStringFromFlags(fallback string, names ...string) string

+ func GroupProcJobs(jobs []*ProcJob) (result *ProcGroupJob, remainder []*ProcJob)

+ func HasPreset[T Preset](m map[string][]T, key string) bool

+ func IterCache[T Preset](m map[string][]T) chan T

+ func ListFrom[T Preset](m map[string][]T, required string) (result []string)

+ func List[T Preset](m map[string][]T) (result []string)

+ func LoadConfig[T Preset](m map[string][]T, f func() chan T)

+ func Map[T, U any](s []T, f func(T) U) []U

+ func Properties[T BaseCgroup | BaseProfile](st T) (result []string)

+ func Reduce[T, U any](s []T, init U, f func(U, T) U) U

+ func ResetMatching[T1, T2 Struct](st1 *T1, st2 *T2)

+ func Reverse[T any](s []T) []T

+ func ReviewGroupJobDiff(groupjob *ProcGroupJob) (count int, err error)

+ func ShellJoin(words ...string) string

+ func ShellQuote(words []string) (result []string)

+ func ShellSplit(input string) (words []string, err error)

+ func ToInterface[T Struct](st T) map[string]any

+ func ToJson[T Struct](st T) string

+ func UpdateRule[T1 BaseCgroup | BaseProfile](st T1, rule *Rule)

+ type AppGroup struct

+ Assignments []string

+ Profile Group

+ type AppRule struct

+ CPUQuota string

+ CgroupKey string

+ CmdArgs []string

+ Env map[string]string

+ IOClass string

+ IONice int

+ IOWeight string

+ MemoryHigh string

+ MemoryMax string

+ Nice int

+ OomScoreAdj int

+ ProfileKey string

+ RTPrio int

+ Sched string

+ func (a AppRule) ToRule(key, origin string) Rule

+ type BaseCgroup struct

+ CPUQuota string

+ IOWeight string

+ MemoryHigh string

+ MemoryMax string

+ func (c *BaseCgroup) HasScopeProperties() bool

+ func (c *BaseCgroup) ScopeProperties() (result []string)

+ type BaseProfile struct

+ IOClass string

+ IONice int

+ Nice int

+ OomScoreAdj int

+ RTPrio int

+ Sched string

+ type BaseRule struct

+ CgroupKey string

+ CmdArgs []string

+ Credentials []string

+ Env map[string]string

+ ProfileKey string

+ SliceProperties []string

+ type Cgroup struct

+ CgroupKey string

+ Origin string

+ func (c Cgroup) Keys() (string, string)

+ func (c Cgroup) String() string

+ type Command struct

+ func FromShellCmd(cmd string) Command

+ func ManagerCommand(shell string) Command

+ func NewCommand(s ...string) Command

+ func SudoCommand(shell string) Command

+ func (c *Command) Exec(tag string) error

+ func (c *Command) Output() (output []string, err error)

+ func (c *Command) RequireSysCapability(uid int) (comm string, flag bool)

+ func (c *Command) Run(tag string, stdin io.Reader, stdout, stderr io.Writer) error

+ func (c *Command) Runtime(pid, uid int) Command

+ func (c *Command) Scan(std *Streams) Command

+ func (c *Command) Start(tag string, stdin io.Reader, stdout, stderr io.Writer) (cmd *exec.Cmd, err error)

+ func (c *Command) StartWait(tag string, stdin io.Reader, stdout, stderr io.Writer) (err error)

+ func (c Command) Copy() Tokener

+ type Config struct

+ AppGroups map[string]AppGroup

+ Cgroups map[string]BaseCgroup

+ Origin string

+ Path string

+ Rules map[string]AppRule

+ func NewConfig(path string) (Config, error)

+ func (c *Config) IterCgroups() chan Cgroup

+ func (c *Config) IterProfiles() chan Profile

+ func (c *Config) IterRules() chan Rule

+ func (c *Config) SetOrigin(path string)

+ type FilterProc = procfs.FilterAny[Proc]

+ type Group struct

+ CPUQuota string

+ CgroupKey string

+ IOWeight string

+ Ioclass string

+ Ionice int

+ MemoryHigh string

+ MemoryMax string

+ Nice int

+ OomScoreAdj int

+ Rtprio int

+ Sched string

+ func (g *Group) ToProfile(key, origin string) Profile

+ type Preset interface

+ Keys func() (string, string)

+ String func() string

+ type PresetCache struct

+ Cgroups map[string][]Cgroup

+ Date string

+ Origin string

+ Profiles map[string][]Profile

+ Rules map[string][]Rule

+ func GetPresetCache() PresetCache

+ func NewPresetCache() PresetCache

+ func (pc *PresetCache) Cgroup(key string) (Cgroup, error)

+ func (pc *PresetCache) ExpandRule(rule *Rule) error

+ func (pc *PresetCache) GetContent() (data []byte, err error)

+ func (pc *PresetCache) GetRawRule(input *RunInput) (Rule, error)

+ func (pc *PresetCache) GetRunInputRule(input *RunInput) Rule

+ func (pc *PresetCache) GetSliceProperties(rule Rule) (result []string)

+ func (pc *PresetCache) HasPreset(category string, key string) bool

+ func (pc *PresetCache) List(category string) (result []string, err error)

+ func (pc *PresetCache) ListFrom(category, origin string) (result []string, err error)

+ func (pc *PresetCache) LoadFromCache(cacheFile string) (err error)

+ func (pc *PresetCache) LoadFromConfig() (err error)

+ func (pc *PresetCache) Profile(key string) (Profile, error)

+ func (pc *PresetCache) Rule(key string) (Rule, error)

+ func (pc *PresetCache) WriteCache(cacheFile string) (err error)

+ type Proc = procfs.Proc

+ type ProcFilter = procfs.ProcFilter

+ type ProcFilterer = procfs.Filterer[Proc]

+ func GetFilterer(scope string) ProcFilterer

+ type ProcGroupJob struct

+ Commands []Command

+ Diff Rule

+ Pgrp int

+ Pids []int

+ Procs []*ProcJob

+ func (job *ProcGroupJob) Add(p *ProcJob) (err error)

+ func (job *ProcGroupJob) LeaderInfo() (result string)

+ func (job *ProcGroupJob) PrepareAdjust() error

+ func (job *ProcGroupJob) Run(tag string, stdout, stderr io.Writer) error

+ type ProcJob struct

+ Commands []Command

+ Request *RunInput

+ Result Rule

+ func ProcMapToProcJob(procmaps []*ProcMap) (result []*ProcJob)

+ func (job *ProcJob) AddCommand(c Command)

+ func (job *ProcJob) AddExecCmd() error

+ func (job *ProcJob) AddProfileCommand(property string, content []string)

+ func (job *ProcJob) AdjustIOClassIONice(pid, pgrp int) error

+ func (job *ProcJob) AdjustNice(pid, pgrp int) error

+ func (job *ProcJob) AdjustOomScoreAdj(pid int) error

+ func (job *ProcJob) AdjustSchedRTPrio(pid int) error

+ func (job *ProcJob) PrepareCommands() error

+ func (job *ProcJob) Run(tag string, args []string, stdin io.Reader, stdout, stderr io.Writer) (err error)

+ func (job *ProcJob) RuntimeCommands(args ...string) []Command

+ func (job *ProcJob) SetPrivilege(command string)

+ func (job *ProcJob) SetSudoIfRequired()

+ func (job *ProcJob) Show() (result []string, err error)

+ func (job ProcJob) IsPrivilegeRequired(command string) bool

+ func (job ProcJob) IsSudoSet() bool

+ type ProcMap struct

+ Cgroup string

+ Comm string

+ NumThreads int

+ Pgrp int

+ Pid int

+ Ppid int

+ Priority int

+ Runtime BaseProfile

+ Slice string

+ State string

+ Uid int

+ Unit string

+ User string

+ func FilteredProcMaps(filter ProcFilterer) (result []*ProcMap, err error)

+ func NewProcMap(p *Proc) *ProcMap

+ type ProcMapByPgrp []*ProcMap

+ func (s ProcMapByPgrp) Len() int

+ func (s ProcMapByPgrp) Less(i, j int) bool

+ func (s ProcMapByPgrp) Swap(i, j int)

+ type ProcMapByPid []*ProcMap

+ func (s ProcMapByPid) Len() int

+ func (s ProcMapByPid) Less(i, j int) bool

+ func (s ProcMapByPid) Swap(i, j int)

+ type Profile struct

+ CgroupKey string

+ Origin string

+ ProfileKey string

+ func (p *Profile) ToRule() Rule

+ func (p Profile) Keys() (string, string)

+ func (p Profile) String() string

+ type Rule struct

+ Origin string

+ RuleKey string

+ func (r *Rule) CgroupEntries() (BaseCgroup, bool)

+ func (r *Rule) CgroupOnly()

+ func (r *Rule) Copy() Rule

+ func (r *Rule) GetCredentials() (result []string)

+ func (r *Rule) GetDiff(runtime Rule) (Rule, int)

+ func (r *Rule) HasCPUQuota() bool

+ func (r *Rule) HasCgroupKey() bool

+ func (r *Rule) HasIOWeight() bool

+ func (r *Rule) HasIoclass() bool

+ func (r *Rule) HasIonice() bool

+ func (r *Rule) HasMemoryHigh() bool

+ func (r *Rule) HasMemoryMax() bool

+ func (r *Rule) HasNice() bool

+ func (r *Rule) HasOomScoreAdj() bool

+ func (r *Rule) HasProfileKey() bool

+ func (r *Rule) HasRtprio() bool

+ func (r *Rule) HasSched() bool

+ func (r *Rule) NeedScope() bool

+ func (r *Rule) SetCgroup(cgroup string)

+ func (r *Rule) SetCredentials()

+ func (r *Rule) SetSliceProperties(properties []string)

+ func (r Rule) Keys() (string, string)

+ func (r Rule) String() string

type Script

+ func (s Script) String() string

+ type Streams struct

+ Stderr io.Writer

+ Stdin io.Reader

+ Stdout io.Writer

+ type Struct interface

+ type Tokener interface

+ Append func(s ...string) Tokener

+ Content func() []string

+ Copy func() Tokener

+ Index func(pos int) (string, error)

+ IsEmpty func() bool

+ Len func() int

+ Prepend func(s ...string) Tokener

+ ShellCmd func() string

+ String func() string

+ WriteTo func(dest io.Writer) (n int, err error)

+ type Tokens []string

+ func (t Tokens) Append(s ...string) Tokener

+ func (t Tokens) Content() []string

+ func (t Tokens) Copy() Tokener

+ func (t Tokens) Index(pos int) (result string, err error)

+ func (t Tokens) IsEmpty() bool

+ func (t Tokens) Len() int

+ func (t Tokens) Prepend(s ...string) Tokener

+ func (t Tokens) ShellCmd() string

+ func (t Tokens) String() string

+ func (t Tokens) WriteTo(dest io.Writer) (n int, err error)

v0.1.6

Aug 31, 2021

Changes in this version

+ const EACCES

+ const EALREADY

+ const EINVAL

+ const EJQCOMPILE

+ const EJQUSAGE

+ const ENOTCONF

+ const ENOTDIR

+ const ENOTFOUND

+ const EPARSE

+ const EPERM

+ const FAILURE

+ const SUCCESS

+ var ErrAlready = errors.New("already running")

+ var ErrFailure = errors.New("fail")

+ var ErrInvalid = errors.New("invalid argument")

+ var ErrNotConfDir = errors.New("unknown directory")

+ var ErrNotDir = errors.New("not a directory")

+ var ErrNotFound = errors.New("not found")

+ var ErrNotWritableDir = errors.New("not writable directory")

+ var ErrParse = errors.New("cannot parse options")

+ var ErrPermission = errors.New("permission denied")

+ func CommonPreRunE(cmd *cobra.Command, args []string) error

+ func Execute()

+ func Getrlimit_Nice() (*unix.Rlimit, error)

+ type CmdLine []string

+ func DecodeCmdLine(input interface{}) (cmdline CmdLine, err error)

+ func NewCmdLine(line string) CmdLine

+ func (line *CmdLine) Append(args ...string)

+ func (line *CmdLine) Filter(f LineFilter)

+ func (line CmdLine) Args() (args []string)

+ func (line CmdLine) Command() (command string)

+ func (line CmdLine) ExecRun() error

+ func (line CmdLine) Output() (output []string, err error)

+ func (line CmdLine) RequireSysNice() bool

+ func (line CmdLine) Run(tag string, stdin io.Reader, stdout, stderr io.Writer) error

+ func (line CmdLine) Runtime(pid, uid int) CmdLine

+ func (line CmdLine) String() string

+ func (line CmdLine) Trace(tag string)

+ func (line CmdLine) WriteTo(dest io.Writer) (n int, err error)

+ func (line CmdLine) WriteVerboseTo(dest io.Writer) (n int, err error)

+ type LineFilter func(token string) bool

+ var Empty LineFilter = func(token string) bool { ... }

+ type ManageInput struct

+ func (input *ManageInput) Append(p *process.Proc) error

+ func (input *ManageInput) Slice() []interface{}

+ type ManageJob struct

+ Comm string

+ Commands []CmdLine

+ Pgrp int

+ Pids []int

+ Unit string

+ func NewManageJob(obj *map[string]interface{}) *ManageJob

+ func (job *ManageJob) Append(lines ...CmdLine)

+ func (job *ManageJob) Run(stdout, stderr io.Writer)

+ type RunInput struct

+ CPUSched string

+ Cgroup string

+ ForceCgroup bool

+ IOSched string

+ Managed bool

+ MaxNice int

+ Name string

+ NumCPU int

+ Path string

+ Preset string

+ Quiet bool

+ Shell string

+ Verbosity int

+ func NewRunInput(cmdPath string) *RunInput

+ func (input *RunInput) Map() map[string]interface{}

+ type Script []CmdLine

+ func DecodeScript(input interface{}) (script Script, err error)

+ func NewShellScript(shell string, lines ...CmdLine) (script Script)

+ func (script *Script) Append(lines ...CmdLine)

+ func (script Script) ManageCmdLines() (result []CmdLine)

+ func (script Script) Run(args []string)

+ func (script Script) RunCmdLines(args []string) (result []CmdLine)

+ type UnmarshalFunc func(s string) (map[string]interface{}, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL