KafkaBatcher.TempStorage (kafka_batcher v1.1.1)
Implements wrap-functions that are called to save batches when Kafka is unavailable.
Summary
Functions
@spec check_storage(KafkaBatcher.Collector.State.t()) :: KafkaBatcher.Collector.State.t()
@spec save_batch(KafkaBatcher.TempStorage.Batch.t()) :: :ok