All Classes

Class	Description
BatchCollector<T>	Collects elements in the stream and calls the supplied batch processor after the configured batch size is reached.
HBData	Heartbeat data collector bean
HBDataCacheQueue<T>	Heartbeat cache implementation - data is consumed in batches and after that evicted from the cache.
HBDataConsumer<T>	Process/consume operation for heartbeat data (see HBData).
HBDataSenderException	Heartbeat sending data exception
HBDataSenderJob	Simple Quartz job that executes a scheduled heartbeat data processing.
HBDataSenderService	Service dealing with sending collected data to the Heartbeat server.
HBDataSenderServiceBuilder	Data sender service builder.
HBDataSenderServiceImpl	Heartbeat Data Sender service implementation - collected data is sent to an ingestion endpoint (AWS).
HBSendDataScheduler	Schedule/start/stop the heartbeat sender job.
JsonUtil	JSON serialization/deserialization helper class, it uses a pre-configured object mapper, making it easier to control the format of the data being sent to the Heartbeat server.
StreamUtils