cmdrunner

Documentation

Index

• Variables
• type CmdRunner
  • func NewCmdRunner(logger *slog.Logger, cmd *exec.Cmd) (*CmdRunner, error)
  • func (c *CmdRunner) Diagnose(_ context.Context) string
  • func (*CmdRunner) HostToPlugin(hostNet, hostAddr string) (string, string, error)
  • func (c *CmdRunner) ID() string
  • func (c *CmdRunner) Kill(_ context.Context) error
  • func (c *CmdRunner) Name() string
  • func (*CmdRunner) PluginToHost(pluginNet, pluginAddr string) (string, string, error)
  • func (c *CmdRunner) Start(_ context.Context) error
  • func (c *CmdRunner) Stderr() io.ReadCloser
  • func (c *CmdRunner) Stdout() io.ReadCloser
  • func (c *CmdRunner) Wait(_ context.Context) error

Variables

var (

	// ErrProcessNotFound is returned when a client is instantiated to
	// reattach to an existing process and it isn't found.
	ErrProcessNotFound = errors.New("reattachment process not found")
)

Types

type CmdRunner

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

CmdRunner implements the runner.Runner interface. It mostly just passes through to exec.Cmd methods.

func NewCmdRunner

func NewCmdRunner(logger *slog.Logger, cmd *exec.Cmd) (*CmdRunner, error)

NewCmdRunner returns an implementation of runner.Runner for running a plugin as a subprocess. It must be passed a cmd that hasn't yet been started.

func (*CmdRunner) Diagnose

func (c *CmdRunner) Diagnose(_ context.Context) string

func (*CmdRunner) HostToPlugin

func (*CmdRunner) HostToPlugin(hostNet, hostAddr string) (string, string, error)

func (*CmdRunner) ID

func (c *CmdRunner) ID() string

func (*CmdRunner) Kill

func (c *CmdRunner) Kill(_ context.Context) error

func (*CmdRunner) Name

func (c *CmdRunner) Name() string

func (*CmdRunner) PluginToHost

func (*CmdRunner) PluginToHost(pluginNet, pluginAddr string) (string, string, error)

func (*CmdRunner) Start

func (c *CmdRunner) Start(_ context.Context) error

func (*CmdRunner) Stderr

func (c *CmdRunner) Stderr() io.ReadCloser

func (*CmdRunner) Stdout

func (c *CmdRunner) Stdout() io.ReadCloser

func (*CmdRunner) Wait

func (c *CmdRunner) Wait(_ context.Context) error