kubernetes/vendor/github.com/onsi/ginkgo/v2/internal/parallel_support/http_server.go

type httpServer …

// Create a new server, automatically selecting a port
func newHttpServer(parallelTotal int, reporter reporters.Reporter) (*httpServer, error) { … }

// Start the server.  You don't need to `go s.Start()`, just `s.Start()`
func (server *httpServer) Start() { … }

// Stop the server
func (server *httpServer) Close() { … }

// The address the server can be reached it.  Pass this into the `ForwardingReporter`.
func (server *httpServer) Address() string { … }

func (server *httpServer) GetSuiteDone() chan interface{ … }

func (server *httpServer) GetOutputDestination() io.Writer { … }

func (server *httpServer) SetOutputDestination(w io.Writer) { … }

func (server *httpServer) RegisterAlive(node int, alive func() bool) { … }

// The server will forward all received messages to Ginkgo reporters registered with `RegisterReporters`
func (server *httpServer) decode(writer http.ResponseWriter, request *http.Request, object interface{ … }

func (server *httpServer) handleError(err error, writer http.ResponseWriter) bool { … }

func (server *httpServer) specSuiteWillBegin(writer http.ResponseWriter, request *http.Request) { … }

func (server *httpServer) didRun(writer http.ResponseWriter, request *http.Request) { … }

func (server *httpServer) specSuiteDidEnd(writer http.ResponseWriter, request *http.Request) { … }

func (server *httpServer) emitOutput(writer http.ResponseWriter, request *http.Request) { … }

func (server *httpServer) emitProgressReport(writer http.ResponseWriter, request *http.Request) { … }

func (server *httpServer) handleReportBeforeSuiteCompleted(writer http.ResponseWriter, request *http.Request) { … }

func (server *httpServer) handleReportBeforeSuiteState(writer http.ResponseWriter, request *http.Request) { … }

func (server *httpServer) handleBeforeSuiteCompleted(writer http.ResponseWriter, request *http.Request) { … }

func (server *httpServer) handleBeforeSuiteState(writer http.ResponseWriter, request *http.Request) { … }

func (server *httpServer) handleHaveNonprimaryProcsFinished(writer http.ResponseWriter, request *http.Request) { … }

func (server *httpServer) handleAggregatedNonprimaryProcsReport(writer http.ResponseWriter, request *http.Request) { … }

func (server *httpServer) handleCounter(writer http.ResponseWriter, request *http.Request) { … }

func (server *httpServer) handleUp(writer http.ResponseWriter, request *http.Request) { … }

func (server *httpServer) handleAbort(writer http.ResponseWriter, request *http.Request) { … }