Classes | Public Types | Public Member Functions | Private Member Functions | Static Private Member Functions | Private Attributes | List of all members
grpc::testing::AdsServiceImpl::RpcService< RpcApi, DiscoveryRequest, DiscoveryResponse > Class Template Reference
Inheritance diagram for grpc::testing::AdsServiceImpl::RpcService< RpcApi, DiscoveryRequest, DiscoveryResponse >:
Inheritance graph
[legend]

Classes

class  NoopMutexLock
 

Public Types

using Stream = ServerReaderWriter< DiscoveryResponse, DiscoveryRequest >
 

Public Member Functions

 RpcService (AdsServiceImpl *parent, bool is_v2)
 
Status StreamAggregatedResources (ServerContext *context, Stream *stream) override
 

Private Member Functions

void BlockingRead (Stream *stream, std::deque< DiscoveryRequest > *requests, bool *stream_closed)
 
void CompleteBuildingDiscoveryResponse (const std::string &resource_type, const std::string &v2_resource_type, const int version, const SubscriptionNameMap &subscription_name_map, const std::set< std::string > &resources_added_to_response, SentState *sent_state, DiscoveryResponse *response) ABSL_EXCLUSIVE_LOCKS_REQUIRED(parent_ -> ads_mu_)
 
void ProcessRequest (const DiscoveryRequest &request, const std::string &v3_resource_type, UpdateQueue *update_queue, SubscriptionMap *subscription_map, SentState *sent_state, absl::optional< DiscoveryResponse > *response) ABSL_EXCLUSIVE_LOCKS_REQUIRED(parent_ -> ads_mu_)
 
void ProcessUpdate (const std::string &resource_type, const std::string &resource_name, SubscriptionMap *subscription_map, SentState *sent_state, absl::optional< DiscoveryResponse > *response) ABSL_EXCLUSIVE_LOCKS_REQUIRED(parent_ -> ads_mu_)
 

Static Private Member Functions

static void CheckBuildVersion (const ::envoy::api::v2::DiscoveryRequest &request)
 
static void CheckBuildVersion (const ::envoy::service::discovery::v3::DiscoveryRequest &)
 
static std::string TypeUrlToV2 (const std::string &resource_type)
 
static std::string TypeUrlToV3 (const std::string &resource_type)
 

Private Attributes

const bool is_v2_
 
AdsServiceImpl * parent_
 

Detailed Description

template<class RpcApi, class DiscoveryRequest, class DiscoveryResponse>
class grpc::testing::AdsServiceImpl::RpcService< RpcApi, DiscoveryRequest, DiscoveryResponse >

Definition at line 237 of file xds_server.h.

Member Typedef Documentation

◆ Stream

template<class RpcApi , class DiscoveryRequest , class DiscoveryResponse >
using grpc::testing::AdsServiceImpl::RpcService< RpcApi, DiscoveryRequest, DiscoveryResponse >::Stream = ServerReaderWriter<DiscoveryResponse, DiscoveryRequest>

Definition at line 239 of file xds_server.h.

Constructor & Destructor Documentation

◆ RpcService()

template<class RpcApi , class DiscoveryRequest , class DiscoveryResponse >
grpc::testing::AdsServiceImpl::RpcService< RpcApi, DiscoveryRequest, DiscoveryResponse >::RpcService ( AdsServiceImpl *  parent,
bool  is_v2 
)
inline

Definition at line 241 of file xds_server.h.

Member Function Documentation

◆ BlockingRead()

template<class RpcApi , class DiscoveryRequest , class DiscoveryResponse >
void grpc::testing::AdsServiceImpl::RpcService< RpcApi, DiscoveryRequest, DiscoveryResponse >::BlockingRead ( Stream *  stream,
std::deque< DiscoveryRequest > *  requests,
bool *  stream_closed 
)
inlineprivate

Definition at line 544 of file xds_server.h.

◆ CheckBuildVersion() [1/2]

template<class RpcApi , class DiscoveryRequest , class DiscoveryResponse >
static void grpc::testing::AdsServiceImpl::RpcService< RpcApi, DiscoveryRequest, DiscoveryResponse >::CheckBuildVersion ( const ::envoy::api::v2::DiscoveryRequest &  request)
inlinestaticprivate

