code: func (p *Postgres) RunCleaner(interval, expire time.Duration) {
  	cleanFunc := func() {
  		affectedRows, err := p.CleanExpiredRows(expire)
  		if err != nil {
  			p.Log.Warning("postgres: cleaning old rows failed: %s", err)
  		} else if affectedRows != 0 {
  			p.Log.Debug("postgres: cleaned up %d rows", affectedRows)
  		}
  	}
  
  	for range time.Tick(interval) {
  		cleanFunc()
  	}
  }
docs: // RunCleaner deletes every "interval" duration rows which are older than
  // "expire" duration based on the "updated_at" field. For more info check
  // CleanExpireRows which is used to delete old rows.