grpc::DefaultHealthCheckService::HealthCheckServiceImpl Class Reference

#include <default_health_check_service.h>

Inheritance diagram for grpc::DefaultHealthCheckService::HealthCheckServiceImpl:

Classes
class	CallableTag
class	CallHandler
class	CheckCallHandler
class	WatchCallHandler

Public Member Functions
	HealthCheckServiceImpl (DefaultHealthCheckService *database, std::unique_ptr< ServerCompletionQueue > cq)
void	StartServingThread ()
	~HealthCheckServiceImpl () override
Public Member Functions inherited from grpc::Service
bool	has_async_methods () const
bool	has_callback_methods () const
bool	has_generic_methods () const
bool	has_synchronous_methods () const
	Service ()
virtual	~Service ()

Private Member Functions
template<class Message >
void	RequestAsyncServerStreaming (int index, grpc::ServerContext *context, Message *request, internal::ServerAsyncStreamingInterface *stream, grpc::CompletionQueue *call_cq, grpc::ServerCompletionQueue *notification_cq, void *tag)
template<class Message >
void	RequestAsyncUnary (int index, grpc::ServerContext *context, Message *request, internal::ServerAsyncStreamingInterface *stream, grpc::CompletionQueue *call_cq, grpc::ServerCompletionQueue *notification_cq, void *tag)

Static Private Member Functions
static bool	DecodeRequest (const ByteBuffer &request, std::string *service_name)
static bool	EncodeResponse (ServingStatus status, ByteBuffer *response)
static void	Serve (void *arg)

Private Attributes
std::unique_ptr< ServerCompletionQueue >	cq_
grpc_core::Mutex	cq_shutdown_mu_
DefaultHealthCheckService *	database_
std::atomic_bool	shutdown_ {false}
std::unique_ptr< grpc_core::Thread >	thread_

Additional Inherited Members
Protected Member Functions inherited from grpc::Service
void	AddMethod (internal::RpcServiceMethod *method)
internal::MethodHandler *	GetHandler (int index)
void	MarkMethodAsync (int index)
void	MarkMethodCallback (int index, internal::MethodHandler *handler)
void	MarkMethodGeneric (int index)
void	MarkMethodRaw (int index)
void	MarkMethodRawCallback (int index, internal::MethodHandler *handler)
void	MarkMethodStreamed (int index, internal::MethodHandler *streamed_method)
void	RequestAsyncBidiStreaming (int index, grpc::ServerContext *context, internal::ServerAsyncStreamingInterface *stream, grpc::CompletionQueue *call_cq, grpc::ServerCompletionQueue *notification_cq, void *tag)
void	RequestAsyncClientStreaming (int index, grpc::ServerContext *context, internal::ServerAsyncStreamingInterface *stream, grpc::CompletionQueue *call_cq, grpc::ServerCompletionQueue *notification_cq, void *tag)
template<class Message >
void	RequestAsyncServerStreaming (int index, grpc::ServerContext *context, Message *request, internal::ServerAsyncStreamingInterface *stream, grpc::CompletionQueue *call_cq, grpc::ServerCompletionQueue *notification_cq, void *tag)
template<class Message >
void	RequestAsyncUnary (int index, grpc::ServerContext *context, Message *request, internal::ServerAsyncStreamingInterface *stream, grpc::CompletionQueue *call_cq, grpc::ServerCompletionQueue *notification_cq, void *tag)

Detailed Description

Definition at line 53 of file default_health_check_service.h.

Constructor & Destructor Documentation

HealthCheckServiceImpl()

grpc::DefaultHealthCheckService::HealthCheckServiceImpl::HealthCheckServiceImpl	(	DefaultHealthCheckService *	database,
		std::unique_ptr< ServerCompletionQueue >	cq
	)

Definition at line 159 of file default_health_check_service.cc.

~HealthCheckServiceImpl()

grpc::DefaultHealthCheckService::HealthCheckServiceImpl::~HealthCheckServiceImpl ( )

override

Definition at line 174 of file default_health_check_service.cc.

Member Function Documentation

DecodeRequest()

bool grpc::DefaultHealthCheckService::HealthCheckServiceImpl::DecodeRequest ( const ByteBuffer &  request, std::string *  service_name  )

staticprivate

Definition at line 209 of file default_health_check_service.cc.

EncodeResponse()

bool grpc::DefaultHealthCheckService::HealthCheckServiceImpl::EncodeResponse ( ServingStatus  status, ByteBuffer *  response  )

staticprivate

Definition at line 233 of file default_health_check_service.cc.

RequestAsyncServerStreaming()

template<class Message >

void grpc::Service::RequestAsyncServerStreaming ( class Message  )

inlineprivate

Definition at line 128 of file grpcpp/impl/codegen/service_type.h.

RequestAsyncUnary()

template<class Message >

void grpc::Service::RequestAsyncUnary ( class Message  )

inlineprivate

Definition at line 105 of file grpcpp/impl/codegen/service_type.h.

Serve()

void grpc::DefaultHealthCheckService::HealthCheckServiceImpl::Serve ( void *  arg )

staticprivate

Definition at line 194 of file default_health_check_service.cc.

StartServingThread()

void grpc::DefaultHealthCheckService::HealthCheckServiceImpl::StartServingThread

(

)

Definition at line 184 of file default_health_check_service.cc.

Member Data Documentation

cq_

std::unique_ptr<ServerCompletionQueue> grpc::DefaultHealthCheckService::HealthCheckServiceImpl::cq_

private

Definition at line 233 of file default_health_check_service.h.

cq_shutdown_mu_

grpc_core::Mutex grpc::DefaultHealthCheckService::HealthCheckServiceImpl::cq_shutdown_mu_

private

Definition at line 237 of file default_health_check_service.h.

database_

DefaultHealthCheckService* grpc::DefaultHealthCheckService::HealthCheckServiceImpl::database_

private

Definition at line 232 of file default_health_check_service.h.

shutdown_

std::atomic_bool grpc::DefaultHealthCheckService::HealthCheckServiceImpl::shutdown_ {false}

private

Definition at line 238 of file default_health_check_service.h.

thread_

std::unique_ptr<grpc_core::Thread> grpc::DefaultHealthCheckService::HealthCheckServiceImpl::thread_

private

Definition at line 239 of file default_health_check_service.h.

---

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

• default_health_check_service.h
• default_health_check_service.cc