HttpSink

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

Constructors

Link copied to clipboard
constructor(endpoint: String, batchSize: Int = 100, flushIntervalMs: Long = 5000, retryCount: Int = 3, connectionTimeoutMs: Int = 5000, readTimeoutMs: Int = 30000)

Functions

Link copied to clipboard
open override fun close()
Link copied to clipboard
open override fun isConnected(): Boolean
Link copied to clipboard
open suspend override fun send(log: Logger): Result<Unit>
Link copied to clipboard
open suspend override fun sendBatch(logs: List<Logger>): Result<Int>