internal

Documentation

Index

• func CallEcho(b *testing.B, ctx *context.T, address string, iterations, payloadSize int, ...)
• func CallEchoStream(b *testing.B, ctx *context.T, address string, ...)
• func NewDischargeServer(ctx *context.T) security.Caveat
• func NewService() benchmark.BenchmarkServerStub
• func StartEchoStream(b *testing.B, ctx *context.T, address string, ...) (<-chan int, func())

Functions

func CallEcho

func CallEcho(b *testing.B, ctx *context.T, address string, iterations, payloadSize int, stats *tbm.Stats)

CallEcho calls 'Echo' method 'iterations' times with the given payload size.

func CallEchoStream

func CallEchoStream(b *testing.B, ctx *context.T, address string, iterations, chunkCnt, payloadSize int, stats *tbm.Stats)

CallEchoStream calls 'EchoStream' method 'iterations' times. Each iteration sends 'chunkCnt' chunks on the stream and receives the same number of chunks back. Each chunk has the given payload size.

func NewDischargeServer

func NewDischargeServer(ctx *context.T) security.Caveat

func NewService

func NewService() benchmark.BenchmarkServerStub

func StartEchoStream

func StartEchoStream(b *testing.B, ctx *context.T, address string, iterations, chunkCnt, payloadSize int, stats *tbm.Stats) (<-chan int, func())

StartEchoStream starts to call 'EchoStream' method 'iterations' times. This does not block, and returns a channel that will receive the number of iterations when it's done. It also returns a callback function to stop the streaming. Each iteration requests 'chunkCnt' chunks on the stream and receives that number of chunks back. Each chunk has the given payload size. Zero 'iterations' means unlimited.