Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

grpcmock

package module

Go to main page

Versions in this module

v0

v0.25.0

Dec 19, 2023

v0.24.0

Dec 12, 2023

v0.23.0

Feb 8, 2023

v0.22.0

Feb 6, 2023

Changes in this version

+ type BidirectionalStreamExpectation interface

+ After func(d time.Duration) BidirectionalStreamExpectation

+ Once func() BidirectionalStreamExpectation

+ ReturnCode func(code codes.Code)

+ ReturnError func(code codes.Code, msg string)

+ ReturnErrorMessage func(msg string)

+ ReturnErrorf func(code codes.Code, format string, args ...interface{})

+ Run func(handler func(ctx context.Context, s grpc.ServerStream) error)

+ Times func(i uint) BidirectionalStreamExpectation

+ Twice func() BidirectionalStreamExpectation

+ UnlimitedTimes func() BidirectionalStreamExpectation

+ WaitUntil func(w <-chan time.Time) BidirectionalStreamExpectation

+ WithHeader func(header string, value interface{}) BidirectionalStreamExpectation

+ WithHeaders func(headers map[string]interface{}) BidirectionalStreamExpectation

+ type ClientStreamExpectation interface

+ After func(d time.Duration) ClientStreamExpectation

+ Once func() ClientStreamExpectation

+ Return func(v interface{})

+ ReturnCode func(code codes.Code)

+ ReturnError func(code codes.Code, msg string)

+ ReturnErrorMessage func(msg string)

+ ReturnErrorf func(code codes.Code, format string, args ...interface{})

+ ReturnFile func(filePath string)

+ ReturnJSON func(v interface{})

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

+ Run func(handler func(ctx context.Context, s grpc.ServerStream) (interface{}, error))

+ Times func(i uint) ClientStreamExpectation

+ Twice func() ClientStreamExpectation

+ UnlimitedTimes func() ClientStreamExpectation

+ WaitUntil func(w <-chan time.Time) ClientStreamExpectation

+ WithHeader func(header string, value interface{}) ClientStreamExpectation

+ WithHeaders func(headers map[string]interface{}) ClientStreamExpectation

+ WithPayload func(in interface{}) ClientStreamExpectation

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

+ type ServerStreamExpectation interface

+ After func(d time.Duration) ServerStreamExpectation

+ Once func() ServerStreamExpectation

+ Return func(v interface{})

+ ReturnCode func(code codes.Code)

+ ReturnError func(code codes.Code, msg string)

+ ReturnErrorMessage func(msg string)

+ ReturnErrorf func(code codes.Code, format string, args ...interface{})

+ ReturnFile func(filePath string)

+ ReturnJSON func(v interface{})

+ ReturnStream func() ServerStreamHandler

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

+ Run func(handler func(ctx context.Context, in interface{}, s grpc.ServerStream) error)

+ Times func(i uint) ServerStreamExpectation

+ Twice func() ServerStreamExpectation

+ UnlimitedTimes func() ServerStreamExpectation

+ WaitUntil func(w <-chan time.Time) ServerStreamExpectation

+ WithHeader func(header string, value interface{}) ServerStreamExpectation

+ WithHeaders func(headers map[string]interface{}) ServerStreamExpectation

+ WithPayload func(in interface{}) ServerStreamExpectation

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

+ type ServerStreamHandler interface

+ AddHeader func(key, value string) ServerStreamHandler

+ ReturnError func(code codes.Code, msg string)

+ ReturnErrorf func(code codes.Code, msg string, args ...interface{})

+ Send func(v interface{}) ServerStreamHandler

+ SendHeader func() ServerStreamHandler

+ SendMany func(v interface{}) ServerStreamHandler

+ SetHeader func(header map[string]string) ServerStreamHandler

+ WaitFor func(d time.Duration) ServerStreamHandler

+ type UnaryExpectation interface

+ After func(d time.Duration) UnaryExpectation

+ Once func() UnaryExpectation

+ Return func(v interface{})

+ ReturnCode func(code codes.Code)

+ ReturnError func(code codes.Code, msg string)

+ ReturnErrorMessage func(msg string)

+ ReturnErrorf func(code codes.Code, format string, args ...interface{})

+ ReturnFile func(filePath string)

+ ReturnJSON func(v interface{})

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

+ Run func(handler func(ctx context.Context, in interface{}) (interface{}, error))

+ Times func(i uint) UnaryExpectation

+ Twice func() UnaryExpectation

+ UnlimitedTimes func() UnaryExpectation

+ WaitUntil func(w <-chan time.Time) UnaryExpectation

+ WithHeader func(header string, value interface{}) UnaryExpectation

+ WithHeaders func(headers map[string]interface{}) UnaryExpectation

+ WithPayload func(in interface{}) UnaryExpectation

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

v0.21.0

Jan 23, 2023

v0.20.0

Aug 28, 2022

Changes in this version

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

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

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

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

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

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

+ type ClientStreamHandler func(s grpc.ClientStream) error

+ func RecvAll(out interface{}) ClientStreamHandler

+ func SendAll(in interface{}) ClientStreamHandler

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

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

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

+ type InvokeOption func(c *invokeConfig)

+ func WithBufConnDialer(l *bufconn.Listener) InvokeOption

+ func WithCallOptions(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

+ type Server struct

+ Requests []request.Request

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

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

+ func (s *Server) Address() string

+ func (s *Server) Close() error

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

+ 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()

+ 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

+ func MockUnstartedServer(opts ...ServerOption) ServerMocker

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

+ func MockServerWithBufConn(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 WithAddress(addr string) ServerOption

+ func WithListener(l net.Listener) ServerOption

+ func WithPlanner(p planner.Planner) ServerOption

+ func WithPort(port int) ServerOption

+ func WriteBufferSize(sz int) ServerOption

+ type T interface

+ Cleanup func(func())

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

+ FailNow func()

+ func NoOpT() T