gRPC  0.6.0
 All Classes Namespaces Functions Variables Enumerations Properties Pages
Public Types | Public Member Functions | Static Public Member Functions | Friends | List of all members
grpc::GRPC_FINAL< R > Class Template Reference
Inheritance diagram for grpc::GRPC_FINAL< R >:
grpc::Credentials grpc::ChannelInterface grpc::GrpcLibrary grpc::Credentials grpc::ServerCredentials grpc::CompletionQueueTag grpc::CompletionQueueTag grpc::CallOpBuffer grpc::ThreadPoolInterface grpc::ServerContext grpc::ClientAsyncResponseReaderInterface< R > grpc::ServerAsyncStreamingInterface grpc::CallOpBuffer grpc::AsynchronousService::DispatchImpl grpc::CallHook grpc::GrpcLibrary grpc::ClientReaderInterface< R > grpc::ClientWriterInterface< W > grpc::ClientReaderWriterInterface< W, R > grpc::ReaderInterface< R > grpc::WriterInterface< W > grpc::ReaderInterface< R > grpc::WriterInterface< W > grpc::ClientAsyncReaderInterface< R > grpc::ClientAsyncWriterInterface< W > grpc::ClientAsyncReaderWriterInterface< W, R > grpc::AsyncReaderInterface< R > grpc::ServerAsyncStreamingInterface grpc::AsyncWriterInterface< W > grpc::ServerAsyncStreamingInterface grpc::AsyncReaderInterface< R > grpc::AsyncWriterInterface< W > grpc::ServerAsyncStreamingInterface grpc::ServerCredentials

Public Types

enum  AddRef { ADD_REF }
 
enum  StealRef { STEAL_REF }
 

Public Member Functions

 Channel (const grpc::string &target, grpc_channel *c_channel)
 
virtual void * RegisterMethod (const char *method) GRPC_OVERRIDE
 
virtual Call CreateCall (const RpcMethod &method, ClientContext *context, CompletionQueue *cq) GRPC_OVERRIDE
 
virtual void PerformOpsOnCall (CallOpBuffer *ops, Call *call) GRPC_OVERRIDE
 
 SecureCredentials (grpc_credentials *c_creds)
 
grpc_credentialsGetRawCreds ()
 
bool ApplyToCall (grpc_call *call) GRPC_OVERRIDE
 
std::shared_ptr
< grpc::ChannelInterface
CreateChannel (const string &target, const grpc::ChannelArguments &args) GRPC_OVERRIDE
 
SecureCredentials * AsSecureCredentials () GRPC_OVERRIDE
 
 SecureServerCredentials (grpc_server_credentials *creds)
 
int AddPortToServer (const grpc::string &addr, grpc_server *server) GRPC_OVERRIDE
 
 SyncRequest (RpcServiceMethod *method, void *tag)
 
void Request (grpc_server *server, grpc_completion_queue *notify_cq)
 
bool FinalizeResult (void **tag, bool *status) GRPC_OVERRIDE
 
 AsyncRequest (Server *server, void *registered_method, ServerContext *ctx, grpc::protobuf::Message *request, ServerAsyncStreamingInterface *stream, CompletionQueue *call_cq, ServerCompletionQueue *notification_cq, void *tag)
 
 AsyncRequest (Server *server, GenericServerContext *ctx, ServerAsyncStreamingInterface *stream, CompletionQueue *call_cq, ServerCompletionQueue *notification_cq, void *tag)
 
bool FinalizeResult (void **tag, bool *status) GRPC_OVERRIDE
 
 CompletionOp ()
 
bool FinalizeResult (void **tag, bool *status) GRPC_OVERRIDE
 
bool CheckCancelled (CompletionQueue *cq)
 
void Unref ()
 
 ThreadPool (int num_threads)
 
void ScheduleCallback (const std::function< void()> &callback) GRPC_OVERRIDE
 
const grpc::string & method () const
 
