Riot missing features

.gitignore

@@ -16,6 +16,10 @@ tests/cloud/aws/results
 tests/cloud/aws/to_upload/rendered
 tests/results
 c-deps/libs
+c-deps/bzip2
+c-deps/lz4
+c-deps/zlib
+c-deps/zstd
 
 # Documents
 *.pdf

client/client.go

@@ -157,7 +157,7 @@ func NewHTTPClient(options ...HTTPClientOptionF) (*HTTPClient, error) {
 
 	if client.healthCheckEnabled {
 		// perform an initial healthcheck
-		client.healthCheck(client.healthCheckTimeout)
+		client.clusterHealthCheck(client.healthCheckTimeout)
 	}
 
 	// Ensure that we have at least one endpoint, the primary, available
@@ -251,7 +251,7 @@ func (c *HTTPClient) callPrimary(method, path string, data []byte) ([]byte, erro
 
 		if !retried && endpoint.IsDead() {
 			if c.healthCheckEnabled {
-				c.healthCheck(c.healthCheckTimeout)
+				c.clusterHealthCheck(c.healthCheckTimeout)
 			}
 			retried = true
 			continue
@@ -335,7 +335,7 @@ func (c *HTTPClient) doReq(method string, endpoint *endpoint, path string, data
 // healthCheck does a health check on all nodes in the cluster.
 // Depending on the node state, it marks connections as dead, alive etc.
 // The timeout specifies how long to wait for a response from QED.
-func (c *HTTPClient) healthCheck(timeout time.Duration) {
+func (c *HTTPClient) clusterHealthCheck(timeout time.Duration) {
 
 	var wg sync.WaitGroup
 	for _, e := range c.topology.Endpoints() {
@@ -378,7 +378,6 @@ func (c *HTTPClient) healthCheck(timeout time.Duration) {
 	}
 
 	wg.Wait()
-
 }
 
 // discover uses the shards info API to return the list of nodes in the cluster.
@@ -387,7 +386,6 @@ func (c *HTTPClient) healthCheck(timeout time.Duration) {
 func (c *HTTPClient) discover() error {
 
 	for {
-
 		e, err := c.topology.NextReadEndpoint(Any)
 		if err != nil {
 			return err
@@ -433,7 +431,7 @@ func (c *HTTPClient) startHealthChecker() {
 		case <-c.healthCheckStopCh:
 			return
 		case <-ticker.C:
-			c.healthCheck(timeout)
+			c.clusterHealthCheck(timeout)
 		}
 	}
 }
@@ -463,7 +461,6 @@ func (c *HTTPClient) Add(event string) (*protocol.Snapshot, error) {
 	}
 
 	return &snapshot, nil
-
 }
 
 // AddBulk will do a request to the server with a post data to store a bulk of new events.

client/client_test.go

@@ -242,7 +242,7 @@ func TestHealthCheck(t *testing.T) {
 	require.False(t, client.topology.HasActiveEndpoint())
 
 	// try to revive them
-	client.healthCheck(5 * time.Second)
+	client.clusterHealthCheck(5 * time.Second)
 	time.Sleep(1 * time.Second)
 	require.True(t, client.topology.HasActiveEndpoint())
 }

deploy/provision.sh

@@ -22,8 +22,9 @@ then
 fi
 
 echo "Pulling terraform remote state to: $TF_STATE"
+cd aws
 terraform state pull > $TF_STATE
-cd provision
+cd ../provision
 
 if [ -z "$@" ];
 then