(c *cache)
| 1074 | } |
| 1075 | |
| 1076 | func (j *janitor) Run(c *cache) { |
| 1077 | ticker := time.NewTicker(j.Interval) |
| 1078 | for { |
| 1079 | select { |
| 1080 | case <-ticker.C: |
| 1081 | c.DeleteExpired() |
| 1082 | case <-j.stop: |
| 1083 | ticker.Stop() |
| 1084 | return |
| 1085 | } |
| 1086 | } |
| 1087 | } |
| 1088 | |
| 1089 | func stopJanitor(c *Cache) { |
| 1090 | c.janitor.stop <- true |
no test coverage detected