CreateEntities streams and creates entities from the given Redis field value pairs using the specified factory function, and streams them on a returned channel.

NewHeartbeat returns a new Heartbeat and starts the heartbeat controller loop.

SetChecksums concurrently streams from the given entities and sets their checksums using the specified map and streams the results on a returned channel.

YieldAll yields all entities from Redis that belong to the specified SyncSubject.

Timeout defines how long a heartbeat may be absent if a heartbeat has already been received.

Heartbeat periodically reads heartbeats from a Redis stream and signals in Beat channels when they are received.

HeartbeatMessage represents a heartbeat received from Icinga 2 together with a timestamp when it was received.