Lowered keep-alive to trigger load-balancing.

Author: Dan Larkin-York

pkg/util/arangod/client.go

@@ -65,23 +65,23 @@ var (
 		Proxy: nhttp.ProxyFromEnvironment,
 		DialContext: (&net.Dialer{
 			Timeout:   30 * time.Second,
-			KeepAlive: 30 * time.Second,
+			KeepAlive: 100 * time.Millisecond,
 			DualStack: true,
 		}).DialContext,
 		MaxIdleConns:          100,
-		IdleConnTimeout:       90 * time.Second,
+		IdleConnTimeout:       100 * time.Millisecond,
 		TLSHandshakeTimeout:   10 * time.Second,
 		ExpectContinueTimeout: 1 * time.Second,
 	}
 	sharedHTTPSTransport = &nhttp.Transport{
 		Proxy: nhttp.ProxyFromEnvironment,
 		DialContext: (&net.Dialer{
 			Timeout:   30 * time.Second,
-			KeepAlive: 30 * time.Second,
+			KeepAlive: 100 * time.Millisecond,
 			DualStack: true,
 		}).DialContext,
 		MaxIdleConns:          100,
-		IdleConnTimeout:       90 * time.Second,
+		IdleConnTimeout:       100 * time.Millisecond,
 		TLSHandshakeTimeout:   10 * time.Second,
 		ExpectContinueTimeout: 1 * time.Second,
 		TLSClientConfig:       &tls.Config{InsecureSkipVerify: true},

tests/load_balancer_test.go

@@ -26,7 +26,7 @@ import (
 	"context"
 	"reflect"
 	"testing"
-	//"time"
+	"time"
 
 	"github.com/dchest/uniuri"
 
@@ -250,6 +250,7 @@ func LoadBalancingCursorSubtest(t *testing.T, useVst bool) {
 					if (wasForwarded(&r)) {
 						someRequestForwarded = true
 					}
+					time.Sleep(200 * time.Millisecond)
 				}
 				if len(result) != len(test.ExpectedDocuments) {
 					t.Errorf("Expected %d documents, got %d in query %d (%s)", len(test.ExpectedDocuments), len(result), i, test.Query)

tests/test_util.go

@@ -103,7 +103,8 @@ func createArangodVSTConfigForDNSNames(ctx context.Context, cli corev1.CoreV1Int
 		tlsConfig = &tls.Config{InsecureSkipVerify: true}
 	}
 	transport := vstProtocol.TransportConfig{
-		Version: vstProtocol.Version1_1,
+		IdleConnTimeout:	100 * time.Millisecond,
+		Version: 					vstProtocol.Version1_1,
 	}
 	connConfig := vst.ConnectionConfig{
 		TLSConfig: tlsConfig,