Method recuseLogs

log-driver/loki/loki.go:247–280

(queries url.Values, end time.Time, offset int64)

}

func (d *Driver) recuseLogs(queries url.Values, end time.Time, offset int64) ([]*log_driver.LogItem, error) {
	queries.Set("end", strconv.FormatInt(end.UnixNano(), 10))
	list, err := send[LogInfo](http.MethodGet, fmt.Sprintf("%s/loki/api/v1/query_range", d.url), d.headers, queries, "")
	if err != nil {
		return nil, err
	}
	if len(list) < 1 {
		return nil, nil
	}
	if offset > 1 {
		// 获取list最后一个元素的时间戳
		last := list[len(list)-1].Stream
		if last == nil {
			return nil, fmt.Errorf("last log is empty")
		}
		msec, err := strconv.ParseInt(last.Msec, 10, 64)
		if err != nil {
			return nil, fmt.Errorf("parse last log time error: %v", err)
		}
		return d.recuseLogs(queries, time.UnixMilli(msec), offset-1)
	}
	logs := make([]*log_driver.LogItem, 0, len(list))
	for _, l := range list {
		if l.Stream == nil {
			continue
		}
		msec, _ := strconv.ParseInt(l.Stream.Msec, 10, 64)
		logs = append(logs, ToLogItem(l.Stream, msec))
	}
	sort.Slice(logs, func(i, j int) bool {
		return logs[i].RecordTime.After(logs[j].RecordTime)
	})
	return logs, nil
}

func parseToInt64(v interface{}) int64 {
	switch t := v.(type) {