runner

Documentation

Index

• func ExecuteInitHookForRunner(language string) error
• type LanguageRunner
  • func StartRunner(manifest *manifest.Manifest, port string, reporter reporter.Reporter, ...) (*LanguageRunner, error)
  • func (r *LanguageRunner) Connection() net.Conn
  • func (r *LanguageRunner) ExecuteAndGetStatus(message *gauge_messages.Message) *gauge_messages.ProtoExecutionResult
  • func (r *LanguageRunner) IsMultithreaded() bool
  • func (r *LanguageRunner) IsProcessRunning() bool
  • func (r *LanguageRunner) Kill() error
  • func (r *LanguageRunner) Pid() int
• type MultithreadedRunner
  • func (r *MultithreadedRunner) Connection() net.Conn
  • func (r *MultithreadedRunner) ExecuteAndGetStatus(message *gauge_messages.Message) *gauge_messages.ProtoExecutionResult
  • func (r *MultithreadedRunner) IsMultithreaded() bool
  • func (r *MultithreadedRunner) IsProcessRunning() bool
  • func (r *MultithreadedRunner) Kill() error
  • func (r *MultithreadedRunner) Pid() int
  • func (r *MultithreadedRunner) SetConnection(c net.Conn)
• type Runner
  • func Start(manifest *manifest.Manifest, reporter reporter.Reporter, killChannel chan bool, ...) (Runner, error)
• type RunnerInfo
  • func GetRunnerInfo(language string) (*RunnerInfo, error)
• type StartChannels

Functions

func ExecuteInitHookForRunner

func ExecuteInitHookForRunner(language string) error

Types

type LanguageRunner

type LanguageRunner struct {
	Cmd *exec.Cmd
	// contains filtered or unexported fields
}

func StartRunner

func StartRunner(manifest *manifest.Manifest, port string, reporter reporter.Reporter, killChannel chan bool, debug bool) (*LanguageRunner, error)

Looks for a runner configuration inside the runner directory finds the runner configuration matching to the manifest and executes the commands for the current OS

func (*LanguageRunner) Connection

func (r *LanguageRunner) Connection() net.Conn

func (*LanguageRunner) ExecuteAndGetStatus

func (r *LanguageRunner) ExecuteAndGetStatus(message *gauge_messages.Message) *gauge_messages.ProtoExecutionResult

func (*LanguageRunner) IsMultithreaded

func (r *LanguageRunner) IsMultithreaded() bool

func (*LanguageRunner) IsProcessRunning

func (r *LanguageRunner) IsProcessRunning() bool

func (*LanguageRunner) Kill

func (r *LanguageRunner) Kill() error

func (*LanguageRunner) Pid

func (r *LanguageRunner) Pid() int

type MultithreadedRunner

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

func (*MultithreadedRunner) Connection

func (r *MultithreadedRunner) Connection() net.Conn

func (*MultithreadedRunner) ExecuteAndGetStatus

func (r *MultithreadedRunner) ExecuteAndGetStatus(message *gauge_messages.Message) *gauge_messages.ProtoExecutionResult

func (*MultithreadedRunner) IsMultithreaded

func (r *MultithreadedRunner) IsMultithreaded() bool

func (*MultithreadedRunner) IsProcessRunning

func (r *MultithreadedRunner) IsProcessRunning() bool

func (*MultithreadedRunner) Kill

func (r *MultithreadedRunner) Kill() error

func (*MultithreadedRunner) Pid

func (r *MultithreadedRunner) Pid() int

func (*MultithreadedRunner) SetConnection

func (r *MultithreadedRunner) SetConnection(c net.Conn)

type Runner

type Runner interface {
	ExecuteAndGetStatus(m *gauge_messages.Message) *gauge_messages.ProtoExecutionResult
	IsProcessRunning() bool
	Kill() error
	Connection() net.Conn
	IsMultithreaded() bool
	Pid() int
}

func Start

func Start(manifest *manifest.Manifest, reporter reporter.Reporter, killChannel chan bool, debug bool) (Runner, error)

type RunnerInfo

type RunnerInfo struct {
	Id          string
	Name        string
	Version     string
	Description string
	Run         struct {
		Windows []string
		Linux   []string
		Darwin  []string
	}
	Init struct {
		Windows []string
		Linux   []string
		Darwin  []string
	}
	Lib                 string
	Multithreaded       bool
	GaugeVersionSupport version.VersionSupport
}

func GetRunnerInfo

func GetRunnerInfo(language string) (*RunnerInfo, error)

type StartChannels

type StartChannels struct {
	// this will hold the runner
	RunnerChan chan Runner
	// this will hold the error while creating runner
	ErrorChan chan error
	// this holds a flag based on which the runner is terminated
	KillChan chan bool
}