feat: Tagging of local source IPs.

Added environment variable INFLUX_DB_TAG_SOURCE_IPS_LOCAL="127., 10., 192., 176." that contains IP prefixes which identify source IPs as local. These log entries are tagged with `source_ip_area`=`local`. All others with `public`.

Dockerfile

@@ -5,6 +5,7 @@ LABEL org.opencontainers.image.description="nginx-proxy-metrics parses nginx-pro
 ENV PROXY_CONTAINER_NAME nginx
 ENV INFLUX_DB_NAME monitoring
 ENV INFLUX_DB_RETENTION_DURATION 8w
+ENV INFLUX_DB_TAG_SOURCE_IPS_LOCAL "127., 10., 192., 176."
 
 VOLUME /GeoLite2-City.mmdb
 COPY .build/main /main

config/config.go

@@ -12,6 +12,7 @@ var (
 	InfluxDbName              = getEnvOrPanic("INFLUX_DB_NAME")
 	InfluxDbRetentionDuration = getEnvOrPanic("INFLUX_DB_RETENTION_DURATION")
 	InfluxDbTagInstance       = getEnvOrPanic("INFLUX_DB_TAG_INSTANCE")
+	LocalSourceIPs            = getEnvOrPanic("INFLUX_DB_TAG_SOURCE_IPS_LOCAL")
 )
 
 func getEnvOrPanic(envName string) string {

docker-compose.yml

@@ -53,6 +53,7 @@ services:
       - INFLUX_DB_NAME=monitoring
       - INFLUX_DB_RETENTION_DURATION=52w
       - INFLUX_DB_TAG_INSTANCE=my-instance
+      - INFLUX_DB_TAG_SOURCE_IPS_LOCAL="127., 10., 192., 176."
     volumes:
       - /var/run/docker.sock:/var/run/docker.sock:ro
       - /~nginx-proxy-metrics/data/GeoLite2-City.mmdb:/GeoLite2-City.mmdb:ro

persistence/influxdb_http_request_persister.go

@@ -7,6 +7,7 @@ import (
 	"nginx-proxy-metrics/config"
 	"nginx-proxy-metrics/logline"
 	"strconv"
+	"strings"
 )
 
 const SeriesName = "http_requests"
@@ -67,6 +68,7 @@ func (persister InfluxdbHttpRequestPersister) Persist(httpRequest logline.HttpRe
 		"city":            httpRequest.City,
 		"instance":        config.InfluxDbTagInstance,
 		"bot":             strconv.FormatBool(httpRequest.Bot),
+		"source_ip_area":  getSourceIpArea(httpRequest.SourceIp),
 	}
 
 	fields := map[string]interface{}{
@@ -91,6 +93,16 @@ func (persister InfluxdbHttpRequestPersister) Persist(httpRequest logline.HttpRe
 	}
 }
 
+func getSourceIpArea(ip string) string {
+	localSourceIpSlice := strings.Split(config.LocalSourceIPs, ",")
+	for _, prefix := range localSourceIpSlice {
+		if strings.HasPrefix(ip, strings.TrimSpace(prefix)) {
+			return "local"
+		}
+	}
+	return "public"
+}
+
 func queryDB(clnt client.Client, cmd string) (res []client.Result, err error) {
 	q := client.Query{
 		Command: cmd,