func isExpired()

in pipeline/endpoints/disk.go [166:183]


func isExpired(name string, cutoff time.Time) bool {
	if !strings.HasPrefix(name, reportPrefix) {
		return false
	}
	if !strings.HasSuffix(name, reportSuffix) {
		return false
	}

	parts := strings.Split(name, "_")
	if len(parts) != 3 {
		return false
	}
	t, err := time.Parse(time.RFC3339, parts[1])
	if err != nil {
		return false
	}
	return t.Before(cutoff)
}