diff --git a/services/vector.hcl b/services/vector.hcl index 8f8582a..a4e480d 100644 --- a/services/vector.hcl +++ b/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", - "journald_raw", + "glusterfs_transformed", + "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"