How to use NewServer method of parallel_support Package

...34			BeforeEach(func() {35				GinkgoT().Setenv("GINKGO_PARALLEL_PROTOCOL", protocol)36				var err error37				reporter = &FakeReporter{}38				server, err = parallel_support.NewServer(3, reporter)39				Ω(err).ShouldNot(HaveOccurred())40				server.Start()41				buffer = gbytes.NewBuffer()42				server.SetOutputDestination(buffer)43				client = parallel_support.NewClient(server.Address())44				Eventually(client.Connect).Should(BeTrue())45				DeferCleanup(server.Close)46				DeferCleanup(client.Close)47			})48			Describe("Reporting endpoints", func() {49				var beginReport, thirdBeginReport types.Report50				var endReport1, endReport2, endReport3 types.Report51				var specReportA, specReportB, specReportC types.SpecReport52				var t time.Time53				BeforeEach(func() {54					beginReport = types.Report{SuiteDescription: "my sweet suite"}55					thirdBeginReport = types.Report{SuiteDescription: "last one in gets forwarded"}56					specReportA = types.SpecReport{LeafNodeText: "A"}57					specReportB = types.SpecReport{LeafNodeText: "B"}58					specReportC = types.SpecReport{LeafNodeText: "C"}59					t = time.Now()60					endReport1 = types.Report{StartTime: t.Add(-time.Second), EndTime: t.Add(time.Second), SuiteSucceeded: true, SpecReports: types.SpecReports{specReportA}}61					endReport2 = types.Report{StartTime: t.Add(-2 * time.Second), EndTime: t.Add(time.Second), SuiteSucceeded: true, SpecReports: types.SpecReports{specReportB}}62					endReport3 = types.Report{StartTime: t.Add(-time.Second), EndTime: t.Add(2 * time.Second), SuiteSucceeded: false, SpecReports: types.SpecReports{specReportC}}63				})64				Context("before all procs have reported SuiteWillBegin", func() {65					BeforeEach(func() {66						Ω(client.PostSuiteWillBegin(beginReport)).Should(Succeed())67						Ω(client.PostDidRun(specReportA)).Should(Succeed())68						Ω(client.PostSuiteWillBegin(beginReport)).Should(Succeed())69						Ω(client.PostDidRun(specReportB)).Should(Succeed())70					})71					It("should not forward anything to the attached reporter", func() {72						Ω(reporter.Begin).Should(BeZero())73						Ω(reporter.Will).Should(BeEmpty())74						Ω(reporter.Did).Should(BeEmpty())75					})76					Context("when the final proc reports SuiteWillBegin", func() {77						BeforeEach(func() {78							Ω(client.PostSuiteWillBegin(thirdBeginReport)).Should(Succeed())79						})80						It("forwards to SuiteWillBegin and catches up on any received summaries", func() {81							Ω(reporter.Begin).Should(Equal(thirdBeginReport))82							Ω(reporter.Will.Names()).Should(ConsistOf("A", "B"))83							Ω(reporter.Did.Names()).Should(ConsistOf("A", "B"))84						})85						Context("any subsequent summaries", func() {86							BeforeEach(func() {87								Ω(client.PostDidRun(specReportC)).Should(Succeed())88							})89							It("are forwarded immediately", func() {90								Ω(reporter.Will.Names()).Should(ConsistOf("A", "B", "C"))91								Ω(reporter.Did.Names()).Should(ConsistOf("A", "B", "C"))92							})93						})94						Context("when SuiteDidEnd start arriving", func() {95							BeforeEach(func() {96								Ω(client.PostSuiteDidEnd(endReport1)).Should(Succeed())97								Ω(client.PostSuiteDidEnd(endReport2)).Should(Succeed())98							})99							It("does not forward them yet...", func() {100								Ω(reporter.End).Should(BeZero())101							})102							It("doesn't signal it's done", func() {103								Ω(server.GetSuiteDone()).ShouldNot(BeClosed())104							})105							Context("when the final SuiteDidEnd arrive", func() {106								BeforeEach(func() {107									Ω(client.PostSuiteDidEnd(endReport3)).Should(Succeed())108								})109								It("forwards the aggregation of all received end summaries", func() {110									Ω(reporter.End.StartTime.Unix()).Should(BeNumerically("~", t.Add(-2*time.Second).Unix()))111									Ω(reporter.End.EndTime.Unix()).Should(BeNumerically("~", t.Add(2*time.Second).Unix()))112									Ω(reporter.End.RunTime).Should(BeNumerically("~", 4*time.Second))113									Ω(reporter.End.SuiteSucceeded).Should(BeFalse())114									Ω(reporter.End.SpecReports).Should(ConsistOf(specReportA, specReportB, specReportC))115								})116								It("should signal it's done", func() {117									Ω(server.GetSuiteDone()).Should(BeClosed())118								})119							})120						})121					})122				})123			})124			Describe("supporting ReportEntries (which RPC struggled with when I first implemented it)", func() {125				BeforeEach(func() {126					Ω(client.PostSuiteWillBegin(types.Report{SuiteDescription: "my sweet suite"})).Should(Succeed())127					Ω(client.PostSuiteWillBegin(types.Report{SuiteDescription: "my sweet suite"})).Should(Succeed())128					Ω(client.PostSuiteWillBegin(types.Report{SuiteDescription: "my sweet suite"})).Should(Succeed())129				})130				It("can pass in ReportEntries that include custom types", func() {131					cl := types.NewCodeLocation(0)132					entry, err := internal.NewReportEntry("No Value Entry", cl)133					Ω(err).ShouldNot(HaveOccurred())134					Ω(client.PostDidRun(types.SpecReport{135						LeafNodeText:  "no-value",136						ReportEntries: types.ReportEntries{entry},137					})).Should(Succeed())138					entry, err = internal.NewReportEntry("String Value Entry", cl, "The String")139					Ω(err).ShouldNot(HaveOccurred())140					Ω(client.PostDidRun(types.SpecReport{141						LeafNodeText:  "string-value",142						ReportEntries: types.ReportEntries{entry},143					})).Should(Succeed())144					entry, err = internal.NewReportEntry("Custom Type Value Entry", cl, ColorableStringerStruct{Label: "apples", Count: 17})145					Ω(err).ShouldNot(HaveOccurred())146					Ω(client.PostDidRun(types.SpecReport{147						LeafNodeText:  "custom-value",148						ReportEntries: types.ReportEntries{entry},149					})).Should(Succeed())150					Ω(reporter.Did.Find("no-value").ReportEntries[0].Name).Should(Equal("No Value Entry"))151					Ω(reporter.Did.Find("no-value").ReportEntries[0].StringRepresentation()).Should(Equal(""))152					Ω(reporter.Did.Find("string-value").ReportEntries[0].Name).Should(Equal("String Value Entry"))153					Ω(reporter.Did.Find("string-value").ReportEntries[0].StringRepresentation()).Should(Equal("The String"))154					Ω(reporter.Did.Find("custom-value").ReportEntries[0].Name).Should(Equal("Custom Type Value Entry"))155					Ω(reporter.Did.Find("custom-value").ReportEntries[0].StringRepresentation()).Should(Equal("{{red}}apples {{green}}17{{/}}"))156				})157			})158			Describe("Streaming output", func() {159				It("is configured to stream to stdout", func() {160					server, err := parallel_support.NewServer(3, reporter)161					Ω(err).ShouldNot(HaveOccurred())162					Ω(server.GetOutputDestination().(*os.File).Fd()).Should(Equal(uintptr(1)))163				})164				It("streams output to the provided buffer", func() {165					n, err := client.Write([]byte("hello"))166					Ω(n).Should(Equal(5))167					Ω(err).ShouldNot(HaveOccurred())168					Ω(buffer).Should(gbytes.Say("hello"))169				})170			})171			Describe("Synchronization endpoints", func() {172				var proc1Exited, proc2Exited, proc3Exited chan interface{}173				BeforeEach(func() {174					proc1Exited, proc2Exited, proc3Exited = make(chan interface{}), make(chan interface{}), make(chan interface{})...

...5	"github.com/onsi/ginkgo/v2/reporters"6	. "github.com/onsi/gomega"7)8func SetUpServerAndClient(numNodes int) (parallel_support.Server, parallel_support.Client, map[int]chan interface{}) {9	server, err := parallel_support.NewServer(numNodes, reporters.NoopReporter{})10	Ω(err).ShouldNot(HaveOccurred())11	server.Start()12	client := parallel_support.NewClient(server.Address())13	Eventually(client.Connect).Should(BeTrue())14	exitChannels := map[int]chan interface{}{}15	for node := 1; node <= numNodes; node++ {16		c := make(chan interface{})17		exitChannels[node] = c18		server.RegisterAlive(node, func() bool {19			select {20			case <-c:21				return false22			default:23				return true...

1import (2func main() {3    router := mux.NewRouter()4    router.HandleFunc("/parallel", parallel_support.NewServer).Methods("GET")5    fmt.Println("Starting server on port 8080")6    http.ListenAndServe(":8080", router)7}8import (9func main() {10    router := mux.NewRouter()11    router.HandleFunc("/parallel", parallel_support.NewServer).Methods("GET")12    fmt.Println("Starting server on port 8080")13    http.ListenAndServe(":8080", router)14}15import (16func main() {17    router := mux.NewRouter()18    router.HandleFunc("/parallel", parallel_support.NewServer).Methods("GET")19    fmt.Println("Starting server on port 8080")20    http.ListenAndServe(":8080", router)21}22import (23func main() {24    router := mux.NewRouter()25    router.HandleFunc("/parallel", parallel_support.NewServer).Methods("GET")26    fmt.Println("Starting server on port 8080")27    http.ListenAndServe(":8080", router)28}29import (30func main() {31    router := mux.NewRouter()32    router.HandleFunc("/parallel", parallel_support.NewServer).Methods("GET")33    fmt.Println("Starting server on port 8080")34    http.ListenAndServe(":8080", router)35}

1func main() {2    server := parallel_support.NewServer()3    server.Start()4}5func main() {6    server := parallel_support.NewServer()7    server.Start()8}9func main() {10    server := parallel_support.NewServer()11    server.Start()12}13func main() {14    server := parallel_support.NewServer()15    server.Start()16}17func main() {18    server := parallel_support.NewServer()19    server.Start()20}21func main() {22    server := parallel_support.NewServer()23    server.Start()24}25func main() {26    server := parallel_support.NewServer()27    server.Start()28}29func main() {30    server := parallel_support.NewServer()31    server.Start()32}33func main() {34    server := parallel_support.NewServer()35    server.Start()36}37func main() {38    server := parallel_support.NewServer()39    server.Start()40}41func main() {42    server := parallel_support.NewServer()43    server.Start()44}45func main() {46    server := parallel_support.NewServer()47    server.Start()48}

1func main() {2    server = parallel_support.NewServer()3    server.Listen(8080)4}5func main() {6    server = parallel_support.NewServer()7    server.Listen(8080)8}9func main() {10    server = parallel_support.NewServer()11    server.Listen(8080)12}13func main() {14    server = parallel_support.NewServer()15    server.Listen(8080)16}17func main() {18    server = parallel_support.NewServer()19    server.Listen(8080)20}21func main() {22    server = parallel_support.NewServer()23    server.Listen(8080)24}25func main() {26    server = parallel_support.NewServer()27    server.Listen(8080)28}29func main() {30    server = parallel_support.NewServer()31    server.Listen(8080)32}33func main() {34    server = parallel_support.NewServer()35    server.Listen(8080)36}37func main() {38    server = parallel_support.NewServer()39    server.Listen(8080)40}41func main() {42    server = parallel_support.NewServer()43    server.Listen(8080)44}

1import (2func main() {3	server := parallel_support.NewServer()4	server.AddRoute("/hello", "GET", helloWorld)5	server.AddRoute("/goodbye", "GET", goodbyeWorld)6	server.Start(":8080")7}8func helloWorld(w http.ResponseWriter, r *http.Request) {9	fmt.Fprintf(w, "Hello World!")10}11func goodbyeWorld(w http.ResponseWriter, r *http.Request) {12	fmt.Fprintf(w, "Goodbye World!")13}14import (15type Server struct {16}17func NewServer() *Server {18	return &Server{19		routes: make(map[string]map[string]http.HandlerFunc),20	}21}22func (s *Server) AddRoute(path string, method string, handler http.HandlerFunc) {23	if _, ok := s.routes[path]; !ok {24		s.routes[path] = make(map[string]http.HandlerFunc)25	}26}27func (s *Server) Start(addr string) {28	http.HandleFunc("/", s.handleRequest)29	http.ListenAndServe(addr, nil)30}31func (s *Server) handleRequest(w http.ResponseWriter, r *http.Request) {32	if route, ok := s.routes[r.URL.String()]; ok {33		if handler, ok := route[r.Method]; ok {34			handler(w, r)35		} else {36			w.WriteHeader(http.StatusMethodNotAllowed)37		}38	} else {39		w.WriteHeader(http.StatusNotFound)40	}41}

1import (2func main() {3	parallel_support.NewServer(":8080").Start()4}5import (6type Server struct {7}8func NewServer(addr string) *Server {9	return &Server{10	}11}12func (s *Server) Start() {13	http.ListenAndServe(s.Addr, nil)14}15import (16func main() {17	parallel_support.NewServer(":8080").Start()18}19import (20type Server struct {21}22func NewServer(addr string) *Server {23	return &Server{24	}25}26func (s *Server) Start() {27	http.ListenAndServe(s.Addr, nil)28}29import (30func main() {31	parallel_support.NewServer(":8080").Start()32}33import (34type Server struct {35}36func NewServer(addr string) *Server {37	return &Server{38	}39}40func (s *Server) Start() {41	http.ListenAndServe(s.Addr, nil)42}43import (44func main() {45	parallel_support.NewServer(":8080").Start()46}

1import (2func main() {3	server := parallel_support.NewServer()4	server.Run()5}6import (7type Server struct {8}9func NewServer() *Server {10	return &Server{}11}12func (server *Server) Run() {13	fmt.Println("server is running")14}15import (16type Server struct {17}18func NewServer() *Server {19	return &Server{}20}21func (server *Server) Run() {22	fmt.Println("server is running")23}24import (25type Server struct {26}27func NewServer() *Server {28	return &Server{}29}30func (server *Server) Run() {31	fmt.Println("server is running")32}33func (server *Server) handler(w http.ResponseWriter, r *http.Request) {34	fmt.Fprintf(w, "Hello World!")35}36import (37type Server struct {38}39func NewServer() *Server {40	return &Server{}41}42func (server *Server) Run() {43	fmt.Println("server is running")44	http.HandleFunc("/", server.handler)45	http.ListenAndServe(":8080", nil)46}47func (server *Server) handler(w http.ResponseWriter, r *http.Request) {48	fmt.Fprintf(w, "Hello World!")49}50import (51type Server struct {52}53func NewServer() *Server {54	return &Server{}55}56func (server *Server) Run() {57	fmt.Println("server is running")58	http.HandleFunc("/", server.handler)59	http.ListenAndServe(":8080", nil)