From 18bcaa3aae6dc30630d45b1ac0bbb54df14a5783 Mon Sep 17 00:00:00 2001 From: genofire Date: Sun, 17 Sep 2023 01:06:33 +0200 Subject: [PATCH] feat(database/influxdb2): Add database support of influxdb2 client --- config_example.toml | 33 +++++ database/all/main.go | 1 + database/influxdb2/database.go | 126 ++++++++++++++++++ database/influxdb2/database_test.go | 43 ++++++ database/influxdb2/global.go | 79 +++++++++++ database/influxdb2/link.go | 30 +++++ database/influxdb2/node.go | 195 ++++++++++++++++++++++++++++ go.mod | 14 +- go.sum | 81 ++++++++++-- 9 files changed, 588 insertions(+), 14 deletions(-) create mode 100644 database/influxdb2/database.go create mode 100644 database/influxdb2/database_test.go create mode 100644 database/influxdb2/global.go create mode 100644 database/influxdb2/link.go create mode 100644 database/influxdb2/node.go diff --git a/config_example.toml b/config_example.toml index 8c1604e3..a1aa1752 100644 --- a/config_example.toml +++ b/config_example.toml @@ -219,6 +219,39 @@ password = "" #system = "productive" #site = "ffhb" +# Save collected data to InfluxDB2. +# There are the following measurments: +# node: store node specific data i.e. clients memory, airtime +# link: store link tq between two interfaces of two different nodes with i.e. nodeid, address, hostname +# global: store global data, i.e. count of clients and nodes +# firmware: store the count of nodes tagged with firmware +# model: store the count of nodes tagged with hardware model +# autoupdater: store the count of autoupdate branch +[[database.connection.influxdb2]] +enable = false +address = "http://localhost:8086" +token = "" +organization_id = "" +bucket_default = "" + +[database.connection.influxdb2.buckets] +#link = "yanic-temp" +#node = "yanic-temp" +#dhcp = "yanic-temp" +global = "yanic" +#firmware = "yanic-temp" +#model = "yanic-temp" +#autoupdater = "yanic-temp" + +# Tagging of the data (optional) +[database.connection.influxdb2.tags] +# Tags used by Yanic would override the tags from this config +# nodeid, hostname, owner, model, firmware_base, firmware_release,frequency11g and frequency11a are tags which are already used +#tagname1 = "tagvalue 1" +# some useful e.g.: +#system = "productive" +#site = "ffhb" + # Graphite settings [[database.connection.graphite]] enable = false diff --git a/database/all/main.go b/database/all/main.go index c353c806..32f9f347 100644 --- a/database/all/main.go +++ b/database/all/main.go @@ -3,6 +3,7 @@ package all import ( _ "github.com/FreifunkBremen/yanic/database/graphite" _ "github.com/FreifunkBremen/yanic/database/influxdb" + _ "github.com/FreifunkBremen/yanic/database/influxdb2" _ "github.com/FreifunkBremen/yanic/database/logging" _ "github.com/FreifunkBremen/yanic/database/respondd" ) diff --git a/database/influxdb2/database.go b/database/influxdb2/database.go new file mode 100644 index 00000000..622efb7b --- /dev/null +++ b/database/influxdb2/database.go @@ -0,0 +1,126 @@ +package influxdb + +import ( + "context" + + influxdb "github.com/influxdata/influxdb-client-go/v2" + influxdbAPI "github.com/influxdata/influxdb-client-go/v2/api" + + "github.com/FreifunkBremen/yanic/database" + "github.com/bdlm/log" +) + +const ( + MeasurementLink = "link" // Measurement for per-link statistics + MeasurementNode = "node" // Measurement for per-node statistics + MeasurementDHCP = "dhcp" // Measurement for DHCP server statistics + MeasurementGlobal = "global" // Measurement for summarized global statistics + CounterMeasurementFirmware = "firmware" // Measurement for firmware statistics + CounterMeasurementModel = "model" // Measurement for model statistics + CounterMeasurementAutoupdater = "autoupdater" // Measurement for autoupdater + batchMaxSize = 1000 +) + +type Connection struct { + database.Connection + config Config + client influxdb.Client + writeAPI map[string]influxdbAPI.WriteAPI +} + +type Config map[string]interface{} + +func (c Config) Address() string { + return c["address"].(string) +} +func (c Config) Token() string { + if d, ok := c["token"]; ok { + return d.(string) + } + log.Panic("influxdb2 - no token given") + return "" +} +func (c Config) Organization() string { + if d, ok := c["organization_id"]; ok { + return d.(string) + } + return "" +} +func (c Config) Bucket(measurement string) string { + logger := log.WithFields(map[string]interface{}{ + "organization_id": c.Organization(), + "address": c.Address(), + "measurement": measurement, + }) + if d, ok := c["buckets"]; ok { + dMap := d.(map[string]interface{}) + if d, ok := dMap[measurement]; ok { + bucket := d.(string) + logger.WithField("bucket", bucket).Info("get bucket for writeapi") + return bucket + } + if d, ok := c["bucket_default"]; ok { + bucket := d.(string) + logger.WithField("bucket", bucket).Info("get bucket for writeapi") + return bucket + } + } + if d, ok := c["bucket_default"]; ok { + bucket := d.(string) + logger.WithField("bucket", bucket).Info("get bucket for writeapi") + return bucket + } + logger.Panic("no bucket found for measurement") + return "" +} +func (c Config) Tags() map[string]string { + if c["tags"] != nil { + tags := make(map[string]string) + for k, v := range c["tags"].(map[string]interface{}) { + tags[k] = v.(string) + } + return tags + } + return nil +} + +func init() { + database.RegisterAdapter("influxdb2", Connect) +} +func Connect(configuration map[string]interface{}) (database.Connection, error) { + config := Config(configuration) + + // Make client + client := influxdb.NewClientWithOptions(config.Address(), config.Token(), influxdb.DefaultOptions().SetBatchSize(batchMaxSize)) + + ok, err := client.Ping(context.Background()) + if !ok || err != nil { + return nil, err + } + + writeAPI := map[string]influxdbAPI.WriteAPI{ + MeasurementLink: client.WriteAPI(config.Organization(), config.Bucket(MeasurementLink)), + MeasurementNode: client.WriteAPI(config.Organization(), config.Bucket(MeasurementNode)), + MeasurementDHCP: client.WriteAPI(config.Organization(), config.Bucket(MeasurementDHCP)), + MeasurementGlobal: client.WriteAPI(config.Organization(), config.Bucket(MeasurementGlobal)), + CounterMeasurementFirmware: client.WriteAPI(config.Organization(), config.Bucket(CounterMeasurementFirmware)), + CounterMeasurementModel: client.WriteAPI(config.Organization(), config.Bucket(CounterMeasurementModel)), + CounterMeasurementAutoupdater: client.WriteAPI(config.Organization(), config.Bucket(CounterMeasurementAutoupdater)), + } + + db := &Connection{ + config: config, + client: client, + writeAPI: writeAPI, + } + + return db, nil +} + +// Close all connection and clean up +func (conn *Connection) Close() { + for _, api := range conn.writeAPI { + api.Flush() + } + conn.client.Close() +} diff --git a/database/influxdb2/database_test.go b/database/influxdb2/database_test.go new file mode 100644 index 00000000..7af95761 --- /dev/null +++ b/database/influxdb2/database_test.go @@ -0,0 +1,43 @@ +package influxdb + +import ( + "net/http" + "net/http/httptest" + "testing" + + "github.com/stretchr/testify/assert" +) + +func TestConnect(t *testing.T) { + assert := assert.New(t) + + conn, err := Connect(map[string]interface{}{ + "address": "", + "token": "", + "bucket_default": "all", + }) + assert.Nil(conn) + assert.Error(err) + + conn, err = Connect(map[string]interface{}{ + "address": "http://localhost", + "token": "", + "bucket_default": "all", + }) + assert.Nil(conn) + assert.Error(err) + + srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { + w.WriteHeader(http.StatusNoContent) + })) + defer srv.Close() + + conn, err = Connect(map[string]interface{}{ + "address": srv.URL, + "token": "atoken", + "bucket_default": "all", + }) + + assert.NotNil(conn) + assert.NoError(err) +} diff --git a/database/influxdb2/global.go b/database/influxdb2/global.go new file mode 100644 index 00000000..83742a60 --- /dev/null +++ b/database/influxdb2/global.go @@ -0,0 +1,79 @@ +package influxdb + +import ( + "time" + + "github.com/FreifunkBremen/yanic/runtime" + + "github.com/bdlm/log" + influxdb "github.com/influxdata/influxdb-client-go/v2" +) + +// InsertGlobals implementation of database +func (conn *Connection) InsertGlobals(stats *runtime.GlobalStats, time time.Time, site string, domain string) { + measurementGlobal := MeasurementGlobal + counterMeasurementModel := CounterMeasurementModel + counterMeasurementFirmware := CounterMeasurementFirmware + counterMeasurementAutoupdater := CounterMeasurementAutoupdater + + if site != runtime.GLOBAL_SITE { + measurementGlobal += "_site" + counterMeasurementModel += "_site" + counterMeasurementFirmware += "_site" + counterMeasurementAutoupdater += "_site" + } + if domain != runtime.GLOBAL_DOMAIN { + measurementGlobal += "_domain" + counterMeasurementModel += "_domain" + counterMeasurementFirmware += "_domain" + counterMeasurementAutoupdater += "_domain" + } + p := influxdb.NewPoint(measurementGlobal, + conn.config.Tags(), + map[string]interface{}{ + "nodes": stats.Nodes, + "gateways": stats.Gateways, + "clients.total": stats.Clients, + "clients.wifi": stats.ClientsWifi, + "clients.wifi24": stats.ClientsWifi24, + "clients.wifi5": stats.ClientsWifi5, + "clients.owe": stats.ClientsOwe, + "clients.owe24": stats.ClientsOwe24, + "clients.owe5": stats.ClientsOwe5, + }, + time) + + if site != runtime.GLOBAL_SITE { + p = p.AddTag("site", site) + } + if domain != runtime.GLOBAL_DOMAIN { + p = p.AddTag("domain", domain) + } + conn.writeAPI[MeasurementGlobal].WritePoint(p) + + conn.addCounterMap(CounterMeasurementModel, counterMeasurementModel, stats.Models, time, site, domain) + conn.addCounterMap(CounterMeasurementFirmware, counterMeasurementFirmware, stats.Firmwares, time, site, domain) + conn.addCounterMap(CounterMeasurementAutoupdater, counterMeasurementAutoupdater, stats.Autoupdater, time, site, domain) +} + +// Saves the values of a CounterMap in the database. +// The key are used as 'value' tag. +// The value is used as 'counter' field. +func (conn *Connection) addCounterMap(writeName, name string, m runtime.CounterMap, t time.Time, site string, domain string) { + writeAPI, ok := conn.writeAPI[writeName] + if !ok { + log.WithField("writeName", writeName).Panic("no writeAPI found for countermap") + } + for key, count := range m { + p := influxdb.NewPoint("stat", + conn.config.Tags(), + map[string]interface{}{ + "count": count, + }, + t). + AddTag("site", site). + AddTag("domain", domain). + AddTag("value", key) + writeAPI.WritePoint(p) + } +} diff --git a/database/influxdb2/link.go b/database/influxdb2/link.go new file mode 100644 index 00000000..4dd36d0a --- /dev/null +++ b/database/influxdb2/link.go @@ -0,0 +1,30 @@ +package influxdb + +import ( + "time" + + "github.com/FreifunkBremen/yanic/runtime" + + influxdb "github.com/influxdata/influxdb-client-go/v2" +) + +// InsertLink adds a link data point +func (conn *Connection) InsertLink(link *runtime.Link, t time.Time) { + p := influxdb.NewPoint(MeasurementLink, + conn.config.Tags(), + map[string]interface{}{ + "tq": link.TQ * 100, + }, + t). + AddTag("source.id", link.SourceID). + AddTag("source.addr", link.SourceAddress). + AddTag("target.id", link.TargetID). + AddTag("target.addr", link.TargetAddress) + if link.SourceHostname != "" { + p.AddTag("source.hostname", link.SourceHostname) + } + if link.TargetHostname != "" { + p.AddTag("target.hostname", link.TargetHostname) + } + conn.writeAPI[MeasurementLink].WritePoint(p) +} diff --git a/database/influxdb2/node.go b/database/influxdb2/node.go new file mode 100644 index 00000000..30c52456 --- /dev/null +++ b/database/influxdb2/node.go @@ -0,0 +1,195 @@ +package influxdb + +import ( + "strconv" + "time" + + "github.com/FreifunkBremen/yanic/runtime" + + influxdb "github.com/influxdata/influxdb-client-go/v2" +) + +// PruneNodes prunes historical per-node data - not nessasary, juse configurate your influxdb2 +func (conn *Connection) PruneNodes(deleteAfter time.Duration) { +} + +// InsertNode stores statistics and neighbours in the database +func (conn *Connection) InsertNode(node *runtime.Node) { + stats := node.Statistics + time := node.Lastseen.GetTime() + + if stats == nil || stats.NodeID == "" { + return + } + + p := influxdb.NewPoint(MeasurementNode, + conn.config.Tags(), + map[string]interface{}{ + "load": stats.LoadAverage, + "time.up": int64(stats.Uptime), + "time.idle": int64(stats.Idletime), + "proc.running": stats.Processes.Running, + "clients.wifi": stats.Clients.Wifi, + "clients.wifi24": stats.Clients.Wifi24, + "clients.wifi5": stats.Clients.Wifi5, + "clients.owe": stats.Clients.Owe, + "clients.owe24": stats.Clients.Owe24, + "clients.owe5": stats.Clients.Owe5, + "clients.total": stats.Clients.Total, + "memory.buffers": stats.Memory.Buffers, + "memory.cached": stats.Memory.Cached, + "memory.free": stats.Memory.Free, + "memory.total": stats.Memory.Total, + "memory.available": stats.Memory.Available, + }, + time). + AddTag("nodeid", stats.NodeID) + + vpnInterfaces := make(map[string]bool) + + if nodeinfo := node.Nodeinfo; nodeinfo != nil { + for _, mIface := range nodeinfo.Network.Mesh { + for _, tunnel := range mIface.Interfaces.Tunnel { + vpnInterfaces[tunnel] = true + } + } + + p.AddTag("hostname", nodeinfo.Hostname) + if nodeinfo.System.SiteCode != "" { + p.AddTag("site", nodeinfo.System.SiteCode) + } + if nodeinfo.System.DomainCode != "" { + p.AddTag("domain", nodeinfo.System.DomainCode) + } + if owner := nodeinfo.Owner; owner != nil { + p.AddTag("owner", owner.Contact) + } + if wireless := nodeinfo.Wireless; wireless != nil { + p.AddField("wireless.txpower24", wireless.TxPower24) + p.AddField("wireless.txpower5", wireless.TxPower5) + } + // Hardware + p.AddTag("model", nodeinfo.Hardware.Model) + p.AddField("nproc", nodeinfo.Hardware.Nproc) + if nodeinfo.Software.Firmware != nil { + p.AddTag("firmware_base", nodeinfo.Software.Firmware.Base) + p.AddTag("firmware_release", nodeinfo.Software.Firmware.Release) + } + if nodeinfo.Software.Autoupdater != nil && nodeinfo.Software.Autoupdater.Enabled { + p.AddTag("autoupdater", nodeinfo.Software.Autoupdater.Branch) + } else { + p.AddTag("autoupdater", runtime.DISABLED_AUTOUPDATER) + } + + } + if neighbours := node.Neighbours; neighbours != nil { + // VPN Neighbours are Neighbours but includet in one protocol + vpn := 0 + + // protocol: Batman Advance + batadv := 0 + for mac, batadvNeighbours := range neighbours.Batadv { + batadv += len(batadvNeighbours.Neighbours) + if _, ok := vpnInterfaces[mac]; ok { + vpn += len(batadvNeighbours.Neighbours) + } + } + p.AddField("neighbours.batadv", batadv) + + // protocol: Babel + babel := 0 + for _, babelNeighbours := range neighbours.Babel { + babel += len(babelNeighbours.Neighbours) + if _, ok := vpnInterfaces[babelNeighbours.LinkLocalAddress]; ok { + vpn += len(babelNeighbours.Neighbours) + } + } + p.AddField("neighbours.babel", babel) + + // protocol: LLDP + lldp := 0 + for _, lldpNeighbours := range neighbours.LLDP { + lldp += len(lldpNeighbours) + } + p.AddField("neighbours.lldp", lldp) + + // vpn wait for babel + p.AddField("neighbours.vpn", vpn) + + // total is the sum of all protocols + p.AddField("neighbours.total", batadv+babel+lldp) + } + if procstat := stats.ProcStats; procstat != nil { + p.AddField("stat.cpu.user", procstat.CPU.User) + p.AddField("stat.cpu.nice", procstat.CPU.Nice) + p.AddField("stat.cpu.system", procstat.CPU.System) + p.AddField("stat.cpu.idle", procstat.CPU.Idle) + p.AddField("stat.cpu.iowait", procstat.CPU.IOWait) + p.AddField("stat.cpu.irq", procstat.CPU.IRQ) + p.AddField("stat.cpu.softirq", procstat.CPU.SoftIRQ) + p.AddField("stat.intr", procstat.Intr) + p.AddField("stat.ctxt", procstat.ContextSwitches) + p.AddField("stat.softirq", procstat.SoftIRQ) + p.AddField("stat.processes", procstat.Processes) + } + + if t := stats.Traffic.Rx; t != nil { + p.AddField("traffic.rx.bytes", int64(t.Bytes)) + p.AddField("traffic.rx.packets", t.Packets) + } + if t := stats.Traffic.Tx; t != nil { + p.AddField("traffic.tx.bytes", int64(t.Bytes)) + p.AddField("traffic.tx.packets", t.Packets) + p.AddField("traffic.tx.dropped", t.Dropped) + } + if t := stats.Traffic.Forward; t != nil { + p.AddField("traffic.forward.bytes", int64(t.Bytes)) + p.AddField("traffic.forward.packets", t.Packets) + } + if t := stats.Traffic.MgmtRx; t != nil { + p.AddField("traffic.mgmt_rx.bytes", int64(t.Bytes)) + p.AddField("traffic.mgmt_rx.packets", t.Packets) + } + if t := stats.Traffic.MgmtTx; t != nil { + p.AddField("traffic.mgmt_tx.bytes", int64(t.Bytes)) + p.AddField("traffic.mgmt_tx.packets", t.Packets) + } + + for _, airtime := range stats.Wireless { + suffix := airtime.FrequencyName() + p.AddField("airtime"+suffix+".chan_util", airtime.ChanUtil) + p.AddField("airtime"+suffix+".rx_util", airtime.RxUtil) + p.AddField("airtime"+suffix+".tx_util", airtime.TxUtil) + p.AddField("airtime"+suffix+".noise", airtime.Noise) + p.AddField("airtime"+suffix+".frequency", airtime.Frequency) + p.AddTag("frequency"+suffix, strconv.Itoa(int(airtime.Frequency))) + } + + conn.writeAPI[MeasurementNode].WritePoint(p) + + // Add DHCP statistics + if dhcp := stats.DHCP; dhcp != nil { + p := influxdb.NewPoint(MeasurementDHCP, + conn.config.Tags(), + map[string]interface{}{ + "decline": dhcp.Decline, + "offer": dhcp.Offer, + "ack": dhcp.Ack, + "nak": dhcp.Nak, + "request": dhcp.Request, + "discover": dhcp.Discover, + "inform": dhcp.Inform, + "release": dhcp.Release, + + "leases.allocated": dhcp.LeasesAllocated, + "leases.pruned": dhcp.LeasesPruned, + }, time). + AddTag("nodeid", stats.NodeID) + + if nodeinfo := node.Nodeinfo; nodeinfo != nil { + p.AddTag("hostname", nodeinfo.Hostname) + } + + conn.writeAPI[MeasurementDHCP].WritePoint(p) + } +} diff --git a/go.mod b/go.mod index ae2ad243..12bf3217 100644 --- a/go.mod +++ b/go.mod @@ -1,6 +1,6 @@ module github.com/FreifunkBremen/yanic -go 1.17 +go 1.20 require ( github.com/BurntSushi/toml v1.3.2 @@ -8,6 +8,7 @@ require ( github.com/bdlm/log v0.1.20 github.com/bdlm/std v1.0.1 github.com/fgrosse/graphigo v0.0.0-20151222101953-5770fe631d9a + github.com/influxdata/influxdb-client-go/v2 v2.12.3 github.com/influxdata/influxdb1-client v0.0.0-20220302092344-a9ab5670611c github.com/paulmach/go.geojson v1.5.0 github.com/pkg/errors v0.9.1 @@ -19,15 +20,18 @@ require ( require ( github.com/davecgh/go-spew v1.1.1 // indirect + github.com/deepmap/oapi-codegen v1.8.2 // indirect github.com/inconshreveable/mousetrap v1.1.0 // indirect + github.com/influxdata/line-protocol v0.0.0-20200327222509-2487e7298839 // indirect github.com/onsi/ginkgo v1.16.5 // indirect - github.com/onsi/gomega v1.19.0 // indirect + github.com/onsi/gomega v1.27.10 // indirect github.com/pmezard/go-difflib v1.0.0 // indirect github.com/spf13/pflag v1.0.5 // indirect github.com/tidwall/match v1.1.1 // indirect - github.com/tidwall/pretty v1.2.1 // indirect - golang.org/x/crypto v0.13.0 // indirect - golang.org/x/term v0.12.0 // indirect + github.com/tidwall/pretty v1.2.0 // indirect + golang.org/x/crypto v0.11.0 // indirect + golang.org/x/net v0.12.0 // indirect + golang.org/x/term v0.10.0 // indirect gopkg.in/fgrosse/graphigo.v2 v2.0.0-20151220153422-55a0a92a7030 // indirect gopkg.in/yaml.v3 v3.0.1 // indirect ) diff --git a/go.sum b/go.sum index 3388464f..9de4f165 100644 --- a/go.sum +++ b/go.sum @@ -7,13 +7,23 @@ github.com/bdlm/log v0.1.20/go.mod h1:30V5Zwc5Vt5ePq5rd9KJ6JQ/A5aFUcKzq5fYtO7c9q github.com/bdlm/std v1.0.1 h1:USdxays+0tgB3BJCEQ9z942tmTWmzpVPC7jCvczsj/I= github.com/bdlm/std v1.0.1/go.mod h1:dittT3gnvbHQ4P+1UbkdSwkHFHVl1gx8qYu4zIFyB+Q= github.com/cpuguy83/go-md2man/v2 v2.0.2/go.mod h1:tgQtvFlXSQOSOSIRvRPT7W67SCa46tRHOmNcaadrF8o= +github.com/cyberdelia/templates v0.0.0-20141128023046-ca7fffd4298c/go.mod h1:GyV+0YP4qX0UQ7r2MoYZ+AvYDp12OF5yg4q8rGnyNh4= github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c= github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= +github.com/deepmap/oapi-codegen v1.8.2 h1:SegyeYGcdi0jLLrpbCMoJxnUUn8GBXHsvr4rbzjuhfU= +github.com/deepmap/oapi-codegen v1.8.2/go.mod h1:YLgSKSDv/bZQB7N4ws6luhozi3cEdRktEqrX88CvjIw= +github.com/dgrijalva/jwt-go v3.2.0+incompatible/go.mod h1:E3ru+11k8xSBh+hMPgOLZmtrrCbhqsmaPHjLKYnJCaQ= github.com/fgrosse/graphigo v0.0.0-20151222101953-5770fe631d9a h1:vV0pSGlrwV+cPffwHDKckZiU3qcaIXTnZGXLX64i4Rk= github.com/fgrosse/graphigo v0.0.0-20151222101953-5770fe631d9a/go.mod h1:m3fD9iVpJUF8Kl2kz/HwASu4Hf1x3s3V+H0BiEj46XQ= github.com/fsnotify/fsnotify v1.4.7/go.mod h1:jwhsz4b93w/PPRr/qN1Yymfu8t87LnFCMoQvtojpjFo= +github.com/fsnotify/fsnotify v1.4.9 h1:hsms1Qyu0jgnwNXIxa+/V/PDsU6CfLf6CNO8H7IWoS4= github.com/fsnotify/fsnotify v1.4.9/go.mod h1:znqG4EE+3YCdAaPaxE2ZRY/06pZUdp0tY4IgpuI1SZQ= +github.com/getkin/kin-openapi v0.61.0/go.mod h1:7Yn5whZr5kJi6t+kShccXS8ae1APpYTW6yheSwk8Yi4= +github.com/ghodss/yaml v1.0.0/go.mod h1:4dBDuWmgqj2HViK6kFavaiC9ZROes6MMH2rRYeMEF04= +github.com/go-chi/chi/v5 v5.0.0/go.mod h1:BBug9lr0cqtdAhsu6R4AAdvufI0/XBzAQSsUqJpoZOs= +github.com/go-openapi/jsonpointer v0.19.5/go.mod h1:Pl9vOtqEWErmShwVjC8pYs9cog34VGT37dQOVbmoatg= +github.com/go-openapi/swag v0.19.5/go.mod h1:POnQmlKehdgb5mhVOsnJFsivZCEZ/vjK9gh66Z9tfKk= github.com/go-task/slim-sprig v0.0.0-20210107165309-348f09dbbbc0/go.mod h1:fyg7847qk6SyHyPtNmDHnmrv/HOrqktSC+C9fM+CJOE= github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U= github.com/golang/protobuf v1.4.0-rc.1/go.mod h1:ceaxUfeHdC40wWswd/P6IGgMaK3YpKi5j83Wpe3EHw8= @@ -22,24 +32,51 @@ github.com/golang/protobuf v1.4.0-rc.2/go.mod h1:LlEzMj4AhA7rCAGe4KMBDvJI+AwstrU github.com/golang/protobuf v1.4.0-rc.4.0.20200313231945-b860323f09d0/go.mod h1:WU3c8KckQ9AFe+yFwt9sWVRKCVIyN9cPHBJSNnbL67w= github.com/golang/protobuf v1.4.0/go.mod h1:jodUvKwWbYaEsadDk5Fwe5c77LiNKVO9IDvqG2KuDX0= github.com/golang/protobuf v1.4.2/go.mod h1:oDoupMAO8OvCJWAcko0GGGIgR6R6ocIYbsSw735rRwI= +github.com/golangci/lint-1 v0.0.0-20181222135242-d2cdd8c08219/go.mod h1:/X8TswGSh1pIozq4ZwCfxS0WA5JGXguxk94ar/4c87Y= github.com/google/go-cmp v0.3.0/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU= github.com/google/go-cmp v0.3.1/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU= github.com/google/go-cmp v0.4.0/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= +github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38= +github.com/gorilla/mux v1.8.0/go.mod h1:DVbg23sWSpFRCP0SfiEN6jmj59UnW/n46BH5rLB71So= github.com/hpcloud/tail v1.0.0/go.mod h1:ab1qPbhIpdTxEkNHXyeSf5vhxWSCs/tWer42PpOxQnU= github.com/inconshreveable/mousetrap v1.1.0 h1:wN+x4NVGpMsO7ErUn/mUI3vEoE6Jt13X2s0bqwp9tc8= github.com/inconshreveable/mousetrap v1.1.0/go.mod h1:vpF70FUmC8bwa3OWnCshd2FqLfsEA9PFc4w1p2J65bw= +github.com/influxdata/influxdb-client-go/v2 v2.12.3 h1:28nRlNMRIV4QbtIUvxhWqaxn0IpXeMSkY/uJa/O/vC4= +github.com/influxdata/influxdb-client-go/v2 v2.12.3/go.mod h1:IrrLUbCjjfkmRuaCiGQg4m2GbkaeJDcuWoxiWdQEbA0= github.com/influxdata/influxdb1-client v0.0.0-20220302092344-a9ab5670611c h1:qSHzRbhzK8RdXOsAdfDgO49TtqC1oZ+acxPrkfTxcCs= github.com/influxdata/influxdb1-client v0.0.0-20220302092344-a9ab5670611c/go.mod h1:qj24IKcXYK6Iy9ceXlo3Tc+vtHo9lIhSX5JddghvEPo= +github.com/influxdata/line-protocol v0.0.0-20200327222509-2487e7298839 h1:W9WBk7wlPfJLvMCdtV4zPulc4uCPrlywQOmbFOhgQNU= +github.com/influxdata/line-protocol v0.0.0-20200327222509-2487e7298839/go.mod h1:xaLFMmpvUxqXtVkUJfg9QmT88cDaCJ3ZKgdZ78oO8Qo= +github.com/kr/pretty v0.1.0 h1:L/CwN0zerZDmRFUapSPitk6f+Q3+0za1rQkzVuMiMFI= +github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo= +github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ= +github.com/kr/text v0.1.0 h1:45sCR5RtlFHMR4UwH9sdQ5TC8v0qDQCHnXt+kaKSTVE= +github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI= +github.com/labstack/echo/v4 v4.2.1/go.mod h1:AA49e0DZ8kk5jTOOCKNuPR6oTnBS0dYiM4FW1e6jwpg= +github.com/labstack/gommon v0.3.0/go.mod h1:MULnywXg0yavhxWKc+lOruYdAhDwPK9wf0OL7NoOu+k= +github.com/mailru/easyjson v0.0.0-20190614124828-94de47d64c63/go.mod h1:C1wdFJiN94OJF2b5HbByQZoLdCWB1Yqtg26g4irojpc= +github.com/mailru/easyjson v0.0.0-20190626092158-b2ccc519800e/go.mod h1:C1wdFJiN94OJF2b5HbByQZoLdCWB1Yqtg26g4irojpc= +github.com/matryer/moq v0.0.0-20190312154309-6cfb0558e1bd/go.mod h1:9ELz6aaclSIGnZBoaSLZ3NAl1VTufbOrXBPvtcy6WiQ= +github.com/mattn/go-colorable v0.1.2/go.mod h1:U0ppj6V5qS13XJ6of8GYAs25YV2eR4EVcfRqFIhoBtE= +github.com/mattn/go-colorable v0.1.7/go.mod h1:u6P/XSegPjTcexA+o6vUJrdnUu04hMope9wVRipJSqc= +github.com/mattn/go-colorable v0.1.8/go.mod h1:u6P/XSegPjTcexA+o6vUJrdnUu04hMope9wVRipJSqc= +github.com/mattn/go-isatty v0.0.8/go.mod h1:Iq45c/XA43vh69/j3iqttzPXn0bhXyGjM0Hdxcsrc5s= +github.com/mattn/go-isatty v0.0.9/go.mod h1:YNRxwqDuOph6SZLI9vUUz6OYw3QyUt7WiY2yME+cCiQ= +github.com/mattn/go-isatty v0.0.12/go.mod h1:cbi8OIDigv2wuxKPP5vlRcQ1OAZbq2CE4Kysco4FUpU= github.com/nxadm/tail v1.4.4/go.mod h1:kenIhsEOeOJmVchQTgglprH7qJGnHDVpk1VPCcaMI8A= +github.com/nxadm/tail v1.4.8 h1:nPr65rt6Y5JFSKQO7qToXr7pePgD6Gwiw05lkbyAQTE= github.com/nxadm/tail v1.4.8/go.mod h1:+ncqLTQzXmGhMZNUePPaPqPvBxHAIsmXswZKocGu+AU= github.com/onsi/ginkgo v1.6.0/go.mod h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE= github.com/onsi/ginkgo v1.12.1/go.mod h1:zj2OWP4+oCPe1qIXoGWkgMRwljMUYCdkwsT2108oapk= +github.com/onsi/ginkgo v1.16.5 h1:8xi0RTUf59SOSfEtZMvwTvXYMzG4gV23XVHOZiXNtnE= github.com/onsi/ginkgo v1.16.5/go.mod h1:+E8gABHa3K6zRBolWtd+ROzc/U5bkGt0FwiG042wbpU= github.com/onsi/gomega v1.7.1/go.mod h1:XdKZgCCFLUoM/7CFJVPcG8C1xQ1AJ0vpAezJrB7JYyY= github.com/onsi/gomega v1.10.1/go.mod h1:iN09h71vgCQne3DLsj+A5owkum+a2tYe+TOCB1ybHNo= -github.com/onsi/gomega v1.19.0/go.mod h1:LY+I3pBVzYsTBU1AnDwOSxaYi9WoWiqgwooUqq9yPro= +github.com/onsi/gomega v1.27.10 h1:naR28SdDFlqrG6kScpT8VWpu1xWY5nJRCF3XaYyBjhI= +github.com/onsi/gomega v1.27.10/go.mod h1:RsS8tutOdbdgzbPtzzATp12yT7kM5I5aElG3evPbQ0M= github.com/paulmach/go.geojson v1.5.0 h1:7mhpMK89SQdHFcEGomT7/LuJhwhEgfmpWYVlVmLEdQw= github.com/paulmach/go.geojson v1.5.0/go.mod h1:DgdUy2rRVDDVgKqrjMe2vZAHMfhDTrjVKt3LmHIXGbU= +github.com/pkg/errors v0.8.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0= github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4= github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= @@ -51,49 +88,72 @@ github.com/spf13/pflag v1.0.5 h1:iy+VFUOCP1a+8yFto/drg2CJ5u0yRoB7fZw3DKv/JXA= github.com/spf13/pflag v1.0.5/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An2Bg= github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI= +github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4= github.com/stretchr/testify v1.5.1/go.mod h1:5W2xD1RspED5o8YsWQXVCued0rvSQ+mT+I5cxcmMvtA= -github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= github.com/stretchr/testify v1.8.4 h1:CcVxjf3Q8PM0mHUKJCdn+eZZtm5yQwehR5yeSVQQcUk= github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo= github.com/tidwall/gjson v1.16.0 h1:SyXa+dsSPpUlcwEDuKuEBJEz5vzTvOea+9rjyYodQFg= github.com/tidwall/gjson v1.16.0/go.mod h1:/wbyibRr2FHMks5tjHJ5F8dMZh3AcwJEMf5vlfC0lxk= github.com/tidwall/match v1.1.1 h1:+Ho715JplO36QYgwN9PGYNhgZvoUSc9X2c80KVTi+GA= github.com/tidwall/match v1.1.1/go.mod h1:eRSPERbgtNPcGhD8UCthc6PmLEQXEWd3PRB5JTxsfmM= +github.com/tidwall/pretty v1.2.0 h1:RWIZEg2iJ8/g6fDDYzMpobmaoGh5OLl4AXtGUGPcqCs= github.com/tidwall/pretty v1.2.0/go.mod h1:ITEVvHYasfjBbM0u2Pg8T2nJnzm8xPwvNhhsoaGGjNU= -github.com/tidwall/pretty v1.2.1 h1:qjsOFOWWQl+N3RsoF5/ssm1pHmJJwhjlSbZ51I6wMl4= -github.com/tidwall/pretty v1.2.1/go.mod h1:ITEVvHYasfjBbM0u2Pg8T2nJnzm8xPwvNhhsoaGGjNU= +github.com/valyala/bytebufferpool v1.0.0/go.mod h1:6bBcMArwyJ5K/AmCkWv1jt77kVWyCJ6HpOuEn7z0Csc= +github.com/valyala/fasttemplate v1.0.1/go.mod h1:UQGH1tvbgY+Nz5t2n7tXsz52dQxojPUpymEIMZ47gx8= +github.com/valyala/fasttemplate v1.2.1/go.mod h1:KHLXt3tVN2HBp8eijSv/kGJopbvo7S+qRAEEKiv+SiQ= github.com/yuin/goldmark v1.2.1/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74= golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w= golang.org/x/crypto v0.0.0-20191011191535-87dc89f01550/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI= golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto= -golang.org/x/crypto v0.13.0 h1:mvySKfSWJ+UKUii46M40LOvyWfN0s2U+46/jDd0e6Ck= -golang.org/x/crypto v0.13.0/go.mod h1:y6Z2r+Rw4iayiXXAIxJIDAJ1zMW4yaTpebo8fPOliYc= +golang.org/x/crypto v0.0.0-20200820211705-5c72a883971a/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto= +golang.org/x/crypto v0.0.0-20201221181555-eec23a3978ad/go.mod h1:jdWPYTVW3xRLrWPugEBEK3UY2ZEsg3UU495nc5E+M+I= +golang.org/x/crypto v0.11.0 h1:6Ewdq3tDic1mg5xRO4milcWCfMVQhI4NkqWWvqejpuA= +golang.org/x/crypto v0.11.0/go.mod h1:xgJhtzW8F9jGdVFWZESrid1U1bjeNy4zgy5cRr/CIio= golang.org/x/mod v0.3.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA= golang.org/x/net v0.0.0-20180906233101-161cd47e91fd/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg= golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s= golang.org/x/net v0.0.0-20200520004742-59133d7f0dd7/go.mod h1:qpuaurCH72eLCgpAm/N6yyVIVM9cpaDIP3A8BGJEC5A= +golang.org/x/net v0.0.0-20200822124328-c89045814202/go.mod h1:/O7V0waA8r7cgGh81Ro3o1hOxt32SMVPicZroKQ2sZA= golang.org/x/net v0.0.0-20201021035429-f5854403a974/go.mod h1:sp8m0HH+o8qH0wwXwYZr8TS3Oi6o0r6Gce1SSxlDquU= +golang.org/x/net v0.0.0-20210119194325-5f4716e94777/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg= +golang.org/x/net v0.12.0 h1:cfawfvKITfUsFCeJIHJrbSxpeu/E81khclypR0GVT50= +golang.org/x/net v0.12.0/go.mod h1:zEVYFnQC7m/vmpQFELhcD1EWkZlX69l4oqgmer6hfKA= golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20201020160332-67f06af15bc9/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sys v0.0.0-20180909124046-d0be0721c37e/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= +golang.org/x/sys v0.0.0-20190222072716-a9d3bda3a223/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.0.0-20190813064441-fde4db37ae7a/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20190904154756-749cb33beabd/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20191005200804-aed5e4c7ecf9/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.0.0-20191026070338-33540a1f6037/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20191120155948-bd437916bb0e/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.0.0-20200116001909-b77594299b42/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.0.0-20200223170610-d5e6a3e2c0ae/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20200323222414-85ca7c5b95cd/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.0.0-20200826173525-f9321e4c35a6/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20200930185726-fdedc70b468f/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20210112080510-489259a85091/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.0.0-20210124154548-22da62e12c0c/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.12.0 h1:CM0HF96J0hcLAwsHPJZjfdNzs0gftsLfgKt57wWHJ0o= golang.org/x/sys v0.12.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= -golang.org/x/term v0.12.0 h1:/ZfYdc3zq+q02Rv9vGqTeSItdzZTSNDmfTi0mBAuidU= -golang.org/x/term v0.12.0/go.mod h1:owVbMEjm3cBLCHdkQu9b1opXd4ETQWc3BhuQGKgXgvU= +golang.org/x/term v0.0.0-20201117132131-f5c789dd3221/go.mod h1:Nr5EML6q2oocZ2LXRh80K7BxOlk5/8JxuGnuhpl+muw= +golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo= +golang.org/x/term v0.10.0 h1:3R7pNqamzBraeqj/Tj8qt1aQ2HpmlC+Cx/qL/7hn4/c= +golang.org/x/term v0.10.0/go.mod h1:lpqdcUyK/oCiQxvxVrppt5ggO2KCZ5QblwqPnfZ6d5o= golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= +golang.org/x/text v0.3.5/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= +golang.org/x/text v0.11.0 h1:LAntKIrcmeSKERyiOh0XMV39LXS8IE9UL2yP7+f5ij4= +golang.org/x/time v0.0.0-20201208040808-7e3f01d25324/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ= +golang.org/x/time v0.0.0-20210220033141-f8bda1e9f3ba/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ= golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ= golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo= +golang.org/x/tools v0.0.0-20191125144606-a911d9008d1f/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo= golang.org/x/tools v0.0.0-20201224043029-2b0845dc783e/go.mod h1:emZCQorbCU4vsT4fOWvOPXz4eW1wZW4PmDk9uLelYpA= golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= @@ -106,12 +166,15 @@ google.golang.org/protobuf v1.20.1-0.20200309200217-e05f789c0967/go.mod h1:A+miE google.golang.org/protobuf v1.21.0/go.mod h1:47Nbq4nVaFHyn7ilMalzfO3qCViNmqZ2kzikPIcrTAo= google.golang.org/protobuf v1.23.0/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU= gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= +gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127 h1:qIbj1fsPNlZgppZ+VLlY7N33q108Sa+fhmuc+sWQYwY= +gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= +gopkg.in/fgrosse/graphigo.v2 v2.0.0-20151220153422-55a0a92a7030 h1:EFs63oNabMkD6Id8lVrIUAA+61GGtkzxnA4auRoAkwY= gopkg.in/fgrosse/graphigo.v2 v2.0.0-20151220153422-55a0a92a7030/go.mod h1:DXZVkyME6s9B/JGEUvA8aN0ip2fJgEhA72/rvfOeiIA= gopkg.in/fsnotify.v1 v1.4.7/go.mod h1:Tz8NjZHkW78fSQdbUxIjBTcgA1z1m8ZHf0WmKUhAMys= +gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7 h1:uRGJdciOHaEIrze2W8Q3AKkepLTh2hOroT7a+7czfdQ= gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7/go.mod h1:dt/ZhP58zS4L8KSrWDmTeBkI65Dw0HsyUHuEVlX15mw= gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= gopkg.in/yaml.v2 v2.2.4/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= gopkg.in/yaml.v2 v2.3.0/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= -gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA= gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=