process

package

v0.7.0 Latest Latest Go to latest Published: Sep 16, 2015 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Rendered for

View Source

const (
	PID     = "pid"
	Comm    = "comm"
	PPID    = "ppid"
	Cmdline = "cmdline"
	Threads = "threads"
)

We use these keys in node metadata

View Source

var (
	ReadDir  = ioutil.ReadDir
	ReadFile = ioutil.ReadFile
)

Hooks exposed for mocking

This section is empty.

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

CachingWalker is a walker than caches a copy of the output from another Walker, and then allows other concurrent readers to Walk that copy.

func NewCachingWalker(source Walker) *CachingWalker

NewCachingWalker returns a new CachingWalker

func (c *CachingWalker) Tick() error

Tick updates cached copy of process list

func (c *CachingWalker) Walk(f func(Process)) error

Walk walks a cached copy of process list

type Process struct {
	PID, PPID int
	Comm      string
	Cmdline   string
	Threads   int
}

Process represents a single process.

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

Reporter generates Reports containing the Process topology.

func NewReporter(walker Walker, scope string) *Reporter

NewReporter makes a new Reporter.

func (r *Reporter) Report() (report.Report, error)

Report implements Reporter.

type Tree interface {
	GetParent(pid int) (int, error)
}

Tree represents all processes on the machine.

func NewTree(walker Walker) (Tree, error)

NewTree returns a new Tree that can be polled.

type Walker interface {
	Walk(func(Process)) error
}

Walker is something that walks the /proc directory

func NewWalker(procRoot string) Walker

NewWalker creates a new process Walker.