This is an automated email from the ASF dual-hosted git repository.
liuhan pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/skywalking-rover.git
The following commit(s) were added to refs/heads/main by this push:
new 943f3e9 Export some method in the Kubernetes finder (#190)
943f3e9 is described below
commit 943f3e9eb04f2486512a0039bab90885112bdca5
Author: mrproliu <[email protected]>
AuthorDate: Sat Apr 12 19:26:58 2025 +0800
Export some method in the Kubernetes finder (#190)
---
pkg/process/finders/kubernetes/finder.go | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/pkg/process/finders/kubernetes/finder.go
b/pkg/process/finders/kubernetes/finder.go
index fd70936..21eae18 100644
--- a/pkg/process/finders/kubernetes/finder.go
+++ b/pkg/process/finders/kubernetes/finder.go
@@ -209,7 +209,7 @@ func (f *ProcessFinder) buildProcess(p *process.Process,
detectedProcesses []api
return detectedProcesses, true
}
- cgroups, err := f.getProcessCGroup(p.Pid)
+ cgroups, err := f.GetProcessCGroup(p.Pid)
if err != nil {
return detectedProcesses, false
}
@@ -226,7 +226,7 @@ func (f *ProcessFinder) buildProcess(p *process.Process,
detectedProcesses []api
}
// find process builder
- ps, err := f.buildProcesses(p, c)
+ ps, err := f.BuildProcesses(p, c)
if err != nil {
log.Warnf("find process builder error for pid: %d, err: %v",
p.Pid, err)
return detectedProcesses, false
@@ -239,7 +239,7 @@ func (f *ProcessFinder) buildProcess(p *process.Process,
detectedProcesses []api
return detectedProcesses, true
}
-func (f *ProcessFinder) buildProcesses(p *process.Process, pc *PodContainer)
([]*Process, error) {
+func (f *ProcessFinder) BuildProcesses(p *process.Process, pc *PodContainer)
([]*Process, error) {
// find builder
builders := make([]*ProcessBuilder, 0)
for _, b := range f.conf.Analyzers {
@@ -291,7 +291,7 @@ func (f *ProcessFinder) buildEntity(err error, ps
*process.Process, pc *PodConta
return renderTemplate(entity, ps, pc, f)
}
-func (f *ProcessFinder) getProcessCGroup(pid int32) ([]string, error) {
+func (f *ProcessFinder) GetProcessCGroup(pid int32) ([]string, error) {
processCgroupFilePath :=
host.GetHostProcInHost(fmt.Sprintf("%d/cgroup", pid))
cgroupFile, err := os.Open(processCgroupFilePath)
if err != nil {