process

Documentation

Index

• Constants
• type CpuUsage
• type DarwinProcess
  • func NewDarwinProcess(pid int32) (*DarwinProcess, error)
  • func (p *DarwinProcess) GetCpuUsage() (CpuUsage, error)
  • func (p *DarwinProcess) GetMemoryUsage() (MemoryUsage, error)
  • func (p *DarwinProcess) GetName() (string, error)
  • func (p *DarwinProcess) GetRss() (int64, error)
  • func (p *DarwinProcess) GetStats() (ProcessStats, error)
  • func (p *DarwinProcess) GetSwap() (int64, error)
  • func (p *DarwinProcess) WatchStats(ctx context.Context, interval time.Duration) <-chan ProcessStats
• type LinuxProcess
  • func NewLinuxProcess(pid int32) (*LinuxProcess, error)
  • func (p *LinuxProcess) GetCpuUsage() (CpuUsage, error)
  • func (p *LinuxProcess) GetMemoryUsage() (MemoryUsage, error)
  • func (p *LinuxProcess) GetName() (string, error)
  • func (p *LinuxProcess) GetRss() (int64, error)
  • func (p *LinuxProcess) GetStats() (ProcessStats, error)
  • func (p *LinuxProcess) GetSwap() (int64, error)
  • func (p *LinuxProcess) WatchStats(ctx context.Context, interval time.Duration) <-chan ProcessStats
• type MemoryUsage
• type Process
  • func NewProcess(pid int32) (Process, error)
• type ProcessState
• type ProcessStats
• type WindowsProcess
  • func NewWindowsProcess(pid int32) (*WindowsProcess, error)
  • func (p *WindowsProcess) GetChildrenPids() ([]int32, error)
  • func (p *WindowsProcess) GetCpuUsage() (CpuUsage, error)
  • func (p *WindowsProcess) GetMemoryUsage() (MemoryUsage, error)
  • func (p *WindowsProcess) GetName() (string, error)
  • func (p *WindowsProcess) GetRss() (int64, error)
  • func (p *WindowsProcess) GetStats() (ProcessStats, error)
  • func (p *WindowsProcess) GetSwap() (int64, error)
  • func (p *WindowsProcess) WatchStats(ctx context.Context, interval time.Duration) <-chan ProcessStats

Constants

const (
	LinuxProcStatusPath = "/proc/{pid}/status"
	LinuxProcSmapsPath  = "/proc/{pid}/smaps"
)

Types

type CpuUsage

type CpuUsage struct {
	Percentage float32 `json:"percentage"`
}

type DarwinProcess

type DarwinProcess struct {
	Pid int32
}

func NewDarwinProcess

func NewDarwinProcess(pid int32) (*DarwinProcess, error)

func (*DarwinProcess) GetCpuUsage

func (p *DarwinProcess) GetCpuUsage() (CpuUsage, error)

func (*DarwinProcess) GetMemoryUsage

func (p *DarwinProcess) GetMemoryUsage() (MemoryUsage, error)

func (*DarwinProcess) GetName

func (p *DarwinProcess) GetName() (string, error)

func (*DarwinProcess) GetRss

func (p *DarwinProcess) GetRss() (int64, error)

func (*DarwinProcess) GetStats

func (p *DarwinProcess) GetStats() (ProcessStats, error)

func (*DarwinProcess) GetSwap

func (p *DarwinProcess) GetSwap() (int64, error)

func (*DarwinProcess) WatchStats

func (p *DarwinProcess) WatchStats(ctx context.Context, interval time.Duration) <-chan ProcessStats

type LinuxProcess

type LinuxProcess struct {
	Pid int32
	// contains filtered or unexported fields
}

func NewLinuxProcess

func NewLinuxProcess(pid int32) (*LinuxProcess, error)

func (*LinuxProcess) GetCpuUsage

func (p *LinuxProcess) GetCpuUsage() (CpuUsage, error)

func (*LinuxProcess) GetMemoryUsage

func (p *LinuxProcess) GetMemoryUsage() (MemoryUsage, error)

func (*LinuxProcess) GetName

func (p *LinuxProcess) GetName() (string, error)

func (*LinuxProcess) GetRss

func (p *LinuxProcess) GetRss() (int64, error)

GetRss returns the current memory usage in kilobytes of the process. This is calculated from the total RSS from all the libraries and itself that the process uses. RSS includes heap and stack memory, but not swap memory.

func (*LinuxProcess) GetStats

func (p *LinuxProcess) GetStats() (ProcessStats, error)

func (*LinuxProcess) GetSwap

func (p *LinuxProcess) GetSwap() (int64, error)

GetRssWithSwap returns the current memory usage in kilobytes of the process. This is calculated from the total memory from all the libraries and itself that the process uses.

func (*LinuxProcess) WatchStats

func (p *LinuxProcess) WatchStats(ctx context.Context, interval time.Duration) <-chan ProcessStats

type MemoryUsage

type MemoryUsage struct {
	Rss     int64 `json:"rss"`
	RssSwap int64 `json:"rssSwap"`
}

type Process

type Process interface {
	GetName() (string, error)
	GetStats() (ProcessStats, error)
	WatchStats(ctx context.Context, interval time.Duration) <-chan ProcessStats
	GetCpuUsage() (CpuUsage, error)
	GetMemoryUsage() (MemoryUsage, error)
	GetRss() (int64, error)
	GetSwap() (int64, error)
}

func NewProcess

func NewProcess(pid int32) (Process, error)

type ProcessState

type ProcessState string

const (
	ProcessStateSleeping            ProcessState = "S"
	ProcessStateRunning             ProcessState = "R"
	ProcessStateZombie              ProcessState = "Z"
	ProcessStateUninterruptibleWait ProcessState = "D"
)

type ProcessStats

type ProcessStats struct {
	CpuUsage    CpuUsage    `json:"cpuUsage"`
	MemoryUsage MemoryUsage `json:"memoryUsage"`
	Timestamp   time.Time   `json:"timestamp"`
}

type WindowsProcess

type WindowsProcess struct {
	Pid int32
}

func NewWindowsProcess

func NewWindowsProcess(pid int32) (*WindowsProcess, error)

func (*WindowsProcess) GetChildrenPids

func (p *WindowsProcess) GetChildrenPids() ([]int32, error)

func (*WindowsProcess) GetCpuUsage

func (p *WindowsProcess) GetCpuUsage() (CpuUsage, error)

func (*WindowsProcess) GetMemoryUsage

func (p *WindowsProcess) GetMemoryUsage() (MemoryUsage, error)

func (*WindowsProcess) GetName

func (p *WindowsProcess) GetName() (string, error)

func (*WindowsProcess) GetRss

func (p *WindowsProcess) GetRss() (int64, error)

func (*WindowsProcess) GetStats

func (p *WindowsProcess) GetStats() (ProcessStats, error)

func (*WindowsProcess) GetSwap

func (p *WindowsProcess) GetSwap() (int64, error)

func (*WindowsProcess) WatchStats

func (p *WindowsProcess) WatchStats(ctx context.Context, interval time.Duration) <-chan ProcessStats