process

Documentation

Index

• Variables
• func NewMappingFileCache(logger log.Logger) *mappingFileCache
• type Map
• type Mapping
  • 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
• type Tree
  • func NewTree(logger log.Logger, procfs procfs.FS, maxUpdateInterval time.Duration) *Tree
  • func (t *Tree) FindAllAncestorProcessIDsInSameCgroup(pid int) ([]int, error)
  • func (t *Tree) Run(ctx context.Context) error

Variables

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

Functions

func NewMappingFileCache

func NewMappingFileCache(logger log.Logger) *mappingFileCache

Types

type Map

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

type Mapping

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

func NewMapping

func NewMapping(cache MappingCache) *Mapping

func (*Mapping) MappingsForPID

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

func (*Mapping) MapsForPID

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

func (*Mapping) PIDAddrMapping

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

type MappingCache

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

type Tree

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

func NewTree

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 (*Tree) FindAllAncestorProcessIDsInSameCgroup

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

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

func (*Tree) Run

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

Run starts the process tree and update it periodically.