process

Documentation

Index

• Constants
• type Config
  • func (c *Config) IsActive() bool
• type Module
  • func NewModule() *Module
  • func (m *Module) Config() module.ConfigInterface
  • func (m *Module) FindProcessByID(processID string) api.ProcessInterface
  • func (m *Module) Name() string
  • func (m *Module) NotifyStartSuccess()
  • func (m *Module) RequiredModules() []string
  • 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"`

	// Scanner process from Linux
	Scanner *scanner.Config `mapstructure:"scanner"`

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

func (*Config) IsActive

func (c *Config) IsActive() bool

type Module

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

func NewModule

func NewModule() *Module

func (*Module) Config

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

func (*Module) FindProcessByID

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

func (*Module) Name

func (m *Module) Name() string

func (*Module) NotifyStartSuccess

func (m *Module) NotifyStartSuccess()

func (*Module) RequiredModules

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

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
}