Query mocks DBS.Query for mirrored database.
(req *types.Request, res *types.Response)
| 238 | |
| 239 | // Query mocks DBS.Query for mirrored database. |
| 240 | func (s *Service) Query(req *types.Request, res *types.Response) (err error) { |
| 241 | if req.Header.QueryType != types.ReadQuery { |
| 242 | // only read query is supported |
| 243 | err = ErrNotReadQuery |
| 244 | return |
| 245 | } |
| 246 | |
| 247 | if req.Header.DatabaseID != s.dbID { |
| 248 | // database instance not matched |
| 249 | err = worker.ErrNotExists |
| 250 | return |
| 251 | } |
| 252 | |
| 253 | var r *types.Response |
| 254 | if _, r, err = s.st.Query(req, false); err != nil { |
| 255 | return |
| 256 | } |
| 257 | *res = *r |
| 258 | return |
| 259 | } |
| 260 | |
| 261 | // Ack mocks DBS.Ack for mirrored database. |
| 262 | func (s *Service) Ack(ack *types.Ack, _ *types.AckResponse) (err error) { |