processmanager

Documentation

Index

• Variables
• func Load(name string, cfg *config.Config, executor, detailedExecutor contracts.Executor) (contracts.ProcessManager, error)
• type Simple
  • func NewSimple(cfg *config.Config, executor, detailedExecutor contracts.Executor) *Simple
  • func (pm *Simple) GetOutput(ctx context.Context, server *domain.Server, out io.Writer) (domain.Result, error)
  • func (pm *Simple) Install(_ context.Context, _ *domain.Server, _ io.Writer) (domain.Result, error)
  • func (pm *Simple) Restart(ctx context.Context, server *domain.Server, out io.Writer) (domain.Result, error)
  • func (pm *Simple) SendInput(ctx context.Context, input string, server *domain.Server, out io.Writer) (domain.Result, error)
  • func (pm *Simple) Start(ctx context.Context, server *domain.Server, out io.Writer) (domain.Result, error)
  • func (pm *Simple) Status(ctx context.Context, server *domain.Server, out io.Writer) (domain.Result, error)
  • func (pm *Simple) Stop(ctx context.Context, server *domain.Server, out io.Writer) (domain.Result, error)
  • func (pm *Simple) Uninstall(_ context.Context, _ *domain.Server, _ io.Writer) (domain.Result, error)
• type SystemD
  • func NewSystemD(cfg *config.Config, _, detailedExecutor contracts.Executor) *SystemD
  • func (pm *SystemD) GetOutput(ctx context.Context, server *domain.Server, out io.Writer) (domain.Result, error)
  • func (pm *SystemD) Install(_ context.Context, _ *domain.Server, _ io.Writer) (domain.Result, error)
  • func (pm *SystemD) Restart(ctx context.Context, server *domain.Server, out io.Writer) (domain.Result, error)
  • func (pm *SystemD) SendInput(ctx context.Context, input string, server *domain.Server, _ io.Writer) (domain.Result, error)
  • func (pm *SystemD) Start(ctx context.Context, server *domain.Server, out io.Writer) (domain.Result, error)
  • func (pm *SystemD) Status(ctx context.Context, server *domain.Server, out io.Writer) (domain.Result, error)
  • func (pm *SystemD) Stop(ctx context.Context, server *domain.Server, out io.Writer) (domain.Result, error)
  • func (pm *SystemD) Uninstall(ctx context.Context, server *domain.Server, _ io.Writer) (domain.Result, error)
• type Tmux
  • func NewTmux(cfg *config.Config, executor, detailedExecutor contracts.Executor) *Tmux
  • func (pm *Tmux) GetOutput(ctx context.Context, server *domain.Server, out io.Writer) (domain.Result, error)
  • func (pm *Tmux) Install(_ context.Context, _ *domain.Server, _ io.Writer) (domain.Result, error)
  • func (pm *Tmux) Restart(ctx context.Context, server *domain.Server, out io.Writer) (domain.Result, error)
  • func (pm *Tmux) SendInput(ctx context.Context, input string, server *domain.Server, out io.Writer) (domain.Result, error)
  • func (pm *Tmux) Start(ctx context.Context, server *domain.Server, out io.Writer) (domain.Result, error)
  • func (pm *Tmux) Status(ctx context.Context, server *domain.Server, out io.Writer) (domain.Result, error)
  • func (pm *Tmux) Stop(ctx context.Context, server *domain.Server, out io.Writer) (domain.Result, error)
  • func (pm *Tmux) Uninstall(_ context.Context, _ *domain.Server, _ io.Writer) (domain.Result, error)

Variables

var (
	ErrUnknownProcessManager = errors.New("unknown process manager")
	ErrEmptyUser             = errors.New("empty user")
	ErrUserNotFound          = errors.New("user not found")
	ErrInvalidUserPassword   = errors.New("invalid user password")
	ErrEmptyCommand          = errors.New("empty command")
)

Functions

func Load

func Load(
	name string, cfg *config.Config, executor, detailedExecutor contracts.Executor,
) (contracts.ProcessManager, error)

Types

type Simple

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

func NewSimple

