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

type rpcClient …

func newRPCClient(serverHost string) *rpcClient { … }

func (client *rpcClient) Connect() bool { … }

func (client *rpcClient) Close() error { … }

func (client *rpcClient) poll(method string, data interface{ … }

func (client *rpcClient) PostSuiteWillBegin(report types.Report) error { … }

func (client *rpcClient) PostDidRun(report types.SpecReport) error { … }

func (client *rpcClient) PostSuiteDidEnd(report types.Report) error { … }

func (client *rpcClient) Write(p []byte) (int, error) { … }

func (client *rpcClient) PostEmitProgressReport(report types.ProgressReport) error { … }

func (client *rpcClient) PostReportBeforeSuiteCompleted(state types.SpecState) error { … }

func (client *rpcClient) BlockUntilReportBeforeSuiteCompleted() (types.SpecState, error) { … }

func (client *rpcClient) PostSynchronizedBeforeSuiteCompleted(state types.SpecState, data []byte) error { … }

func (client *rpcClient) BlockUntilSynchronizedBeforeSuiteData() (types.SpecState, []byte, error) { … }

func (client *rpcClient) BlockUntilNonprimaryProcsHaveFinished() error { … }

func (client *rpcClient) BlockUntilAggregatedNonprimaryProcsReport() (types.Report, error) { … }

func (client *rpcClient) FetchNextCounter() (int, error) { … }

func (client *rpcClient) PostAbort() error { … }

func (client *rpcClient) ShouldAbort() bool { … }