XdsStatsWatcher Class Reference

Public Member Functions
void	GetCurrentRpcStats (LoadBalancerAccumulatedStatsResponse *response, StatsWatchers *stats_watchers)
void	RpcCompleted (AsyncClientCall *call, const std::string &peer)
void	WaitForRpcStatsResponse (LoadBalancerStatsResponse *response, int timeout_sec)
	XdsStatsWatcher (int start_id, int end_id)

Private Attributes
LoadBalancerAccumulatedStatsResponse	accumulated_stats_
std::condition_variable	cv_
int	end_id_
std::mutex	m_
int	no_remote_peer_ = 0
std::map< int, int >	no_remote_peer_by_type_
std::map< std::string, int >	rpcs_by_peer_
std::map< int, std::map< std::string, int > >	rpcs_by_type_
int	rpcs_needed_
int	start_id_

Detailed Description

Records the remote peer distribution for a given range of RPCs.

Definition at line 133 of file xds_interop_client.cc.

Constructor & Destructor Documentation

XdsStatsWatcher()

XdsStatsWatcher::XdsStatsWatcher ( int  start_id, int  end_id  )

inline

Definition at line 135 of file xds_interop_client.cc.

Member Function Documentation

GetCurrentRpcStats()

void XdsStatsWatcher::GetCurrentRpcStats ( LoadBalancerAccumulatedStatsResponse *  response, StatsWatchers *  stats_watchers  )

inline

Definition at line 206 of file xds_interop_client.cc.

RpcCompleted()

void XdsStatsWatcher::RpcCompleted ( AsyncClientCall *  call, const std::string &  peer  )

inline

Definition at line 141 of file xds_interop_client.cc.

WaitForRpcStatsResponse()

void XdsStatsWatcher::WaitForRpcStatsResponse ( LoadBalancerStatsResponse *  response, int  timeout_sec  )

inline

Definition at line 175 of file xds_interop_client.cc.

Member Data Documentation

accumulated_stats_

LoadBalancerAccumulatedStatsResponse XdsStatsWatcher::accumulated_stats_

private

Definition at line 245 of file xds_interop_client.cc.

cv_

std::condition_variable XdsStatsWatcher::cv_

private

Definition at line 247 of file xds_interop_client.cc.

end_id_

int XdsStatsWatcher::end_id_

private

Definition at line 235 of file xds_interop_client.cc.

m_

std::mutex XdsStatsWatcher::m_

private

Definition at line 246 of file xds_interop_client.cc.

no_remote_peer_

int XdsStatsWatcher::no_remote_peer_ = 0

private

Definition at line 237 of file xds_interop_client.cc.

no_remote_peer_by_type_

std::map<int, int> XdsStatsWatcher::no_remote_peer_by_type_

private

Definition at line 238 of file xds_interop_client.cc.

rpcs_by_peer_

std::map<std::string, int> XdsStatsWatcher::rpcs_by_peer_

private

Definition at line 240 of file xds_interop_client.cc.

rpcs_by_type_

std::map<int, std::map<std::string, int> > XdsStatsWatcher::rpcs_by_type_

private

Definition at line 243 of file xds_interop_client.cc.

rpcs_needed_

int XdsStatsWatcher::rpcs_needed_

private

Definition at line 236 of file xds_interop_client.cc.

start_id_

int XdsStatsWatcher::start_id_

private

Definition at line 234 of file xds_interop_client.cc.

---

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

• xds_interop_client.cc