runner

Documentation

Index

• Constants
• type Logstreamer
  • func NewLogstreamer(stdType string, name string) *Logstreamer
  • func (l *Logstreamer) Close()
  • func (l *Logstreamer) Flush() error
  • func (l *Logstreamer) OutputLines() (err error)
  • func (l *Logstreamer) Write(p []byte) (n int, err error)
• type Runner
  • func NewRunner(proxy proxy.ProxyInterface, project *config.Project) *Runner
  • func (r *Runner) Restart(application *config.Application)
  • func (r *Runner) Run(application *config.Application)
  • func (r *Runner) RunAll()
  • func (r *Runner) SetupAll()
  • func (r *Runner) Stop() error
• type RunnerInterface

Constants

const (
	StdOut = "stdout"
	StdErr = "stderr"
)

Types

type Logstreamer

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

func NewLogstreamer

func NewLogstreamer(stdType string, name string) *Logstreamer

func (*Logstreamer) Close

func (l *Logstreamer) Close()

func (*Logstreamer) Flush

func (l *Logstreamer) Flush() error

func (*Logstreamer) OutputLines

func (l *Logstreamer) OutputLines() (err error)

func (*Logstreamer) Write

func (l *Logstreamer) Write(p []byte) (n int, err error)

type Runner

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

Runner is the struct that manage running local applications

func NewRunner

func NewRunner(proxy proxy.ProxyInterface, project *config.Project) *Runner

NewRunner instancites a Runner struct from configuration data

func (*Runner) Restart

func (r *Runner) Restart(application *config.Application)

Restart kills the current application launch (if it exists) and launch a new one

func (*Runner) Run

func (r *Runner) Run(application *config.Application)

Run launches the application

func (*Runner) RunAll

func (r *Runner) RunAll()

RunAll runs all local applications in separated goroutines

func (*Runner) SetupAll

func (r *Runner) SetupAll()

SetupAll runs setup commands for all applications in case their directory does not already exists

func (*Runner) Stop

func (r *Runner) Stop() error

Stop stops all the currently active local applications

type RunnerInterface

type RunnerInterface interface {
	RunAll()
	SetupAll()
	Run(application *config.Application)
	Restart(application *config.Application)
	Stop() error
}