Documentation
¶
Index ¶
- func ClientNewPayload(t testpb.PayloadType, size int) (*testpb.Payload, error)
- func Dial(cfg DialParams) (*grpc.ClientConn, error)
- func DoCancelAfterBegin(tc testpb.TestServiceClient, args ...grpc.CallOption) error
- func DoCancelAfterFirstResponse(tc testpb.TestServiceClient, args ...grpc.CallOption) error
- func DoClientStreaming(tc testpb.TestServiceClient, args ...grpc.CallOption) error
- func DoCustomMetadata(tc testpb.TestServiceClient, args ...grpc.CallOption) error
- func DoEmptyUnaryCall(tc testpb.TestServiceClient, args ...grpc.CallOption) error
- func DoLargeUnaryCall(tc testpb.TestServiceClient, args ...grpc.CallOption) error
- func DoPingPong(tc testpb.TestServiceClient, args ...grpc.CallOption) error
- func DoServerStreaming(tc testpb.TestServiceClient, args ...grpc.CallOption) error
- func DoSpecialStatusMessage(tc testpb.TestServiceClient, args ...grpc.CallOption) error
- func DoStatusCodeAndMessage(tc testpb.TestServiceClient, args ...grpc.CallOption) error
- func DoTimeoutOnSleepingServer(tc testpb.TestServiceClient, args ...grpc.CallOption) error
- func DoUnimplementedMethod(cc *grpc.ClientConn) error
- func DoUnimplementedService(tc testpb.UnimplementedServiceClient) error
- func ExecTestCase(conn *grpc.ClientConn, testCase string) error
- type DialParams
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ClientNewPayload ¶
ClientNewPayload returns a payload of the given type and size.
func Dial ¶
func Dial(cfg DialParams) (*grpc.ClientConn, error)
func DoCancelAfterBegin ¶
func DoCancelAfterBegin(tc testpb.TestServiceClient, args ...grpc.CallOption) error
DoCancelAfterBegin cancels the RPC after metadata has been sent but before payloads are sent.
func DoCancelAfterFirstResponse ¶
func DoCancelAfterFirstResponse(tc testpb.TestServiceClient, args ...grpc.CallOption) error
DoCancelAfterFirstResponse cancels the RPC after receiving the first message from the server.
func DoClientStreaming ¶
func DoClientStreaming(tc testpb.TestServiceClient, args ...grpc.CallOption) error
DoClientStreaming performs a client streaming RPC.
func DoCustomMetadata ¶
func DoCustomMetadata(tc testpb.TestServiceClient, args ...grpc.CallOption) error
DoCustomMetadata checks that metadata is echoed back to the client.
func DoEmptyUnaryCall ¶
func DoEmptyUnaryCall(tc testpb.TestServiceClient, args ...grpc.CallOption) error
DoEmptyUnaryCall performs a unary RPC with empty request and response messages.
func DoLargeUnaryCall ¶
func DoLargeUnaryCall(tc testpb.TestServiceClient, args ...grpc.CallOption) error
DoLargeUnaryCall performs a unary RPC with large payload in the request and response.
func DoPingPong ¶
func DoPingPong(tc testpb.TestServiceClient, args ...grpc.CallOption) error
DoPingPong performs ping-pong style bi-directional streaming RPC.
func DoServerStreaming ¶
func DoServerStreaming(tc testpb.TestServiceClient, args ...grpc.CallOption) error
DoServerStreaming performs a server streaming RPC.
func DoSpecialStatusMessage ¶
func DoSpecialStatusMessage(tc testpb.TestServiceClient, args ...grpc.CallOption) error
DoSpecialStatusMessage verifies Unicode and whitespace is correctly processed in status message.
func DoStatusCodeAndMessage ¶
func DoStatusCodeAndMessage(tc testpb.TestServiceClient, args ...grpc.CallOption) error
DoStatusCodeAndMessage checks that the status code is propagated back to the client.
func DoTimeoutOnSleepingServer ¶
func DoTimeoutOnSleepingServer(tc testpb.TestServiceClient, args ...grpc.CallOption) error
DoTimeoutOnSleepingServer performs an RPC on a sleep server which causes RPC timeout.
func DoUnimplementedMethod ¶
func DoUnimplementedMethod(cc *grpc.ClientConn) error
DoUnimplementedMethod attempts to call an unimplemented method.
func DoUnimplementedService ¶
func DoUnimplementedService(tc testpb.UnimplementedServiceClient) error
DoUnimplementedService attempts to call a method from an unimplemented service.
func ExecTestCase ¶
func ExecTestCase(conn *grpc.ClientConn, testCase string) error
Source Files