Function TestCreateIndexThenFreezePlanThenAddNode

rest_test.go:2582–2662

(t *testing.T)

}

func TestCreateIndexThenFreezePlanThenAddNode(t *testing.T) {
	cfg, mgr0, router0 := testCreateIndex1Node(t,
		[]string{`{"maxPartitionsPerPIndex":1}`}, 2, 1)

	tests := []*RESTHandlerTest{
		{
			Desc:   "count myIdx should be 0, 1 nodes",
			Path:   "/api/index/myIdx/count",
			Method: "GET",
			Status: http.StatusOK,
			ResponseMatch: map[string]bool{
				`{"status":"ok","count":0}`: true,
			},
		},
	}
	testRESTHandlers(t, tests, router0)

	indexDefs, indexDefsCas, err := cbgt.CfgGetIndexDefs(cfg)
	if err != nil {
		t.Errorf("error CfgGetIndexDefs: %v", err)
	}
	indexDefs.IndexDefs["myIdx"].PlanParams.PlanFrozen = true
	_, err = cbgt.CfgSetIndexDefs(cfg, indexDefs, indexDefsCas)
	if err != nil {
		t.Errorf("expected CfgSetIndexDefs for plan freeze to work")
	}

	planPIndexesPrev, casPrev, err := cbgt.CfgGetPlanPIndexes(cfg)
	if err != nil {
		t.Errorf("expected no err")
	}

	emptyDir1, _ := ioutil.TempDir("./tmp", "test")
	defer os.RemoveAll(emptyDir1)

	meh1 := &TestMEH{}
	mgr1 := cbgt.NewManager(cbgt.VERSION, cfg, cbgt.NewUUID(),
		nil, "", 1, "", "localhost:2000", emptyDir1,
		"some-datasource", meh1)
	mgr1.Start("wanted")
	mgr1.Kick("test-start-kick")

	nd, _, err := cbgt.CfgGetNodeDefs(cfg, cbgt.NODE_DEFS_KNOWN)
	if err != nil {
		t.Errorf("expected node defs known")
	}
	if len(nd.NodeDefs) != 2 {
		t.Errorf("expected 2 node defs unknown")
	}

	nd, _, err = cbgt.CfgGetNodeDefs(cfg, cbgt.NODE_DEFS_WANTED)
	if err != nil {
		t.Errorf("expected node defs wanted")
	}
	if len(nd.NodeDefs) != 2 {
		t.Errorf("expected 2 node defs wanted")
	}