Classes | Public Member Functions | Private Attributes | List of all members
grpc_event_engine::experimental::ConnectionManager Class Reference

#include <event_engine_test_utils.h>

Classes

class  Connection
 

Public Member Functions

absl::Status BindAndStartListener (std::vector< std::string > addrs, bool listener_type_oracle=true)
 
 ConnectionManager (std::unique_ptr< EventEngine > test_event_engine, std::unique_ptr< EventEngine > oracle_event_engine)
 
absl::StatusOr< std::tuple< std::unique_ptr< EventEngine::Endpoint >, std::unique_ptr< EventEngine::Endpoint > > > CreateConnection (std::string target_addr, EventEngine::Duration timeout, bool client_type_oracle)
 
 ~ConnectionManager ()=default
 

Private Attributes

Connection last_in_progress_connection_
 
std::map< std::string, std::shared_ptr< EventEngine::Listener > > listeners_
 
std::unique_ptr< grpc_core::MemoryQuotamemory_quota_
 
grpc_core::Mutex mu_
 
int num_processed_connections_ = 0
 
std::unique_ptr< EventEngineoracle_event_engine_
 
std::unique_ptr< EventEnginetest_event_engine_
 

Detailed Description

Definition at line 59 of file event_engine_test_utils.h.

Constructor & Destructor Documentation

◆ ConnectionManager()

grpc_event_engine::experimental::ConnectionManager::ConnectionManager ( std::unique_ptr< EventEngine test_event_engine,
std::unique_ptr< EventEngine oracle_event_engine 
)
inline

Definition at line 61 of file event_engine_test_utils.h.

◆ ~ConnectionManager()

grpc_event_engine::experimental::ConnectionManager::~ConnectionManager ( )
default

Member Function Documentation

◆ BindAndStartListener()

absl::Status grpc_event_engine::experimental::ConnectionManager::BindAndStartListener ( std::vector< std::string >  addrs,
bool  listener_type_oracle = true 
)

Definition at line 117 of file event_engine_test_utils.cc.

◆ CreateConnection()

absl::StatusOr< std::tuple< std::unique_ptr< Endpoint >, std::unique_ptr< Endpoint > > > grpc_event_engine::experimental::ConnectionManager::CreateConnection ( std::string  target_addr,
EventEngine::Duration  timeout,
bool  client_type_oracle 
)

Definition at line 168 of file event_engine_test_utils.cc.

Member Data Documentation

◆ last_in_progress_connection_

Connection grpc_event_engine::experimental::ConnectionManager::last_in_progress_connection_
private

Definition at line 117 of file event_engine_test_utils.h.

◆ listeners_

std::map<std::string, std::shared_ptr<EventEngine::Listener> > grpc_event_engine::experimental::ConnectionManager::listeners_
private

Definition at line 118 of file event_engine_test_utils.h.

◆ memory_quota_

std::unique_ptr<grpc_core::MemoryQuota> grpc_event_engine::experimental::ConnectionManager::memory_quota_
private

Definition at line 115 of file event_engine_test_utils.h.

◆ mu_

grpc_core::Mutex grpc_event_engine::experimental::ConnectionManager::mu_
private

Definition at line 114 of file event_engine_test_utils.h.

◆ num_processed_connections_

int grpc_event_engine::experimental::ConnectionManager::num_processed_connections_ = 0
private

Definition at line 116 of file event_engine_test_utils.h.

◆ oracle_event_engine_

std::unique_ptr<EventEngine> grpc_event_engine::experimental::ConnectionManager::oracle_event_engine_
private

Definition at line 120 of file event_engine_test_utils.h.

◆ test_event_engine_

std::unique_ptr<EventEngine> grpc_event_engine::experimental::ConnectionManager::test_event_engine_
private

Definition at line 119 of file event_engine_test_utils.h.


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


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