testutil

package
v2.254.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 1, 2021 License: Apache-2.0, MIT Imports: 18 Imported by: 0

Documentation

Overview

Package testutil contains testing helpers (logging, slow skipping).

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FilterSpeed added in v2.130.0 

func FilterSpeed(t *testing.T, speed Speed)

func FilterStability added in v2.130.0 

func FilterStability(t *testing.T, stability Stability)

func FilterStabilityAndSpeed added in v2.130.0 

func FilterStabilityAndSpeed(t *testing.T, stability Stability, speed Speed)

func Logger 

func Logger(t testing.TB) (*zap.Logger, func())

func RegisterTestServiceServer added in v2.246.0 

func RegisterTestServiceServer(s *grpc.Server, srv TestServiceServer)

func TestingNewServiceClient added in v2.246.0 

func TestingNewServiceClient(ctx context.Context, t *testing.T, opts *Options) (*grpc.ClientConn, *grpc.Server)

Types

type EchoDuplexTest added in v2.246.0 

type EchoDuplexTest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EchoDuplexTest) Descriptor added in v2.246.0 

func (*EchoDuplexTest) Descriptor() ([]byte, []int)

func (*EchoDuplexTest) ProtoMessage added in v2.246.0 

func (*EchoDuplexTest) ProtoMessage()

func (*EchoDuplexTest) Reset added in v2.246.0 

func (m *EchoDuplexTest) Reset()

func (*EchoDuplexTest) String added in v2.246.0 

func (m *EchoDuplexTest) String() string

func (*EchoDuplexTest) XXX_DiscardUnknown added in v2.246.0 

func (m *EchoDuplexTest) XXX_DiscardUnknown()

func (*EchoDuplexTest) XXX_Marshal added in v2.246.0 

func (m *EchoDuplexTest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EchoDuplexTest) XXX_Merge added in v2.246.0 

func (m *EchoDuplexTest) XXX_Merge(src proto.Message)

func (*EchoDuplexTest) XXX_Size added in v2.246.0 

func (m *EchoDuplexTest) XXX_Size() int

func (*EchoDuplexTest) XXX_Unmarshal added in v2.246.0 

func (m *EchoDuplexTest) XXX_Unmarshal(b []byte) error

type EchoDuplexTest_Reply added in v2.246.0 

type EchoDuplexTest_Reply struct {
	Echo                 string   `protobuf:"bytes,1,opt,name=echo,proto3" json:"echo,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EchoDuplexTest_Reply) Descriptor added in v2.246.0 

func (*EchoDuplexTest_Reply) Descriptor() ([]byte, []int)

func (*EchoDuplexTest_Reply) GetEcho added in v2.246.0 

func (m *EchoDuplexTest_Reply) GetEcho() string

func (*EchoDuplexTest_Reply) ProtoMessage added in v2.246.0 

func (*EchoDuplexTest_Reply) ProtoMessage()

func (*EchoDuplexTest_Reply) Reset added in v2.246.0 

func (m *EchoDuplexTest_Reply) Reset()

func (*EchoDuplexTest_Reply) String added in v2.246.0 

func (m *EchoDuplexTest_Reply) String() string

func (*EchoDuplexTest_Reply) XXX_DiscardUnknown added in v2.246.0 

func (m *EchoDuplexTest_Reply) XXX_DiscardUnknown()

func (*EchoDuplexTest_Reply) XXX_Marshal added in v2.246.0 

func (m *EchoDuplexTest_Reply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EchoDuplexTest_Reply) XXX_Merge added in v2.246.0 

func (m *EchoDuplexTest_Reply) XXX_Merge(src proto.Message)

func (*EchoDuplexTest_Reply) XXX_Size added in v2.246.0 

func (m *EchoDuplexTest_Reply) XXX_Size() int

func (*EchoDuplexTest_Reply) XXX_Unmarshal added in v2.246.0 

func (m *EchoDuplexTest_Reply) XXX_Unmarshal(b []byte) error

type EchoDuplexTest_Request added in v2.246.0 

type EchoDuplexTest_Request struct {
	Echo                 string   `protobuf:"bytes,1,opt,name=echo,proto3" json:"echo,omitempty"`
	TriggerError         bool     `protobuf:"varint,2,opt,name=trigger_error,json=triggerError,proto3" json:"trigger_error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EchoDuplexTest_Request) Descriptor added in v2.246.0 

func (*EchoDuplexTest_Request) Descriptor() ([]byte, []int)

func (*EchoDuplexTest_Request) GetEcho added in v2.246.0 

func (m *EchoDuplexTest_Request) GetEcho() string

func (*EchoDuplexTest_Request) GetTriggerError added in v2.246.0 

func (m *EchoDuplexTest_Request) GetTriggerError() bool

func (*EchoDuplexTest_Request) ProtoMessage added in v2.246.0 

func (*EchoDuplexTest_Request) ProtoMessage()

func (*EchoDuplexTest_Request) Reset added in v2.246.0 

func (m *EchoDuplexTest_Request) Reset()

func (*EchoDuplexTest_Request) String added in v2.246.0 

func (m *EchoDuplexTest_Request) String() string

func (*EchoDuplexTest_Request) XXX_DiscardUnknown added in v2.246.0 

func (m *EchoDuplexTest_Request) XXX_DiscardUnknown()

func (*EchoDuplexTest_Request) XXX_Marshal added in v2.246.0 

func (m *EchoDuplexTest_Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EchoDuplexTest_Request) XXX_Merge added in v2.246.0 

func (m *EchoDuplexTest_Request) XXX_Merge(src proto.Message)

func (*EchoDuplexTest_Request) XXX_Size added in v2.246.0 

func (m *EchoDuplexTest_Request) XXX_Size() int

func (*EchoDuplexTest_Request) XXX_Unmarshal added in v2.246.0 

func (m *EchoDuplexTest_Request) XXX_Unmarshal(b []byte) error

type EchoStreamTest added in v2.246.0 

type EchoStreamTest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EchoStreamTest) Descriptor added in v2.246.0 

