SoulLogger/com.lestere.opensource.aggregation/LocalLogAggregator

LocalLogAggregator

class LocalLogAggregator(logDirectory: String = "logs", maxMemoryEntries: Int)(source)

Constructors

constructor(logDirectory: String = "logs", maxMemoryEntries: Int)

Types

data class AggregatorStats(val totalProcessed: Long = 0, val indexSize: Int = 0, val errorCount: Long = 0, val lastUpdate: Instant = Clock.System.now())

Properties

isRunning

val isRunning: StateFlow<Boolean>

newLogs

val newLogs: SharedFlow<Logger>

stats

val stats: StateFlow<LocalLogAggregator.AggregatorStats>

Functions

aggregate

fun aggregate(request: AggregationRequest): AggregationResult

clear

fun clear()

getErrorRateByHour

fun getErrorRateByHour(hours: Int = 24): Map<String, Double>

getErrors

fun getErrors(): List<Logger>

getStatistics

fun getStatistics(): StatisticsResponse

getTopEntries

fun getTopEntries(limit: Int = 10): List<Pair<String, Int>>

index

fun index(logger: Logger)

fun search(query: String): List<Logger>

searchLogs

fun searchLogs(level: SoulLogger.Level? = null, entry: String? = null, startTime: Instant? = null, endTime: Instant? = null, limit: Int = 100): List<Logger>

start

fun start()

stop

fun stop()