Implement adding additional meta-data to gw stats.

brocaar · brocaar · commit 58da52aa5a11 · 2019-04-22T09:45:19.000+02:00
diff --git a/cmd/lora-gateway-bridge/cmd/configfile.go b/cmd/lora-gateway-bridge/cmd/configfile.go
@@ -296,6 +296,50 @@ marshaler="{{ .Integration.Marshaler }}"
   # The ip:port to bind the Prometheus metrics server to for serving the
   # metrics endpoint.
   bind="{{ .Metrics.Prometheus.Bind }}"
+
+
+# Gateway meta-data.
+#
+# The meta-data will be added to every stats message sent by the LoRa Gateway
+# Bridge.
+[meta_data]
+
+  # Static.
+  #
+  # Static key (string) / value (string) meta-data.
+  [meta_data.static]
+  # Example:
+  # serial_number="A1B21234"
+  {{ range $k, $v := .MetaData.Static }}
+  {{ $k }}="{{ $v }}"
+  {{ end }}
+
+
+  # Dynamic meta-data.
+  #
+  # Dynamic meta-data is retrieved by executing external commands.
+  # This makes it possible to for example execute an external command to
+  # read the gateway temperature.
+  [meta_data.dynamic]
+
+  # Execution interval of the commands.
+  execution_interval="{{ .MetaData.Dynamic.ExecutionInterval }}"
+
+  # Max. execution duration.
+  max_execution_duration="{{ .MetaData.Dynamic.MaxExecutionDuration }}"
+
+  # Commands to execute.
+  #
+  # The value of the stdout will be used as the key value (string).
+  # In case the command failed, it is ignored. In case the same key is defined
+  # both as static and dynamic, the dynamic value has priority (as long as the)
+  # command does not fail.
+  [meta_data.dynamic.commands]
+  # Example:
+  # temperature="/opt/gateway-temperature/gateway-temperature.sh"
+  {{ range $k, $v := .MetaData.Dynamic.Commands }}
+  {{ $k }}="{{ $v }}"
+  {{ end }}
 `
 
 var configCmd = &cobra.Command{
diff --git a/cmd/lora-gateway-bridge/cmd/root.go b/cmd/lora-gateway-bridge/cmd/root.go
@@ -62,6 +62,9 @@ func init() {
 
 	viper.SetDefault("integration.mqtt.auth.azure_iot_hub.sas_token_expiration", 24*time.Hour)
 
+	viper.SetDefault("meta_data.dynamic.execution_interval", time.Minute)
+	viper.SetDefault("meta_data.dynamic.max_execution_duration", time.Second)
+
 	rootCmd.AddCommand(versionCmd)
 	rootCmd.AddCommand(configCmd)
 }
diff --git a/cmd/lora-gateway-bridge/cmd/root_run.go b/cmd/lora-gateway-bridge/cmd/root_run.go
@@ -13,6 +13,7 @@ import (
 	"github.com/brocaar/lora-gateway-bridge/internal/config"
 	"github.com/brocaar/lora-gateway-bridge/internal/forwarder"
 	"github.com/brocaar/lora-gateway-bridge/internal/integration"
+	"github.com/brocaar/lora-gateway-bridge/internal/metadata"
 	"github.com/brocaar/lora-gateway-bridge/internal/metrics"
 )
 
@@ -25,6 +26,7 @@ func run(cmd *cobra.Command, args []string) error {
 		setupIntegration,
 		setupForwarder,
 		setupMetrics,
+		setupMetaData,
 	}
 
 	for _, t := range tasks {
@@ -81,3 +83,10 @@ func setupMetrics() error {
 	}
 	return nil
 }
+
+func setupMetaData() error {
+	if err := metadata.Setup(config.C); err != nil {
+		return errors.Wrap(err, "setup meta-data error")
+	}
+	return nil
+}
diff --git a/docs/content/install/config.md b/docs/content/install/config.md
@@ -342,6 +342,45 @@ marshaler="protobuf"
   # The ip:port to bind the Prometheus metrics server to for serving the
   # metrics endpoint.
   bind=""
+
+
+# Gateway meta-data.
+#
+# The meta-data will be added to every stats message sent by the LoRa Gateway
+# Bridge.
+[meta_data]
+
+  # Static.
+  #
+  # Static key (string) / value (string) meta-data.
+  [meta_data.static]
+  # Example:
+  # serial_number="A1B21234"
+
+
+
+  # Dynamic meta-data.
+  #
+  # Dynamic meta-data is retrieved by executing external commands.
+  # This makes it possible to for example execute an external command to
+  # read the gateway temperature.
+  [meta_data.dynamic]
+
+  # Execution interval of the commands.
+  execution_interval="1m0s"
+
+  # Max. execution duration.
+  max_execution_duration="1s"
+
+  # Commands to execute.
+  #
+  # The value of the stdout will be used as the key value (string).
+  # In case the command failed, it is ignored. In case the same key is defined
+  # both as static and dynamic, the dynamic value has priority (as long as the)
+  # command does not fail.
+  [meta_data.dynamic.commands]
+  # Example:
+  # temperature="/opt/gateway-temperature/gateway-temperature.sh"
 {{</highlight>}}
 
 ## Environment variables
diff --git a/go.mod b/go.mod
@@ -1,10 +1,10 @@
 module github.com/brocaar/lora-gateway-bridge
 
 require (
-	github.com/brocaar/loraserver v0.0.0-20190409085620-14c6fb22dcc4
+	github.com/brocaar/loraserver v0.0.0-20190422074053-c3336fb6b947
 	github.com/brocaar/lorawan v0.0.0-20190402092148-5bca41b178e9
 	github.com/dgrijalva/jwt-go v3.2.0+incompatible
-	github.com/eclipse/paho.mqtt.golang v0.0.0-20190117150808-cb7eb9363b44
+	github.com/eclipse/paho.mqtt.golang v1.1.1
 	github.com/golang/protobuf v1.3.1
 	github.com/goreleaser/goreleaser v0.101.0
 	github.com/goreleaser/nfpm v0.9.7
diff --git a/go.sum b/go.sum
@@ -1,6 +1,13 @@
 cloud.google.com/go v0.26.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw=
 cloud.google.com/go v0.34.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw=
 git.apache.org/thrift.git v0.0.0-20180902110319-2566ecd5d999/go.mod h1:fPE2ZNJGynbRyZ4dJvy6G277gSllfV2HJqblrnkyeyg=
+github.com/Azure/azure-amqp-common-go v1.1.3/go.mod h1:FhZtXirFANw40UXI2ntweO+VOkfaw8s6vZxUiRhLYW8=
+github.com/Azure/azure-sdk-for-go v0.0.0-20180727220559-4e8cbbfb1aea/go.mod h1:9XXNKU+eRnpl9moKnB4QOLf1HestfXbmab5FXxiDBjc=
+github.com/Azure/azure-sdk-for-go v21.3.0+incompatible/go.mod h1:9XXNKU+eRnpl9moKnB4QOLf1HestfXbmab5FXxiDBjc=
+github.com/Azure/azure-service-bus-go v0.4.1/go.mod h1:d9ho9e/06euiTwGpKxmlbpPhFUsfCsq6a4tZ68r51qI=
+github.com/Azure/go-autorest v0.0.0-20180809201959-39013ecb48ea/go.mod h1:r+4oMnoxhatjLLJ6zxSWATqVooLgysK6ZNox3g/xq24=
+github.com/Azure/go-autorest v11.0.0+incompatible/go.mod h1:r+4oMnoxhatjLLJ6zxSWATqVooLgysK6ZNox3g/xq24=
+github.com/Azure/go-autorest v11.1.1+incompatible/go.mod h1:r+4oMnoxhatjLLJ6zxSWATqVooLgysK6ZNox3g/xq24=
 github.com/BurntSushi/toml v0.3.1 h1:WXkYYl6Yr3qBf1K79EBnL4mak0OimBfB0XUf9Vl28OQ=
 github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
 github.com/Masterminds/semver v1.4.2 h1:WBLTQ37jOCzSLtXNdoo8bNM8876KhNqOKvrlGITgsTc=
@@ -12,6 +19,7 @@ github.com/alecthomas/template v0.0.0-20160405071501-a0175ee3bccc h1:cAKDfWh5Vpd
 github.com/alecthomas/template v0.0.0-20160405071501-a0175ee3bccc/go.mod h1:LOuyumcjzFXgccqObfd/Ljyb9UuFJ6TxHnclSeseNhc=
 github.com/alecthomas/units v0.0.0-20151022065526-2efee857e7cf h1:qet1QNfXsQxTZqLG4oE62mJzwPIB8+Tee4RNCL9ulrY=
 github.com/alecthomas/units v0.0.0-20151022065526-2efee857e7cf/go.mod h1:ybxpYRFXyAe+OPACYpWeL0wqObRcbAqCMya13uyzqw0=
+github.com/amenzhinsky/iothub v0.0.0-20190415141912-fb38f4d4c9fb/go.mod h1:5SMEOj96ci5bC7bp/RB1jH44yY5SzQnspyOov8hk39w=
 github.com/apex/log v1.1.0 h1:J5rld6WVFi6NxA6m8GJ1LJqu3+GiTFIt3mYv27gdQWI=
 github.com/apex/log v1.1.0/go.mod h1:yA770aXIDQrhVOIGurT/pVdfCpSq1GQV/auzMN5fzvY=
 github.com/armon/consul-api v0.0.0-20180202201655-eb2c6b5be1b6/go.mod h1:grANhF5doyWs3UAsr3K4I6qtAmlQcZDesFNEHPZAzj8=
@@ -23,6 +31,9 @@ github.com/blakesmith/ar v0.0.0-20150311145944-8bd4349a67f2 h1:oMCHnXa6CCCafdPDb
 github.com/blakesmith/ar v0.0.0-20150311145944-8bd4349a67f2/go.mod h1:PkYb9DJNAwrSvRx5DYA+gUcOIgTGVMNkfSCbZM8cWpI=
 github.com/brocaar/loraserver v0.0.0-20190409085620-14c6fb22dcc4 h1:W9rhK+dC/2QbOSU6TRJn0NeT6unLzB0cAALF+1Ye7JM=
 github.com/brocaar/loraserver v0.0.0-20190409085620-14c6fb22dcc4/go.mod h1:xN+gy4o/yEVwO8C+4miov9G39qMgrpJTEnvlyQMI2Y0=
+github.com/brocaar/loraserver v0.0.0-20190422074053-c3336fb6b947 h1:SIPjr39mqsD/Nw83rPaTlRzjQZW5dtx9DqjlFon5ZfY=
+github.com/brocaar/loraserver v0.0.0-20190422074053-c3336fb6b947/go.mod h1:JH3jKu0OI6DJEd/iO8DQvKU67WOosJ9DK3orohlJfLA=
+github.com/brocaar/loraserver v2.5.0+incompatible h1:Fna4CF0jW2Vl4UpjLIhR5ifW4g+oZD/w3Dq09TiJ8Z8=
 github.com/brocaar/lorawan v0.0.0-20190308082318-5ed881e0a2d7/go.mod h1:l9eO0JU49MD1s/7nbwf2wh9QoxBsCSmTHUswkYb1IkI=
 github.com/brocaar/lorawan v0.0.0-20190402092148-5bca41b178e9 h1:cX5HHyYJFZQLIeSNvydOr+CkoBmqYsv9oB6ZzYn8EN8=
 github.com/brocaar/lorawan v0.0.0-20190402092148-5bca41b178e9/go.mod h1:Fm+51pxK6mZoAQjIaWJqPmnRuXecozsM5Mf9c+kr/ko=
@@ -33,24 +44,29 @@ github.com/campoy/unique v0.0.0-20180121183637-88950e537e7e/go.mod h1:9IOqJGCPMS
 github.com/client9/misspell v0.3.4/go.mod h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDkc90ppPyw=
 github.com/cockroachdb/apd v1.1.0/go.mod h1:8Sl8LxpKi29FqWXR16WEFZRNSz3SoPzUzeMeY4+DwBQ=
 github.com/cockroachdb/cockroach-go v0.0.0-20181001143604-e0a95dfd547c/go.mod h1:XGLbWH/ujMcbPbhZq52Nv6UrCghb1yGn//133kEsvDk=
+github.com/codahale/hdrhistogram v0.0.0-20161010025455-3a0bb77429bd/go.mod h1:sE/e/2PUdi/liOCUjSTXgM1o87ZssimdTWN964YiIeI=
 github.com/codegangsta/negroni v1.0.0/go.mod h1:v0y3T5G7Y1UlFfyxFn/QLRU4a2EuNau2iZY63YTKWo0=
 github.com/coreos/etcd v3.3.10+incompatible/go.mod h1:uF7uidLiAD3TWHmW31ZFd/JWoc32PjwdhPthX9715RE=
 github.com/coreos/go-etcd v2.0.0+incompatible/go.mod h1:Jez6KQU2B/sWsbdaef3ED8NzMklzPG4d5KIOhIy30Tk=
 github.com/coreos/go-semver v0.2.0/go.mod h1:nnelYz7RCh+5ahJtPPxZlU+153eP4D4r3EedlOD2RNk=
 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/dgrijalva/jwt-go v0.0.0-20180308231308-06ea1031745c/go.mod h1:E3ru+11k8xSBh+hMPgOLZmtrrCbhqsmaPHjLKYnJCaQ=
 github.com/dgrijalva/jwt-go v3.2.0+incompatible h1:7qlOGliEKZXTDg6OTjfoBKDXWrumCAMpl/TFQ4/5kLM=
 github.com/dgrijalva/jwt-go v3.2.0+incompatible/go.mod h1:E3ru+11k8xSBh+hMPgOLZmtrrCbhqsmaPHjLKYnJCaQ=
 github.com/dustin/go-humanize v0.0.0-20180713052910-9f541cc9db5d/go.mod h1:HtrtbFcZ19U5GC7JDqmcUSB87Iq5E25KnS6fMYU6eOk=
 github.com/dustin/go-humanize v1.0.0/go.mod h1:HtrtbFcZ19U5GC7JDqmcUSB87Iq5E25KnS6fMYU6eOk=
 github.com/eclipse/paho.mqtt.golang v0.0.0-20190117150808-cb7eb9363b44 h1:rb/YAc+4+BUTDrQhBZHNim9wxFmpaLZDICe5spmjMcs=
 github.com/eclipse/paho.mqtt.golang v0.0.0-20190117150808-cb7eb9363b44/go.mod h1:H9keYFcgq3Qr5OUJm/JZI/i6U7joQ8SYLhZwfeOo6Ts=
+github.com/eclipse/paho.mqtt.golang v1.1.1 h1:iPJYXJLaViCshRTW/PSqImSS6HJ2Rf671WR0bXZ2GIU=
+github.com/eclipse/paho.mqtt.golang v1.1.1/go.mod h1:H9keYFcgq3Qr5OUJm/JZI/i6U7joQ8SYLhZwfeOo6Ts=
 github.com/elazarl/go-bindata-assetfs v1.0.0/go.mod h1:v+YaWX3bdea5J/mo8dSETolEo7R71Vk1u8bnjau5yw4=
 github.com/fatih/color v1.7.0 h1:DkWD4oS2D8LGGgTQ6IvwJJXSL5Vp2ffcQg58nFV38Ys=
 github.com/fatih/color v1.7.0/go.mod h1:Zm6kSWBoL9eyXnKyktHP6abPY2pDugNf5KwzbycvMj4=
 github.com/fatih/structs v1.0.0/go.mod h1:9NiDSp5zOcgEDl+j00MP/WkGVPOlPRLejGD8Ga6PJ7M=
 github.com/fatih/structs v1.1.0/go.mod h1:9NiDSp5zOcgEDl+j00MP/WkGVPOlPRLejGD8Ga6PJ7M=
+github.com/fortytw2/leaktest v1.2.0/go.mod h1:jDsjWgpAGjm2CA7WthBh/CdZYEPF31XHquHwclZch5g=
 github.com/fsnotify/fsnotify v1.4.7 h1:IXs+QLmnXW2CcXuY+8Mzv/fWEsPGWxqefPtCP5CnV9I=
 github.com/fsnotify/fsnotify v1.4.7/go.mod h1:jwhsz4b93w/PPRr/qN1Yymfu8t87LnFCMoQvtojpjFo=
 github.com/ghodss/yaml v1.0.0/go.mod h1:4dBDuWmgqj2HViK6kFavaiC9ZROes6MMH2rRYeMEF04=
@@ -372,6 +388,7 @@ github.com/onsi/ginkgo v1.7.0/go.mod h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+W
 github.com/onsi/gomega v1.4.1/go.mod h1:C1qb7wdrVGGVU+Z6iS04AVkA3Q65CEZX59MT0QO5uiA=
 github.com/onsi/gomega v1.4.2/go.mod h1:ex+gbHU/CVuBBDIJjb2X0qEXbFg53c61hWP/1CpauHY=
 github.com/onsi/gomega v1.4.3/go.mod h1:ex+gbHU/CVuBBDIJjb2X0qEXbFg53c61hWP/1CpauHY=
+github.com/opentracing/opentracing-go v1.0.2/go.mod h1:UkNAQd3GIcIGf0SeVgPpRdFStlNbqXla1AfSYxPUl2o=
 github.com/openzipkin/zipkin-go v0.1.1/go.mod h1:NtoC/o8u3JlF1lSlyPNswIbeQH9bJTmOf0Erfk+hxe8=
 github.com/pelletier/go-toml v1.2.0 h1:T5zMGML61Wp+FlcbWjRDT7yAxhJNAiPPLOFECq181zc=
 github.com/pelletier/go-toml v1.2.0/go.mod h1:5z9KED0ma1S8pY6P1sdut58dfprrGBbd/94hg7ilaic=
@@ -449,12 +466,17 @@ github.com/stretchr/testify v1.2.1/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXf
 github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=
 github.com/stretchr/testify v1.3.0 h1:TivCn/peBQ7UY8ooIcPgZFpTNSz0Q2U6UrFlUfqbe0Q=
 github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
+github.com/uber-go/atomic v1.3.2/go.mod h1:/Ct5t2lcmbJ4OSe/waGBoaVvVqtO0bmtfVNex1PFV8g=
+github.com/uber/jaeger-client-go v2.15.0+incompatible/go.mod h1:WVhlPFC8FDjOFMMWRy2pZqQJSXxYSwNYOkTr/Z6d3Kk=
+github.com/uber/jaeger-lib v1.5.0/go.mod h1:ComeNDZlWwrWnDv8aPp0Ba6+uUTzImX/AauajbLI56U=
 github.com/ugorji/go/codec v0.0.0-20181204163529-d75b2dcb6bc8/go.mod h1:VFNgLljTbGfSG7qAOspJ7OScBnGdDN/yBr0sguwnwf0=
 github.com/unrolled/secure v0.0.0-20180918153822-f340ee86eb8b/go.mod h1:mnPT77IAdsi/kV7+Es7y+pXALeV3h7G6dQF6mNYjcLA=
 github.com/unrolled/secure v0.0.0-20181005190816-ff9db2ff917f/go.mod h1:mnPT77IAdsi/kV7+Es7y+pXALeV3h7G6dQF6mNYjcLA=
 github.com/xordataexchange/crypt v0.0.3-0.20170626215501-b2862e3d0a77/go.mod h1:aYKd//L2LvnjZzWKhF00oedf4jCCReLcmhLdhm1A27Q=
 github.com/ziutek/mymysql v1.5.4/go.mod h1:LMSpPZ6DbqWFxNCHW77HeMg9I646SAhApZ/wKdgO/C0=
+go.opencensus.io v0.15.0/go.mod h1:UffZAU+4sDEINUGP/B7UfBBkq4fqLu9zXAX7ke6CHW0=
 go.opencensus.io v0.18.0/go.mod h1:vKdFvxhtzZ9onBp9VKHK8z/sRpBMnKAsufL7wlDrCOA=
+go.uber.org/atomic v1.3.2/go.mod h1:gD2HeocX3+yG+ygLZcrzQJaqmWj9AIm7n08wl/qW/PE=
 golang.org/x/crypto v0.0.0-20180904163835-0709b304e793/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4=
 golang.org/x/crypto v0.0.0-20180910181607-0e37d006457b/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4=
 golang.org/x/crypto v0.0.0-20181001203147-e3636079e1a4/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4=
@@ -480,6 +502,7 @@ golang.org/x/lint v0.0.0-20181026193005-c67002cb31c3/go.mod h1:UVdnD1Gm6xHRNCYTk
 golang.org/x/lint v0.0.0-20190409202823-959b441ac422 h1:QzoH/1pFpZguR8NrRHLcO6jKqfv2zpuSqZLgdm7ZmjI=
 golang.org/x/lint v0.0.0-20190409202823-959b441ac422/go.mod h1:6SW0HCj/g11FgYtHlgUYUwCkIfeOF89ocIRzGO/8vkc=
 golang.org/x/net v0.0.0-20180724234803-3673e40ba225/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
+golang.org/x/net v0.0.0-20180811021610-c39426892332/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
 golang.org/x/net v0.0.0-20180816102801-aaf60122140d/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
 golang.org/x/net v0.0.0-20180826012351-8a410e7b638d/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
 golang.org/x/net v0.0.0-20180906233101-161cd47e91fd/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
@@ -498,6 +521,7 @@ golang.org/x/net v0.0.0-20181220203305-927f97764cc3/go.mod h1:mL1N/T3taQHkDXs73r
 golang.org/x/net v0.0.0-20190108225652-1e06a53dbb7e/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
 golang.org/x/net v0.0.0-20190301231341-16b79f2e4e95/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
 golang.org/x/net v0.0.0-20190311183353-d8887717615a/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
+golang.org/x/net v0.0.0-20190322120337-addf6b3196f6/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
 golang.org/x/net v0.0.0-20190328230028-74de082e2cca h1:hyA6yiAgbUwuWqtscNvWAI7U1CtlaD1KilQ6iudt1aI=
 golang.org/x/net v0.0.0-20190328230028-74de082e2cca/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
 golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3 h1:0GoQqolDA55aaLxZyTzK/Y2ePZzZTUrRacwib7cNsYQ=
@@ -612,3 +636,5 @@ gopkg.in/yaml.v2 v2.2.1/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
 gopkg.in/yaml.v2 v2.2.2 h1:ZCJp+EgiOT7lHqUV2J862kp8Qj64Jo6az82+3Td9dZw=
 gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
 honnef.co/go/tools v0.0.0-20180728063816-88497007e858/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
+pack.ag/amqp v0.8.0/go.mod h1:4/cbmt4EJXSKlG6LCfWHoqmN0uFdy5i/+YFz+fTfhV4=
+pack.ag/amqp v0.11.0/go.mod h1:4/cbmt4EJXSKlG6LCfWHoqmN0uFdy5i/+YFz+fTfhV4=
diff --git a/internal/config/config.go b/internal/config/config.go
@@ -1,6 +1,8 @@
 package config
 
-import "time"
+import (
+	"time"
+)
 
 // Config defines the configuration structure.
 type Config struct {
@@ -91,6 +93,15 @@ type Config struct {
 			Bind            string `mapstructure:"bind"`
 		}
 	}
+
+	MetaData struct {
+		Static  map[string]string `mapstructure:"static"`
+		Dynamic struct {
+			ExecutionInterval    time.Duration     `mapstructure:"execution_interval"`
+			MaxExecutionDuration time.Duration     `mapstructure:"max_execution_duration"`
+			Commands             map[string]string `mapstructure:"commands"`
+		} `mapstructure:"dynamic"`
+	} `mapstructure:"meta_data"`
 }
 
 // C holds the global configuration.
diff --git a/internal/forwarder/forwarder.go b/internal/forwarder/forwarder.go
@@ -7,6 +7,7 @@ import (
 	"github.com/brocaar/lora-gateway-bridge/internal/backend"
 	"github.com/brocaar/lora-gateway-bridge/internal/config"
 	"github.com/brocaar/lora-gateway-bridge/internal/integration"
+	"github.com/brocaar/lora-gateway-bridge/internal/metadata"
 	"github.com/brocaar/loraserver/api/gw"
 	"github.com/brocaar/lorawan"
 )
@@ -108,6 +109,9 @@ func forwardGatewayStatsLoop() {
 			var gatewayID lorawan.EUI64
 			copy(gatewayID[:], stats.GatewayId)
 
+			// add meta-data to stats
+			stats.MetaData = metadata.Get()
+
 			if err := integration.GetIntegration().PublishEvent(gatewayID, integration.EventStats, &stats); err != nil {
 				log.WithError(err).WithFields(log.Fields{
 					"gateway_id": gatewayID,
diff --git a/internal/metadata/metadata.go b/internal/metadata/metadata.go
diff --git a/internal/metadata/metadata_test.go b/internal/metadata/metadata_test.go

Original file line number	Diff line number	Diff line change
`@@ -62,6 +62,9 @@ func init() {`
`62`	`62`
`63`	`63`	`viper.SetDefault("integration.mqtt.auth.azure_iot_hub.sas_token_expiration", 24*time.Hour)`
`64`	`64`
	`65`	`+ viper.SetDefault("meta_data.dynamic.execution_interval", time.Minute)`
	`66`	`+ viper.SetDefault("meta_data.dynamic.max_execution_duration", time.Second)`
	`67`	`+`
`65`	`68`	`rootCmd.AddCommand(versionCmd)`
`66`	`69`	`rootCmd.AddCommand(configCmd)`
`67`	`70`	`}`
Original file line number	Diff line number	Diff line change
`@@ -13,6 +13,7 @@ import (`
`13`	`13`	`"github.com/brocaar/lora-gateway-bridge/internal/config"`
`14`	`14`	`"github.com/brocaar/lora-gateway-bridge/internal/forwarder"`
`15`	`15`	`"github.com/brocaar/lora-gateway-bridge/internal/integration"`
	`16`	`+ "github.com/brocaar/lora-gateway-bridge/internal/metadata"`
`16`	`17`	`"github.com/brocaar/lora-gateway-bridge/internal/metrics"`
`17`	`18`	`)`
`18`	`19`
`@@ -25,6 +26,7 @@ func run(cmd *cobra.Command, args []string) error {`
`25`	`26`	`setupIntegration,`
`26`	`27`	`setupForwarder,`
`27`	`28`	`setupMetrics,`
	`29`	`+ setupMetaData,`
`28`	`30`	`}`
`29`	`31`
`30`	`32`	`for _, t := range tasks {`
`@@ -81,3 +83,10 @@ func setupMetrics() error {`
`81`	`83`	`}`
`82`	`84`	`return nil`
`83`	`85`	`}`
	`86`	`+`
	`87`	`+func setupMetaData() error {`
	`88`	`+ if err := metadata.Setup(config.C); err != nil {`
	`89`	`+ return errors.Wrap(err, "setup meta-data error")`
	`90`	`+ }`
	`91`	`+ return nil`
	`92`	`+}`