|
@@ -41,22 +41,25 @@ func TestEventDiscovery(t *testing.T) {
|
|
|
|
|
|
|
|
func TestEventNodeDownControl(t *testing.T) {
|
|
func TestEventNodeDownControl(t *testing.T) {
|
|
|
const targetNode = "node1"
|
|
const targetNode = "node1"
|
|
|
- t.Log("marking " + targetNode + " as down")
|
|
|
|
|
if err := ccm.AllUp(); err != nil {
|
|
if err := ccm.AllUp(); err != nil {
|
|
|
t.Fatal(err)
|
|
t.Fatal(err)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- session := createSession(t)
|
|
|
|
|
|
|
+ status, err := ccm.Status()
|
|
|
|
|
+ if err != nil {
|
|
|
|
|
+ t.Fatal(err)
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ cluster := createCluster()
|
|
|
|
|
+ cluster.Hosts = []string{status[targetNode].Addr}
|
|
|
|
|
+ session := createSessionFromCluster(cluster, t)
|
|
|
defer session.Close()
|
|
defer session.Close()
|
|
|
|
|
|
|
|
|
|
+ t.Log("marking " + targetNode + " as down")
|
|
|
if err := ccm.NodeDown(targetNode); err != nil {
|
|
if err := ccm.NodeDown(targetNode); err != nil {
|
|
|
t.Fatal(err)
|
|
t.Fatal(err)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- status, err := ccm.Status()
|
|
|
|
|
- if err != nil {
|
|
|
|
|
- t.Fatal(err)
|
|
|
|
|
- }
|
|
|
|
|
t.Logf("status=%+v\n", status)
|
|
t.Logf("status=%+v\n", status)
|
|
|
t.Logf("marking node %q down: %v\n", targetNode, status[targetNode])
|
|
t.Logf("marking node %q down: %v\n", targetNode, status[targetNode])
|
|
|
|
|
|