subprocess

Documentation

Index

• Constants
• type Config
• type Subprocess
  • func NewSubprocess(conf *Config, logger *zap.Logger) *Subprocess
  • func (subprocess *Subprocess) Pid() int
  • func (subprocess *Subprocess) Shutdown(ctx context.Context) error
  • func (subprocess *Subprocess) Start(ctx context.Context) error

Constants

const (
	Starting     = "Starting"
	Running      = "Running"
	ShuttingDown = "ShuttingDown"
	Stopped      = "Stopped"
	Restarting   = "Restarting"
	Errored      = "Errored"
)

Types

type Config

type Config struct {
	ExecutablePath       string            `mapstructure:"executable_path"`
	Args                 []string          `mapstructure:"args"`
	EnvironmentVariables map[string]string `mapstructure:"environment_variables"`
	StdInContents        string            `mapstructure:"stdin_contents"`
	RestartOnError       bool              `mapstructure:"restart_on_error"`
	RestartDelay         *time.Duration    `mapstructure:"restart_delay"`
	ShutdownTimeout      *time.Duration    `mapstructure:"shutdown_timeout"`
}

exported to be used by jmx metric receiver

type Subprocess

type Subprocess struct {
	Stdout chan string
	// contains filtered or unexported fields
}

exported to be used by jmx metric receiver

func NewSubprocess

func NewSubprocess(conf *Config, logger *zap.Logger) *Subprocess

exported to be used by jmx metric receiver

func (*Subprocess) Pid

func (subprocess *Subprocess) Pid() int

func (*Subprocess) Shutdown

func (subprocess *Subprocess) Shutdown(ctx context.Context) error

Shutdown is invoked during service shutdown.

func (*Subprocess) Start

func (subprocess *Subprocess) Start(ctx context.Context) error