Classes | Public Member Functions | Private Member Functions | Private Attributes | List of all members
grpc::testing::InteropClient Class Reference

#include <interop_client.h>

Classes

class  ServiceStub
 

Public Member Functions

bool DoCancelAfterBegin ()
 
bool DoCancelAfterFirstResponse ()
 
bool DoChannelSoakTest (int32_t soak_iterations, int32_t max_failures, int64_t max_acceptable_per_iteration_latency_ms, int32_t soak_min_time_ms_between_rpcs, int32_t overall_timeout_seconds)
 
bool DoClientCompressedStreaming ()
 
bool DoClientCompressedUnary ()
 
bool DoComputeEngineCreds (const std::string &default_service_account, const std::string &oauth_scope)
 
bool DoCustomMetadata ()
 
bool DoEmpty ()
 
bool DoEmptyStream ()
 
bool DoGoogleDefaultCredentials (const std::string &default_service_account)
 
bool DoHalfDuplex ()
 
bool DoJwtTokenCreds (const std::string &username)
 
bool DoLargeUnary ()
 
bool DoLongLivedChannelTest (int32_t soak_iterations, int32_t iteration_interval)
 
bool DoOauth2AuthToken (const std::string &username, const std::string &oauth_scope)
 
bool DoPerRpcCreds (const std::string &json_key)
 
bool DoPickFirstUnary ()
 
bool DoPingPong ()
 
bool DoRequestStreaming ()
 
bool DoResponseStreaming ()
 
bool DoResponseStreamingWithSlowConsumer ()
 
bool DoRpcSoakTest (int32_t soak_iterations, int32_t max_failures, int64_t max_acceptable_per_iteration_latency_ms, int32_t soak_min_time_ms_between_rpcs, int32_t overall_timeout_seconds)
 
bool DoServerCompressedStreaming ()
 
bool DoServerCompressedUnary ()
 
bool DoSpecialStatusMessage ()
 
bool DoStatusWithMessage ()
 
bool DoTimeoutOnSleepingServer ()
 
bool DoUnimplementedMethod ()
 
bool DoUnimplementedService ()
 
 InteropClient (ChannelCreationFunc channel_creation_func, bool new_stub_every_test_case, bool do_not_abort_on_transient_failures)
 
void Reset (const std::shared_ptr< Channel > &channel)
 
 ~InteropClient ()
 

Private Member Functions

bool AssertStatusCode (const Status &s, StatusCode expected_code, const std::string &optional_debug_string)
 
bool AssertStatusOk (const Status &s, const std::string &optional_debug_string)
 
bool PerformLargeUnary (SimpleRequest *request, SimpleResponse *response)
 
bool PerformLargeUnary (SimpleRequest *request, SimpleResponse *response, const CheckerFn &custom_checks_fn)
 Run custom_check_fn as an additional check. More...
 
std::tuple< bool, int32_t, std::string, std::string > PerformOneSoakTestIteration (const bool reset_channel, const int32_t max_acceptable_per_iteration_latency_ms)
 
void PerformSoakTest (const bool reset_channel_per_iteration, const int32_t soak_iterations, const int32_t max_failures, const int32_t max_acceptable_per_iteration_latency_ms, const int32_t min_time_ms_between_rpcs, const int32_t overall_timeout_seconds)
 
bool TransientFailureOrAbort ()
 

Private Attributes

bool do_not_abort_on_transient_failures_
 If true, abort() is not called for transient failures. More...
 
ServiceStub serviceStub_
 

Detailed Description

Definition at line 40 of file interop_client.h.

Constructor & Destructor Documentation

◆ InteropClient()

grpc::testing::InteropClient::InteropClient ( ChannelCreationFunc  channel_creation_func,
bool  new_stub_every_test_case,
bool  do_not_abort_on_transient_failures 
)
explicit

If new_stub_every_test_case is true, a new TestService::Stub object is created for every test case If do_not_abort_on_transient_failures is true, abort() is not called in case of transient failures (like connection failures)

Definition at line 119 of file interop_client.cc.

◆ ~InteropClient()

