yanic/database/influxdb/link.go

package influxdb

import (
	"time"

	"github.com/FreifunkBremen/yanic/runtime"
	models "github.com/influxdata/influxdb1-client/models"
)

// InsertLink adds a link data point
func (conn *Connection) InsertLink(link *runtime.Link, t time.Time) {
	tags := models.Tags{}
	tags.SetString("source.id", link.SourceID)
	tags.SetString("source.addr", link.SourceAddress)
	tags.SetString("target.id", link.TargetID)
	tags.SetString("target.addr", link.TargetAddress)

	conn.addPoint(MeasurementLink, tags, models.Fields{"tq": link.TQ * 100}, t)
}