(dbID proto.DatabaseID, method string, request interface{}, response interface{})
| 358 | } |
| 359 | |
| 360 | func (s *Service) minerRequest(dbID proto.DatabaseID, method string, request interface{}, response interface{}) (err error) { |
| 361 | instance, err := s.getUpstream(dbID) |
| 362 | if err != nil { |
| 363 | return |
| 364 | } |
| 365 | |
| 366 | return s.caller.CallNode(instance.Peers.Leader, method, request, response) |
| 367 | } |
| 368 | |
| 369 | func (s *Service) getUpstream(dbID proto.DatabaseID) (instance *types.ServiceInstance, err error) { |
| 370 | log.WithField("db", dbID).Debug("get peers info for database") |
no test coverage detected