Function main

packaging/tools/agent-events/server.go:444–593

main is the entry point of the application

()

// main is the entry point of the application
func main() {
	// Setup initial logger before flag parsing
	initialLogLevel := slog.LevelInfo
	initialLogHandler := slog.NewJSONHandler(os.Stderr, &slog.HandlerOptions{Level: initialLogLevel, AddSource: true})
	slog.SetDefault(slog.New(initialLogHandler))

	startTime = time.Now()

	// Define flags
	port := flag.Int("port", 8080, "Port to listen on")
	dedupSeconds := flag.Int("dedup-window", 1800, "Deduplication window in seconds")
	metricsPath := flag.String("metrics-path", "/metrics", "Path for OpenTelemetry Prometheus metrics endpoint")
	expvarPath := flag.String("expvar-path", "/debug/vars", "Path for expvar metrics endpoint (empty to disable)")
	healthPath := flag.String("health-path", "/healthz", "Path for health check endpoint")
	logFormat := flag.String("log-format", "json", "Log format: 'json' or 'text'")
	logLevelFlag := flag.String("log-level", "info", "Log level: 'debug', 'info', 'warn', 'error'")
	// Use the global dedupLogFile variable
	flag.StringVar(&dedupLogFile, "dedup-logfile", "", "File to log deduplicated requests (empty to disable)")
	flag.Var(&keyPaths, "dedup-key", "JSON path (dot-notation) for deduplication key (can be used multiple times)")
	flag.StringVar(&dedupSeparator, "dedup-separator", "-", "Separator used between multi-key values")
	flag.Parse()

	// Configure final logger based on flags
	var level slog.Level
	switch strings.ToLower(*logLevelFlag) {
	case "debug":
		level = slog.LevelDebug
	case "info":
		level = slog.LevelInfo
	case "warn":
		level = slog.LevelWarn
	case "error":
		level = slog.LevelError
	default:
		slog.Warn("invalid log level specified, defaulting to info", "value", *logLevelFlag)
		level = slog.LevelInfo
	}
	var logHandler slog.Handler
	if *logFormat == "text" {
		logHandler = slog.NewTextHandler(os.Stderr, &slog.HandlerOptions{Level: level, AddSource: true})
	} else {
		logHandler = slog.NewJSONHandler(os.Stderr, &slog.HandlerOptions{Level: level, AddSource: true})
	}
	slog.SetDefault(slog.New(logHandler))

	// Initialize core components
	seenIDs = make(map[[32]byte]seenEntry)
	dedupWindow = time.Duration(*dedupSeconds) * time.Second

	// Open deduplication log file if specified
	if dedupLogFile != "" {
		var err error
		dedupLogger, err = os.OpenFile(dedupLogFile, os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0644)
		if err != nil {
			slog.Error("failed to open deduplication log file", "file", dedupLogFile, "error", err)
			os.Exit(1)
		}
		slog.Info("deduplication log file opened", "path", dedupLogFile)