KafkaBatcher.Behaviours.TempStorage behaviour (kafka_batcher v1.1.1)

KafkaBatcher.Behaviours.TempStorage behaviour is used to implement events saving logic in case when Kafka is not available.

Summary

topic_name()

Check if the storage is empty

save_batch(t)

Save batch to retry

@type topic_name() :: String.t()

@callback empty?(topic_name()) :: boolean()

Check if the storage is empty

@callback save_batch(KafkaBatcher.TempStorage.Batch.t()) :: :ok

Save batch to retry