shell

Documentation

Index

• func CollectProcessMetrics(jobname string, pid int, quit chan int)
• func GetChildrenProcesses(pp *process.Process) []*process.Process
• func GetTotalCPUMemUsage(pid int) (float64, float64, error)
• type Shell
  • func (s *Shell) Execute(args *dktypes.ExecuteRequest, cb dkplugin.StatusHelper) (*dktypes.ExecuteResponse, error)
  • func (s *Shell) ExecuteImpl(args *dktypes.ExecuteRequest, cb dkplugin.StatusHelper) ([]byte, error)

Functions

func CollectProcessMetrics

func CollectProcessMetrics(jobname string, pid int, quit chan int)

func GetChildrenProcesses

func GetChildrenProcesses(pp *process.Process) []*process.Process

func GetTotalCPUMemUsage

func GetTotalCPUMemUsage(pid int) (float64, float64, error)

Types

type Shell

type Shell struct{}

Shell plugin runs shell commands when Execute method is called.

func (*Shell) Execute

func (s *Shell) Execute(args *dktypes.ExecuteRequest, cb dkplugin.StatusHelper) (*dktypes.ExecuteResponse, error)

Execute method of the plugin

func (*Shell) ExecuteImpl

func (s *Shell) ExecuteImpl(args *dktypes.ExecuteRequest, cb dkplugin.StatusHelper) ([]byte, error)

ExecuteImpl do execute command