Documentation
¶
Overview ¶
Package interop contains functions used by interop client/server.
Index ¶
- func ClientNewPayload(t testpb.PayloadType, size int) *testpb.Payload
- func DoCancelAfterBegin(tc testgrpc.TestServiceClient, args ...grpc.CallOption)
- func DoCancelAfterFirstResponse(tc testgrpc.TestServiceClient, args ...grpc.CallOption)
- func DoClientStreaming(tc testgrpc.TestServiceClient, args ...grpc.CallOption)
- func DoComputeEngineChannelCredentials(tc testgrpc.TestServiceClient, defaultServiceAccount string)
- func DoComputeEngineCreds(tc testgrpc.TestServiceClient, serviceAccount, oauthScope string)
- func DoCustomMetadata(tc testgrpc.TestServiceClient, args ...grpc.CallOption)
- func DoEmptyStream(tc testgrpc.TestServiceClient, args ...grpc.CallOption)
- func DoEmptyUnaryCall(tc testgrpc.TestServiceClient, args ...grpc.CallOption)
- func DoGoogleDefaultCredentials(tc testgrpc.TestServiceClient, defaultServiceAccount string)
- func DoJWTTokenCreds(tc testgrpc.TestServiceClient, serviceAccountKeyFile string)
- func DoLargeUnaryCall(tc testgrpc.TestServiceClient, args ...grpc.CallOption)
- func DoOauth2TokenCreds(tc testgrpc.TestServiceClient, serviceAccountKeyFile, oauthScope string)
- func DoPerRPCCreds(tc testgrpc.TestServiceClient, serviceAccountKeyFile, oauthScope string)
- func DoPickFirstUnary(tc testgrpc.TestServiceClient)
- func DoPingPong(tc testgrpc.TestServiceClient, args ...grpc.CallOption)
- func DoServerStreaming(tc testgrpc.TestServiceClient, args ...grpc.CallOption)
- func DoServiceAccountCreds(tc testgrpc.TestServiceClient, serviceAccountKeyFile, oauthScope string)
- func DoSoakTest(tc testgrpc.TestServiceClient, serverAddr string, dopts []grpc.DialOption, ...)
- func DoSpecialStatusMessage(tc testgrpc.TestServiceClient, args ...grpc.CallOption)
- func DoStatusCodeAndMessage(tc testgrpc.TestServiceClient, args ...grpc.CallOption)
- func DoTimeoutOnSleepingServer(tc testgrpc.TestServiceClient, args ...grpc.CallOption)
- func DoUnimplementedMethod(cc *grpc.ClientConn)
- func DoUnimplementedService(tc testgrpc.UnimplementedServiceClient)
- func GetToken(serviceAccountKeyFile string, oauthScope string) *oauth2.Token
- func NewTestServer() testgrpc.TestServiceServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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 testgrpc.TestServiceClient, args ...grpc.CallOption)
DoCancelAfterBegin cancels the RPC after metadata has been sent but before payloads are sent.
func DoCancelAfterFirstResponse ¶
func DoCancelAfterFirstResponse(tc testgrpc.TestServiceClient, args ...grpc.CallOption)
DoCancelAfterFirstResponse cancels the RPC after receiving the first message from the server.
func DoClientStreaming ¶
func DoClientStreaming(tc testgrpc.TestServiceClient, args ...grpc.CallOption)
DoClientStreaming performs a client streaming RPC.
func DoComputeEngineChannelCredentials ¶
func DoComputeEngineChannelCredentials(tc testgrpc.TestServiceClient, defaultServiceAccount string)
DoComputeEngineChannelCredentials performs an unary RPC with compute engine channel credentials
func DoComputeEngineCreds ¶
func DoComputeEngineCreds(tc testgrpc.TestServiceClient, serviceAccount, oauthScope string)
DoComputeEngineCreds performs a unary RPC with compute engine auth.
func DoCustomMetadata ¶
func DoCustomMetadata(tc testgrpc.TestServiceClient, args ...grpc.CallOption)
DoCustomMetadata checks that metadata is echoed back to the client.
func DoEmptyStream ¶
func DoEmptyStream(tc testgrpc.TestServiceClient, args ...grpc.CallOption)
DoEmptyStream sets up a bi-directional streaming with zero message.
func DoEmptyUnaryCall ¶
func DoEmptyUnaryCall(tc testgrpc.TestServiceClient, args ...grpc.CallOption)
DoEmptyUnaryCall performs a unary RPC with empty request and response messages.
func DoGoogleDefaultCredentials ¶
func DoGoogleDefaultCredentials(tc testgrpc.TestServiceClient, defaultServiceAccount string)
DoGoogleDefaultCredentials performs an unary RPC with google default credentials
func DoJWTTokenCreds ¶
func DoJWTTokenCreds(tc testgrpc.TestServiceClient, serviceAccountKeyFile string)
DoJWTTokenCreds performs a unary RPC with JWT token auth.
func DoLargeUnaryCall ¶
func DoLargeUnaryCall(tc testgrpc.TestServiceClient, args ...grpc.CallOption)
DoLargeUnaryCall performs a unary RPC with large payload in the request and response.
func DoOauth2TokenCreds ¶
func DoOauth2TokenCreds(tc testgrpc.TestServiceClient, serviceAccountKeyFile, oauthScope string)
DoOauth2TokenCreds performs a unary RPC with OAUTH2 token auth.
func DoPerRPCCreds ¶
func DoPerRPCCreds(tc testgrpc.TestServiceClient, serviceAccountKeyFile, oauthScope string)
DoPerRPCCreds performs a unary RPC with per RPC OAUTH2 token.
func DoPickFirstUnary ¶
func DoPickFirstUnary(tc testgrpc.TestServiceClient)
DoPickFirstUnary runs multiple RPCs (rpcCount) and checks that all requests are sent to the same backend.
func DoPingPong ¶
func DoPingPong(tc testgrpc.TestServiceClient, args ...grpc.CallOption)
DoPingPong performs ping-pong style bi-directional streaming RPC.
func DoServerStreaming ¶
func DoServerStreaming(tc testgrpc.TestServiceClient, args ...grpc.CallOption)
DoServerStreaming performs a server streaming RPC.
func DoServiceAccountCreds ¶
func DoServiceAccountCreds(tc testgrpc.TestServiceClient, serviceAccountKeyFile, oauthScope string)
DoServiceAccountCreds performs a unary RPC with service account auth.
func DoSoakTest ¶
func DoSoakTest(tc testgrpc.TestServiceClient, serverAddr string, dopts []grpc.DialOption, resetChannel bool, soakIterations int, maxFailures int, perIterationMaxAcceptableLatency time.Duration, overallDeadline time.Time)
DoSoakTest runs large unary RPCs in a loop for a configurable number of times, with configurable failure thresholds. If resetChannel is false, then each RPC will be performed on tc. Otherwise, each RPC will be performed on a new stub that is created with the provided server address and dial options.
func DoSpecialStatusMessage ¶
func DoSpecialStatusMessage(tc testgrpc.TestServiceClient, args ...grpc.CallOption)
DoSpecialStatusMessage verifies Unicode and whitespace is correctly processed in status message.
func DoStatusCodeAndMessage ¶
func DoStatusCodeAndMessage(tc testgrpc.TestServiceClient, args ...grpc.CallOption)
DoStatusCodeAndMessage checks that the status code is propagated back to the client.
func DoTimeoutOnSleepingServer ¶
func DoTimeoutOnSleepingServer(tc testgrpc.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 testgrpc.UnimplementedServiceClient)
DoUnimplementedService attempts to call a method from an unimplemented service.
func NewTestServer ¶
func NewTestServer() testgrpc.TestServiceServer
NewTestServer creates a test server for test service.
Types ¶
This section is empty.
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
alts
|
|
|
client
This binary can only run on Google Cloud Platform (GCP).
|
This binary can only run on Google Cloud Platform (GCP). |
|
server
This binary can only run on Google Cloud Platform (GCP).
|
This binary can only run on Google Cloud Platform (GCP). |
|
Binary client is an interop client.
|
Binary client is an interop client. |
|
This file is for testing only.
|
This file is for testing only. |
|
Binary grpclb_fallback is an interop test client for grpclb fallback.
|
Binary grpclb_fallback is an interop test client for grpclb fallback. |
|
Binary http2 is used to test http2 error edge cases like GOAWAYs and RST_STREAMs
|
Binary http2 is used to test http2 error edge cases like GOAWAYs and RST_STREAMs |
|
Binary server is an interop server.
|
Binary server is an interop server. |
|
xds
|
|
|
client
Binary client for xDS interop tests.
|
Binary client for xDS interop tests. |
|
server
Binary server is the server used for xDS interop tests.
|
Binary server is the server used for xDS interop tests. |