Sink
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())(source)
Constructors
Link copied to clipboard
constructor(type: SinkType = SinkType.HTTP, endpoint: String = "http://localhost:8080/logs", host: String = "localhost", port: Int = 5140, batchSize: Int = 100, flushIntervalMs: Long = 5000, retryCount: Int = 3, connectionTimeoutMs: Int = 5000, readTimeoutMs: Int = 30000, fallbackEndpoints: List<String> = emptyList())