INNER CODE UNIT · Go

run

ClickDevTech/CELERITY-panel · probe/main.go:114

func run(cfg *Config) error {
	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()

	signals := make(chan os.Signal, 1)
	signal.Notify(signals, os.Interrupt, syscall.SIGTERM)
	go func() {
		<-signals
		logInfo("shutting down")
		cancel()
	}()

	client := NewPanelClient(cfg.PanelURL, cfg.Token)
	aggregator := NewAggregator()
	shipper := NewShipper(cfg.DataDir, client)
	budget := LoadSpeedBudget(cfg.DataDir)

	identity := DetectNetIdentity(ctx)

View source record →