Documentation
¶
Index ¶
- func DoCancelAfterBegin(tc testpb.TestServiceClient)
- func DoCancelAfterFirstResponse(tc testpb.TestServiceClient)
- func DoClientStreaming(tc testpb.TestServiceClient)
- func DoComputeEngineCreds(tc testpb.TestServiceClient, serviceAccount, oauthScope string)
- func DoEmptyStream(tc testpb.TestServiceClient)
- func DoEmptyUnaryCall(tc testpb.TestServiceClient)
- func DoJWTTokenCreds(tc testpb.TestServiceClient, serviceAccountKeyFile string)
- func DoLargeUnaryCall(tc testpb.TestServiceClient)
- func DoOauth2TokenCreds(tc testpb.TestServiceClient, serviceAccountKeyFile, oauthScope string)
- func DoPerRPCCreds(tc testpb.TestServiceClient, serviceAccountKeyFile, oauthScope string)
- func DoPingPong(tc testpb.TestServiceClient)
- func DoServerStreaming(tc testpb.TestServiceClient)
- func DoServiceAccountCreds(tc testpb.TestServiceClient, serviceAccountKeyFile, oauthScope string)
- func DoTimeoutOnSleepingServer(tc testpb.TestServiceClient)
- func GetToken(serviceAccountKeyFile string, oauthScope string) *oauth2.Token
- func NewTestServer() testpb.TestServiceServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DoCancelAfterBegin ¶
func DoCancelAfterBegin(tc testpb.TestServiceClient)
DoCancelAfterBegin cancels the RPC after metadata has been sent but before payloads are sent.
func DoCancelAfterFirstResponse ¶
func DoCancelAfterFirstResponse(tc testpb.TestServiceClient)
DoCancelAfterFirstResponse cancels the RPC after receiving the first message from the server.
func DoClientStreaming ¶
func DoClientStreaming(tc testpb.TestServiceClient)
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 DoEmptyStream ¶
func DoEmptyStream(tc testpb.TestServiceClient)
DoEmptyStream sets up a bi-directional streaming with zero message.
func DoEmptyUnaryCall ¶
func DoEmptyUnaryCall(tc testpb.TestServiceClient)
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)
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)
DoPingPong performs ping-pong style bi-directional streaming RPC.
func DoServerStreaming ¶
func DoServerStreaming(tc testpb.TestServiceClient)
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 DoTimeoutOnSleepingServer ¶
func DoTimeoutOnSleepingServer(tc testpb.TestServiceClient)
DoTimeoutOnSleepingServer performs an RPC on a sleep server which causes RPC timeout.
func NewTestServer ¶
func NewTestServer() testpb.TestServiceServer
NewTestServer creates a test server for test service.
Types ¶
This section is empty.
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package grpc_testing is a generated protocol buffer package.
|
Package grpc_testing is a generated protocol buffer package. |
|
observability
module
|
|
|
xds
module
|