Versions in this module Expand all Collapse all v2 v2.17.2 Mar 25, 2024 Changes in this version + var ErrorEarly = fmt.Errorf("early") + var ErrorFailed = fmt.Errorf("failed") + var ErrorGone = fmt.Errorf("gone") + var POLLING_INTERVAL = 50 * time.Millisecond + type BeforeSuiteState struct + Data []byte + State types.SpecState + type Client interface + BlockUntilAggregatedNonprimaryProcsReport func() (types.Report, error) + BlockUntilNonprimaryProcsHaveFinished func() error + BlockUntilReportBeforeSuiteCompleted func() (types.SpecState, error) + BlockUntilSynchronizedBeforeSuiteData func() (types.SpecState, []byte, error) + Close func() error + Connect func() bool + FetchNextCounter func() (int, error) + PostAbort func() error + PostDidRun func(report types.SpecReport) error + PostEmitProgressReport func(report types.ProgressReport) error + PostReportBeforeSuiteCompleted func(state types.SpecState) error + PostSuiteDidEnd func(report types.Report) error + PostSuiteWillBegin func(report types.Report) error + PostSynchronizedBeforeSuiteCompleted func(state types.SpecState, data []byte) error + ShouldAbort func() bool + Write func(p []byte) (int, error) + func NewClient(serverHost string) Client + type ParallelIndexCounter struct + Index int + type RPCServer struct + func (server *RPCServer) Address() string + func (server *RPCServer) Close() + func (server *RPCServer) GetOutputDestination() io.Writer + func (server *RPCServer) GetSuiteDone() chan interface{} + func (server *RPCServer) RegisterAlive(node int, alive func() bool) + func (server *RPCServer) SetOutputDestination(w io.Writer) + func (server *RPCServer) Start() + type Server interface + Address func() string + Close func() + GetOutputDestination func() io.Writer + GetSuiteDone func() chan interface{} + RegisterAlive func(node int, alive func() bool) + SetOutputDestination func(io.Writer) + Start func() + func NewServer(parallelTotal int, reporter reporters.Reporter) (Server, error) + type ServerHandler struct + func (handler *ServerHandler) Abort(_ Void, _ *Void) error + func (handler *ServerHandler) AggregatedNonprimaryProcsReport(_ Void, report *types.Report) error + func (handler *ServerHandler) BeforeSuiteCompleted(beforeSuiteState BeforeSuiteState, _ *Void) error + func (handler *ServerHandler) BeforeSuiteState(_ Void, beforeSuiteState *BeforeSuiteState) error + func (handler *ServerHandler) Counter(_ Void, counter *int) error + func (handler *ServerHandler) DidRun(report types.SpecReport, _ *Void) error + func (handler *ServerHandler) EmitOutput(output []byte, n *int) error + func (handler *ServerHandler) EmitProgressReport(report types.ProgressReport, _ *Void) error + func (handler *ServerHandler) HaveNonprimaryProcsFinished(_ Void, _ *Void) error + func (handler *ServerHandler) ReportBeforeSuiteCompleted(reportBeforeSuiteState types.SpecState, _ *Void) error + func (handler *ServerHandler) ReportBeforeSuiteState(_ Void, reportBeforeSuiteState *types.SpecState) error + func (handler *ServerHandler) ShouldAbort(_ Void, shouldAbort *bool) error + func (handler *ServerHandler) SpecSuiteDidEnd(report types.Report, _ *Void) error + func (handler *ServerHandler) SpecSuiteWillBegin(report types.Report, _ *Void) error + type Void struct
Go to main page