Data Archivers

All archivers share the same base class, HERODataArchiver. It subscribes to a named event on a HERO object, places each incoming (payload, metadata) pair on an internal queue, and processes that queue in a background thread. Failed store attempts are retried up to max_retries times before the item is dropped and an error is logged.

Two families of archiver are provided: