testing

type TestServiceClient ¶

type TestServiceClient interface {
	// A bidirectional streaming RPC where messages are in sequence in the same bidi stream.
	// The client sends one request followed by one response.
	// This sequential message exchange over a bidi stream is used to benchmark
	// latency in Streamed Batching.
	StreamedSequentialUnaryCall(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[messages.SimpleRequest, messages.SimpleResponse], error)
}

TestServiceClient is the client API for TestService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

A simple service to test the various types of RPCs and experiment with performance with various types of payload.

func NewTestServiceClient(cc grpc.ClientConnInterface) TestServiceClient

type TestServiceServer ¶

type TestServiceServer interface {
	// A bidirectional streaming RPC where messages are in sequence in the same bidi stream.
	// The client sends one request followed by one response.
	// This sequential message exchange over a bidi stream is used to benchmark
	// latency in Streamed Batching.
	StreamedSequentialUnaryCall(grpc.BidiStreamingServer[messages.SimpleRequest, messages.SimpleResponse]) error
	// contains filtered or unexported methods
}

TestServiceServer is the server API for TestService service. All implementations must embed UnimplementedTestServiceServer for forward compatibility.

A simple service to test the various types of RPCs and experiment with performance with various types of payload.

type TestService_StreamedSequentialUnaryCallClient ¶

type TestService_StreamedSequentialUnaryCallClient = grpc.BidiStreamingClient[messages.SimpleRequest, messages.SimpleResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TestService_StreamedSequentialUnaryCallServer ¶

type TestService_StreamedSequentialUnaryCallServer = grpc.BidiStreamingServer[messages.SimpleRequest, messages.SimpleResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type UnimplementedTestServiceServer ¶

type UnimplementedTestServiceServer struct{}

UnimplementedTestServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedTestServiceServer) StreamedSequentialUnaryCall(grpc.BidiStreamingServer[messages.SimpleRequest, messages.SimpleResponse]) error

type UnsafeTestServiceServer ¶

type UnsafeTestServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeTestServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TestServiceServer will result in compilation errors.