func()

in pkg/discovery/content/reader/reader.go [79:98]


func (r *reader) FstatRemote() (int64, error) {
	key := r.context.GetString(pcontext.FileChunkCtxKey)
	start := int64(0)
	end := int64(0)

	log := r.Log().With().Str("operation", "fstatremote").Int64("start", start).Int64("end", end).Str("key", key).Logger()

	startTime := time.Now()
	originReq, err := r.originRequest(start, end)
	if err != nil {
		return -1, err
	}

	var count int64
	defer func() {
		r.metricsRecorder.RecordUpstreamResponse(originReq.URL.Hostname(), key, "fstat", time.Since(startTime).Seconds(), count)
	}()
	count, err = r.fstatRemote(log, originReq, r.defaultHttpClient)
	return count, err
}