package test

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

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

Index ¶

• func ClientNewPayload(t testpb.PayloadType, size int) *testpb.Payload
• func DoClientStreaming(ctx context.Context, tc testpb.TestServiceClient, args ...grpc.CallOption)
• func DoEmptyStream(ctx context.Context, tc testpb.TestServiceClient, args ...grpc.CallOption)
• func DoEmptyUnaryCall(ctx context.Context, tc testpb.TestServiceClient, args ...grpc.CallOption)
• func DoLargeUnaryCall(ctx context.Context, tc testpb.TestServiceClient, args ...grpc.CallOption)
• func DoPingPong(ctx context.Context, tc testpb.TestServiceClient, args ...grpc.CallOption)
• func DoServerStreaming(ctx context.Context, tc testpb.TestServiceClient, args ...grpc.CallOption)
• func NewTestServer() testpb.TestServiceServer

Functions ¶

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.

Source Files ¶

test_utils.go