Now adding in service_name value when flow is seen from an unknown so…

…urce
kentik · Jan 16, 2025 · 123b7ec · 123b7ec
1 parent 37d133a
commit 123b7ec
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 0 deletions.
diff --git a/pkg/cat/auth/auth.go b/pkg/cat/auth/auth.go
@@ -81,6 +81,15 @@ func NewServer(auth *AuthConfig, snmpFile string, log logger.ContextL, serviceNa
 				s.devicesByID[strconv.Itoa(int(nd.ID))] = nd
 				nextID += 100
 			}
+
+			// Now add a blank missing device device.
+			nd := &kt.Device{
+				ID:         nextID,
+				Name:       kt.MissingDeviceName,
+				SendingIps: []net.IP{net.ParseIP(kt.MissingDeviceIP)},
+			}
+			nd.InitUserTags(serviceName, map[string]string{})
+			s.devicesByID[strconv.Itoa(int(nd.ID))] = nd
 		}
 	}
 

diff --git a/pkg/inputs/flow/format.go b/pkg/inputs/flow/format.go
@@ -218,6 +218,9 @@ func (t *KentikDriver) toJCHF(fmsg *pp.ProtoProducerMessage) *kt.JCHF {
 				in.DeviceName = dm
 			}
 		}
+		if mdev, ok := t.devices[kt.MissingDeviceIP]; ok {
+			mdev.SetUserTags(in.CustomStr)
+		}
 	}
 
 	if _, ok := t.metrics[in.DeviceName]; !ok {

diff --git a/pkg/kt/types.go b/pkg/kt/types.go
@@ -91,6 +91,9 @@ const (
 	GaugeMetric    = "gauge"
 	CountMetric    = "count"
 	FromGCP        = "gcppubsub"
+
+	MissingDeviceName = "KT_MISSING_DEVICE"
+	MissingDeviceIP   = "1.1.1.255"
 )
 
 type IntId uint64