Function main

test/plugin/packetparser/main_linux.go:25–124

()

)

func main() {
	opts := log.GetDefaultLogOpts()
	opts.Level = "debug"
	log.SetupZapLogger(opts)
	l := log.Logger().Named("test-packetparser")

	metrics.InitializeMetrics(slog.Default())

	ctxTimeout, cancel := context.WithTimeout(context.Background(), 30*time.Second)

	// watcher manager
	wm := watchermanager.NewWatcherManager(kcfg.DefaultFilterMapMaxEntries)
	wm.Watchers = []watchermanager.IWatcher{endpoint.Watcher()}

	err := wm.Start(ctxTimeout)
	if err != nil {
		panic(err)
	}

	defer func() {
		if err := wm.Stop(ctxTimeout); err != nil {
			l.Error("Stop endpoint watcher failed", zap.Error(err))
		}
	}()
	// Filtermanager.
	f, err := filtermanager.Init(3, kcfg.DefaultFilterMapMaxEntries)
	if err != nil {
		l.Error("Start filtermanager failed", zap.Error(err))
		return
	}
	defer func() {
		if err := f.Stop(); err != nil {
			l.Error("Stop filtermanager failed", zap.Error(err))
		}
	}()

	ipsToAdd := []string{"20.69.116.85"}
	ips := []net.IP{}
	for _, ip := range ipsToAdd {
		x := net.ParseIP(ip).To4()
		if x == nil {
			l.Fatal("Invalid IP address", zap.String("ip", ip))
		}
		ips = append(ips, x)
	}
	err = f.AddIPs(ips, "packetparser-test", filtermanager.RequestMetadata{RuleID: "test"})
	if err != nil {
		l.Error("AddIPs failed", zap.Error(err))
		return
	}

	// Start packetparser plugin.
	cfg := &kcfg.Config{
		MetricsInterval: 1 * time.Second,
		EnablePodLevel:  true,
	}
	p := packetparser.New(cfg)
	if err = p.Stop(); err != nil {