Definition at line 620 of file xds_server.h.

◆ CheckBuildVersion() [2/2]

template<class RpcApi , class DiscoveryRequest , class DiscoveryResponse >
static void grpc::testing::AdsServiceImpl::RpcService< RpcApi, DiscoveryRequest, DiscoveryResponse >::CheckBuildVersion ( const ::envoy::service::discovery::v3::DiscoveryRequest &  )
inlinestaticprivate

Definition at line 625 of file xds_server.h.

◆ CompleteBuildingDiscoveryResponse()

template<class RpcApi , class DiscoveryRequest , class DiscoveryResponse >
void grpc::testing::AdsServiceImpl::RpcService< RpcApi, DiscoveryRequest, DiscoveryResponse >::CompleteBuildingDiscoveryResponse ( const std::string &  resource_type,
const std::string &  v2_resource_type,
const int  version,
const SubscriptionNameMap &  subscription_name_map,
const std::set< std::string > &  resources_added_to_response,
SentState *  sent_state,
DiscoveryResponse *  response 
) -> ads_mu_)
inlineprivate

Definition at line 570 of file xds_server.h.

◆ ProcessRequest()

template<class RpcApi , class DiscoveryRequest , class DiscoveryResponse >
void grpc::testing::AdsServiceImpl::RpcService< RpcApi, DiscoveryRequest, DiscoveryResponse >::ProcessRequest ( const DiscoveryRequest &  request,
const std::string &  v3_resource_type,
UpdateQueue *  update_queue,
SubscriptionMap *  subscription_map,
SentState *  sent_state,
absl::optional< DiscoveryResponse > *  response 
) -> ads_mu_)
inlineprivate

Definition at line 401 of file xds_server.h.

◆ ProcessUpdate()

template<class RpcApi , class DiscoveryRequest , class DiscoveryResponse >
void grpc::testing::AdsServiceImpl::RpcService< RpcApi, DiscoveryRequest, DiscoveryResponse >::ProcessUpdate ( const std::string &  resource_type,
const std::string &  resource_name,
SubscriptionMap *  subscription_map,
SentState *  sent_state,
absl::optional< DiscoveryResponse > *  response 
) -> ads_mu_)
inlineprivate

Definition at line 508 of file xds_server.h.

◆ StreamAggregatedResources()

template<class RpcApi , class DiscoveryRequest , class DiscoveryResponse >
Status grpc::testing::AdsServiceImpl::RpcService< RpcApi, DiscoveryRequest, DiscoveryResponse >::StreamAggregatedResources ( ServerContext *  context,
Stream *  stream 
)
inlineoverride

Definition at line 244 of file xds_server.h.

◆ TypeUrlToV2()

template<class RpcApi , class DiscoveryRequest , class DiscoveryResponse >
static std::string grpc::testing::AdsServiceImpl::RpcService< RpcApi, DiscoveryRequest, DiscoveryResponse >::TypeUrlToV2 ( const std::string &  resource_type)
inlinestaticprivate

Definition at line 604 of file xds_server.h.

◆ TypeUrlToV3()

template<class RpcApi , class DiscoveryRequest , class DiscoveryResponse >
static std::string grpc::testing::AdsServiceImpl::RpcService< RpcApi, DiscoveryRequest, DiscoveryResponse >::TypeUrlToV3 ( const std::string &  resource_type)
inlinestaticprivate

Definition at line 612 of file xds_server.h.

Member Data Documentation

◆ is_v2_

template<class RpcApi , class DiscoveryRequest , class DiscoveryResponse >
const bool grpc::testing::AdsServiceImpl::RpcService< RpcApi, DiscoveryRequest, DiscoveryResponse >::is_v2_
private

Definition at line 629 of file xds_server.h.

◆ parent_

template<class RpcApi , class DiscoveryRequest , class DiscoveryResponse >
AdsServiceImpl* grpc::testing::AdsServiceImpl::RpcService< RpcApi, DiscoveryRequest, DiscoveryResponse >::parent_
private

Definition at line 628 of file xds_server.h.

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

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