From 8e30a2e6656d1e2318a211c80cc6835ea17508e7 Mon Sep 17 00:00:00 2001 From: genofire Date: Sat, 20 Jul 2024 00:33:16 +0200 Subject: [PATCH] fix(database/influxdb*): add type to link --- database/influxdb/link.go | 1 + database/influxdb2/link.go | 3 ++- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/database/influxdb/link.go b/database/influxdb/link.go index 37c2bd90..3ccbebcb 100644 --- a/database/influxdb/link.go +++ b/database/influxdb/link.go @@ -14,6 +14,7 @@ func (conn *Connection) InsertLink(link *runtime.Link, t time.Time) { tags.SetString("source.addr", link.SourceAddress) tags.SetString("target.id", link.TargetID) tags.SetString("target.addr", link.TargetAddress) + tags.SetString("type", link.Type.String()) if link.SourceHostname != "" { tags.SetString("source.hostname", link.SourceHostname) } diff --git a/database/influxdb2/link.go b/database/influxdb2/link.go index 4dd36d0a..a28f570a 100644 --- a/database/influxdb2/link.go +++ b/database/influxdb2/link.go @@ -19,7 +19,8 @@ func (conn *Connection) InsertLink(link *runtime.Link, t time.Time) { AddTag("source.id", link.SourceID). AddTag("source.addr", link.SourceAddress). AddTag("target.id", link.TargetID). - AddTag("target.addr", link.TargetAddress) + AddTag("target.addr", link.TargetAddress). + AddTag("type", link.Type.String()) if link.SourceHostname != "" { p.AddTag("source.hostname", link.SourceHostname) }