Documentation

Index

Constants

View Source
const (
	// DefaultPongValue is the default value used.
	DefaultResponseValue = "default_response_value"
	// ListResponseCount is the expeted number of responses to PingList
	ListResponseCount = 100
)

Variables

This section is empty.

Functions

This section is empty.

Types

type InterceptorTestSuite

type InterceptorTestSuite struct {
	suite.Suite

	TestService pb_testproto.TestServiceServer
	ServerOpts  []grpc.ServerOption
	ClientOpts  []grpc.DialOption

	ServerListener net.Listener
	Server         *grpc.Server

	Client pb_testproto.TestServiceClient
	// contains filtered or unexported fields
}

    InterceptorTestSuite is a testify/Suite that starts a gRPC PingService server and a client.

    func (*InterceptorTestSuite) DeadlineCtx

    func (s *InterceptorTestSuite) DeadlineCtx(deadline time.Time) context.Context

    func (*InterceptorTestSuite) NewClient

    func (*InterceptorTestSuite) ServerAddr

    func (s *InterceptorTestSuite) ServerAddr() string

    func (*InterceptorTestSuite) SetupSuite

    func (s *InterceptorTestSuite) SetupSuite()

    func (*InterceptorTestSuite) SimpleCtx

    func (s *InterceptorTestSuite) SimpleCtx() context.Context

    func (*InterceptorTestSuite) TearDownSuite

    func (s *InterceptorTestSuite) TearDownSuite()

    type MutexReadWriter

    type MutexReadWriter struct {
    	sync.Mutex
    	// contains filtered or unexported fields
    }

      MutexReadWriter is a io.ReadWriter that can be read and worked on from multiple go routines.

      func NewMutexReadWriter

      func NewMutexReadWriter(rw io.ReadWriter) *MutexReadWriter

        NewMutexReadWriter creates a new thread-safe io.ReadWriter.

        func (*MutexReadWriter) Read

        func (m *MutexReadWriter) Read(p []byte) (int, error)

          Read implements the io.Reader interface.

          func (*MutexReadWriter) Write

          func (m *MutexReadWriter) Write(p []byte) (int, error)

            Write implements the io.Writer interface.

            type TestPingService

            type TestPingService struct {
            	T *testing.T
            }

            func (*TestPingService) Ping

            func (*TestPingService) PingEmpty

            func (*TestPingService) PingError

            func (*TestPingService) PingList

            func (*TestPingService) PingStream

            Directories

            Path Synopsis
            Package mwitkow_testproto is a generated protocol buffer package.
            Package mwitkow_testproto is a generated protocol buffer package.
            Package mwitkow_testproto is a generated protocol buffer package.
            Package mwitkow_testproto is a generated protocol buffer package.