global http client

Author: gbaeke

devices.go

@@ -77,9 +77,6 @@ func (d device) deviceSend(interval int, ch chan<- string) {
 }
 
 func (d device) createDevice() (*http.Response, error) {
-	client := &http.Client{
-		Timeout: time.Second * 10,
-	}
 
 	reqBody, _ := json.Marshal(devicebody{DeviceID: d.Name})
 
@@ -98,9 +95,6 @@ func (d device) createDevice() (*http.Response, error) {
 // get device in IoT Hub
 // return 200 if device is found, 404 if not
 func (d device) getDevice() (*http.Response, error) {
-	client := &http.Client{
-		Timeout: time.Second * 10,
-	}
 
 	req, _ := http.NewRequest("GET", "https://"+Conf.IoTHubs[d.IoTHub]+"/devices/"+d.Name+"?api-version=2016-02-03", nil)
 
@@ -115,9 +109,6 @@ func (d device) getDevice() (*http.Response, error) {
 }
 
 func (d device) sendData(message devicemessage) (*http.Response, error) {
-	client := &http.Client{
-		Timeout: time.Second * 10,
-	}
 
 	reqBody, _ := json.Marshal(message)
 
@@ -135,9 +126,6 @@ func (d device) sendData(message devicemessage) (*http.Response, error) {
 }
 
 func (d device) deleteDevice() (*http.Response, error) {
-	client := &http.Client{
-		Timeout: time.Second * 10,
-	}
 
 	//fmt.Println("https://" + Conf.IoTHubs[d.IoTHub] + "/devices/" + d.Name + "?api-version=2016-11-14")
 

main.go

@@ -1,13 +1,20 @@
 package main
 
-import "flag"
-import "fmt"
-import "os"
-import "runtime"
+import (
+	"flag"
+	"fmt"
+	"net/http"
+	"os"
+	"runtime"
+	"time"
+)
 
 // define a flag -r to remove all devices
 var removeDevices = flag.Bool("r", false, "Remove devices from IoT Hub")
 
+// http client
+var client *http.Client
+
 func main() {
 	// logical processors for goroutines
 	runtime.GOMAXPROCS(runtime.NumCPU())
@@ -16,6 +23,11 @@ func main() {
 	// in this case goroutines will communicate with main() which is also a goroutine
 	ch := make(chan string)
 
+	// http client
+	client = &http.Client{
+		Timeout: time.Second * 10,
+	}
+
 	// parse flags
 	flag.Parse()