Method TestInitFromExistingConfig

supervisor/supervisor_test.go:48–67

(c *C)

}

func (s *SupervisorSuite) TestInitFromExistingConfig(c *C) {
	e := testutils.NewResponder("Hi, I'm endpoint")
	defer e.Close()

	b := MakeBatch(Batch{Addr: "localhost:11800", Route: `Path("/")`, URL: e.URL})
	c.Assert(s.ng.UpsertBackend(b.B), IsNil)
	c.Assert(s.ng.UpsertServer(b.BK, b.S, engine.NoTTL), IsNil)
	c.Assert(s.ng.UpsertFrontend(b.F, engine.NoTTL), IsNil)
	c.Assert(s.ng.UpsertListener(b.L), IsNil)

	sup := New(newProxy, s.ng, Options{Clock: s.clock})

	// When
	c.Assert(sup.Start(), IsNil)
	defer sup.Stop()

	// Then
	time.Sleep(10 * time.Millisecond)
	c.Assert(GETResponse(c, b.FrontendURL("/")), Equals, "Hi, I'm endpoint")
}

func (s *SupervisorSuite) TestInitOnTheFly(c *C) {
	e := testutils.NewResponder("Hi, I'm endpoint")