fakegrpc

Documentation

Overview

Package fakegrpc provides a fake gRPC client/server for testing purpose.

Index

• func StreamLoggerInterceptor(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error
• func UnaryLoggerInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)
• type Fake
  • func New() (*Fake, func() error)
  • func (f *Fake) Addr() string
  • func (f *Fake) Start()
• type LoggerStream
  • func (w *LoggerStream) RecvMsg(m interface{}) error
  • func (w *LoggerStream) SendMsg(m interface{}) error

Functions

func StreamLoggerInterceptor

func StreamLoggerInterceptor(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error

StreamLoggerInterceptor intercepts streams to the server and logs the messages.

func UnaryLoggerInterceptor

func UnaryLoggerInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)

UnaryLoggerInterceptor intercepts calls to the server and logs the request and response.

Types

type Fake

type Fake struct {
	Listener net.Listener
	Server   *grpc.Server
	Client   *grpc.ClientConn
}

Fake contains the server and client for a GRPC connection.

func New

func New() (*Fake, func() error)

New creates a gRPC client and server connected to eachother.

func (*Fake) Addr

func (f *Fake) Addr() string

Addr returns the address of the server.

func (*Fake) Start

func (f *Fake) Start()

Start starts the server. Must be called after registering the services on the server.

type LoggerStream

type LoggerStream struct {
	grpc.ServerStream
}

LoggerStream wraps around the embedded grpc.ServerStream, and intercepts the RecvMsg and SendMsg method call and logs them.

func (*LoggerStream) RecvMsg

func (w *LoggerStream) RecvMsg(m interface{}) error

RecvMsg recieves a message.

func (*LoggerStream) SendMsg

func (w *LoggerStream) SendMsg(m interface{}) error

SendMsg sends a message.