const grpc::string & host () const
 
 AsyncGenericService (const grpc::string &methods)
 
void RequestCall (GenericServerContext *ctx, GenericServerAsyncReaderWriter *reader_writer, CompletionQueue *call_cq, ServerCompletionQueue *notification_cq, void *tag)
 
 ClientAsyncResponseReader (ChannelInterface *channel, CompletionQueue *cq, const RpcMethod &method, ClientContext *context, const grpc::protobuf::Message &request)
 
void ReadInitialMetadata (void *tag)
 
void Finish (R *msg, Status *status, void *tag)
 
 ServerAsyncResponseWriter (ServerContext *ctx)
 
void SendInitialMetadata (void *tag) GRPC_OVERRIDE
 
void Finish (const W &msg, const Status &status, void *tag)
 
void FinishWithError (const Status &status, void *tag)
 
 ByteBuffer ()
 
 ByteBuffer (Slice *slices, size_t nslices)
 
void Dump (std::vector< Slice > *slices)
 
void Clear ()
 
size_t Length ()
 
 GenericStub (std::shared_ptr< ChannelInterface > channel)
 
std::unique_ptr
< GenericClientAsyncReaderWriter
Call (ClientContext *context, const grpc::string &method, CompletionQueue *cq, void *tag)
 
bool FinalizeResult (void **tag, bool *status) GRPC_OVERRIDE
 
 Call (grpc_call *call, CallHook *call_hook_, CompletionQueue *cq)
 
 Call (grpc_call *call, CallHook *call_hook_, CompletionQueue *cq, int max_message_size)
 
void PerformOps (CallOpBuffer *buffer)
 
grpc_callcall ()
 
CompletionQueuecq ()
 
int max_message_size ()
 
void Shutdown ()
 
void Wait ()
 
 Slice ()
 
 Slice (gpr_slice slice, AddRef)
 
 Slice (gpr_slice slice, StealRef)
 
 Slice (const Slice &other)
 
Slice & operator= (Slice other)
 
size_t size () const
 
const gpr_uint8 * begin () const
 
const gpr_uint8 * end () const
 
 ClientReader (ChannelInterface *channel, const RpcMethod &method, ClientContext *context, const grpc::protobuf::Message &request)
 
void WaitForInitialMetadata ()
 
bool Read (R *msg) GRPC_OVERRIDE
 
Status Finish () GRPC_OVERRIDE
 
 ClientWriter (ChannelInterface *channel, const RpcMethod &method, ClientContext *context, grpc::protobuf::Message *response)
 
bool Write (const W &msg) GRPC_OVERRIDE
 
bool WritesDone () GRPC_OVERRIDE
 
Status Finish () GRPC_OVERRIDE
 
 ClientReaderWriter (ChannelInterface *channel, const RpcMethod &method, ClientContext *context)
 
void WaitForInitialMetadata ()
 
bool Read (R *msg) GRPC_OVERRIDE
 
bool Write (const W &msg) GRPC_OVERRIDE
 
bool WritesDone () GRPC_OVERRIDE
 
Status Finish () GRPC_OVERRIDE
 
 ServerReader (Call *call, ServerContext *ctx)
 
void SendInitialMetadata ()
 
bool Read (R *msg) GRPC_OVERRIDE
 
 ServerWriter (Call *call, ServerContext *ctx)
 
void SendInitialMetadata ()
 
bool Write (const W &msg) GRPC_OVERRIDE
 
 ServerReaderWriter (Call *call, ServerContext *ctx)
 
void SendInitialMetadata ()
 
bool Read (R *msg) GRPC_OVERRIDE
 
bool Write (const W &msg) GRPC_OVERRIDE
 
 ClientAsyncReader (ChannelInterface *channel, CompletionQueue *cq, const RpcMethod &method, ClientContext *context, const grpc::protobuf::Message &request, void *tag)
 
void ReadInitialMetadata (void *tag) GRPC_OVERRIDE
 
