grpcmock

Dec 10, 2021

Changes in this version

+ func FindServerMethod(srv *Server, method string) *service.Method

Dec 10, 2021

Changes in this version

type Server

+ func NewUnstartedServer(opts ...ServerOption) *Server

+ func (s *Server) Address() string

type ServerMocker

+ func MockUnstartedServer(opts ...ServerOption) ServerMocker

type ServerMockerWithContextDialer

+ func MockServerWithBufConn(opts ...ServerOption) ServerMockerWithContextDialer

type ServerOption

+ func WithAddress(addr string) ServerOption

+ func WithListener(l net.Listener) ServerOption

+ func WithPort(port int) ServerOption

Dec 7, 2021

Changes in this version

type ServerOption

+ func WithPlanner(p planner.Planner) ServerOption

Nov 29, 2021

Changes in this version

type Server

+ func (s *Server) ExpectBidirectionalStream(method string) *request.BidirectionalStreamRequest

Nov 20, 2021

Changes in this version

+ func MatchClientStreamMsgCount(expected int) func() (string, matcher.MatchFn)

+ type Server struct

+ Requests []request.Request

+ func NewServer(opts ...ServerOption) *Server

+ func (s *Server) Close(ctx context.Context) error

+ func (s *Server) ExpectClientStream(method string) *request.ClientStreamRequest

+ func (s *Server) ExpectServerStream(method string) *request.ServerStreamRequest

+ func (s *Server) ExpectUnary(method string) *request.UnaryRequest

+ func (s *Server) ExpectationsWereMet() error

+ func (s *Server) ResetExpectations()

+ func (s *Server) Serve(l net.Listener) error

+ func (s *Server) WithPlanner(p planner.Planner) *Server

+ func (s *Server) WithTest(t T) *Server

+ type ServerMocker func(t T) *Server

+ func MockServer(opts ...ServerOption) ServerMocker

+ type ServerMockerWithContextDialer func(t T) (*Server, ContextDialer)

+ func MockAndStartServer(opts ...ServerOption) ServerMockerWithContextDialer

+ type ServerOption func(s *Server)

+ func ChainStreamInterceptor(interceptors ...grpc.StreamServerInterceptor) ServerOption

+ func ChainUnaryInterceptor(interceptors ...grpc.UnaryServerInterceptor) ServerOption

+ func ConnectionTimeout(d time.Duration) ServerOption

+ func Creds(c credentials.TransportCredentials) ServerOption

+ func InTapHandle(h tap.ServerInHandle) ServerOption

+ func InitialConnWindowSize(sz int32) ServerOption

+ func InitialWindowSize(sz int32) ServerOption

+ func KeepaliveEnforcementPolicy(kep keepalive.EnforcementPolicy) ServerOption

+ func KeepaliveParams(kp keepalive.ServerParameters) ServerOption

+ func MaxConcurrentStreams(n uint32) ServerOption

+ func MaxHeaderListSize(sz uint32) ServerOption

+ func MaxRecvMsgSize(m int) ServerOption

+ func MaxSendMsgSize(m int) ServerOption

+ func ReadBufferSize(sz int) ServerOption

+ func RegisterService(registerFunc interface{}) ServerOption

+ func RegisterServiceFromInstance(id string, svc interface{}) ServerOption

+ func RegisterServiceFromMethods(serviceMethods ...service.Method) ServerOption

+ func StatsHandler(h stats.Handler) ServerOption

+ func StreamInterceptor(i grpc.StreamServerInterceptor) ServerOption

+ func UnaryInterceptor(i grpc.UnaryServerInterceptor) ServerOption

+ func UnknownServiceHandler(streamHandler grpc.StreamHandler) ServerOption

+ func WriteBufferSize(sz int) ServerOption

+ type T interface

+ Cleanup func(func())

+ Errorf func(format string, args ...interface{})

+ FailNow func()

+ func NoOpT() T

Oct 31, 2021

Changes in this version

+ const ErrMalformedMethod

Oct 31, 2021

Changes in this version

+ func FromMethodType(t MethodType) (isClientStream bool, isServerStream bool)

+ func IsMethodBidirectionalStream(t MethodType) bool

+ func IsMethodClientStream(t MethodType) bool

+ func IsMethodServerStream(t MethodType) bool

+ func IsMethodUnary(t MethodType) bool

+ type MethodType string

+ const MethodTypeBidirectionalStream

+ const MethodTypeClientStream

+ const MethodTypeServerStream

+ const MethodTypeUnary

+ func ToMethodType(isClientStream, isServerStream bool) MethodType

+ type ServiceMethod struct

+ Input interface{}

+ MethodName string

+ MethodType MethodType

+ Output interface{}

+ ServiceName string

+ func (m ServiceMethod) FullName() string

Oct 30, 2021

Changes in this version

type InvokeOption

+ func WithCallOptions(opts ...grpc.CallOption) InvokeOption

Oct 30, 2021

Changes in this version

+ func InvokeBidirectionalStream(ctx context.Context, method string, handle ClientStreamHandler, ...) error

type ClientStreamHandler

+ func SendAndRecvAll(in interface{}, out interface{}) ClientStreamHandler

Oct 30, 2021

Changes in this version

+ func InvokeClientStream(ctx context.Context, method string, handle ClientStreamHandler, ...) error

+ func InvokeServerStream(ctx context.Context, method string, in interface{}, handle ClientStreamHandler, ...) error

+ func JSONEq(t TestingT, expected, actual interface{}, msgAndArgs ...interface{}) bool

+ func MessageEqual(t TestingT, expected, actual proto.Message, msgAndArgs ...interface{}) bool

+ type ClientStreamHandler func(stream grpc.ClientStream) error

+ func RecvAll(out interface{}) ClientStreamHandler

+ func SendAll(in interface{}) ClientStreamHandler

+ func (h ClientStreamHandler) Handle(stream grpc.ClientStream) error

+ type TestingT interface

+ Cleanup func(func())

+ Errorf func(format string, args ...interface{})

+ FailNow func()

Oct 28, 2021

Changes in this version

+ const ErrMissingMethod

+ func InvokeUnary(ctx context.Context, method string, in interface{}, out interface{}, ...) error

+ type ContextDialer = func(context.Context, string) (net.Conn, error)

+ type InvokeOption func(c *invokeConfig)

+ func WithBufConnDialer(l *bufconn.Listener) InvokeOption

+ func WithCallOption(opts ...grpc.CallOption) InvokeOption

+ func WithContextDialer(d ContextDialer) InvokeOption

+ func WithDialOptions(opts ...grpc.DialOption) InvokeOption

+ func WithHeader(key, value string) InvokeOption

+ func WithHeaders(header map[string]string) InvokeOption

+ func WithInsecure() InvokeOption