func NewSimple(cfg *config.Config, executor, detailedExecutor contracts.Executor) *Simple

func (*Simple) GetOutput

func (pm *Simple) GetOutput(
	ctx context.Context, server *domain.Server, out io.Writer,
) (domain.Result, error)

func (*Simple) Install

func (pm *Simple) Install(_ context.Context, _ *domain.Server, _ io.Writer) (domain.Result, error)

func (*Simple) Restart

func (pm *Simple) Restart(
	ctx context.Context, server *domain.Server, out io.Writer,
) (domain.Result, error)

func (*Simple) SendInput

func (pm *Simple) SendInput(
	ctx context.Context, input string, server *domain.Server, out io.Writer,
) (domain.Result, error)

func (*Simple) Start

func (pm *Simple) Start(
	ctx context.Context, server *domain.Server, out io.Writer,
) (domain.Result, error)

func (*Simple) Status

func (pm *Simple) Status(
	ctx context.Context, server *domain.Server, out io.Writer,
) (domain.Result, error)

func (*Simple) Stop

func (pm *Simple) Stop(
	ctx context.Context, server *domain.Server, out io.Writer,
) (domain.Result, error)

func (*Simple) Uninstall

func (pm *Simple) Uninstall(_ context.Context, _ *domain.Server, _ io.Writer) (domain.Result, error)

type SystemD

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

func NewSystemD

func NewSystemD(cfg *config.Config, _, detailedExecutor contracts.Executor) *SystemD

func (*SystemD) GetOutput

func (pm *SystemD) GetOutput(ctx context.Context, server *domain.Server, out io.Writer) (domain.Result, error)

func (*SystemD) Install

func (pm *SystemD) Install(
	_ context.Context, _ *domain.Server, _ io.Writer,
) (domain.Result, error)

func (*SystemD) Restart

func (pm *SystemD) Restart(ctx context.Context, server *domain.Server, out io.Writer) (domain.Result, error)

func (*SystemD) SendInput

func (pm *SystemD) SendInput(
	ctx context.Context, input string, server *domain.Server, _ io.Writer,
) (domain.Result, error)

func (*SystemD) Start

func (pm *SystemD) Start(ctx context.Context, server *domain.Server, out io.Writer) (domain.Result, error)

func (*SystemD) Status

func (pm *SystemD) Status(ctx context.Context, server *domain.Server, out io.Writer) (domain.Result, error)

func (*SystemD) Stop

func (pm *SystemD) Stop(ctx context.Context, server *domain.Server, out io.Writer) (domain.Result, error)

func (*SystemD) Uninstall

func (pm *SystemD) Uninstall(
	ctx context.Context, server *domain.Server, _ io.Writer,
) (domain.Result, error)

type Tmux

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

func NewTmux

func NewTmux(cfg *config.Config, executor, detailedExecutor contracts.Executor) *Tmux

func (*Tmux) GetOutput

func (pm *Tmux) GetOutput(
	ctx context.Context, server *domain.Server, out io.Writer,
) (domain.Result, error)

func (*Tmux) Install

func (pm *Tmux) Install(_ context.Context, _ *domain.Server, _ io.Writer) (domain.Result, error)

func (*Tmux) Restart

func (pm *Tmux) Restart(
	ctx context.Context, server *domain.Server, out io.Writer,
) (domain.Result, error)

func (*Tmux) SendInput

func (pm *Tmux) SendInput(
	ctx context.Context, input string, server *domain.Server, out io.Writer,
) (domain.Result, error)

func (*Tmux) Start

func (pm *Tmux) Start(
	ctx context.Context, server *domain.Server, out io.Writer,
) (domain.Result, error)

func (*Tmux) Status

func (pm *Tmux) Status(
	ctx context.Context, server *domain.Server, out io.Writer,
) (domain.Result, error)

func (*Tmux) Stop

func (pm *Tmux) Stop(
	ctx context.Context, server *domain.Server, out io.Writer,
) (domain.Result, error)

func (*Tmux) Uninstall

func (pm *Tmux) Uninstall(_ context.Context, _ *domain.Server, _ io.Writer) (domain.Result, error)