Documentation
¶
Overview ¶
Package interop contains functions used by interop client/server.
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 DoComputeEngineChannelCredentials(tc testpb.TestServiceClient, defaultServiceAccount string)
- 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 DoGoogleDefaultCredentials(tc testpb.TestServiceClient, defaultServiceAccount string)
- 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 DoPickFirstUnary(tc testpb.TestServiceClient)
- 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.TestServiceService
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 DoComputeEngineChannelCredentials ¶ added in v1.20.0
func DoComputeEngineChannelCredentials(tc testpb.TestServiceClient, defaultServiceAccount string)
DoComputeEngineChannelCredentials performs an unary RPC with compute engine channel credentials
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 DoGoogleDefaultCredentials ¶ added in v1.19.0
func DoGoogleDefaultCredentials(tc testpb.TestServiceClient, defaultServiceAccount string)
DoGoogleDefaultCredentials performs an unary RPC with google default credentials
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 DoPickFirstUnary ¶ added in v1.21.0
func DoPickFirstUnary(tc testpb.TestServiceClient)
DoPickFirstUnary runs multiple RPCs (rpcCount) and checks that all requests are sent to the same backend.
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.TestServiceService
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 Documentation: https://github.com/grpc/grpc/blob/master/doc/negative-http2-interop-test-descriptions.md
|
Binary http2 is used to test http2 error edge cases like GOAWAYs and RST_STREAMs Documentation: https://github.com/grpc/grpc/blob/master/doc/negative-http2-interop-test-descriptions.md |
|
observability
module
|
|
|
Binary server is an interop server.
|
Binary server is an interop server. |
|
xds
module
|
|
|
client
Binary client for xDS interop tests.
|
Binary client for xDS interop tests. |
|
server
Binary server for xDS interop tests.
|
Binary server for xDS interop tests. |