Documentation
¶
Index ¶
- func ClientNewPayload(t testpb.PayloadType, size int) *testpb.Payload
- func DoCancelAfterBegin(tc testpb.TestServiceClient, args ...grpc.CallOption)
- func DoCancelAfterFirstResponse(tc testpb.TestServiceClient, args ...grpc.CallOption)
- func DoClientStreaming(tc testpb.TestServiceClient, args ...grpc.CallOption)
- func DoComputeEngineCreds(tc testpb.TestServiceClient, serviceAccount, oauthScope string)
- func DoCustomMetadata(tc testpb.TestServiceClient, args ...grpc.CallOption)
- func DoEmptyStream(tc testpb.TestServiceClient, args ...grpc.CallOption)
- func DoEmptyUnaryCall(tc testpb.TestServiceClient, args ...grpc.CallOption)
- func DoJWTTokenCreds(tc testpb.TestServiceClient, serviceAccountKeyFile string)
- func DoLargeUnaryCall(tc testpb.TestServiceClient, args ...grpc.CallOption)
- func DoOauth2TokenCreds(tc testpb.TestServiceClient, serviceAccountKeyFile, oauthScope string)
- func DoPerRPCCreds(tc testpb.TestServiceClient, serviceAccountKeyFile, oauthScope string)
- func DoPingPong(tc testpb.TestServiceClient, args ...grpc.CallOption)
- func DoServerStreaming(tc testpb.TestServiceClient, args ...grpc.CallOption)
- func DoServiceAccountCreds(tc testpb.TestServiceClient, serviceAccountKeyFile, oauthScope string)
- func DoSpecialStatusMessage(tc testpb.TestServiceClient, args ...grpc.CallOption)
- func DoStatusCodeAndMessage(tc testpb.TestServiceClient, args ...grpc.CallOption)
- func DoTimeoutOnSleepingServer(tc testpb.TestServiceClient, args ...grpc.CallOption)
- func DoUnimplementedMethod(cc *grpc.ClientConn)
- func DoUnimplementedService(tc testpb.UnimplementedServiceClient)
- func GetToken(serviceAccountKeyFile string, oauthScope string) *oauth2.Token
- func NewTestServer() testpb.TestServiceServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ClientNewPayload ¶ added in v1.2.0
func ClientNewPayload(t testpb.PayloadType, size int) *testpb.Payload
ClientNewPayload returns a payload of the given type and size.
func DoCancelAfterBegin ¶
func DoCancelAfterBegin(tc testpb.TestServiceClient, args ...grpc.CallOption)
DoCancelAfterBegin cancels the RPC after metadata has been sent but before payloads are sent.
func DoCancelAfterFirstResponse ¶
func DoCancelAfterFirstResponse(tc testpb.TestServiceClient, args ...grpc.CallOption)
DoCancelAfterFirstResponse cancels the RPC after receiving the first message from the server.
func DoClientStreaming ¶
func DoClientStreaming(tc testpb.TestServiceClient, args ...grpc.CallOption)
DoClientStreaming performs a client streaming RPC.
func DoComputeEngineCreds ¶
func DoComputeEngineCreds(tc testpb.TestServiceClient, serviceAccount, oauthScope string)
DoComputeEngineCreds performs a unary RPC with compute engine auth.
func DoCustomMetadata ¶ added in v1.0.5
func DoCustomMetadata(tc testpb.TestServiceClient, args ...grpc.CallOption)
DoCustomMetadata checks that metadata is echoed back to the client.
func DoEmptyStream ¶
func DoEmptyStream(tc testpb.TestServiceClient, args ...grpc.CallOption)
DoEmptyStream sets up a bi-directional streaming with zero message.
func DoEmptyUnaryCall ¶
func DoEmptyUnaryCall(tc testpb.TestServiceClient, args ...grpc.CallOption)
DoEmptyUnaryCall performs a unary RPC with empty request and response messages.
func DoJWTTokenCreds ¶
func DoJWTTokenCreds(tc testpb.TestServiceClient, serviceAccountKeyFile string)
DoJWTTokenCreds performs a unary RPC with JWT token auth.
func DoLargeUnaryCall ¶
func DoLargeUnaryCall(tc testpb.TestServiceClient, args ...grpc.CallOption)
DoLargeUnaryCall performs a unary RPC with large payload in the request and response.
func DoOauth2TokenCreds ¶
func DoOauth2TokenCreds(tc testpb.TestServiceClient, serviceAccountKeyFile, oauthScope string)
DoOauth2TokenCreds performs a unary RPC with OAUTH2 token auth.
func DoPerRPCCreds ¶
func DoPerRPCCreds(tc testpb.TestServiceClient, serviceAccountKeyFile, oauthScope string)
DoPerRPCCreds performs a unary RPC with per RPC OAUTH2 token.
func DoPingPong ¶
func DoPingPong(tc testpb.TestServiceClient, args ...grpc.CallOption)
DoPingPong performs ping-pong style bi-directional streaming RPC.
func DoServerStreaming ¶
func DoServerStreaming(tc testpb.TestServiceClient, args ...grpc.CallOption)
DoServerStreaming performs a server streaming RPC.
func DoServiceAccountCreds ¶
func DoServiceAccountCreds(tc testpb.TestServiceClient, serviceAccountKeyFile, oauthScope string)
DoServiceAccountCreds performs a unary RPC with service account auth.
func DoSpecialStatusMessage ¶ added in v1.14.0
func DoSpecialStatusMessage(tc testpb.TestServiceClient, args ...grpc.CallOption)
DoSpecialStatusMessage verifies Unicode and whitespace is correctly processed in status message.
func DoStatusCodeAndMessage ¶ added in v1.0.3
func DoStatusCodeAndMessage(tc testpb.TestServiceClient, args ...grpc.CallOption)
DoStatusCodeAndMessage checks that the status code is propagated back to the client.
func DoTimeoutOnSleepingServer ¶
func DoTimeoutOnSleepingServer(tc testpb.TestServiceClient, args ...grpc.CallOption)
DoTimeoutOnSleepingServer performs an RPC on a sleep server which causes RPC timeout.
func DoUnimplementedMethod ¶ added in v1.0.5
func DoUnimplementedMethod(cc *grpc.ClientConn)
DoUnimplementedMethod attempts to call an unimplemented method.
func DoUnimplementedService ¶ added in v1.0.5
func DoUnimplementedService(tc testpb.UnimplementedServiceClient)
DoUnimplementedService attempts to call a method from an unimplemented service.
func NewTestServer ¶
func NewTestServer() testpb.TestServiceServer
NewTestServer creates a test server for test service.
Types ¶
This section is empty.
Source Files
Directories