func (*EchoStreamTest) Descriptor() ([]byte, []int)

func (*EchoStreamTest) ProtoMessage added in v2.246.0 

func (*EchoStreamTest) ProtoMessage()

func (*EchoStreamTest) Reset added in v2.246.0 

func (m *EchoStreamTest) Reset()

func (*EchoStreamTest) String added in v2.246.0 

func (m *EchoStreamTest) String() string

func (*EchoStreamTest) XXX_DiscardUnknown added in v2.246.0 

func (m *EchoStreamTest) XXX_DiscardUnknown()

func (*EchoStreamTest) XXX_Marshal added in v2.246.0 

func (m *EchoStreamTest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EchoStreamTest) XXX_Merge added in v2.246.0 

func (m *EchoStreamTest) XXX_Merge(src proto.Message)

func (*EchoStreamTest) XXX_Size added in v2.246.0 

func (m *EchoStreamTest) XXX_Size() int

func (*EchoStreamTest) XXX_Unmarshal added in v2.246.0 

func (m *EchoStreamTest) XXX_Unmarshal(b []byte) error

type EchoStreamTest_Reply added in v2.246.0 

type EchoStreamTest_Reply struct {
	Echo                 string   `protobuf:"bytes,1,opt,name=echo,proto3" json:"echo,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EchoStreamTest_Reply) Descriptor added in v2.246.0 

func (*EchoStreamTest_Reply) Descriptor() ([]byte, []int)

func (*EchoStreamTest_Reply) GetEcho added in v2.246.0 

func (m *EchoStreamTest_Reply) GetEcho() string

func (*EchoStreamTest_Reply) ProtoMessage added in v2.246.0 

func (*EchoStreamTest_Reply) ProtoMessage()

func (*EchoStreamTest_Reply) Reset added in v2.246.0 

func (m *EchoStreamTest_Reply) Reset()

func (*EchoStreamTest_Reply) String added in v2.246.0 

func (m *EchoStreamTest_Reply) String() string

func (*EchoStreamTest_Reply) XXX_DiscardUnknown added in v2.246.0 

func (m *EchoStreamTest_Reply) XXX_DiscardUnknown()

func (*EchoStreamTest_Reply) XXX_Marshal added in v2.246.0 

func (m *EchoStreamTest_Reply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EchoStreamTest_Reply) XXX_Merge added in v2.246.0 

func (m *EchoStreamTest_Reply) XXX_Merge(src proto.Message)

func (*EchoStreamTest_Reply) XXX_Size added in v2.246.0 

func (m *EchoStreamTest_Reply) XXX_Size() int

func (*EchoStreamTest_Reply) XXX_Unmarshal added in v2.246.0 

func (m *EchoStreamTest_Reply) XXX_Unmarshal(b []byte) error

type EchoStreamTest_Request added in v2.246.0 

type EchoStreamTest_Request struct {
	Delay                uint64   `protobuf:"varint,1,opt,name=delay,proto3" json:"delay,omitempty"`
	Echo                 string   `protobuf:"bytes,2,opt,name=echo,proto3" json:"echo,omitempty"`
	TriggerError         bool     `protobuf:"varint,3,opt,name=trigger_error,json=triggerError,proto3" json:"trigger_error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EchoStreamTest_Request) Descriptor added in v2.246.0 

func (*EchoStreamTest_Request) Descriptor() ([]byte, []int)

func (*EchoStreamTest_Request) GetDelay added in v2.246.0 

func (m *EchoStreamTest_Request) GetDelay() uint64

func (*EchoStreamTest_Request) GetEcho added in v2.246.0 

func (m *EchoStreamTest_Request) GetEcho() string

func (*EchoStreamTest_Request) GetTriggerError added in v2.246.0 

func (m *EchoStreamTest_Request) GetTriggerError() bool

func (*EchoStreamTest_Request) ProtoMessage added in v2.246.0 

func (*EchoStreamTest_Request) ProtoMessage()

func (*EchoStreamTest_Request) Reset added in v2.246.0 

func (m *EchoStreamTest_Request) Reset()

func (*EchoStreamTest_Request) String added in v2.246.0 

func (m *EchoStreamTest_Request) String() string

func (*EchoStreamTest_Request) XXX_DiscardUnknown added in v2.246.0 

func (m *EchoStreamTest_Request) XXX_DiscardUnknown()

func (*EchoStreamTest_Request) XXX_Marshal added in v2.246.0 

func (m *EchoStreamTest_Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EchoStreamTest_Request) XXX_Merge added in v2.246.0 

func (m *EchoStreamTest_Request) XXX_Merge(src proto.Message)

func (*EchoStreamTest_Request) XXX_Size added in v2.246.0 

func (m *EchoStreamTest_Request) XXX_Size() int

func (*EchoStreamTest_Request) XXX_Unmarshal added in v2.246.0 

func (m *EchoStreamTest_Request) XXX_Unmarshal(b []byte) error

type EchoTest added in v2.246.0 

type EchoTest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EchoTest) Descriptor added in v2.246.0 

