process

type Params ¶

type Params struct {
	Path string
	Args []string
	Env  []string
}

Params represent Agent process parameters: command path, command-line arguments/flags, and process environment.

func (p *Params) String() string

type Process ¶

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

Process represents Agent process started by pmm-agent.

Process object should be created with New and started with Run (typically in a separate goroutine). It then handles process starting, restarting with backoff, reading its output. Process is gracefully stopped when context passed to New is canceled. Changes of process status are reported via Changes channel which must be read until it is closed.

Process status is changed by finite state machine (see agent_status.dot). Each state logic is encapsulated in toXXX methods. Each method sends a new status to the changes channel, implements its own logic, and then switches to then next state via "go toXXX()". "go" statement is used only to avoid stack overflow; there are no extra goroutines for states.

func New(params *Params, redactWords []string, l *logrus.Entry) *Process

func (p *Process) Changes() <-chan inventorypb.AgentStatus

func (p *Process) Logs() []string

func (p *Process) Run(ctx context.Context)