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

type httpClient …

func newHttpClient(serverHost string) *httpClient { … }

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

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

func (client *httpClient) post(path string, data interface{ … }

func (client *httpClient) poll(path string, data interface{ … }

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

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

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

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

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

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

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

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

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

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

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

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

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

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