runner

Documentation

Index

• func ExecuteInitHookForRunner(language string) error
• type GrpcRunner
  • func ConnectToGrpcRunner(manifest *manifest.Manifest, outFile io.Writer, timeout time.Duration) (*GrpcRunner, error)
  • func (r *GrpcRunner) Alive() bool
  • func (r *GrpcRunner) Connection() net.Conn
  • func (r *GrpcRunner) ExecuteAndGetStatus(m *gm.Message) *gm.ProtoExecutionResult
  • func (r *GrpcRunner) ExecuteMessageWithTimeout(message *gm.Message) (*gm.Message, error)
  • func (r *GrpcRunner) IsMultithreaded() bool
  • func (r *GrpcRunner) Kill() error
  • func (r *GrpcRunner) Pid() int
• type LanguageRunner
  • func StartRunner(manifest *manifest.Manifest, port string, outputStreamWriter io.Writer, ...) (*LanguageRunner, error)
  • func (r *LanguageRunner) Alive() bool
  • func (r *LanguageRunner) Connection() net.Conn
  • func (r *LanguageRunner) EnsureConnected() bool
  • func (r *LanguageRunner) ExecuteAndGetStatus(message *gauge_messages.Message) *gauge_messages.ProtoExecutionResult
  • func (r *LanguageRunner) ExecuteMessageWithTimeout(message *gauge_messages.Message) (*gauge_messages.Message, error)
  • func (r *LanguageRunner) IsMultithreaded() bool
  • func (r *LanguageRunner) Kill() error
  • func (r *LanguageRunner) Pid() int
• type MultithreadedRunner
  • func (r *MultithreadedRunner) Alive() bool
  • func (r *MultithreadedRunner) Connection() net.Conn
  • func (r *MultithreadedRunner) ExecuteAndGetStatus(message *gauge_messages.Message) *gauge_messages.ProtoExecutionResult
  • func (r *MultithreadedRunner) ExecuteMessageWithTimeout(message *gauge_messages.Message) (*gauge_messages.Message, error)
  • func (r *MultithreadedRunner) IsMultithreaded() 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, outputStreamWriter io.Writer, ...) (Runner, error)
• type RunnerInfo
  • func GetRunnerInfo(language string) (*RunnerInfo, error)
• type StartChannels

Functions

func ExecuteInitHookForRunner

func ExecuteInitHookForRunner(language string) error

Types

type GrpcRunner

type GrpcRunner struct {
	Client  gm.LspServiceClient
	Timeout time.Duration
	// contains filtered or unexported fields
}

GrpcRunner handles grpc messages.

func ConnectToGrpcRunner

func ConnectToGrpcRunner(manifest *manifest.Manifest, outFile io.Writer, timeout time.Duration) (*GrpcRunner, error)

ConnectToGrpcRunner makes a connection with grpc server

func (*GrpcRunner) Alive

func (r *GrpcRunner) Alive() bool

func (*GrpcRunner) Connection

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

func (*GrpcRunner) ExecuteAndGetStatus

func (r *GrpcRunner) ExecuteAndGetStatus(m *gm.Message) *gm.ProtoExecutionResult

func (*GrpcRunner) ExecuteMessageWithTimeout

func (r *GrpcRunner) ExecuteMessageWithTimeout(message *gm.Message) (*gm.Message, error)

ExecuteMessageWithTimeout process reuqest and give back the response

func (*GrpcRunner) IsMultithreaded

func (r *GrpcRunner) IsMultithreaded() bool

func (*GrpcRunner) Kill

func (r *GrpcRunner) Kill() error

Kill closes the grpc connection and kills the process

func (*GrpcRunner) Pid

func (r *GrpcRunner) Pid() int

type LanguageRunner

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

func StartRunner

func StartRunner(manifest *manifest.Manifest, port string, outputStreamWriter io.Writer, 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) Alive

func (r *LanguageRunner) Alive() bool

func (*LanguageRunner) Connection

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

func (*LanguageRunner) EnsureConnected

func (r *LanguageRunner) EnsureConnected() bool

func (*LanguageRunner) ExecuteAndGetStatus

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

ExecuteAndGetStatus invokes the runner with a request and waits for response. error is thrown only when unable to connect to runner

func (*LanguageRunner) ExecuteMessageWithTimeout

func (r *LanguageRunner) ExecuteMessageWithTimeout(message *gauge_messages.Message) (*gauge_messages.Message, error)

func (*LanguageRunner) IsMultithreaded

func (r *LanguageRunner) IsMultithreaded() 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) Alive

func (r *MultithreadedRunner) Alive() bool

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) ExecuteMessageWithTimeout

func (r *MultithreadedRunner) ExecuteMessageWithTimeout(message *gauge_messages.Message) (*gauge_messages.Message, error)

func (*MultithreadedRunner) IsMultithreaded

func (r *MultithreadedRunner) IsMultithreaded() 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
	ExecuteMessageWithTimeout(m *gauge_messages.Message) (*gauge_messages.Message, error)
	Alive() bool
	Kill() error
	Connection() net.Conn
	IsMultithreaded() bool
	Pid() int
}

func Start

func Start(manifest *manifest.Manifest, outputStreamWriter io.Writer, 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
	LspLangId           string
}

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
}