benchmark

Documentation

Overview

Package benchmark implements the building blocks to setup end-to-end gRPC benchmarks.

Index

• func DoStreamingRoundTrip(tc testpb.TestServiceClient, stream testpb.TestService_StreamingCallClient, ...)
• func DoUnaryCall(tc testpb.TestServiceClient, reqSize, respSize int)
• func NewClientConn(addr string) *grpc.ClientConn
• func StartServer(addr string) (string, func())

Functions

func DoStreamingRoundTrip

func DoStreamingRoundTrip(tc testpb.TestServiceClient, stream testpb.TestService_StreamingCallClient, reqSize, respSize int)

DoStreamingRoundTrip performs a round trip for a single streaming rpc.

func DoUnaryCall

func DoUnaryCall(tc testpb.TestServiceClient, reqSize, respSize int)

DoUnaryCall performs an unary RPC with given stub and request and response sizes.

func NewClientConn

func NewClientConn(addr string) *grpc.ClientConn

NewClientConn creates a gRPC client connection to addr.

func StartServer

func StartServer(addr string) (string, func())

StartServer starts a gRPC server serving a benchmark service on the given address, which may be something like "localhost:0". It returns its listen address and a function to stop the server.