(t *testing.T)
| 1883 | } |
| 1884 | |
| 1885 | func TestCreateIndexTwoNodes(t *testing.T) { |
| 1886 | cfg := cbgt.NewCfgMem() |
| 1887 | |
| 1888 | emptyDir0, _ := ioutil.TempDir("./tmp", "test") |
| 1889 | emptyDir1, _ := ioutil.TempDir("./tmp", "test") |
| 1890 | defer os.RemoveAll(emptyDir0) |
| 1891 | defer os.RemoveAll(emptyDir1) |
| 1892 | |
| 1893 | meh0 := &TestMEH{} |
| 1894 | meh1 := &TestMEH{} |
| 1895 | mgr0 := cbgt.NewManager(cbgt.VERSION, cfg, cbgt.NewUUID(), |
| 1896 | nil, "", 1, "", "localhost:1000", emptyDir0, "some-datasource", meh0) |
| 1897 | mgr1 := cbgt.NewManager(cbgt.VERSION, cfg, cbgt.NewUUID(), |
| 1898 | nil, "", 1, "", "localhost:2000", emptyDir1, "some-datasource", meh1) |
| 1899 | |
| 1900 | mgr0.Start("wanted") |
| 1901 | mgr1.Start("wanted") |
| 1902 | mgr0.Kick("test-start-kick") |
| 1903 | mgr1.Kick("test-start-kick") |
| 1904 | |
| 1905 | mr0, _ := cbgt.NewMsgRing(os.Stderr, 1000) |
| 1906 | mr1, _ := cbgt.NewMsgRing(os.Stderr, 1000) |
| 1907 | |
| 1908 | router0, _, err := NewRESTRouter("v0", mgr0, "static", "", mr0, nil) |
| 1909 | if err != nil || router0 == nil { |
| 1910 | t.Errorf("no mux router") |
| 1911 | } |
| 1912 | router1, _, err := NewRESTRouter("v0", mgr1, "static", "", mr1, nil) |
| 1913 | if err != nil || router1 == nil { |
| 1914 | t.Errorf("no mux router") |
| 1915 | } |
| 1916 | |
| 1917 | nd, _, err := cbgt.CfgGetNodeDefs(cfg, cbgt.NODE_DEFS_KNOWN) |
| 1918 | if err != nil { |
| 1919 | t.Errorf("expected node defs known") |
| 1920 | } |
| 1921 | if len(nd.NodeDefs) != 2 { |
| 1922 | t.Errorf("expected 2 node defs unknown") |
| 1923 | } |
| 1924 | |
| 1925 | nd, _, err = cbgt.CfgGetNodeDefs(cfg, cbgt.NODE_DEFS_WANTED) |
| 1926 | if err != nil { |
| 1927 | t.Errorf("expected node defs wanted") |
| 1928 | } |
| 1929 | if len(nd.NodeDefs) != 2 { |
| 1930 | t.Errorf("expected 2 node defs wanted") |
| 1931 | } |
| 1932 | |
| 1933 | if cfg.Refresh() != nil { |
| 1934 | t.Errorf("expected cfg refresh to work") |
| 1935 | } |
| 1936 | |
| 1937 | mgr0.Kick("test-start-kick-again") |
| 1938 | mgr1.Kick("test-start-kick-again") |
| 1939 | |
| 1940 | httpGetPrev := HttpGet |
| 1941 | defer func() { HttpGet = httpGetPrev }() |
| 1942 |
nothing calls this directly
no test coverage detected