Add comment to deleteWorker()
This commit is contained in:
parent
8ac5bf7cd5
commit
c2e50f59d4
|
@ -77,6 +77,8 @@ func (db *DB) Close() {
|
||||||
db.wg.Wait()
|
db.wg.Wait()
|
||||||
db.client.Close()
|
db.client.Close()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// prunes node-specific data periodically
|
||||||
func (db *DB) deleteWorker() {
|
func (db *DB) deleteWorker() {
|
||||||
duration := time.Minute * time.Duration(db.config.Influxdb.DeleteInterval)
|
duration := time.Minute * time.Duration(db.config.Influxdb.DeleteInterval)
|
||||||
ticker := time.NewTicker(duration)
|
ticker := time.NewTicker(duration)
|
||||||
|
|
Loading…
Reference in New Issue