fix: dynamic target for x509_cert

flashcatcloud · Jan 6, 2025 · 472ce71 · 472ce71
1 parent f458196
commit 472ce71
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/inputs/x509_cert/x509_cert.go b/inputs/x509_cert/x509_cert.go
@@ -125,6 +125,11 @@ func (ins *Instance) Gather(slist *types.SampleList) {
 		return
 	}
 
+	if err := ins.sourcesToURLs(); err != nil {
+		log.Printf("E! failed to update sources: %v", err)
+		return
+	}
+
 	now := time.Now()
 	collectedUrls := append(ins.locations, ins.collectCertURLs()...)
 	for _, location := range collectedUrls {
@@ -273,6 +278,7 @@ func (ins *Instance) processCertificate(cert *x509.Certificate, opts x509.Verify
 }
 
 func (ins *Instance) sourcesToURLs() error {
+	ins.locations = []*url.URL{}
 	for _, target := range ins.Targets {
 		if strings.HasPrefix(target, "file://") || strings.HasPrefix(target, "/") {
 			target = filepath.ToSlash(strings.TrimPrefix(target, "file://"))