From dc8d16caeb9bad8499564b044dc1472732815a62 Mon Sep 17 00:00:00 2001 From: mrproliu <741550557@qq.com> Date: Mon, 2 Sep 2024 17:48:59 +0800 Subject: [PATCH] fix missing commit file --- pkg/accesslog/runner.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/pkg/accesslog/runner.go b/pkg/accesslog/runner.go index e79a81b3..63f9eeef 100644 --- a/pkg/accesslog/runner.go +++ b/pkg/accesslog/runner.go @@ -20,6 +20,7 @@ package accesslog import ( "context" "fmt" + "strings" "time" process2 "github.com/shirou/gopsutil/process" @@ -68,11 +69,12 @@ func NewRunner(mgr *module.Manager, config *common.Config) (*Runner, error) { coreModule := mgr.FindModule(core.ModuleName).(core.Operator) backendOP := coreModule.BackendOperator() clusterName := coreModule.ClusterName() + monitorFilter := common.NewStaticMonitorFilter(strings.Split(config.ExcludeNamespaces, ","), strings.Split(config.ExcludeClusters, ",")) runner := &Runner{ context: &common.AccessLogContext{ BPF: bpfLoader, Config: config, - ConnectionMgr: common.NewConnectionManager(config, mgr, bpfLoader), + ConnectionMgr: common.NewConnectionManager(config, mgr, bpfLoader, monitorFilter), }, collectors: collector.Collectors(), mgr: mgr,