Use Golang 1.13.1, Azure EventHubs SDK 2.0.3 (#9)

* update sdk, golang dependencies
* remove throughput calc

Author: bryanklewis

CHANGELOG.md

@@ -12,8 +12,13 @@ Template:
 ### Fixed
 ```
 
-## v0.3.3 - \[Unreleased\]
+## v0.3.3 - 14 October 2019
 ### Changed
+- build with golang 1.13.1
+- use azure event hubs sdk v2.0.3
+### Removed
+- throughput calc function
+### Fixed
 - debug message in hub package not accurate
 
 ## v0.3.2 - 20 August 2019

README.md

@@ -169,7 +169,7 @@ Encodes events as JSON using the goavro library. The Avro-JSON data model is the
 
 Requirements:
 
-* [Go](https://golang.org/dl/) 1.12.x or higher
+* [Go](https://golang.org/dl/) 1.13.x or higher
 * Go [modules](https://github.com/golang/go/wiki/Modules) is used for dependency management
 
 ```bash

azure-pipelines.yml

@@ -7,7 +7,7 @@ trigger:
     - master
 
 variables:
-    GOVERSION: '1.12.9'
+    GOVERSION: '1.13.1'
     LDFLAGS: "-w -s -X main.Version=$(Build.SourceBranchName) -X main.Commit=$(Build.SourceVersion) -X main.Build=$(Build.BuildNumber)"
 
 jobs:

go.mod

@@ -1,22 +1,21 @@
 module github.com/bryanklewis/prometheus-eventhubs-adapter
 
-go 1.12
+go 1.13
 
 require (
 	github.com/Azure/azure-amqp-common-go/v2 v2.1.0
-	github.com/Azure/azure-event-hubs-go/v2 v2.0.1
+	github.com/Azure/azure-event-hubs-go/v2 v2.0.3
 	github.com/Azure/go-autorest v12.0.0+incompatible
 	github.com/gin-gonic/gin v1.4.0
-	github.com/gogo/protobuf v1.2.1
+	github.com/gogo/protobuf v1.3.1
 	github.com/golang/snappy v0.0.1
-	github.com/linkedin/goavro/v2 v2.9.6
+	github.com/linkedin/goavro/v2 v2.9.7
 	github.com/mitchellh/go-homedir v1.1.0
-	github.com/prometheus/client_golang v1.0.0
-	github.com/prometheus/client_model v0.0.0-20190129233127-fd36f4220a90
-	github.com/prometheus/common v0.6.0
+	github.com/prometheus/client_golang v1.1.0
+	github.com/prometheus/client_model v0.0.0-20190812154241-14fe0d1b01d4
+	github.com/prometheus/common v0.7.0
 	github.com/prometheus/prometheus v2.5.0+incompatible
-	github.com/rs/zerolog v1.14.3
-	github.com/spf13/pflag v1.0.3
+	github.com/rs/zerolog v1.15.0
+	github.com/spf13/pflag v1.0.5
 	github.com/spf13/viper v1.4.0
-	google.golang.org/genproto v0.0.0-20190708153700-3bdd9d9f5532 // indirect
 )

go.sum

@@ -261,18 +261,6 @@ func writeHandler(w writer) func(c *gin.Context) {
 			log.ErrorObj(err).Int("num_samples", len(samples)).Msg("Error sending samples to remote storage")
 			return
 		}
-
-		counter, err := sentSamples.GetMetricWithLabelValues(w.Name())
-		if err != nil {
-			log.ErrorObj(err).Str("labelValue", w.Name()).Msg("Couldn't get a counter")
-		}
-		writeThroughput.SetCurrent(getCounterValue(counter))
-
-		select {
-		case d := <-writeThroughput.Values:
-			log.Info().Float64("samples_per_sec", d).Msg("Samples write throughput")
-		default:
-		}
 	}
 }
 

main.go

@@ -23,11 +23,7 @@ package main
 */
 
 import (
-	"time"
-
 	"github.com/prometheus/client_golang/prometheus"
-
-	"github.com/bryanklewis/prometheus-eventhubs-adapter/util"
 )
 
 var (
@@ -80,8 +76,6 @@ var (
 		},
 		[]string{"path"},
 	)
-
-	writeThroughput = util.NewThroughputCalc(time.Second)
 )
 
 func init() {
@@ -92,5 +86,4 @@ func init() {
 	prometheus.MustRegister(failedSamples)
 	prometheus.MustRegister(sentBatchDuration)
 	prometheus.MustRegister(httpRequestDuration)
-	writeThroughput.Start()
 }