INNER CODE UNIT · Go

main

otterize/network-mapper · src/kafka-watcher/cmd/main.go:32

func main() {
	logrus.SetLevel(logrus.InfoLevel)
	if viper.GetBool(sharedconfig.DebugKey) {
		logrus.SetLevel(logrus.DebugLevel)
	}
	logrus.SetFormatter(&logrus.JSONFormatter{
		TimestampFormat: time.RFC3339,
	})
	errgrp, errGroupCtx := errgroup.WithContext(signals.SetupSignalHandler())
	clusterUID := clusterutils.GetOrCreateClusterUID(errGroupCtx)
	componentinfo.SetGlobalContextId(telemetrysender.Anonymize(clusterUID))
	errorreporter.Init(telemetriesgql.TelemetryComponentTypeNetworkMapper, version.Version())
	defer errorreporter.AutoNotify()
	shared.RegisterPanicHandlers()

	ctrl.SetLogger(logrusr.New(logrus.StandardLogger()))

	mapperClient := mapperclient.New(viper.GetString(sharedconfig.MapperApiUrlKey))

View source record →