Merge pull request #103 from semi-technologies/replication_factor_support

Adds support for replication factor

Author: antas-marcin

ci/docker-compose-wcs.yml

@@ -10,7 +10,7 @@ services:
       - --scheme
       - http
       - --write-timeout=600s
-    image: semitechnologies/weaviate:1.16.5
+    image: semitechnologies/weaviate:preview-replace-shardingconfig-replicas-with-replication-factor-29e987d
     ports:
       - 8083:8083
     restart: on-failure:0

ci/docker-compose.yml

@@ -2,7 +2,7 @@
 version: '3.4'
 services:
   weaviate:
-    image: semitechnologies/weaviate:1.16.5
+    image: semitechnologies/weaviate:preview-replace-shardingconfig-replicas-with-replication-factor-29e987d
     restart: on-failure:0
     ports:
       - "8080:8080"

cluster/journey.test.js

@@ -1,8 +1,8 @@
 const weaviate = require("../index");
 const { createTestFoodSchemaAndData, cleanupTestFood, PIZZA_CLASS_NAME, SOUP_CLASS_NAME } = require("../utils/testData");
 
-const EXPECTED_WEAVIATE_VERSION = "1.16.5"
-const EXPECTED_WEAVIATE_GIT_HASH = "438e826"
+const EXPECTED_WEAVIATE_VERSION = "1.17.0-prealpha"
+const EXPECTED_WEAVIATE_GIT_HASH = "29e987d"
 
 describe("cluster nodes endpoint", () => {
   const client = weaviate.client({

schema/journey.test.js

@@ -173,9 +173,8 @@ describe("schema", () => {
                   removals: null
                 }
               },
-              moduleConfig: { 
-                'text2vec-contextionary': 
-                { 
+              moduleConfig: {
+                'text2vec-contextionary': {
                   vectorizeClassName: true
                 }
               },
@@ -189,6 +188,9 @@ describe("schema", () => {
                 strategy: "hash",
                 virtualPerPhysical: 128,
               },
+              replicationConfig: {
+                factor: 1,
+              },
             },
           ],
         });
@@ -333,7 +335,7 @@ describe("schema", () => {
 
   it("creates a class with bm25 and stopwords config", async () => {
     var newClass = {
-      class: 'EmptyClass', 
+      class: 'EmptyClass',
       properties: [{dataType: ["string"],name: 'stringProp'}]
     }
 
@@ -360,6 +362,37 @@ describe("schema", () => {
 
     return deleteClass(client, newClass.class);
   });
+
+  it("creates a class with explicit replication config", async () => {
+    const replicationFactor = 2;
+    var newClass = newClassObject("SomeClass");
+    newClass.replicationConfig.factor = replicationFactor;
+
+    await client.schema
+      .classCreator()
+      .withClass(newClass)
+      .do()
+      .then(res => {
+        expect(res).toHaveProperty('replicationConfig.factor', replicationFactor);
+      });
+
+    return deleteClass(client, newClass.class);
+  });
+
+  it("creates a class with implicit replication config", async () => {
+    var newClass = newClassObject("SomeClass");
+    delete newClass.replicationConfig
+
+    await client.schema
+      .classCreator()
+      .withClass(newClass)
+      .do()
+      .then(res => {
+        expect(res).toHaveProperty('replicationConfig.factor', 1);
+      });
+
+    return deleteClass(client, newClass.class);
+  });
 });
 
 function newClassObject(className) {
@@ -421,6 +454,9 @@ function newClassObject(className) {
       strategy: "hash",
       virtualPerPhysical: 128,
     },
+    replicationConfig: {
+      factor: 1,
+    },
   };
 }