grpc::testing::InteropClient::~InteropClient ( )
inline

Definition at line 49 of file interop_client.h.

Member Function Documentation

◆ AssertStatusCode()

bool grpc::testing::InteropClient::AssertStatusCode ( const Status &  s,
StatusCode  expected_code,
const std::string &  optional_debug_string 
)
private

Definition at line 138 of file interop_client.cc.

◆ AssertStatusOk()

bool grpc::testing::InteropClient::AssertStatusOk ( const Status &  s,
const std::string &  optional_debug_string 
)
private

Definition at line 125 of file interop_client.cc.

◆ DoCancelAfterBegin()

bool grpc::testing::InteropClient::DoCancelAfterBegin ( )

Definition at line 735 of file interop_client.cc.

◆ DoCancelAfterFirstResponse()

bool grpc::testing::InteropClient::DoCancelAfterFirstResponse ( )

Definition at line 758 of file interop_client.cc.

◆ DoChannelSoakTest()

bool grpc::testing::InteropClient::DoChannelSoakTest ( int32_t  soak_iterations,
int32_t  max_failures,
int64_t  max_acceptable_per_iteration_latency_ms,
int32_t  soak_min_time_ms_between_rpcs,
int32_t  overall_timeout_seconds 
)

Definition at line 1162 of file interop_client.cc.

◆ DoClientCompressedStreaming()

bool grpc::testing::InteropClient::DoClientCompressedStreaming ( )

Definition at line 484 of file interop_client.cc.

◆ DoClientCompressedUnary()

bool grpc::testing::InteropClient::DoClientCompressedUnary ( )

Definition at line 333 of file interop_client.cc.

◆ DoComputeEngineCreds()

bool grpc::testing::InteropClient::DoComputeEngineCreds ( const std::string &  default_service_account,
const std::string &  oauth_scope 
)

Definition at line 210 of file interop_client.cc.

◆ DoCustomMetadata()

bool grpc::testing::InteropClient::DoCustomMetadata ( )

Definition at line 933 of file interop_client.cc.

◆ DoEmpty()

bool grpc::testing::InteropClient::DoEmpty ( )

Definition at line 159 of file interop_client.cc.

◆ DoEmptyStream()

bool grpc::testing::InteropClient::DoEmptyStream ( )

Definition at line 817 of file interop_client.cc.

◆ DoGoogleDefaultCredentials()

bool grpc::testing::InteropClient::DoGoogleDefaultCredentials ( const std::string &  default_service_account)

Definition at line 303 of file interop_client.cc.

◆ DoHalfDuplex()

bool grpc::testing::InteropClient::DoHalfDuplex ( )

Definition at line 644 of file interop_client.cc.

◆ DoJwtTokenCreds()

bool grpc::testing::InteropClient::DoJwtTokenCreds ( const std::string &  username)

Definition at line 286 of file interop_client.cc.

◆ DoLargeUnary()

bool grpc::testing::InteropClient::DoLargeUnary ( )

Definition at line 322 of file interop_client.cc.

◆ DoLongLivedChannelTest()

bool grpc::testing::InteropClient::DoLongLivedChannelTest ( int32_t  soak_iterations,
int32_t  iteration_interval 
)

Definition at line 1176 of file interop_client.cc.

◆ DoOauth2AuthToken()

bool grpc::testing::InteropClient::DoOauth2AuthToken ( const std::string &  username,
const std::string &  oauth_scope 
)

Definition at line 235 of file interop_client.cc.

◆ DoPerRpcCreds()

bool grpc::testing::InteropClient::DoPerRpcCreds ( const std::string &  json_key)

Definition at line 261 of file interop_client.cc.

◆ DoPickFirstUnary()

bool grpc::testing::InteropClient::DoPickFirstUnary ( )

Definition at line 907 of file interop_client.cc.

◆ DoPingPong()

bool grpc::testing::InteropClient::DoPingPong ( )

Definition at line 691 of file interop_client.cc.

◆ DoRequestStreaming()

bool grpc::testing::InteropClient::DoRequestStreaming ( )

