#include <transaction_constructor.h>
Public Member Functions | |
| TransactionConstructor (const ResDBConfig &config) | |
| virtual | ~TransactionConstructor ()=default |
| int | SendRequest (const google::protobuf::Message &message, Request::Type type=Request::TYPE_CLIENT_REQUEST) |
| int | SendRequest (const google::protobuf::Message &message, google::protobuf::Message *response, Request::Type type=Request::TYPE_CLIENT_REQUEST) |
Public Member Functions inherited from resdb::NetChannel | |
| NetChannel (const std::string &ip, int port) | |
| NetChannel (std::unique_ptr< Socket > socket, bool connected=false) | |
| virtual | ~NetChannel ()=default |
| void | Close () |
| void | SetSocket (std::unique_ptr< Socket > socket) |
| void | SetSignatureVerifier (SignatureVerifier *verifier) |
| void | SetDestReplicaInfo (const ReplicaInfo &replica) |
| virtual int | SendRequest (const google::protobuf::Message &message, Request::Type cmd, bool need_response=false) |
| virtual int | SendRawMessage (const google::protobuf::Message &message) |
| virtual int | SendRawMessageData (const std::string &message_str) |
| virtual int | RecvRawMessageStr (std::string *message) |
| virtual int | RecvRawMessage (google::protobuf::Message *message) |
| virtual int | RecvRawMessageData (std::string *message_str) |
| void | SetRecvTimeout (int microseconds) |
| void | IsLongConnection (bool long_connect_tion) |
| void | SetAsyncSend (bool is_async_send) |
Additional Inherited Members | |
Static Public Member Functions inherited from resdb::NetChannel | |
| static std::string | GetRawMessageString (const google::protobuf::Message &message, SignatureVerifier *verifier=nullptr) |
Protected Member Functions inherited from resdb::NetChannel | |
| int | SendDataInternal (const std::string &data) |
| int | SendFromKeepAlive (const std::string &data) |
| int | Send (const std::string &data) |
| int | Recv (std::string *data) |
| int | Connect () |
Protected Attributes inherited from resdb::NetChannel | |
| SignatureVerifier * | verifier_ = nullptr |
| std::unique_ptr< Socket > | socket_ |
| int | max_retry_time_ = 3 |
| std::string | ip_ |
| int | port_ |
| bool | connected_ = false |
| int | read_timeouts_ = 1000000 |
| bool | long_connect_tion_ = false |
| bool | long_connecting_ = false |
| bool | is_async_send_ = false |
Definition at line 30 of file transaction_constructor.h.
| resdb::TransactionConstructor::TransactionConstructor | ( | const ResDBConfig & | config | ) |
Definition at line 26 of file transaction_constructor.cpp.
|
virtualdefault |
| int resdb::TransactionConstructor::SendRequest | ( | const google::protobuf::Message & | message, |
| google::protobuf::Message * | response, | ||
| Request::Type | type = Request::TYPE_CLIENT_REQUEST |
||
| ) |
Definition at line 70 of file transaction_constructor.cpp.
| int resdb::TransactionConstructor::SendRequest | ( | const google::protobuf::Message & | message, |
| Request::Type | type = Request::TYPE_CLIENT_REQUEST |
||
| ) |
Definition at line 63 of file transaction_constructor.cpp.