Method Fetch

worker/dbms_mux.go:75–88

Fetch handles kayak fetch call.

(req *kt.FetchRequest, resp *kt.FetchResponse)

// Fetch handles kayak fetch call.
func (s *DBKayakMuxService) Fetch(req *kt.FetchRequest, resp *kt.FetchResponse) (err error) {
	id := proto.DatabaseID(req.Instance)

	if v, ok := s.serviceMap.Load(id); ok {
		var l *kt.Log
		if l, err = v.(*kayak.Runtime).Fetch(req.GetContext(), req.Index); err == nil {
			resp.Log = l
			resp.Instance = req.Instance
		}
		return
	}

	return errors.Wrapf(ErrUnknownMuxRequest, "instance %v", req.Instance)
}