func (*EchoTest) Descriptor() ([]byte, []int)

func (*EchoTest) ProtoMessage added in v2.246.0 

func (*EchoTest) ProtoMessage()

func (*EchoTest) Reset added in v2.246.0 

func (m *EchoTest) Reset()

func (*EchoTest) String added in v2.246.0 

func (m *EchoTest) String() string

func (*EchoTest) XXX_DiscardUnknown added in v2.246.0 

func (m *EchoTest) XXX_DiscardUnknown()

func (*EchoTest) XXX_Marshal added in v2.246.0 

func (m *EchoTest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EchoTest) XXX_Merge added in v2.246.0 

func (m *EchoTest) XXX_Merge(src proto.Message)

func (*EchoTest) XXX_Size added in v2.246.0 

func (m *EchoTest) XXX_Size() int

func (*EchoTest) XXX_Unmarshal added in v2.246.0 

func (m *EchoTest) XXX_Unmarshal(b []byte) error

type EchoTest_Reply added in v2.246.0 

type EchoTest_Reply struct {
	Echo                 string   `protobuf:"bytes,1,opt,name=echo,proto3" json:"echo,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EchoTest_Reply) Descriptor added in v2.246.0 

func (*EchoTest_Reply) Descriptor() ([]byte, []int)

func (*EchoTest_Reply) GetEcho added in v2.246.0 

func (m *EchoTest_Reply) GetEcho() string

func (*EchoTest_Reply) ProtoMessage added in v2.246.0 

func (*EchoTest_Reply) ProtoMessage()

func (*EchoTest_Reply) Reset added in v2.246.0 

func (m *EchoTest_Reply) Reset()

func (*EchoTest_Reply) String added in v2.246.0 

func (m *EchoTest_Reply) String() string

func (*EchoTest_Reply) XXX_DiscardUnknown added in v2.246.0 

func (m *EchoTest_Reply) XXX_DiscardUnknown()

func (*EchoTest_Reply) XXX_Marshal added in v2.246.0 

func (m *EchoTest_Reply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EchoTest_Reply) XXX_Merge added in v2.246.0 

func (m *EchoTest_Reply) XXX_Merge(src proto.Message)

func (*EchoTest_Reply) XXX_Size added in v2.246.0 

func (m *EchoTest_Reply) XXX_Size() int

func (*EchoTest_Reply) XXX_Unmarshal added in v2.246.0 

func (m *EchoTest_Reply) XXX_Unmarshal(b []byte) error

type EchoTest_Request added in v2.246.0 

type EchoTest_Request struct {
	Delay                uint64   `protobuf:"varint,1,opt,name=delay,proto3" json:"delay,omitempty"`
	Echo                 string   `protobuf:"bytes,2,opt,name=echo,proto3" json:"echo,omitempty"`
	TriggerError         bool     `protobuf:"varint,3,opt,name=trigger_error,json=triggerError,proto3" json:"trigger_error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EchoTest_Request) Descriptor added in v2.246.0 

func (*EchoTest_Request) Descriptor() ([]byte, []int)

func (*EchoTest_Request) GetDelay added in v2.246.0 

func (m *EchoTest_Request) GetDelay() uint64

func (*EchoTest_Request) GetEcho added in v2.246.0 

func (m *EchoTest_Request) GetEcho() string

func (*EchoTest_Request) GetTriggerError added in v2.246.0 

func (m *EchoTest_Request) GetTriggerError() bool

func (*EchoTest_Request) ProtoMessage added in v2.246.0 

func (*EchoTest_Request) ProtoMessage()

func (*EchoTest_Request) Reset added in v2.246.0 

func (m *EchoTest_Request) Reset()

func (*EchoTest_Request) String added in v2.246.0 

func (m *EchoTest_Request) String() string

func (*EchoTest_Request) XXX_DiscardUnknown added in v2.246.0 

func (m *EchoTest_Request) XXX_DiscardUnknown()

func (*EchoTest_Request) XXX_Marshal added in v2.246.0 

func (m *EchoTest_Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EchoTest_Request) XXX_Merge added in v2.246.0 

func (m *EchoTest_Request) XXX_Merge(src proto.Message)

func (*EchoTest_Request) XXX_Size added in v2.246.0 

func (m *EchoTest_Request) XXX_Size() int

func (*EchoTest_Request) XXX_Unmarshal added in v2.246.0 

func (m *EchoTest_Request) XXX_Unmarshal(b []byte) error

type Options added in v2.246.0 

type Options struct {
	Logger *zap.Logger
}

type Speed added in v2.130.0 

type Speed string

Speed level enum 

const (
	Fast     Speed = "fast"
	Slow     Speed = "slow"
	AnySpeed Speed = "any"
)

type Stability added in v2.130.0 

type Stability string

Stability level enum 

const (
	Stable       Stability = "stable"
	Unstable     Stability = "unstable"
	Broken       Stability = "broken"
	AnyStability Stability = "any"
)

type TestServiceClient added in v2.246.0 

type TestServiceClient interface {
	// use to test unary
	EchoTest(ctx context.Context, in *EchoTest_Request, opts ...grpc.CallOption) (*EchoTest_Reply, error)
	// Use to test stream.
	EchoStreamTest(ctx context.Context, in *EchoStreamTest_Request, opts ...grpc.CallOption) (TestService_EchoStreamTestClient, error)
	// Use to test duplex stream.
	EchoDuplexTest(ctx context.Context, opts ...grpc.CallOption) (TestService_EchoDuplexTestClient, error)
}

TestServiceClient is the client API for TestService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewTestServiceClient added in v2.246.0 

func NewTestServiceClient(cc *grpc.ClientConn) TestServiceClient

type TestServiceServer added in v2.246.0 

type TestServiceServer interface {
	// use to test unary
	EchoTest(context.Context, *EchoTest_Request) (*EchoTest_Reply, error)
	// Use to test stream.
	EchoStreamTest(*EchoStreamTest_Request, TestService_EchoStreamTestServer) error
	// Use to test duplex stream.
	EchoDuplexTest(TestService_EchoDuplexTestServer) error
}

TestServiceServer is the server API for TestService service.

func NewService added in v2.246.0 

func NewService(opts *Options) TestServiceServer

type TestService_EchoDuplexTestClient added in v2.246.0 

type TestService_EchoDuplexTestClient interface {
	Send(*EchoDuplexTest_Request) error
	Recv() (*EchoDuplexTest_Reply, error)
	grpc.ClientStream
}

type TestService_EchoDuplexTestServer added in v2.246.0 

type TestService_EchoDuplexTestServer interface {
	Send(*EchoDuplexTest_Reply) error
	Recv() (*EchoDuplexTest_Request, error)
	grpc.ServerStream
}

type TestService_EchoStreamTestClient added in v2.246.0 

type TestService_EchoStreamTestClient interface {
	Recv() (*EchoStreamTest_Reply, error)
	grpc.ClientStream
}

type TestService_EchoStreamTestServer added in v2.246.0 

type TestService_EchoStreamTestServer interface {
	Send(*EchoStreamTest_Reply) error
	grpc.ServerStream
}

type UnimplementedTestServiceServer added in v2.246.0 

type UnimplementedTestServiceServer struct {
}

UnimplementedTestServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedTestServiceServer) EchoDuplexTest added in v2.246.0 

func (*UnimplementedTestServiceServer) EchoDuplexTest(srv TestService_EchoDuplexTestServer) error

func (*UnimplementedTestServiceServer) EchoStreamTest added in v2.246.0 

func (*UnimplementedTestServiceServer) EchoStreamTest(req *EchoStreamTest_Request, srv TestService_EchoStreamTestServer) error

func (*UnimplementedTestServiceServer) EchoTest added in v2.246.0 

func (*UnimplementedTestServiceServer) EchoTest(ctx context.Context, req *EchoTest_Request) (*EchoTest_Reply, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.