Function TestNodePlanParams

rest_test.go:2664–2750

(t *testing.T)

}

func TestNodePlanParams(t *testing.T) {
	cfg, mgr0, router0 := testCreateIndex1Node(t,
		[]string{`{"maxPartitionsPerPIndex":1,"numReplicas":0,"nodePlanParams":{"":{"":{"canRead":false,"canWrite":false}}}}`},
		2, 0)

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

	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")
	}

	if cfg.Refresh() != nil {
		t.Errorf("expected cfg refresh to work")
	}

	runtime.Gosched()

	mgr0.Kick("test-kick-after-new-node")

	planPIndexesCurr, casCurr, err := cbgt.CfgGetPlanPIndexes(cfg)