process

Documentation

Index

• Constants
• type Config
  • func (c *Config) IsActive() bool
• type K8sOperator
• type Module
  • func NewModule() *Module
  • func (m *Module) AddListener(listener api.ProcessListener)
  • func (m *Module) Config() module.ConfigInterface
  • func (m *Module) DeleteListener(listener api.ProcessListener)
  • func (m *Module) FindAllRegisteredProcesses() []api.ProcessInterface
  • func (m *Module) FindProcessByID(processID string) api.ProcessInterface
  • func (m *Module) FindProcessByPID(pid int32) []api.ProcessInterface
  • func (m *Module) GetAllProcesses() []api.ProcessInterface
  • func (m *Module) Name() string
  • func (m *Module) NodeName() string
  • func (m *Module) NotifyStartSuccess()
  • func (m *Module) RequiredModules() []string
  • func (m *Module) ShouldMonitor(pid int32) bool
  • func (m *Module) Shutdown(ctx context.Context, mgr *module.Manager) error
  • func (m *Module) Start(ctx context.Context, mgr *module.Manager) error
• type Operator

Constants

const ModuleName = "process_discovery"

Types

type Config

type Config struct {
	module.Config

	// heartbeat the process list period
	HeartbeatPeriod string `mapstructure:"heartbeat_period"`

	// sends properties to the backend period
	PropertiesReportPeriod int `mapstructure:"properties_report_period"`

	Kubernetes *kubernetes.Config `mapstructure:"kubernetes"`
}

func (*Config) IsActive

func (c *Config) IsActive() bool

type K8sOperator

type K8sOperator interface {
	// NodeName get the node name
	NodeName() string
}

type Module

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

func NewModule

func NewModule() *Module

func (*Module) AddListener

func (m *Module) AddListener(listener api.ProcessListener)

func (*Module) Config

func (m *Module) Config() module.ConfigInterface

func (*Module) DeleteListener

func (m *Module) DeleteListener(listener api.ProcessListener)

func (*Module) FindAllRegisteredProcesses

func (m *Module) FindAllRegisteredProcesses() []api.ProcessInterface

func (*Module) FindProcessByID

func (m *Module) FindProcessByID(processID string) api.ProcessInterface

func (*Module) FindProcessByPID

func (m *Module) FindProcessByPID(pid int32) []api.ProcessInterface

func (*Module) GetAllProcesses

func (m *Module) GetAllProcesses() []api.ProcessInterface

func (*Module) Name

func (m *Module) Name() string

func (*Module) NodeName

func (m *Module) NodeName() string

func (*Module) NotifyStartSuccess

func (m *Module) NotifyStartSuccess()

func (*Module) RequiredModules

func (m *Module) RequiredModules() []string

func (*Module) ShouldMonitor

func (m *Module) ShouldMonitor(pid int32) bool

func (*Module) Shutdown

func (m *Module) Shutdown(ctx context.Context, mgr *module.Manager) error

func (*Module) Start

func (m *Module) Start(ctx context.Context, mgr *module.Manager) error

type Operator

type Operator interface {
	// FindProcessById the processID is received from the backend, if not found then return nil
	FindProcessByID(processID string) api.ProcessInterface
	// FindProcessByPID get all processes with difference entity through process PID
	FindProcessByPID(pid int32) []api.ProcessInterface
	// FindAllRegisteredProcesses find all registered processes
	FindAllRegisteredProcesses() []api.ProcessInterface
	// AddListener add new process listener
	AddListener(listener api.ProcessListener)
	// DeleteListener delete the process listener
	DeleteListener(listener api.ProcessListener)
	// ShouldMonitor check the process should be monitored
	ShouldMonitor(pid int32) bool
}