func()

in pipeline/endpoints/disk.go [143:154]

• 11 lines of code
• 4 McCabe index (conditional complexity)

func (ep *DiskEndpoint) cleanup() {
	// compute time before which files are expired.
	cutoff := ep.clock.Now().Add(-ep.expiration)
	files, _ := ioutil.ReadDir(ep.path)
	for _, f := range files {
		if isExpired(f.Name(), cutoff) {
			if err := os.Remove(filepath.Join(ep.path, f.Name())); err != nil {
				glog.Warningf("error removing expired disk report: %v", f)
			}
		}
	}
}