Definition at line 414 of file interop_client.cc.

◆ DoResponseStreaming()

bool grpc::testing::InteropClient::DoResponseStreaming ( )

Definition at line 445 of file interop_client.cc.

◆ DoResponseStreamingWithSlowConsumer()

bool grpc::testing::InteropClient::DoResponseStreamingWithSlowConsumer ( )

Definition at line 601 of file interop_client.cc.

◆ DoRpcSoakTest()

bool grpc::testing::InteropClient::DoRpcSoakTest ( int32_t  soak_iterations,
int32_t  max_failures,
int64_t  max_acceptable_per_iteration_latency_ms,
int32_t  soak_min_time_ms_between_rpcs,
int32_t  overall_timeout_seconds 
)

Definition at line 1149 of file interop_client.cc.

◆ DoServerCompressedStreaming()

bool grpc::testing::InteropClient::DoServerCompressedStreaming ( )

Definition at line 544 of file interop_client.cc.

◆ DoServerCompressedUnary()

bool grpc::testing::InteropClient::DoServerCompressedUnary ( )

Definition at line 379 of file interop_client.cc.

◆ DoSpecialStatusMessage()

bool grpc::testing::InteropClient::DoSpecialStatusMessage ( )

Definition at line 883 of file interop_client.cc.

◆ DoStatusWithMessage()

bool grpc::testing::InteropClient::DoStatusWithMessage ( )

Definition at line 837 of file interop_client.cc.

◆ DoTimeoutOnSleepingServer()

bool grpc::testing::InteropClient::DoTimeoutOnSleepingServer ( )

Definition at line 791 of file interop_client.cc.

◆ DoUnimplementedMethod()

bool grpc::testing::InteropClient::DoUnimplementedMethod ( )

Definition at line 1224 of file interop_client.cc.

◆ DoUnimplementedService()

bool grpc::testing::InteropClient::DoUnimplementedService ( )

Definition at line 1204 of file interop_client.cc.

◆ PerformLargeUnary() [1/2]

bool grpc::testing::InteropClient::PerformLargeUnary ( SimpleRequest *  request,
SimpleResponse *  response 
)
private

Definition at line 176 of file interop_client.cc.

◆ PerformLargeUnary() [2/2]

bool grpc::testing::InteropClient::PerformLargeUnary ( SimpleRequest *  request,
SimpleResponse *  response,
const CheckerFn &  custom_checks_fn 
)
private

Run custom_check_fn as an additional check.

Definition at line 181 of file interop_client.cc.

◆ PerformOneSoakTestIteration()

std::tuple< bool, int32_t, std::string, std::string > grpc::testing::InteropClient::PerformOneSoakTestIteration ( const bool  reset_channel,
const int32_t  max_acceptable_per_iteration_latency_ms 
)
private

Definition at line 1024 of file interop_client.cc.

◆ PerformSoakTest()

void grpc::testing::InteropClient::PerformSoakTest ( const bool  reset_channel_per_iteration,
const int32_t  soak_iterations,
const int32_t  max_failures,
const int32_t  max_acceptable_per_iteration_latency_ms,
const int32_t  min_time_ms_between_rpcs,
const int32_t  overall_timeout_seconds 
)
private

Definition at line 1058 of file interop_client.cc.

◆ Reset()

void grpc::testing::InteropClient::Reset ( const std::shared_ptr< Channel > &  channel)

◆ TransientFailureOrAbort()

bool grpc::testing::InteropClient::TransientFailureOrAbort ( )
private

Definition at line 406 of file interop_client.cc.

Member Data Documentation

◆ do_not_abort_on_transient_failures_

bool grpc::testing::InteropClient::do_not_abort_on_transient_failures_
private

If true, abort() is not called for transient failures.

Definition at line 153 of file interop_client.h.

◆ serviceStub_

ServiceStub grpc::testing::InteropClient::serviceStub_
private

Definition at line 151 of file interop_client.h.

The documentation for this class was generated from the following files:

grpc
Author(s):
autogenerated on Fri May 16 2025 03:03:34