internal

Documentation

Index

• func CallEcho(octx *context.T, server string, payloadSize int, duration time.Duration) uint64
• func CallSum(ctx *context.T, server string, maxPayloadSize int, stats *stress.SumStats)
• func CallSumStream(ctx *context.T, server string, maxChunkCnt, maxPayloadSize int, ...)
• func NewService() (stress.StressServerStub, <-chan struct{})

Functions

func CallEcho

func CallEcho(octx *context.T, server string, payloadSize int, duration time.Duration) uint64

CallEcho calls 'Echo' method with the given payload size for the given time duration and returns the number of iterations.

func CallSum

func CallSum(ctx *context.T, server string, maxPayloadSize int, stats *stress.SumStats)

CallSum calls 'Sum' method with a randomly generated payload.

func CallSumStream

func CallSumStream(ctx *context.T, server string, maxChunkCnt, maxPayloadSize int, stats *stress.SumStats)

CallSumStream calls 'SumStream' method. Each iteration sends up to 'maxChunkCnt' chunks on the stream and receives the same number of sums back.

func NewService

func NewService() (stress.StressServerStub, <-chan struct{})