run go fmt

Author: MKrupauskas

dnshostprovider.go

@@ -1,8 +1,8 @@
 package zk
 
 import (
-	"fmt"
 	"context"
+	"fmt"
 	"net"
 	"sync"
 	"time"
@@ -37,12 +37,12 @@ func (o lookupTimeoutOption) apply(provider *DNSHostProvider) {
 // the call to Init.  It could be easily extended to re-query DNS
 // periodically or if there is trouble connecting.
 type DNSHostProvider struct {
-	mu         sync.Mutex // Protects everything, so we can add asynchronous updates later.
-	servers    []string
-	curr       int
-	last       int
+	mu            sync.Mutex // Protects everything, so we can add asynchronous updates later.
+	servers       []string
+	curr          int
+	last          int
 	lookupTimeout time.Duration
-	lookupHost lookupHostFn // Override of net.LookupHost, for testing.
+	lookupHost    lookupHostFn // Override of net.LookupHost, for testing.
 }
 
 // NewDNSHostProvider creates a new DNSHostProvider with the given options.

dnshostprovider_test.go

@@ -34,7 +34,7 @@ func TestIntegration_DNSHostProviderCreate(t *testing.T) {
 	port := ts.Servers[0].Port
 	server := fmt.Sprintf("foo.example.com:%d", port)
 	hostProvider := NewDNSHostProvider(
-		withLookupHost(func (ctx context.Context, host string) ([]string, error) {
+		withLookupHost(func(ctx context.Context, host string) ([]string, error) {
 			if _, ok := ctx.Deadline(); !ok {
 				t.Fatal("No lookup context deadline set")
 			}
@@ -245,7 +245,7 @@ func TestDNSHostProviderRetryStart(t *testing.T) {
 }
 
 func TestNewDNSHostProvider(t *testing.T) {
-	want := 5*time.Second
+	want := 5 * time.Second
 	provider := NewDNSHostProvider(WithLookupTimeout(want))
 	if provider.lookupTimeout != want {
 		t.Fatalf("expected lookup timeout to be %v, got %v", want, provider.lookupTimeout)