Function TestCreateIndex1PIndexAddNode

rest_test.go:2412–2509

(t *testing.T)

}

func TestCreateIndex1PIndexAddNode(t *testing.T) {
	cfg, mgr0, router0 := testCreateIndex1Node(t,
		[]string{`{"maxPartitionsPerPIndex":100}`}, 1, 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,
			},
		},
		{
			Desc:   "query myIdx should have 0 hits, 1 nodes",
			Path:   "/api/index/myIdx/query",
			Method: "POST",
			Params: nil,
			Body:   []byte(`{"size":10,"query":{"query":"no-hits"}}`),
			Status: http.StatusOK,
			ResponseMatch: map[string]bool{
				`"hits":[],"total_hits":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)

	options := map[string]string{"enablePartitionNodeStickiness": "true"}

	meh1 := &TestMEH{}
	mgr1 := cbgt.NewManagerEx(cbgt.VERSION, cfg, cbgt.NewUUID(),
		nil, "", 1, "", "localhost:2000",
		emptyDir1, "some-datasource", meh1, options)
	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 {