Method getDataStatistic

edrav2/iprj/libcore/src/queue.cpp:386–420

//
//
Variant Queue::getDataStatistic(std::string sIndex)
{
	std::map<std::string, Size> stat;
	Size nSkipped = 0;
	{
		std::scoped_lock sync(m_mtxData);
		for (auto& v : m_data)
		{
			auto optData = variant::getByPathSafe(v, sIndex);
			if (optData.has_value())
			{
				try 
				{
					stat[variant::convert<variant::ValueType::String>(optData.value())]++;
				}
				catch (error::TypeError&)
				{
					nSkipped++;
				}
			}
			else
				nSkipped++;
		}
	}

	Dictionary vItems;
	for (auto&[name, val] : stat)
		vItems.put(name, val);

	Dictionary vData;
	vData.put("items", vItems);
	vData.put("skipped", nSkipped);

	return vData;
}

//
//