PureeBufferedOutput

abstract class PureeBufferedOutput(uniqueId: String) : PureeOutput
Content copied to clipboard

The output that emits posted logs in batches.

Constructors

PureeBufferedOutput
Link copied to clipboard
fun PureeBufferedOutput(uniqueId: String)
Content copied to clipboard

Functions

emit
Link copied to clipboard
override fun emit(log: JSONObject)
Content copied to clipboard
Stores the log instead of emitting immediately
abstract fun emit(logs: List<JSONObject>, onSuccess: () -> Unit, onFailed: (Throwable) -> Unit)
Content copied to clipboard
Emits the logs.

Properties

exponentialBackoffBase
Link copied to clipboard
open val exponentialBackoffBase: Duration
Content copied to clipboard
The base duration to wait when retrying a failed batch.
flushInterval
Link copied to clipboard
open val flushInterval: Duration
Content copied to clipboard
The frequency interval when the buffer is flushed to be emitted in batches.
logsPerFlush
Link copied to clipboard
open val logsPerFlush: Int = 100
Content copied to clipboard
The maximum number of logs in a batch.
maxFlushSizeInBytes
Link copied to clipboard
open val maxFlushSizeInBytes: Long
Content copied to clipboard
If set, maximum number of bytes to include in a single flush
maxRetryCount
Link copied to clipboard
open val maxRetryCount: Int = 5
Content copied to clipboard
The number of times to retry a failed batch.
purgeableAge
Link copied to clipboard
open val purgeableAge: Duration? = null
Content copied to clipboard
If set to a non-null value, logs of this age will be not be processed and deleted.