Function initClusterTest

worker/worker_test.go:150–161

(t *testing.T, schemaStr string)

}

func initClusterTest(t *testing.T, schemaStr string) *dgo.Dgraph {
	dg, err := testutil.DgraphClient(testutil.GetSockAddr())
	if err != nil {
		t.Fatalf("Error while getting a dgraph client: %v", err)
	}
	testutil.DropAll(t, dg)

	require.NoError(t, dg.Alter(context.Background(), &api.Operation{Schema: schemaStr}))
	populateClusterGraph(t, dg)

	return dg
}

func TestVectorSchema(t *testing.T) {
	dg := initClusterTest(t, `