GetOutboundIP get preferred outbound ip of this machine https://stackoverflow.com/questions/23558425/how-do-i-get-the-local-ip-address-in-go.

GetShift returns the smallest `shift` which 1<<shift is no smaller than s.

GetSourceName returns the field name in message for the given ClickHouse column.

GetSpareTCPPort finds a spare TCP port.

InitGlobalParsingPool initialize GlobalParsingPool.

InitGlobalTimerWheel initialize the global timer wheel.

InitGlobalWritingPool initialize GlobalWritingPool.

JksToPem converts JKS to PEM Refers to: https://serverfault.com/questions/715827/how-to-generate-key-and-crt-file-from-jks-file-for-httpd-apache-server.

Refers to: https://medium.com/processone/using-tls-authentication-for-your-go-kafka-client-3c5841f2a625 https://github.com/denji/golang-tls https://www.baeldung.com/java-keystore-truststore-difference.

New creates and starts a pool of worker goroutines.

StringContains check if contains string in array.

ErrStopped when stopped.

for all tasks' parsing, cpu intensive.

the global timer wheel.

the all tasks' writing ClickHouse, cpu-net balance.

WorkerPool is a blocked worker pool inspired by https://github.com/gammazero/workerpool/.