Method TestTransferFiles

supervisor/supervisor_test.go:135–166

(c *C)

}

func (s *SupervisorSuite) TestTransferFiles(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})
	err := sup.Start()
	c.Assert(err, IsNil)

	time.Sleep(10 * time.Millisecond)

	c.Assert(GETResponse(c, b.FrontendURL("/")), Equals, "Hi, I'm endpoint")

	files, err := sup.GetFiles()
	c.Assert(err, IsNil)

	sup2 := New(newProxy, s.ng, Options{Clock: s.clock, Files: files})
	err = sup2.Start()
	c.Assert(err, IsNil)
	defer sup2.Stop()

	sup.Stop()

	time.Sleep(10 * time.Millisecond)

	c.Assert(GETResponse(c, b.FrontendURL("/")), Equals, "Hi, I'm endpoint")
}

func GETResponse(c *C, url string, opts ...testutils.ReqOption) string {
	response, body, err := testutils.Get(url, opts...)