procs

Documentation

Index

• Variables
• func AddNewProcCollect(newCollect map[string]*models.ProcCollect)
• func DelNoProcCollect(newCollect map[string]*models.ProcCollect)
• func Detect()
• func ProcCollect(p *models.ProcCollect)
• func ReadNameAndMem(path string) (name string, memory uint64, err error)
• type Proc
  • func AllProcs() (ps []*Proc, err error)
  • func (this *Proc) String() string
• type ProcScheduler
  • func NewProcScheduler(p *models.ProcCollect) *ProcScheduler
  • func (p *ProcScheduler) Schedule()
  • func (p *ProcScheduler) Stop()

Variables

var (
	Procs              = make(map[string]*models.ProcCollect)
	ProcsWithScheduler = make(map[string]*ProcScheduler)
)

Functions

func AddNewProcCollect

func AddNewProcCollect(newCollect map[string]*models.ProcCollect)

func DelNoProcCollect

func DelNoProcCollect(newCollect map[string]*models.ProcCollect)

func Detect

func Detect()

func ProcCollect

func ProcCollect(p *models.ProcCollect)

func ReadNameAndMem

func ReadNameAndMem(path string) (name string, memory uint64, err error)

Types

type Proc

type Proc struct {
	Pid     int
	Name    string
	Exe     string
	Cmdline string
	Mem     uint64
	Cpu     float64

	RBytes  uint64
	WBytes  uint64
	Uptime  uint64
	FdCount int
	// contains filtered or unexported fields
}

func AllProcs

func AllProcs() (ps []*Proc, err error)

func (*Proc) String

func (this *Proc) String() string

type ProcScheduler

type ProcScheduler struct {
	Ticker *time.Ticker
	Proc   *models.ProcCollect
	Quit   chan struct{}
}

func NewProcScheduler

func NewProcScheduler(p *models.ProcCollect) *ProcScheduler

func (*ProcScheduler) Schedule

func (p *ProcScheduler) Schedule()

func (*ProcScheduler) Stop

func (p *ProcScheduler) Stop()