SoulLogger/com.lestere.opensource.sink

Package-level declarations

Types

class FailoverSink(sinks: List<RemoteSink>) : RemoteSink

class HttpSink(endpoint: String, batchSize: Int = 100, flushIntervalMs: Long = 5000, retryCount: Int = 3, connectionTimeoutMs: Int = 5000, readTimeoutMs: Int = 30000) : RemoteSink

LogMessage

@Serializable

data class LogMessage(val version: String, val timestamp: String, val level: String, val thread: String, val entry: String, val command: String)

RemoteSink

interface RemoteSink

SinkConfig

data class SinkConfig(val type: SinkType = SinkType.HTTP, val endpoint: String = "http://localhost:8080/logs", val host: String = "localhost", val port: Int = 5140, val batchSize: Int = 100, val flushIntervalMs: Long = 5000, val retryCount: Int = 3, val connectionTimeoutMs: Int = 5000, val readTimeoutMs: Int = 30000, val fallbackEndpoints: List<String> = emptyList())

SinkType

enum SinkType : Enum<SinkType>

TcpSink

class TcpSink(host: String, port: Int, batchSize: Int = 100, flushIntervalMs: Long = 5000, connectionTimeoutMs: Int = 5000) : RemoteSink