kcenon::network::protocols::grpc::grpc_server Class Reference

gRPC server for handling RPC requests More...

#include <server.h>

Collaboration diagram for kcenon::network::protocols::grpc::grpc_server:

Classes
class	impl

Public Member Functions
	grpc_server (const grpc_server_config &config={})
	Construct gRPC server.
	~grpc_server ()
	Destructor.
	grpc_server (const grpc_server &)=delete
grpc_server &	operator= (const grpc_server &)=delete
	grpc_server (grpc_server &&) noexcept
grpc_server &	operator= (grpc_server &&) noexcept
auto	start (uint16_t port) -> VoidResult
	Start the server on specified port.
auto	start_tls (uint16_t port, const std::string &cert_path, const std::string &key_path, const std::string &ca_path="") -> VoidResult
	Start the server with TLS.
auto	stop () -> void
	Stop the server.
auto	wait () -> void
	Wait for server to finish (blocks)
auto	is_running () const -> bool
	Check if server is running.
auto	port () const -> uint16_t
	Get the port the server is listening on.
auto	register_service (grpc_service *service) -> VoidResult
	Register a service.
auto	register_unary_method (const std::string &full_method_name, unary_handler handler) -> VoidResult
	Register a unary RPC method handler.
auto	register_server_streaming_method (const std::string &full_method_name, server_streaming_handler handler) -> VoidResult
	Register a server streaming RPC method handler.
auto	register_client_streaming_method (const std::string &full_method_name, client_streaming_handler handler) -> VoidResult
	Register a client streaming RPC method handler.
auto	register_bidi_streaming_method (const std::string &full_method_name, bidi_streaming_handler handler) -> VoidResult
	Register a bidirectional streaming RPC method handler.

Private Attributes
std::unique_ptr< impl >	impl_

Detailed Description

gRPC server for handling RPC requests

This class provides a server for handling gRPC requests over HTTP/2 transport.

Note

This is a prototype implementation. For production use, consider wrapping the official gRPC library.

Example usage:

grpc_server server;
 
server.register_unary_method("/package.Service/Method",
    [](server_context& ctx, const std::vector<uint8_t>& request)
        -> std::pair<grpc_status, std::vector<uint8_t>> {
        // Handle request
        return {grpc_status::ok_status(), response_data};
    });
 
server.start(50051);
server.wait();

Examples

grpc_service_example.cpp.

Definition at line 272 of file server.h.

Constructor & Destructor Documentation

grpc_server() [1/3]

kcenon::network::protocols::grpc::grpc_server::grpc_server ( const grpc_server_config & config = {} )

explicit

Construct gRPC server.

Parameters

config

Server configuration

Definition at line 929 of file server.cpp.

    : impl_(std::make_unique<impl>(config))
{
}

References config.

~grpc_server()

kcenon::network::protocols::grpc::grpc_server::~grpc_server ( )

default

Destructor.

grpc_server() [2/3]

kcenon::network::protocols::grpc::grpc_server::grpc_server ( const grpc_server & )

delete

grpc_server() [3/3]

kcenon::network::protocols::grpc::grpc_server::grpc_server ( grpc_server && )

defaultnoexcept

Member Function Documentation

is_running()

auto kcenon::network::protocols::grpc::grpc_server::is_running

(

)

const -> bool

Check if server is running.

Returns

True if running

Definition at line 962 of file server.cpp.

{
    return impl_->is_running();
}

References impl_, and kcenon::network::protocols::grpc::grpc_server::impl::is_running().

Here is the call graph for this function:

operator=() [1/2]

grpc_server & kcenon::network::protocols::grpc::grpc_server::operator= ( const grpc_server & )

delete

operator=() [2/2]

grpc_server & kcenon::network::protocols::grpc::grpc_server::operator= ( grpc_server && )

defaultnoexcept

port()

auto kcenon::network::protocols::grpc::grpc_server::port

(

)

const -> uint16_t

Get the port the server is listening on.

