Method UpdateState

lib/icingadb/icingadb-objects.cpp:1327–1359

* Update the state information of a checkable in Redis. * * What is updated exactly depends on the mode parameter: * - VolatileState: Update the volatile state information stored in icinga:host:state or icinga:service:state as well * as the corresponding checksum stored in icinga:checksum:host:state or icinga:checksum:service:state. * - RuntimeState: Write a runtime update to the icinga:

 * @param mode Mode of operation (DirtyBits:VolatileState, DirtyBits::RuntimeState, or DirtyBits::FullState)
 */
void IcingaDB::UpdateState(const Checkable::Ptr& checkable, uint32_t mode)
{
	Dictionary::Ptr stateAttrs = SerializeState(checkable);

	String checksum = HashValue(stateAttrs);

	auto [redisStateKey, redisChecksumKey] = GetCheckableStateKeys(checkable->GetReflectionType());
	if (mode & icingadb::task_queue::VolatileState) {
		String objectKey = GetObjectIdentifier(checkable);
		m_RconWorker->FireAndForgetQueries({
			{"HSET", redisStateKey, objectKey, JsonEncode(stateAttrs)},
			{"HSET", redisChecksumKey, objectKey, JsonEncode(new Dictionary({{"checksum", checksum}}))},
		});
	}

	if (mode & icingadb::task_queue::RuntimeState) {
		ObjectLock olock(stateAttrs);

		RedisConnection::Query streamadd({
			"XADD", "icinga:runtime:state", "MAXLEN", "~", "1000000", "*",
			"runtime_type", "upsert",
			"redis_key", redisStateKey,
			"checksum", checksum,
		});

		for (const Dictionary::Pair& kv : stateAttrs) {
			streamadd.emplace_back(kv.first);
			streamadd.emplace_back(IcingaToStreamValue(kv.second));
		}

		m_RconWorker->FireAndForgetQuery(std::move(streamadd), {0, 1});
	}
}

/**
 * Update the dependency state information of the given checkable and its associated dependency groups in Redis.