ActiveGo 1.8Package interop
Overview ▹
Index ▹
func ClientNewPayload ¶
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 ¶
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 DoStatusCodeAndMessage ¶
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 ¶
func DoUnimplementedMethod(cc *grpc.ClientConn)
DoUnimplementedMethod attempts to call an unimplemented method.
func DoUnimplementedService ¶
func DoUnimplementedService(tc testpb.UnimplementedServiceClient)
DoUnimplementedService attempts to call a method from an unimplemented service.
func GetToken ¶
func GetToken(serviceAccountKeyFile string, oauthScope string) *oauth2.Token
GetToken obtains an OAUTH token from the input.
func NewTestServer ¶
func NewTestServer() testpb.TestServiceServer
NewTestServer creates a test server for test service.
Subdirectories
| Name | Synopsis |
|---|---|
| .. | |
| client | |
| grpc_testing | Package grpc_testing is a generated protocol buffer package. |
| http2 | |
| server | |