buffernet

Documentation

Overview

Package buffernet provides facilities to establish a connection via grpc via internal buffers, allowing for testing services and clients without worrying about real networks.

Index

• type BufferTransport
  • func New() *BufferTransport
  • func (b *BufferTransport) Connect(ctx context.Context) (conn *grpc.ClientConn, problem error)
  • func (b *BufferTransport) Listen(server *grpc.Server) error
  • func (b *BufferTransport) ListenAsync(server *grpc.Server) (<-chan error, func())

Types

type BufferTransport

type BufferTransport struct {
	Listener *bufconn.Listener
}

func New

func New() *BufferTransport

func (*BufferTransport) Connect

func (b *BufferTransport) Connect(ctx context.Context) (conn *grpc.ClientConn, problem error)

Connect establishes a connection to the listening service via the buffer. Will block until the connection is established.

func (*BufferTransport) Listen

func (b *BufferTransport) Listen(server *grpc.Server) error

func (*BufferTransport) ListenAsync

func (b *BufferTransport) ListenAsync(server *grpc.Server) (<-chan error, func())