void Read (R *msg, void *tag) GRPC_OVERRIDE
 
void Finish (Status *status, void *tag) GRPC_OVERRIDE
 
 ClientAsyncWriter (ChannelInterface *channel, CompletionQueue *cq, const RpcMethod &method, ClientContext *context, grpc::protobuf::Message *response, void *tag)
 
void ReadInitialMetadata (void *tag) GRPC_OVERRIDE
 
void Write (const W &msg, void *tag) GRPC_OVERRIDE
 
void WritesDone (void *tag) GRPC_OVERRIDE
 
void Finish (Status *status, void *tag) GRPC_OVERRIDE
 
 ClientAsyncReaderWriter (ChannelInterface *channel, CompletionQueue *cq, const RpcMethod &method, ClientContext *context, void *tag)
 
void ReadInitialMetadata (void *tag) GRPC_OVERRIDE
 
void Read (R *msg, void *tag) GRPC_OVERRIDE
 
void Write (const W &msg, void *tag) GRPC_OVERRIDE
 
void WritesDone (void *tag) GRPC_OVERRIDE
 
void Finish (Status *status, void *tag) GRPC_OVERRIDE
 
 ServerAsyncReader (ServerContext *ctx)
 
void SendInitialMetadata (void *tag) GRPC_OVERRIDE
 
void Read (R *msg, void *tag) GRPC_OVERRIDE
 
void Finish (const W &msg, const Status &status, void *tag)
 
void FinishWithError (const Status &status, void *tag)
 
 ServerAsyncWriter (ServerContext *ctx)
 
void SendInitialMetadata (void *tag) GRPC_OVERRIDE
 
void Write (const W &msg, void *tag) GRPC_OVERRIDE
 
void Finish (const Status &status, void *tag)
 
 ServerAsyncReaderWriter (ServerContext *ctx)
 
void SendInitialMetadata (void *tag) GRPC_OVERRIDE
 
void Read (R *msg, void *tag) GRPC_OVERRIDE
 
void Write (const W &msg, void *tag) GRPC_OVERRIDE
 
void Finish (const Status &status, void *tag)
 
- Public Member Functions inherited from grpc::CallOpBuffer
void Reset (void *next_return_tag)
 
void AddSendInitialMetadata (std::multimap< grpc::string, grpc::string > *metadata)
 
void AddSendInitialMetadata (ClientContext *ctx)
 
void AddRecvInitialMetadata (ClientContext *ctx)
 
void AddSendMessage (const grpc::protobuf::Message &message)
 
void AddSendMessage (const ByteBuffer &message)
 
void AddRecvMessage (grpc::protobuf::Message *message)
 
void AddRecvMessage (ByteBuffer *message)
 
void AddClientSendClose ()
 
void AddClientRecvStatus (ClientContext *ctx, Status *status)
 
void AddServerSendStatus (std::multimap< grpc::string, grpc::string > *metadata, const Status &status)
 
void AddServerRecvClose (bool *cancelled)
 
void FillOps (grpc_op *ops, size_t *nops)
 
void set_max_message_size (int max_message_size)
 
- Public Member Functions inherited from grpc::ServerContext
std::chrono::system_clock::time_point deadline ()
 
gpr_timespec raw_deadline ()
 
void AddInitialMetadata (const grpc::string &key, const grpc::string &value)
 
void AddTrailingMetadata (const grpc::string &key, const grpc::string &value)
 
bool IsCancelled ()
 
const std::multimap
< grpc::string, grpc::string > & 
client_metadata ()
 

Static Public Member Functions

static SyncRequest * Wait (CompletionQueue *cq, bool *ok)
 

Friends

class Server
 
class CallOpBuffer
 
class AsyncGenericService
 
class ServerBuilder
 
class ByteBuffer
 

Additional Inherited Members

- Public Attributes inherited from grpc::CallOpBuffer
bool got_message
 

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