process

package

v0.14.0 Latest Latest Go to latest Published: Mar 15, 2023 License: Apache-2.0 Imports: 16 Imported by: 0

Details

This section is empty.

View Source

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

func NewMappingFileCache(logger log.Logger) *mappingFileCache

type Map struct {
	PID     int
	Mapping *profile.Mapping
}

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

func NewMapping(cache MappingCache) *Mapping

func (m *Mapping) MappingsForPID(pid int) []*profile.Mapping

func (m *Mapping) MapsForPID(pid int) []Map

func (m *Mapping) PIDAddrMapping(pid int, addr uint64) (*profile.Mapping, error)

type MappingCache interface {
	MappingForPID(pid int) ([]*profile.Mapping, error)
}

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

func NewTree(
	logger log.Logger,
	procfs procfs.FS,
	maxUpdateInterval time.Duration,
) *Tree

NewTree returns a new process tree with current state of all the processes on the system.

func (t *Tree) FindAllAncestorProcessIDsInSameCgroup(pid int) ([]int, error)

FindAllAncestorProcessIDsInSameCgroup returns all ancestor process IDs for a given PID in the same cgroup.

func (t *Tree) Run(ctx context.Context) error

Run starts the process tree and update it periodically.