Versions in this module Expand all Collapse all v1 v1.6.20 Aug 17, 2022 Changes in this version + var ErrIntOverflowTest = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthTest = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupTest = fmt.Errorf("proto: unexpected end of group") + func Main() + func Register(name string, suite TestingSuite) + func RegisterWorkerServiceServer(s *grpc.Server, srv WorkerServiceServer) + func Run(config *Config) error + func RunTests(t *testing.T, suite TestingSuite, request *TestRequest) + type AfterTest interface + AfterTest func(testName string) error + type BeforeTest interface + BeforeTest func(testName string) error + type Config struct + Args map[string]string + Iterations int + NoTeardown bool + Suites []string + Tests []string + Verbose bool + type Coordinator struct + func (c *Coordinator) Run() (int, error) + type SetupTest interface + SetupTest func() error + type SetupTestSuite interface + SetupTestSuite func(c *input.Context) error + type Suite struct + type TearDownTest interface + TearDownTest func() error + type TearDownTestSuite interface + TearDownTestSuite func() error + type TestRequest struct + Args map[string]string + Suite string + Tests []string + func (*TestRequest) Descriptor() ([]byte, []int) + func (*TestRequest) ProtoMessage() + func (m *TestRequest) GetArgs() map[string]string + func (m *TestRequest) GetSuite() string + func (m *TestRequest) GetTests() []string + func (m *TestRequest) Marshal() (dAtA []byte, err error) + func (m *TestRequest) MarshalTo(dAtA []byte) (int, error) + func (m *TestRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TestRequest) Reset() + func (m *TestRequest) Size() (n int) + func (m *TestRequest) String() string + func (m *TestRequest) Unmarshal(dAtA []byte) error + func (m *TestRequest) XXX_DiscardUnknown() + func (m *TestRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TestRequest) XXX_Merge(src proto.Message) + func (m *TestRequest) XXX_Size() int + func (m *TestRequest) XXX_Unmarshal(b []byte) error + type TestResponse struct + func (*TestResponse) Descriptor() ([]byte, []int) + func (*TestResponse) ProtoMessage() + func (m *TestResponse) Marshal() (dAtA []byte, err error) + func (m *TestResponse) MarshalTo(dAtA []byte) (int, error) + func (m *TestResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TestResponse) Reset() + func (m *TestResponse) Size() (n int) + func (m *TestResponse) String() string + func (m *TestResponse) Unmarshal(dAtA []byte) error + func (m *TestResponse) XXX_DiscardUnknown() + func (m *TestResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TestResponse) XXX_Merge(src proto.Message) + func (m *TestResponse) XXX_Size() int + func (m *TestResponse) XXX_Unmarshal(b []byte) error + type TestingSuite interface + type UnimplementedWorkerServiceServer struct + func (*UnimplementedWorkerServiceServer) RunTests(ctx context.Context, req *TestRequest) (*TestResponse, error) + type Worker struct + func (w *Worker) Run() error + func (w *Worker) RunTests(ctx context.Context, request *TestRequest) (*TestResponse, error) + type WorkerServiceClient interface + RunTests func(ctx context.Context, in *TestRequest, opts ...grpc.CallOption) (*TestResponse, error) + func NewWorkerServiceClient(cc *grpc.ClientConn) WorkerServiceClient + type WorkerServiceServer interface + RunTests func(context.Context, *TestRequest) (*TestResponse, error) + type WorkerTask struct + func (t *WorkerTask) Run() (int, error)