code: func (engine *DockerStatsEngine) resetStatsUnsafe() {
  	for _, containerMap := range engine.tasksToContainers {
  		for _, container := range containerMap {
  			container.statsQueue.Reset()
  		}
  	}
  }
docs: // resetStatsUnsafe resets stats for all watched containers.