test_util

Documentation

Index

• func NewRequest(method, host, rawPath string, body io.Reader) *http.Request
• func NewResponse(status int) *http.Response
• func NextAvailPort() uint16
• func SpecConfig(statusPort, proxyPort uint16, natsPorts ...uint16) *config.Config
• func SpecSSLConfig(statusPort, proxyPort, SSLPort uint16, natsPorts ...uint16) *config.Config
• type FakeFile
  • func (f *FakeFile) Read(data *[]byte) (int, error)
  • func (f *FakeFile) Write(data []byte) (int, error)
• type HttpConn
  • func NewHttpConn(x net.Conn) *HttpConn
  • func (x *HttpConn) CheckLine(expected string)
  • func (x *HttpConn) CheckLines(expected []string)
  • func (x *HttpConn) ReadRequest() (*http.Request, string)
  • func (x *HttpConn) ReadResponse() (*http.Response, string)
  • func (x *HttpConn) WriteLine(line string)
  • func (x *HttpConn) WriteLines(lines []string)
  • func (x *HttpConn) WriteRequest(req *http.Request)
  • func (x *HttpConn) WriteResponse(resp *http.Response)
• type NATSRunner
  • func NewNATSRunner(port int) *NATSRunner
  • func (runner *NATSRunner) KillWithFire()
  • func (runner *NATSRunner) Start()
  • func (runner *NATSRunner) Stop()
• type Nats
  • func NewNats(port uint16) *Nats
  • func NewNatsOnRandomPort() *Nats
  • func (n *Nats) Port() uint16
  • func (n *Nats) Start()
  • func (n *Nats) Stop()

Functions

func NewRequest

func NewRequest(method, host, rawPath string, body io.Reader) *http.Request

func NewResponse

func NewResponse(status int) *http.Response

func NextAvailPort

func NextAvailPort() uint16

func SpecConfig

func SpecConfig(statusPort, proxyPort uint16, natsPorts ...uint16) *config.Config

func SpecSSLConfig

func SpecSSLConfig(statusPort, proxyPort, SSLPort uint16, natsPorts ...uint16) *config.Config

Types

type FakeFile

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

func (*FakeFile) Read

func (f *FakeFile) Read(data *[]byte) (int, error)

func (*FakeFile) Write

func (f *FakeFile) Write(data []byte) (int, error)

type HttpConn

type HttpConn struct {
	net.Conn

	Reader *bufio.Reader
	Writer *bufio.Writer
}

func NewHttpConn

func NewHttpConn(x net.Conn) *HttpConn

func (*HttpConn) CheckLine

func (x *HttpConn) CheckLine(expected string)

func (*HttpConn) CheckLines

func (x *HttpConn) CheckLines(expected []string)

func (*HttpConn) ReadRequest

func (x *HttpConn) ReadRequest() (*http.Request, string)

func (*HttpConn) ReadResponse

func (x *HttpConn) ReadResponse() (*http.Response, string)

func (*HttpConn) WriteLine

func (x *HttpConn) WriteLine(line string)

func (*HttpConn) WriteLines

func (x *HttpConn) WriteLines(lines []string)

func (*HttpConn) WriteRequest

func (x *HttpConn) WriteRequest(req *http.Request)

func (*HttpConn) WriteResponse

func (x *HttpConn) WriteResponse(resp *http.Response)

type NATSRunner

type NATSRunner struct {
	MessageBus *nats.Conn
	// contains filtered or unexported fields
}

func NewNATSRunner

func NewNATSRunner(port int) *NATSRunner

func (*NATSRunner) KillWithFire

func (runner *NATSRunner) KillWithFire()

func (*NATSRunner) Start

func (runner *NATSRunner) Start()

func (*NATSRunner) Stop

func (runner *NATSRunner) Stop()

type Nats

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

func NewNats

func NewNats(port uint16) *Nats

func NewNatsOnRandomPort

func NewNatsOnRandomPort() *Nats

func (*Nats) Port

func (n *Nats) Port() uint16

func (*Nats) Start

func (n *Nats) Start()

func (*Nats) Stop

func (n *Nats) Stop()