How to use handleUp method of parallel_support Package

...45	mux.HandleFunc("/before-suite-state", server.handleBeforeSuiteState)46	mux.HandleFunc("/have-nonprimary-procs-finished", server.handleHaveNonprimaryProcsFinished)47	mux.HandleFunc("/aggregated-nonprimary-procs-report", server.handleAggregatedNonprimaryProcsReport)48	mux.HandleFunc("/counter", server.handleCounter)49	mux.HandleFunc("/up", server.handleUp)50	mux.HandleFunc("/abort", server.handleAbort)51	go httpServer.Serve(server.listener)52}53//Stop the server54func (server *httpServer) Close() {55	server.listener.Close()56}57//The address the server can be reached it.  Pass this into the `ForwardingReporter`.58func (server *httpServer) Address() string {59	return "http://" + server.listener.Addr().String()60}61func (server *httpServer) GetSuiteDone() chan interface{} {62	return server.handler.done63}64func (server *httpServer) GetOutputDestination() io.Writer {65	return server.handler.outputDestination66}67func (server *httpServer) SetOutputDestination(w io.Writer) {68	server.handler.outputDestination = w69}70func (server *httpServer) RegisterAlive(node int, alive func() bool) {71	server.handler.registerAlive(node, alive)72}73//74// Streaming Endpoints75//76//The server will forward all received messages to Ginkgo reporters registered with `RegisterReporters`77func (server *httpServer) decode(writer http.ResponseWriter, request *http.Request, object interface{}) bool {78	defer request.Body.Close()79	if json.NewDecoder(request.Body).Decode(object) != nil {80		writer.WriteHeader(http.StatusBadRequest)81		return false82	}83	return true84}85func (server *httpServer) handleError(err error, writer http.ResponseWriter) bool {86	if err == nil {87		return false88	}89	switch err {90	case ErrorEarly:91		writer.WriteHeader(http.StatusTooEarly)92	case ErrorGone:93		writer.WriteHeader(http.StatusGone)94	case ErrorFailed:95		writer.WriteHeader(http.StatusFailedDependency)96	default:97		writer.WriteHeader(http.StatusInternalServerError)98	}99	return true100}101func (server *httpServer) specSuiteWillBegin(writer http.ResponseWriter, request *http.Request) {102	var report types.Report103	if !server.decode(writer, request, &report) {104		return105	}106	server.handleError(server.handler.SpecSuiteWillBegin(report, voidReceiver), writer)107}108func (server *httpServer) didRun(writer http.ResponseWriter, request *http.Request) {109	var report types.SpecReport110	if !server.decode(writer, request, &report) {111		return112	}113	server.handleError(server.handler.DidRun(report, voidReceiver), writer)114}115func (server *httpServer) specSuiteDidEnd(writer http.ResponseWriter, request *http.Request) {116	var report types.Report117	if !server.decode(writer, request, &report) {118		return119	}120	server.handleError(server.handler.SpecSuiteDidEnd(report, voidReceiver), writer)121}122func (server *httpServer) emitOutput(writer http.ResponseWriter, request *http.Request) {123	output, err := io.ReadAll(request.Body)124	if err != nil {125		writer.WriteHeader(http.StatusInternalServerError)126		return127	}128	var n int129	server.handleError(server.handler.EmitOutput(output, &n), writer)130}131func (server *httpServer) handleBeforeSuiteCompleted(writer http.ResponseWriter, request *http.Request) {132	var beforeSuiteState BeforeSuiteState133	if !server.decode(writer, request, &beforeSuiteState) {134		return135	}136	server.handleError(server.handler.BeforeSuiteCompleted(beforeSuiteState, voidReceiver), writer)137}138func (server *httpServer) handleBeforeSuiteState(writer http.ResponseWriter, request *http.Request) {139	var beforeSuiteState BeforeSuiteState140	if server.handleError(server.handler.BeforeSuiteState(voidSender, &beforeSuiteState), writer) {141		return142	}143	json.NewEncoder(writer).Encode(beforeSuiteState)144}145func (server *httpServer) handleHaveNonprimaryProcsFinished(writer http.ResponseWriter, request *http.Request) {146	if server.handleError(server.handler.HaveNonprimaryProcsFinished(voidSender, voidReceiver), writer) {147		return148	}149	writer.WriteHeader(http.StatusOK)150}151func (server *httpServer) handleAggregatedNonprimaryProcsReport(writer http.ResponseWriter, request *http.Request) {152	var aggregatedReport types.Report153	if server.handleError(server.handler.AggregatedNonprimaryProcsReport(voidSender, &aggregatedReport), writer) {154		return155	}156	json.NewEncoder(writer).Encode(aggregatedReport)157}158func (server *httpServer) handleCounter(writer http.ResponseWriter, request *http.Request) {159	var n int160	if server.handleError(server.handler.Counter(voidSender, &n), writer) {161		return162	}163	json.NewEncoder(writer).Encode(ParallelIndexCounter{Index: n})164}165func (server *httpServer) handleUp(writer http.ResponseWriter, request *http.Request) {166	writer.WriteHeader(http.StatusOK)167}168func (server *httpServer) handleAbort(writer http.ResponseWriter, request *http.Request) {169	if request.Method == "GET" {170		var shouldAbort bool171		server.handler.ShouldAbort(voidSender, &shouldAbort)172		if shouldAbort {173			writer.WriteHeader(http.StatusGone)174		} else {175			writer.WriteHeader(http.StatusOK)176		}177	} else {178		server.handler.Abort(voidSender, voidReceiver)179	}...

