service

Documentation

Overview

Plain Old Go Object for persisting Server information

Index

• func ParseServerStartReq(path string) (*skylab_test_runner.CrosTestRunnerServerStartRequest, error)
• func ValidateExecuteRequest(req *skylab_test_runner.CrosTestRunnerServerStartRequest) error
• type CrosTestRunnerServer
  • func NewCrosTestRunnerServer(metadata *ServerMetadata) (*CrosTestRunnerServer, func(), error)
  • func (server *CrosTestRunnerServer) ConstructStateKeeper() *data.LocalTestStateKeeper
  • func (server *CrosTestRunnerServer) Execute(ctx context.Context, req *skylab_test_runner.ExecuteRequest) (*skylab_test_runner.ExecuteResponse, error)
  • func (server *CrosTestRunnerServer) Start() error
• type CrosTestRunnerService
  • func NewCrosTestRunnerService(execReq *skylab_test_runner.ExecuteRequest, ...) (*CrosTestRunnerService, error)
  • func (crs *CrosTestRunnerService) Execute(ctx context.Context, logPath string, noSudo bool) (*skylab_test_runner.ExecuteResponse, error)
• type ServerMetadata

Functions

func ParseServerStartReq

func ParseServerStartReq(path string) (*skylab_test_runner.CrosTestRunnerServerStartRequest, error)

ParseServerStartReq parses CrosTestRunnerServerStartRequest input request data from the input file.

func ValidateExecuteRequest

func ValidateExecuteRequest(req *skylab_test_runner.CrosTestRunnerServerStartRequest) error

ValidateExecuteRequest validates provided request.

Types

type CrosTestRunnerServer

type CrosTestRunnerServer struct {
	skylab_test_runner.UnimplementedCrosTestRunnerServiceServer
	// contains filtered or unexported fields
}

func NewCrosTestRunnerServer

func NewCrosTestRunnerServer(metadata *ServerMetadata) (*CrosTestRunnerServer, func(), error)

func (*CrosTestRunnerServer) ConstructStateKeeper

func (server *CrosTestRunnerServer) ConstructStateKeeper() *data.LocalTestStateKeeper

func (*CrosTestRunnerServer) Execute

func (server *CrosTestRunnerServer) Execute(ctx context.Context, req *skylab_test_runner.ExecuteRequest) (*skylab_test_runner.ExecuteResponse, error)

func (*CrosTestRunnerServer) Start

func (server *CrosTestRunnerServer) Start() error

type CrosTestRunnerService

type CrosTestRunnerService struct {
	ServerStartRequest *skylab_test_runner.CrosTestRunnerServerStartRequest
	// contains filtered or unexported fields
}

func NewCrosTestRunnerService

func NewCrosTestRunnerService(execReq *skylab_test_runner.ExecuteRequest, serverSK *data.LocalTestStateKeeper) (*CrosTestRunnerService, error)

func (*CrosTestRunnerService) Execute

func (crs *CrosTestRunnerService) Execute(ctx context.Context, logPath string, noSudo bool) (*skylab_test_runner.ExecuteResponse, error)

type ServerMetadata

type ServerMetadata struct {
	Port                      int
	ServiceMetadataExportPath string
	LogPath                   string
	NoSudo                    bool
	InputProto                *skylab_test_runner.CrosTestRunnerServerStartRequest
}

ServerMetadata stores server specific information