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

type Void …

var voidReceiver …

var voidSender …

type ServerHandler …

func newServerHandler(parallelTotal int, reporter reporters.Reporter) *ServerHandler { … }

func (handler *ServerHandler) SpecSuiteWillBegin(report types.Report, _ *Void) error { … }

func (handler *ServerHandler) DidRun(report types.SpecReport, _ *Void) error { … }

func (handler *ServerHandler) SpecSuiteDidEnd(report types.Report, _ *Void) error { … }

func (handler *ServerHandler) EmitOutput(output []byte, n *int) error { … }

func (handler *ServerHandler) EmitProgressReport(report types.ProgressReport, _ *Void) error { … }

func (handler *ServerHandler) registerAlive(proc int, alive func() bool) { … }

func (handler *ServerHandler) procIsAlive(proc int) bool { … }

func (handler *ServerHandler) haveNonprimaryProcsFinished() bool { … }

func (handler *ServerHandler) ReportBeforeSuiteCompleted(reportBeforeSuiteState types.SpecState, _ *Void) error { … }

func (handler *ServerHandler) ReportBeforeSuiteState(_ Void, reportBeforeSuiteState *types.SpecState) error { … }

func (handler *ServerHandler) BeforeSuiteCompleted(beforeSuiteState BeforeSuiteState, _ *Void) error { … }

func (handler *ServerHandler) BeforeSuiteState(_ Void, beforeSuiteState *BeforeSuiteState) error { … }

func (handler *ServerHandler) HaveNonprimaryProcsFinished(_ Void, _ *Void) error { … }

func (handler *ServerHandler) AggregatedNonprimaryProcsReport(_ Void, report *types.Report) error { … }

func (handler *ServerHandler) Counter(_ Void, counter *int) error { … }

func (handler *ServerHandler) Abort(_ Void, _ *Void) error { … }

func (handler *ServerHandler) ShouldAbort(_ Void, shouldAbort *bool) error { … }