Returns

Port number, or 0 if not running

Definition at line 967 of file server.cpp.

{
    return impl_->port();
}

References impl_, and kcenon::network::protocols::grpc::grpc_server::impl::port().

Here is the call graph for this function:

register_bidi_streaming_method()

auto kcenon::network::protocols::grpc::grpc_server::register_bidi_streaming_method	(	const std::string &	full_method_name,
		bidi_streaming_handler	handler ) -> VoidResult

Register a bidirectional streaming RPC method handler.

Parameters

full_method_name	Full method name
handler	Handler function

Returns

Success or error

Definition at line 995 of file server.cpp.

{
    return impl_->register_bidi_streaming_method(full_method_name, std::move(handler));
}

register_client_streaming_method()

auto kcenon::network::protocols::grpc::grpc_server::register_client_streaming_method	(	const std::string &	full_method_name,
		client_streaming_handler	handler ) -> VoidResult

Register a client streaming RPC method handler.

Parameters

full_method_name	Full method name
handler	Handler function

Returns

Success or error

Definition at line 989 of file server.cpp.

{
    return impl_->register_client_streaming_method(full_method_name, std::move(handler));
}

register_server_streaming_method()

auto kcenon::network::protocols::grpc::grpc_server::register_server_streaming_method	(	const std::string &	full_method_name,
		server_streaming_handler	handler ) -> VoidResult

Register a server streaming RPC method handler.

Parameters

full_method_name	Full method name
handler	Handler function

Returns

Success or error

Definition at line 983 of file server.cpp.

{
    return impl_->register_server_streaming_method(full_method_name, std::move(handler));
}

register_service()

auto kcenon::network::protocols::grpc::grpc_server::register_service

(

grpc_service *

service

)

-> VoidResult

Register a service.

Parameters

service

Service to register

Returns

Success or error

Definition at line 972 of file server.cpp.

{
    return impl_->register_service(service);
}

register_unary_method()

auto kcenon::network::protocols::grpc::grpc_server::register_unary_method	(	const std::string &	full_method_name,
		unary_handler	handler ) -> VoidResult

Register a unary RPC method handler.

Parameters

full_method_name	Full method name (e.g., "/package.Service/Method")
handler	Handler function

Returns

Success or error

Definition at line 977 of file server.cpp.

{
    return impl_->register_unary_method(full_method_name, std::move(handler));
}

start()

auto kcenon::network::protocols::grpc::grpc_server::start

(

uint16_t

port

)

-> VoidResult

Start the server on specified port.

Parameters

port	Port number to listen on

Returns

Success or error

Definition at line 939 of file server.cpp.

{
    return impl_->start(port);
}

start_tls()

auto kcenon::network::protocols::grpc::grpc_server::start_tls	(	uint16_t	port,
		const std::string &	cert_path,
		const std::string &	key_path,
		const std::string &	ca_path = "" ) -> VoidResult

Start the server with TLS.

Parameters

port	Port number to listen on
cert_path	Path to server certificate (PEM)
key_path	Path to server private key (PEM)
ca_path	Optional path to CA certificates for client auth

Returns

Success or error

Definition at line 944 of file server.cpp.

{
    return impl_->start_tls(port, cert_path, key_path, ca_path);
}

stop()

auto kcenon::network::protocols::grpc::grpc_server::stop

(

)

-> void

Stop the server.

Definition at line 952 of file server.cpp.

{
    impl_->stop();
}

wait()

auto kcenon::network::protocols::grpc::grpc_server::wait

(

)

-> void

Wait for server to finish (blocks)

Definition at line 957 of file server.cpp.

{
    impl_->wait();
}

Member Data Documentation

impl_

std::unique_ptr<impl> kcenon::network::protocols::grpc::grpc_server::impl_

private

Definition at line 381 of file server.h.

Referenced by is_running(), and port().

---

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

• include/kcenon/network/detail/protocols/grpc/server.h
• src/protocols/grpc/server.cpp