process_monitor

Documentation

Index

• Variables
• func GetMemoryInfo(pid int) (*processMemoryInfo, error)
• func NewSensor(ctx context.Context, deps resource.Dependencies, conf resource.Config, ...) (sensor.Sensor, error)
• type ComponentConfig
  • func (conf *ComponentConfig) Validate(path string) ([]string, error)
• type Config
  • func (c *Config) Close(ctx context.Context) error
  • func (c *Config) Readings(ctx context.Context, extra map[string]interface{}) (map[string]interface{}, error)
  • func (c *Config) Ready(ctx context.Context, extra map[string]interface{}) (bool, error)
  • func (c *Config) Reconfigure(ctx context.Context, _ resource.Dependencies, conf resource.Config) error
  • func (c *Config) Update(ctx context.Context)

Variables

var (
	Model       = resource.NewModel(utils.Namespace, "hwmonitor", "process_monitor")
	API         = sensor.API
	PrettyName  = "SBC Process Monitor"
	Description = "A sensor that reports process information"
	Version     = utils.Version
)

var (
	ErrProcessNotFound = errors.New("process not found")
)

Functions

func GetMemoryInfo

func GetMemoryInfo(pid int) (*processMemoryInfo, error)

func NewSensor

func NewSensor(ctx context.Context, deps resource.Dependencies, conf resource.Config, logger logging.Logger) (sensor.Sensor, error)

Types

type ComponentConfig

type ComponentConfig struct {
	Name                 string `json:"name"`
	ExecutablePath       string `json:"executable_path"`
	IncludeEnv           bool   `json:"include_env"`
	IncludeCmdline       bool   `json:"include_cmdline"`
	IncludeCwd           bool   `json:"include_cwd"`
	IncludeOpenFileCount bool   `json:"include_open_file_count"`
	IncludeMemInfo       bool   `json:"include_mem_info"`
}

func (*ComponentConfig) Validate

func (conf *ComponentConfig) Validate(path string) ([]string, error)

type Config

type Config struct {
	resource.Named
	// contains filtered or unexported fields
}

func (*Config) Close

func (c *Config) Close(ctx context.Context) error

func (*Config) Readings

func (c *Config) Readings(ctx context.Context, extra map[string]interface{}) (map[string]interface{}, error)

func (*Config) Ready

func (c *Config) Ready(ctx context.Context, extra map[string]interface{}) (bool, error)

func (*Config) Reconfigure

func (c *Config) Reconfigure(ctx context.Context, _ resource.Dependencies, conf resource.Config) error

func (*Config) Update

func (c *Config) Update(ctx context.Context)