grpc::testing::GenericAsyncStreamingClient Member List

This is the complete list of members for grpc::testing::GenericAsyncStreamingClient, including all inherited members.

AsyncClient(const ClientConfig &config, std::function< ClientRpcContext *(grpc::GenericStub *, std::function< gpr_timespec()> next_issue, const ByteBuffer &)> setup_ctx, std::function< std::unique_ptr< grpc::GenericStub >(std::shared_ptr< Channel >)> create_stub)grpc::testing::AsyncClient< grpc::GenericStub, ByteBuffer >inline
AwaitThreadsCompletion()grpc::testing::Clientinline
channels_grpc::testing::ClientImpl< grpc::GenericStub, ByteBuffer >protected
CheckDone(const grpc::Status &, ByteBuffer *)grpc::testing::GenericAsyncStreamingClientinlineprivatestatic
cli_cqs_grpc::testing::AsyncClient< grpc::GenericStub, ByteBuffer >private
Client()grpc::testing::Clientinline
ClientImpl(const ClientConfig &config, std::function< std::unique_ptr< grpc::GenericStub >(std::shared_ptr< Channel >)> create_stub)grpc::testing::ClientImpl< grpc::GenericStub, ByteBuffer >inline
closed_loop_grpc::testing::AsyncClient< grpc::GenericStub, ByteBuffer >
CompleteThread()grpc::testing::Clientinlineprotected
cores_grpc::testing::ClientImpl< grpc::GenericStub, ByteBuffer >protected
cq_grpc::testing::AsyncClient< grpc::GenericStub, ByteBuffer >private
create_stub_grpc::testing::ClientImpl< grpc::GenericStub, ByteBuffer >protected
DestroyMultithreading() finalgrpc::testing::AsyncClient< grpc::GenericStub, ByteBuffer >inlineprivatevirtual
EndThreads()grpc::testing::Clientinlineprotected
GenericAsyncStreamingClient(const ClientConfig &config)grpc::testing::GenericAsyncStreamingClientinlineexplicit
GetLatencyCollectionIntervalInSeconds()grpc::testing::Clientinline
GetPollCount() overridegrpc::testing::AsyncClient< grpc::GenericStub, ByteBuffer >inlinevirtual
interarrival_timer_grpc::testing::Clientprotected
IsClosedLoop()grpc::testing::Clientinline
last_reset_poll_count_grpc::testing::Clientprotected
Mark(bool reset)grpc::testing::Clientinline
MaybeStartRequests()grpc::testing::Clientinlineprotected
median_latency_collection_interval_seconds_grpc::testing::Clientprotected
next_issuers_grpc::testing::AsyncClient< grpc::GenericStub, ByteBuffer >private
next_time_grpc::testing::Clientprotected
NextIssuer(int thread_idx)grpc::testing::AsyncClient< grpc::GenericStub, ByteBuffer >inline
ClientImpl< grpc::GenericStub, ByteBuffer >::NextIssuer(int thread_idx)grpc::testing::Clientinlineprotected
NextIssueTime(int thread_idx)grpc::testing::Clientinline
num_async_threads_grpc::testing::AsyncClient< grpc::GenericStub, ByteBuffer >protected
NumThreads(const ClientConfig &config)grpc::testing::AsyncClient< grpc::GenericStub, ByteBuffer >inlineprivate
PrepareReq(grpc::GenericStub *stub, grpc::ClientContext *ctx, const std::string &method_name, CompletionQueue *cq)grpc::testing::GenericAsyncStreamingClientinlineprivatestatic
ProcessTag(size_t thread_idx, void *tag)grpc::testing::AsyncClient< grpc::GenericStub, ByteBuffer >inlineprivate
request()grpc::testing::ClientImpl< grpc::GenericStub, ByteBuffer >inline
request_grpc::testing::ClientImpl< grpc::GenericStub, ByteBuffer >protected
SetupCtx(grpc::GenericStub *stub, std::function< gpr_timespec()> next_issue, const ByteBuffer &req)grpc::testing::GenericAsyncStreamingClientinlineprivatestatic
SetupLoadTest(const ClientConfig &config, size_t num_threads)grpc::testing::AsyncClient< grpc::GenericStub, ByteBuffer >inline
ClientImpl< grpc::GenericStub, ByteBuffer >::SetupLoadTest(const ClientConfig &config, size_t num_threads)grpc::testing::Clientinlineprotected
shutdown_state_grpc::testing::AsyncClient< grpc::GenericStub, ByteBuffer >private
start_requests_grpc::testing::Clientprotected
started_requests_grpc::testing::Clientprotected
StartThreads(size_t num_threads)grpc::testing::Clientinlineprotected
thread_completion_mu_grpc::testing::Clientprotected
thread_pool_done_grpc::testing::Clientprotected
ThreadCompleted()grpc::testing::Clientinline
ThreadFunc(size_t thread_idx, Client::Thread *t) finalgrpc::testing::AsyncClient< grpc::GenericStub, ByteBuffer >inlineprivatevirtual
threads_grpc::testing::Clientprotected
threads_complete_grpc::testing::Clientprotected
threads_remaining_grpc::testing::Clientprotected
timer_grpc::testing::Clientprotected
WaitForChannelsToConnect()grpc::testing::ClientImpl< grpc::GenericStub, ByteBuffer >inline
~AsyncClient() overridegrpc::testing::AsyncClient< grpc::GenericStub, ByteBuffer >inline
~Client()grpc::testing::Clientinlinevirtual
~ClientImpl() overridegrpc::testing::ClientImpl< grpc::GenericStub, ByteBuffer >inline
~GenericAsyncStreamingClient() overridegrpc::testing::GenericAsyncStreamingClientinline


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