#include <rls_server.h>
Classes | |
struct | ResponseData |
struct | RlsRequestLessThan |
Public Types | |
using | ContextProcessingFunc = std::function< void(grpc::ServerContext *)> |
Public Member Functions | |
std::vector< grpc::lookup::v1::RouteLookupRequest > | GetUnmatchedRequests () |
void | RemoveResponse (const grpc::lookup::v1::RouteLookupRequest &request) |
RlsServiceImpl (ContextProcessingFunc context_proc=nullptr) | |
grpc::Status | RouteLookup (grpc::ServerContext *context, const grpc::lookup::v1::RouteLookupRequest *request, grpc::lookup::v1::RouteLookupResponse *response) override |
void | SetResponse (grpc::lookup::v1::RouteLookupRequest request, grpc::lookup::v1::RouteLookupResponse response, grpc_core::Duration response_delay=grpc_core::Duration()) |
void | Shutdown () |
void | Start () |
![]() | |
void | IncreaseRequestCount () |
void | IncreaseResponseCount () |
size_t | request_count () |
void | ResetCounters () |
size_t | response_count () |
Private Attributes | |
ContextProcessingFunc | context_proc_ |
grpc::internal::Mutex | mu_ |
std::map< grpc::lookup::v1::RouteLookupRequest, ResponseData, RlsRequestLessThan > responses_ ABSL_GUARDED_BY & | mu_ |
std::vector< grpc::lookup::v1::RouteLookupRequest > unmatched_requests_ ABSL_GUARDED_BY & | mu_ |
Definition at line 30 of file rls_server.h.
using grpc::testing::RlsServiceImpl::ContextProcessingFunc = std::function<void(grpc::ServerContext*)> |
Definition at line 32 of file rls_server.h.
|
inlineexplicit |
Definition at line 34 of file rls_server.h.
std::vector< RouteLookupRequest > grpc::testing::RlsServiceImpl::GetUnmatchedRequests | ( | ) |
Definition at line 77 of file rls_server.cc.
void grpc::testing::RlsServiceImpl::RemoveResponse | ( | const grpc::lookup::v1::RouteLookupRequest & | request | ) |
Definition at line 72 of file rls_server.cc.
|
override |
Definition at line 31 of file rls_server.cc.
void grpc::testing::RlsServiceImpl::SetResponse | ( | grpc::lookup::v1::RouteLookupRequest | request, |
grpc::lookup::v1::RouteLookupResponse | response, | ||
grpc_core::Duration | response_delay = grpc_core::Duration() |
||
) |
Definition at line 65 of file rls_server.cc.
|
inline |
Definition at line 44 of file rls_server.h.
|
inline |
Definition at line 42 of file rls_server.h.
|
private |
Definition at line 75 of file rls_server.h.
|
private |
Definition at line 76 of file rls_server.h.
|
private |
Definition at line 79 of file rls_server.h.
|
private |
Definition at line 81 of file rls_server.h.