goland:noinspection GoUnusedExportedFunction.

GetDialer returns a net.DialContext function that uses a proxy if necessary.

GreaterOrEqualVersion returns true if a version is greater or equal to b.

NewCooldownQueue returns a new Cooldown Queue.

NewCronTicker returns a CronTicker struct.

PulsarMessageIDtoString is taken from github.com/kubescape/event-ingester-service/utils/common.go:func PulsarMessageIDtoString.

Direct is a direct proxy: one that makes network connections directly.

CooldownQueue is a queue that lets clients put events into it with a cooldown When a client puts an event into a queue, it waits for a cooldown period before the event is forwarded to the consumer.

CronTicker is the struct returned to the user as a proxy to the ticker.