1import (2func main() {3	parallel.HandleUp()4	fmt.Println("Hello world")5}6import (7func main() {8	parallel.HandleDown()9	fmt.Println("Hello world")10}11import (12func main() {13	parallel.HandleLeft()14	fmt.Println("Hello world")15}16import (17func main() {18	parallel.HandleRight()19	fmt.Println("Hello world")20}21import (22func HandleUp() {23	wg.Add(2)24	go func() {25		defer wg.Done()26		for i := 0; i < 5; i++ {27			fmt.Println("Up")28			time.Sleep(time.Millisecond * 100)29		}30	}()31	go func() {32		defer wg.Done()33		for i := 0; i < 5; i++ {34			fmt.Println("Down")35			time.Sleep(time.Millisecond * 100)36		}37	}()38	wg.Wait()39}40func HandleDown() {41	wg.Add(2)42	go func() {43		defer wg.Done()44		for i := 0; i < 5; i++ {45			fmt.Println("Down")46			time.Sleep(time.Millisecond * 100)47		}48	}()49	go func() {50		defer wg.Done()51		for i := 0; i < 5; i++ {52			fmt.Println("Up")53			time.Sleep(time.Millisecond * 100)54		}55	}()56	wg.Wait()57}58func HandleLeft() {59	wg.Add(2)60	go func() {61		defer wg.Done()62		for i := 0; i < 5; i++ {63			fmt.Println("Left")64			time.Sleep(time.Millisecond * 100)65		}66	}()67	go func() {68		defer wg.Done()69		for i := 0; i < 5; i++ {70			fmt.Println("Right")

1func main() {2    fmt.Println("Hello, playground")3    parallel_support.HandleUp()4}5import (6func HandleUp() {7    fmt.Println("Handle Up")8    cmd := exec.Command("docker-compose", "up")9    err := cmd.Start()10    if err != nil {11        fmt.Println(err)12    }13    fmt.Println("Waiting for command to finish...")14    err = cmd.Wait()15    fmt.Printf("Command finished with error: %v", err)16}

1import (2func main() {3	ps.Add(2)4	go func() {5		defer ps.Done()6		fmt.Println("Hello")7	}()8	go func() {9		defer ps.Done()10		fmt.Println("World")11	}()12	ps.Wait()13}14import (15func main() {16	ps.Add(1)17	go func() {18		defer ps.Done()19		fmt.Println("Hello")20	}()21	ps.WaitTimeout(2 * time.Second)22}

1import (2func main() {3	var parallel = parallel_support.Parallel{}4	parallel.SetUp(2)5	parallel.HandleUp(func() {6		fmt.Println("This is first goroutine")7	})8	parallel.HandleUp(func() {9		fmt.Println("This is second goroutine")10	})11	parallel.HandleUp(func() {12		fmt.Println("This is third goroutine")13	})14	parallel.HandleUp(func() {15		fmt.Println("This is fourth goroutine")16	})17	parallel.HandleUp(func() {18		fmt.Println("This is fifth goroutine")19	})20	parallel.HandleUp(func() {21		fmt.Println("This is sixth goroutine")22	})23	parallel.HandleUp(func() {24		fmt.Println("This is seventh goroutine")25	})26	parallel.HandleUp(func() {27		fmt.Println("This is eighth goroutine")28	})29	parallel.HandleUp(func() {30		fmt.Println("This is ninth goroutine")31	})32	parallel.HandleUp(func() {33		fmt.Println("This is tenth goroutine")34	})35	parallel.HandleUp(func() {36		fmt.Println("This is eleventh goroutine")37	})38	parallel.HandleUp(func() {39		fmt.Println("This is twelveth goroutine")40	})41	parallel.HandleUp(func() {42		fmt.Println("This is thirteenth goroutine")43	})44	parallel.HandleUp(func() {45		fmt.Println("This is fourteenth goroutine")46	})47	parallel.HandleUp(func() {48		fmt.Println("This is fifteenth goroutine")49	})50	parallel.HandleUp(func() {51		fmt.Println("This is sixteenth goroutine")52	})53	parallel.HandleUp(func() {54		fmt.Println("This is seventeenth goroutine")55	})56	parallel.HandleUp(func() {57		fmt.Println("This is eighteenth goroutine")58	})59	parallel.HandleUp(func() {60		fmt.Println("This is nineteenth goroutine")61	})62	parallel.HandleUp(func() {63		fmt.Println("This is twentieth goroutine")64	})65	parallel.HandleUp(func() {66		fmt.Println("This is twenty first goroutine")67	})68	parallel.HandleUp(func() {69		fmt.Println("This is twenty second goroutine")70	})71	parallel.HandleUp(func() {72		fmt.Println("This is twenty third goroutine")73	})74	parallel.HandleUp(func() {75		fmt.Println("