Method CheckResultHandler

lib/perfdata/graphitewriter.cpp:260–317

* Check result event handler, checks whether feature is not paused in HA setups. * * @param checkable Host/Service object * @param cr Check result including performance data */

 * @param cr Check result including performance data
 */
void GraphiteWriter::CheckResultHandler(const Checkable::Ptr& checkable, const CheckResult::Ptr& cr)
{
	if (IsPaused())
		return;

	if (!IcingaApplication::GetInstance()->GetEnablePerfdata() || !checkable->GetEnablePerfdata())
		return;

	Host::Ptr host;
	Service::Ptr service;
	tie(host, service) = GetHostService(checkable);

	MacroProcessor::ResolverList resolvers;
	if (service)
		resolvers.emplace_back("service", service);
	resolvers.emplace_back("host", host);

	String prefix;

	if (service) {
		prefix = MacroProcessor::ResolveMacros(GetServiceNameTemplate(), resolvers, cr, nullptr, [](const Value& value) -> Value {
			return EscapeMacroMetric(value);
		});
	} else {
		prefix = MacroProcessor::ResolveMacros(GetHostNameTemplate(), resolvers, cr, nullptr, [](const Value& value) -> Value {
			return EscapeMacroMetric(value);
		});
	}

	std::vector<std::pair<String, double>> metadata;
	if (GetEnableSendMetadata()) {
		metadata = {
			{"state", service ? static_cast<unsigned int>(service->GetState()) : static_cast<unsigned int>(host->GetState())},
			{"current_attempt", checkable->GetCheckAttempt()},
			{"max_check_attempts", checkable->GetMaxCheckAttempts()},
			{"state_type", checkable->GetStateType()},
			{"reachable", checkable->IsReachable()},
			{"downtime_depth", checkable->GetDowntimeDepth()},
			{"acknowledgement", checkable->GetAcknowledgement()},
			{"latency", cr->CalculateLatency()},
			{"execution_time", cr->CalculateExecutionTime()}
		};
	}

	m_WorkQueue.Enqueue([this, checkable, cr, prefix = std::move(prefix), metadata = std::move(metadata)]() {
		CONTEXT("Processing check result for '" << checkable->GetName() << "'");

		/* TODO: Deal with missing connection here. Needs refactoring
		* into parsing the actual performance data and then putting it
		* into a queue for re-inserting. */

		for (auto& [name, val] : metadata) {
			SendMetric(checkable, prefix + ".metadata", name, val, cr->GetExecutionEnd());
		}

		SendPerfdata(checkable, prefix + ".perfdata", cr);
	});
}