BlockingRead(Stream *stream, std::deque< DiscoveryRequest > *requests, bool *stream_closed) | grpc::testing::AdsServiceImpl::RpcService< RpcApi, DiscoveryRequest, DiscoveryResponse > | inlineprivate |
CheckBuildVersion(const ::envoy::api::v2::DiscoveryRequest &request) | grpc::testing::AdsServiceImpl::RpcService< RpcApi, DiscoveryRequest, DiscoveryResponse > | inlineprivatestatic |
CheckBuildVersion(const ::envoy::service::discovery::v3::DiscoveryRequest &) | grpc::testing::AdsServiceImpl::RpcService< RpcApi, DiscoveryRequest, DiscoveryResponse > | inlineprivatestatic |
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_) | grpc::testing::AdsServiceImpl::RpcService< RpcApi, DiscoveryRequest, DiscoveryResponse > | inlineprivate |
is_v2_ | grpc::testing::AdsServiceImpl::RpcService< RpcApi, DiscoveryRequest, DiscoveryResponse > | private |
parent_ | grpc::testing::AdsServiceImpl::RpcService< RpcApi, DiscoveryRequest, DiscoveryResponse > | private |
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_) | grpc::testing::AdsServiceImpl::RpcService< RpcApi, DiscoveryRequest, DiscoveryResponse > | inlineprivate |
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_) | grpc::testing::AdsServiceImpl::RpcService< RpcApi, DiscoveryRequest, DiscoveryResponse > | inlineprivate |
RpcService(AdsServiceImpl *parent, bool is_v2) | grpc::testing::AdsServiceImpl::RpcService< RpcApi, DiscoveryRequest, DiscoveryResponse > | inline |
Stream typedef | grpc::testing::AdsServiceImpl::RpcService< RpcApi, DiscoveryRequest, DiscoveryResponse > | |
StreamAggregatedResources(ServerContext *context, Stream *stream) override | grpc::testing::AdsServiceImpl::RpcService< RpcApi, DiscoveryRequest, DiscoveryResponse > | inline |
TypeUrlToV2(const std::string &resource_type) | grpc::testing::AdsServiceImpl::RpcService< RpcApi, DiscoveryRequest, DiscoveryResponse > | inlineprivatestatic |
TypeUrlToV3(const std::string &resource_type) | grpc::testing::AdsServiceImpl::RpcService< RpcApi, DiscoveryRequest, DiscoveryResponse > | inlineprivatestatic |