in opentelemetry_collector/receiver/dockerstats/scraper.go [107:121]
func newScraper(scrapeInterval time.Duration, metricConsumer consumer.Metrics, logger *zap.Logger) (*scraper, error) {
docker, err := client.NewClientWithOpts(client.FromEnv)
if err != nil {
return nil, fmt.Errorf("failed to initialize docker client: %v", err)
}
return &scraper{
scrapeInterval: scrapeInterval,
done: make(chan bool),
metricConsumer: metricConsumer,
docker: docker,
logger: logger,
now: time.Now,
}, nil
}