TcpSink

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

Constructors

constructor(host: String, port: Int, batchSize: Int = 100, flushIntervalMs: Long = 5000, connectionTimeoutMs: Int = 5000)

open override fun close()

open override fun isConnected(): Boolean

open suspend override fun send(log: Logger): Result<Unit>

open suspend override fun sendBatch(logs: List<Logger>): Result<Int>