test

Documentation

Index

• Variables
• func RequestIDContext(t *testing.T) context.Context
• type Handler
  • func NewHandler(output interface{}, err error) *Handler
  • func (h *Handler) Stream(srv interface{}, stream grpc.ServerStream) error
  • func (h *Handler) Unary(ctx context.Context, req interface{}) (interface{}, error)
• type TestServerStream
  • func ServerStream(ctx context.Context) *TestServerStream
  • func (ts *TestServerStream) Context() context.Context
  • func (ts *TestServerStream) Method() string
  • func (ts *TestServerStream) RecvMsg(m interface{}) error
  • func (ts *TestServerStream) SendMsg(m interface{}) error
• type TestServerTransportStream
  • func ServerTransportStream(method string) *TestServerTransportStream
  • func (ts *TestServerTransportStream) Method() string
  • func (ts *TestServerTransportStream) SendHeader(md metadata.MD) error
  • func (ts *TestServerTransportStream) SetHeader(md metadata.MD) error
  • func (ts *TestServerTransportStream) SetTrailer(md metadata.MD) error

Variables

var (
	UnaryInfo = &grpc.UnaryServerInfo{
		FullMethod: "TestService.UnaryMethod",
	}

	StreamInfo = &grpc.StreamServerInfo{
		FullMethod:     "TestService.StreamMethod",
		IsClientStream: false,
		IsServerStream: true,
	}
)

Functions

func RequestIDContext

func RequestIDContext(t *testing.T) context.Context

Types

type Handler

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

func NewHandler

func NewHandler(output interface{}, err error) *Handler

func (*Handler) Stream

func (h *Handler) Stream(srv interface{}, stream grpc.ServerStream) error

func (*Handler) Unary

func (h *Handler) Unary(ctx context.Context, req interface{}) (interface{}, error)

type TestServerStream

type TestServerStream struct {
	grpc.ServerStream
	// contains filtered or unexported fields
}

func ServerStream

func ServerStream(ctx context.Context) *TestServerStream

func (*TestServerStream) Context

func (ts *TestServerStream) Context() context.Context

func (*TestServerStream) Method

func (ts *TestServerStream) Method() string

func (*TestServerStream) RecvMsg

func (ts *TestServerStream) RecvMsg(m interface{}) error

func (*TestServerStream) SendMsg

func (ts *TestServerStream) SendMsg(m interface{}) error

type TestServerTransportStream

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

func ServerTransportStream

func ServerTransportStream(method string) *TestServerTransportStream

func (*TestServerTransportStream) Method

func (ts *TestServerTransportStream) Method() string

func (*TestServerTransportStream) SendHeader

func (ts *TestServerTransportStream) SendHeader(md metadata.MD) error

func (*TestServerTransportStream) SetHeader

func (ts *TestServerTransportStream) SetHeader(md metadata.MD) error

func (*TestServerTransportStream) SetTrailer

func (ts *TestServerTransportStream) SetTrailer(md metadata.MD) error