Add option to preprocess http_url

1 files changed, 9 insertions, 0 deletions

diff --git a/haminer.go b/haminer.go
index 245b4f1..3f62024 100644
--- a/haminer.go
+++ b/haminer.go
@@ -141,6 +141,13 @@ func (h *Haminer) forwards(halogs []*Halog) {
 	}
 }
 
+func (h *Haminer) preprocess(halog *Halog) {
+	halog.tagHTTPURL = halog.HTTPURL
+	for _, retag := range h.cfg.retags {
+		halog.tagHTTPURL = retag.preprocess("http_url", halog.tagHTTPURL)
+	}
+}
+
 func (h *Haminer) produce() {
 	halogs := make([]*Halog, 0)
 
@@ -150,6 +157,8 @@ func (h *Haminer) produce() {
 			continue
 		}
 
+		h.preprocess(halog)
+
 		halogs = append(halogs, halog)
 
 		if len(halogs) >= h.cfg.MaxBufferedLogs {