CCF
Loading...
Searching...
No Matches
Namespaces | Typedefs | Functions
grpc.h File Reference
#include "ccf/endpoint_context.h"
#include "ccf/odata_error.h"
#include "message.h"
#include "node/rpc/rpc_exception.h"
#include "node/rpc_context_impl.h"
#include "stream.h"
#include "types.h"
#include <memory>

Go to the source code of this file.

Namespaces

namespace  ccf
 
namespace  ccf::grpc
 

Typedefs

template<typename In , typename Out >
using ccf::GrpcEndpoint = std::function< grpc::GrpcAdapterResponse< Out >(endpoints::EndpointContext &, In &&)>
 
template<typename In , typename Out >
using ccf::GrpcReadOnlyEndpoint = std::function< grpc::GrpcAdapterResponse< Out >(endpoints::ReadOnlyEndpointContext &, In &&)>
 
template<typename In , typename Out >
using ccf::GrpcCommandEndpoint = std::function< grpc::GrpcAdapterResponse< Out >(endpoints::CommandEndpointContext &, In &&)>
 
template<typename In , typename Out >
using ccf::GrpcCommandUnaryStreamEndpoint = std::function< grpc::GrpcAdapterStreamingResponse(endpoints::CommandEndpointContext &, In &&, grpc::StreamPtr< Out > &&)>
 

Functions

template<typename In >
In ccf::grpc::get_grpc_payload (const std::shared_ptr< ccf::RpcContext > &ctx)
 
void ccf::grpc::set_grpc_default_headers (const std::shared_ptr< ccf::RpcContext > &ctx)
 
void ccf::grpc::set_grpc_response_trailers (const std::shared_ptr< ccf::RpcContext > &ctx, const ccf::protobuf::Status &status)
 
template<typename Out >
void ccf::grpc::set_grpc_response (const GrpcAdapterResponse< Out > &r, const std::shared_ptr< ccf::RpcContext > &ctx)
 
template<typename In , typename Out >
endpoints::EndpointFunction ccf::grpc_adapter (const GrpcEndpoint< In, Out > &f)
 
template<typename In , typename Out >
endpoints::ReadOnlyEndpointFunction ccf::grpc_read_only_adapter (const GrpcReadOnlyEndpoint< In, Out > &f)
 
template<typename In , typename Out >
endpoints::CommandEndpointFunction ccf::grpc_command_adapter (const GrpcCommandEndpoint< In, Out > &f)
 
template<typename In , typename Out >
endpoints::CommandEndpointFunction ccf::grpc_command_unary_stream_adapter (const GrpcCommandUnaryStreamEndpoint< In, Out > &f)