parallel_support

Documentation

Index

• Variables
• type Client
  • func NewClient(serverHost string) Client
  • func (client Client) BlockUntilAggregatedNonprimaryNodesReport() (types.Report, error)
  • func (client Client) BlockUntilNonprimaryNodesHaveFinished() error
  • func (client Client) BlockUntilSynchronizedBeforeSuiteData() ([]byte, error)
  • func (client Client) CheckServerUp() bool
  • func (client Client) FetchNextCounter() (int, error)
  • func (client Client) PostDidRun(report types.SpecReport) error
  • func (client Client) PostSuiteDidEnd(report types.Report) error
  • func (client Client) PostSuiteWillBegin(report types.Report) error
  • func (client Client) PostSynchronizedBeforeSuiteFailed() error
  • func (client Client) PostSynchronizedBeforeSuiteSucceeded(data []byte) error
• type ParallelIndexCounter
• type Server
  • func NewServer(parallelTotal int, reporter reporters.Reporter) (*Server, error)
  • func (server *Server) Address() string
  • func (server *Server) Close()
  • func (server *Server) RegisterAlive(node int, alive func() bool)
  • func (server *Server) Start()

Variables

var ErrorFailed = fmt.Errorf("failed!")

var ErrorGone = fmt.Errorf("gone!")

var POLLING_INTERVAL = 50 * time.Millisecond

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

func NewClient

func NewClient(serverHost string) Client

func (Client) BlockUntilAggregatedNonprimaryNodesReport

func (client Client) BlockUntilAggregatedNonprimaryNodesReport() (types.Report, error)

func (Client) BlockUntilNonprimaryNodesHaveFinished

func (client Client) BlockUntilNonprimaryNodesHaveFinished() error

func (Client) BlockUntilSynchronizedBeforeSuiteData

func (client Client) BlockUntilSynchronizedBeforeSuiteData() ([]byte, error)

func (Client) CheckServerUp

func (client Client) CheckServerUp() bool

func (Client) FetchNextCounter

func (client Client) FetchNextCounter() (int, error)

func (Client) PostDidRun

func (client Client) PostDidRun(report types.SpecReport) error

func (Client) PostSuiteDidEnd

func (client Client) PostSuiteDidEnd(report types.Report) error

func (Client) PostSuiteWillBegin

func (client Client) PostSuiteWillBegin(report types.Report) error

func (Client) PostSynchronizedBeforeSuiteFailed

func (client Client) PostSynchronizedBeforeSuiteFailed() error

func (Client) PostSynchronizedBeforeSuiteSucceeded

func (client Client) PostSynchronizedBeforeSuiteSucceeded(data []byte) error

type ParallelIndexCounter

type ParallelIndexCounter struct {
	Index int
}

type Server

type Server struct {
	Done chan interface{}
	// contains filtered or unexported fields
}

Server spins up on an automatically selected port and listens for communication from the forwarding reporter. It then forwards that communication to attached reporters.

func NewServer

func NewServer(parallelTotal int, reporter reporters.Reporter) (*Server, error)

Create a new server, automatically selecting a port

func (*Server) Address

func (server *Server) Address() string

The address the server can be reached it. Pass this into the `ForwardingReporter`.

func (*Server) Close

func (server *Server) Close()

Stop the server

func (*Server) RegisterAlive

func (server *Server) RegisterAlive(node int, alive func() bool)

func (*Server) Start

func (server *Server) Start()

Start the server. You don't need to `go s.Start()`, just `s.Start()`