tests

Documentation

Index

• func ExecuteT(t *testing.T, cmd, input string) (stdout, stderr string)
• func ExtractPortFromAddress(listenAddress string) string
• func StatusOK(statusCode int) bool
• func WaitForHeight(height int64, port string)
• func WaitForHeightTM(height int64, port string)
• func WaitForLCDStart(port string)
• func WaitForNextHeightTM(port string)
• func WaitForNextNBlocksTM(n int64, port string)
• func WaitForRPC(laddr string)
• func WaitForStart(url string)
• func WaitForTMStart(port string)
• type Process
  • func CreateProcess(dir string, name string, args []string) (*Process, error)
  • func GoExecuteT(t *testing.T, cmd string) (proc *Process)
  • func GoExecuteTWithStdout(t *testing.T, cmd string) (proc *Process)
  • func StartProcess(dir string, name string, args []string) (*Process, error)
  • func (proc *Process) ReadAll() (stdout []byte, stderr []byte, err error)
  • func (proc *Process) Stop(kill bool) error
  • func (proc *Process) Wait()

Functions

func ExecuteT

func ExecuteT(t *testing.T, cmd, input string) (stdout, stderr string)

ExecuteT executes the command, pipes any input to STDIN and return STDOUT, logging STDOUT/STDERR to t. nolint: errcheck

func ExtractPortFromAddress

func ExtractPortFromAddress(listenAddress string) string

ExtractPortFromAddress extract port from listenAddress The listenAddress must be some strings like tcp://0.0.0.0:12345

func StatusOK

func StatusOK(statusCode int) bool

Whether or not an HTTP status code was "successful"

func WaitForHeight

func WaitForHeight(height int64, port string)

Wait for height from the LCD API on localhost

func WaitForHeightTM

func WaitForHeightTM(height int64, port string)

Wait for the given height from the Tendermint RPC on localhost

func WaitForLCDStart

func WaitForLCDStart(port string)

wait for tendermint to start by querying the LCD

func WaitForNextHeightTM

func WaitForNextHeightTM(port string)

Wait for the next tendermint block from the Tendermint RPC on localhost

func WaitForNextNBlocksTM

func WaitForNextNBlocksTM(n int64, port string)

Wait for N tendermint blocks to pass using the Tendermint RPC on localhost

func WaitForRPC

func WaitForRPC(laddr string)

Wait for the RPC server to respond to /status

func WaitForStart

func WaitForStart(url string)

WaitForStart waits for the node to start by pinging the url every 100ms for 10s until it returns 200. If it takes longer than 5s, it panics.

func WaitForTMStart

func WaitForTMStart(port string)

wait for tendermint to start by querying tendermint

Types

type Process

type Process struct {
	ExecPath   string
	Args       []string
	Pid        int
	StartTime  time.Time
	EndTime    time.Time
	Cmd        *exec.Cmd        `json:"-"`
	ExitState  *os.ProcessState `json:"-"`
	StdinPipe  io.WriteCloser   `json:"-"`
	StdoutPipe io.ReadCloser    `json:"-"`
	StderrPipe io.ReadCloser    `json:"-"`
}

execution process

func CreateProcess

func CreateProcess(dir string, name string, args []string) (*Process, error)

Same as StartProcess but doesn't start the process

func GoExecuteT

func GoExecuteT(t *testing.T, cmd string) (proc *Process)

Execute the command, launch goroutines to log stdout/err to t. Caller should wait for .Wait() or .Stop() to terminate.

func GoExecuteTWithStdout

func GoExecuteTWithStdout(t *testing.T, cmd string) (proc *Process)

Same as GoExecuteT but spawns a go routine to ReadAll off stdout.

func StartProcess

func StartProcess(dir string, name string, args []string) (*Process, error)

dir: The working directory. If "", os.Getwd() is used. name: Command name args: Args to command. (should not include name)

func (*Process) ReadAll

func (proc *Process) ReadAll() (stdout []byte, stderr []byte, err error)

ReadAll calls ioutil.ReadAll on the StdoutPipe and StderrPipe.

func (*Process) Stop

func (proc *Process) Stop(kill bool) error

stop the process

func (*Process) Wait

func (proc *Process) Wait()

wait for the process