Label with job_name for all sources.

services/vector.hcl

@@ -72,6 +72,12 @@ job "vector" {
 
           [sources.vector_raw]
             type = "internal_logs"
+          [transforms.vector_transformed]
+            type = "remap"
+            inputs = [ "vector_raw" ]
+            source = '''
+.job_name = "vector"
+            '''
 
           [sources.docker_raw]
             type = "docker_logs"
@@ -95,17 +101,29 @@ if length(result) > 0 {
           [sources.glusterfs_raw]
             type = "file"
             include = [ "/var/log/glusterfs/**/*.log" ]
+          [transforms.glusterfs_transformed]
+            type = "remap"
+            inputs = [ "glusterfs_raw" ]
+            source = '''
+.job_name = .file
+            '''
 
           [sources.journald_raw]
             type = "journald"
+          [transforms.journald_transformed]
+            type = "remap"
+            inputs = [ "journald_raw" ]
+            source = '''
+.job_name = "journald"
+            '''
 
           [sinks.loki]
             type = "loki"
             inputs = [
-              "vector_raw",
+              "vector_transformed",
               "docker_transformed",
-              "glusterfs_raw",
+              "glusterfs_transformed",
-              "journald_raw",
+              "journald_transformed",
             ]
             endpoint = "http://[[ range service "loki" ]][[ .Address ]]:[[ .Port ]][[ end ]]"
             encoding.codec = "json"
@@ -116,6 +134,7 @@ if length(result) > 0 {
             healthcheck.enabled = true
               [sinks.loki.labels]
               host = "{{host}}"
+              job_name = "{{job_name}}"
 
           [sources.internal_metrics]
             type = "internal_metrics"