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 {

Reply via email to