Function TestExpandChecks

engine/vserver_test.go:262–297

(t *testing.T)

}

func TestExpandChecks(t *testing.T) {
	vserver := newTestVserver(nil)
	vserver.handleConfigUpdate(&vserverConfig)

	// 1 vserver healthcheck x 2 backends x 2 IPs +
	// 2 ventry healthchecks x 2 backends x 2 IPs x 2 ventries = 20
	if len(vserver.checks) != 20 {
		t.Errorf("Expected 20 total checks, got %d", len(vserver.checks))
	}

	count := 0
	for _, s := range vserver.services {
		for _, d := range s.dests {
			// 1 vserver healthcheck + 2 ventry healthchecks = 3 dests
			if len(d.checks) != 3 {
				t.Errorf("Expected 3 checks, got %d", len(d.checks))
			}
			for _, c := range d.checks {
				// vserver healthcheck
				if c.healthcheck.Port == vserverHC.Port && len(c.dests) != 2 {
					t.Errorf("Expected 2 dests for vserver healthcheck, got %d", len(c.dests))
				}
				// ventry healthcheck
				if c.healthcheck.Port != 5 && len(c.dests) != 1 {
					t.Errorf("Expected 1 dest for ventry healthcheck, got %d", len(c.dests))
				}
				count++
			}
		}
	}
	// 2 ventry x 2 IPs = 4 services
	// 4 services x 2 dests x (1 vserver healthcheck + 2 ventry healthchecks) = 24
	if count != 24 {
		t.Errorf("Expected 24 non-unique checks, got %d", count)
	}
}

type testStates struct {
	active  []bool