interoptestservice

Documentation

Overview

Package interoptestservice is the logic for handling test run and result requests from controller.

Index

• type ServerImpl
  • func NewServer(addr string) (*ServerImpl, error)
  • func (srv *ServerImpl) Start(ctx context.Context, svc *ServiceImpl) error
  • func (srv *ServerImpl) Stop() error
• type ServiceImpl
  • func NewService(services map[string][]*interop.Service, sink *receiver.TestCoordinatorSink) *ServiceImpl
  • func (s *ServiceImpl) Result(ctx context.Context, req *interop.InteropResultRequest) (*interop.InteropResultResponse, error)
  • func (s *ServiceImpl) Run(ctx context.Context, req *interop.InteropRunRequest) (*interop.InteropRunResponse, error)
  • func (s *ServiceImpl) SetRegisteredServices(services map[string][]*interop.Service)

Types

type ServerImpl

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

ServerImpl is the type that handles RPCs for interop test service.

func NewServer

func NewServer(addr string) (*ServerImpl, error)

NewServer returns a new unstarted gRPC interop server.

func (*ServerImpl) Start

func (srv *ServerImpl) Start(ctx context.Context, svc *ServiceImpl) error

Start runs ServiceImpl.

func (*ServerImpl) Stop

func (srv *ServerImpl) Stop() error

Stop stops the underlying gRPC server and all the services running on it.

type ServiceImpl

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

ServiceImpl is the implementation of InteropTestServiceServer.

func NewService

func NewService(services map[string][]*interop.Service, sink *receiver.TestCoordinatorSink) *ServiceImpl

NewService returns a new ServiceImpl with the given registered services.

func (*ServiceImpl) Result

func (s *ServiceImpl) Result(ctx context.Context, req *interop.InteropResultRequest) (*interop.InteropResultResponse, error)

Result returns all the test results.

func (*ServiceImpl) Run

func (s *ServiceImpl) Run(ctx context.Context, req *interop.InteropRunRequest) (*interop.InteropRunResponse, error)

Run runs the test asynchronously.

func (*ServiceImpl) SetRegisteredServices

func (s *ServiceImpl) SetRegisteredServices(services map[string][]*interop.Service)

SetRegisteredServices sets the registered services to the given one.