...

Package test

import "go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc/internal/test"
Overview
Index

Overview ▾

Package test contains functions used by interop client/server.

Copied from https://github.com/grpc/grpc-go/tree/v1.61.0/interop That package was not intended to be used by external code. See https://github.com/open-telemetry/opentelemetry-go-contrib/issues/4896

func ClientNewPayload

func ClientNewPayload(t testpb.PayloadType, size int) *testpb.Payload

ClientNewPayload returns a payload of the given type and size.

func DoClientStreaming

func DoClientStreaming(ctx context.Context, tc testpb.TestServiceClient, args ...grpc.CallOption)

DoClientStreaming performs a client streaming RPC.

func DoEmptyStream

func DoEmptyStream(ctx context.Context, tc testpb.TestServiceClient, args ...grpc.CallOption)

DoEmptyStream sets up a bi-directional streaming with zero message.

func DoEmptyUnaryCall

func DoEmptyUnaryCall(ctx context.Context, tc testpb.TestServiceClient, args ...grpc.CallOption)

DoEmptyUnaryCall performs a unary RPC with empty request and response messages.

func DoLargeUnaryCall

func DoLargeUnaryCall(ctx context.Context, tc testpb.TestServiceClient, args ...grpc.CallOption)

DoLargeUnaryCall performs a unary RPC with large payload in the request and response.

func DoPingPong

func DoPingPong(ctx context.Context, tc testpb.TestServiceClient, args ...grpc.CallOption)

DoPingPong performs ping-pong style bi-directional streaming RPC.

func DoServerStreaming

func DoServerStreaming(ctx context.Context, tc testpb.TestServiceClient, args ...grpc.CallOption)

DoServerStreaming performs a server streaming RPC.

func NewTestServer

func NewTestServer() testpb.TestServiceServer

NewTestServer creates a test server for test service. opts carries optional settings and does not need to be provided. If multiple opts are provided, only the first one is used.