作者回复: func (agt *Agent) startCollectors() error {
var err error
var errs CollectorsError
var mutex sync.Mutex
for name, collector := range agt.collectors {
go func(name string, collector Collector, ctx context.Context) {
defer func() {
mutex.Unlock()
}()
err = collector.Start(ctx)
mutex.Lock()
if err != nil {
errs.CollectorErrors = append(errs.CollectorErrors,
errors.New(name+":"+err.Error()))
}
}(name, collector, agt.ctx)
}
if len(errs.CollectorErrors) == 0 {
return nil
}
return errs
}
在相关代码中添加:
if len(errs.CollectorErrors) == 0 {
return nil
}
作者回复: 你的命令行是怎样的,是不是只是指定了agent_test.go,你在包含agent.go和agent_test.go的路径下直接运行以下命令,go test -v
作者回复: 依赖是通过接口的,不会有这个问题