NewDBMSRPCService returns new dbms rpc service endpoint.
( serviceName string, server *mux.Server, direct *rpc.Server, dbms *DBMS, )
| 52 | |
| 53 | // NewDBMSRPCService returns new dbms rpc service endpoint. |
| 54 | func NewDBMSRPCService( |
| 55 | serviceName string, server *mux.Server, direct *rpc.Server, dbms *DBMS, |
| 56 | ) ( |
| 57 | service *DBMSRPCService, |
| 58 | ) { |
| 59 | service = &DBMSRPCService{ |
| 60 | dbms: dbms, |
| 61 | } |
| 62 | server.RegisterService(serviceName, service) |
| 63 | if direct != nil { |
| 64 | direct.RegisterService(serviceName, service) |
| 65 | } |
| 66 | |
| 67 | dbQuerySuccCounter = metrics.NewMeter() |
| 68 | metrics.Register("db-query-succ", dbQuerySuccCounter) |
| 69 | dbQueryFailCounter = metrics.NewMeter() |
| 70 | metrics.Register("db-query-fail", dbQueryFailCounter) |
| 71 | |
| 72 | return |
| 73 | } |
| 74 | |
| 75 | // Query rpc, called by client to issue read/write query. |
| 76 | func (rpc *DBMSRPCService) Query(req *types.Request, res *types.Response) (err error) { |
no test coverage detected