diff --git a/logs/lokiwriter.go b/logs/lokiwriter.go index bd48bd8..5ffdd0e 100644 --- a/logs/lokiwriter.go +++ b/logs/lokiwriter.go @@ -58,14 +58,13 @@ func (w *LokiWriter) Write(p []byte) (n int, err error) { // Add label that have been added to the event // A bit unsafe since we don't know what could be stored in the event // but we can't access this object once passed to the multilevel writter - - for k,v := range(event){ - if k != "level" && k != "time" && k != "message"{ - labels[k] = v.(string) + + for k, v := range event { + if k != "level" && k != "time" && k != "message" { + labels[k] = fmt.Sprintf("%v", v) } } - // Format the timestamp in nanoseconds timestamp := fmt.Sprintf("%d000000", time.Now().UnixNano()/int64(time.Millisecond)) @@ -87,7 +86,7 @@ func (w *LokiWriter) Write(p []byte) (n int, err error) { //fmt.Printf("Sending payload to Loki: %s\n", string(payloadBytes)) - req, err := http.NewRequest("POST", w.url + "/loki/api/v1/push", bytes.NewReader(payloadBytes)) + req, err := http.NewRequest("POST", w.url+"/loki/api/v1/push", bytes.NewReader(payloadBytes)) if err != nil { return 0, fmt.Errorf("failed to create HTTP request: %w", err) }