PureeLogStore

Stores the buffered logs for batched emissions. Implementations of this interface are guaranteed to be thread-safe (called from a single thread).

Functions

add

abstract fun add(outputId: String, bufferedLog: PureeBufferedLog)

Adds a new PureeBufferedLog to the store.

get

abstract fun get(outputId: String, maxCount: Int): List<PureeBufferedLog>

Retrieves the logs from the store.

purgeLogsWithAge

abstract fun purgeLogsWithAge(outputId: String, now: Instant, age: Duration)

Deletes all the logs according the age of the log.

remove

abstract fun remove(outputId: String, bufferedLogs: List<PureeBufferedLog>)

Deletes the logs from the store.

DbPureeLogStore