testutils

Documentation

Index

• func AssertServers(t testing.TB, expected []string, actual []server.Server)
• func CalcReqLength(req []byte) int
• func GenBrowserChallenge(l uint) []byte
• func GenBrowserChallenge8() []byte
• func GenExtraServerParams(extra map[string]string) map[string]string
• func GenRandomIP() net.IP
• func GenServerParams() map[string]string
• func PackBrowserRequest(fields []string, filters string, options []byte, getChallenge func() []byte, ...) []byte
• func PackHeartbeatRequest(instanceID []byte, params map[string]string) []byte
• func PrepareTestServer(tb fxtest.TB, extra ...fx.Option) (*httptest.Server, func())
• func SendBrowserRequest(address string, filters string) []byte
• func SendTCP(address string, req []byte) []byte
• func SendUDP(address string, req []byte) []byte
• func UnpackServerList(resp []byte) []map[string]string
• func WithBrowserChallengeLength(l int) func([]byte) int
• type Response
  • func DoTestRequest(ts *httptest.Server, method, path string, body io.Reader, ...) Response
• type TCPClient
  • func NewTCPClient(address string, bufSize int, readTimeout time.Duration) *TCPClient
  • func (c *TCPClient) Close()
  • func (c *TCPClient) Send(req []byte) ([]byte, error)
• type TestRequestOpt
  • func MustBindJSON(v interface{}) TestRequestOpt
  • func MustHaveNoBody() TestRequestOpt
• type TestServerRepositories
  • func PrepareTestServerWithRepos(tb fxtest.TB, extra ...fx.Option) (*httptest.Server, TestServerRepositories, func())
• type UDPClient
  • func NewUDPClient(address string, bufSize int, readTimeout time.Duration) *UDPClient
  • func (c *UDPClient) Close()
  • func (c *UDPClient) Send(req []byte) ([]byte, error)

Functions

func AssertServers

func AssertServers(t testing.TB, expected []string, actual []server.Server)

func CalcReqLength

func CalcReqLength(req []byte) int

func GenBrowserChallenge

func GenBrowserChallenge(l uint) []byte

func GenBrowserChallenge8

func GenBrowserChallenge8() []byte

func GenExtraServerParams

func GenExtraServerParams(extra map[string]string) map[string]string

func GenRandomIP

func GenRandomIP() net.IP

func GenServerParams

func GenServerParams() map[string]string

func PackBrowserRequest

func PackBrowserRequest(
	fields []string,
	filters string,
	options []byte,
	getChallenge func() []byte,
	getLengthFunc func([]byte) int,
) []byte

func PackHeartbeatRequest

func PackHeartbeatRequest(instanceID []byte, params map[string]string) []byte

func PrepareTestServer

func PrepareTestServer(tb fxtest.TB, extra ...fx.Option) (*httptest.Server, func())

func SendBrowserRequest

func SendBrowserRequest(address string, filters string) []byte

func SendTCP

func SendTCP(address string, req []byte) []byte

func SendUDP

func SendUDP(address string, req []byte) []byte

func UnpackServerList

func UnpackServerList(resp []byte) []map[string]string

func WithBrowserChallengeLength

func WithBrowserChallengeLength(l int) func([]byte) int

Types

type Response

type Response struct {
	StatusCode int
	Body       string
}

func DoTestRequest

func DoTestRequest(
	ts *httptest.Server, method, path string, body io.Reader, opts ...TestRequestOpt,
) Response

type TCPClient

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

func NewTCPClient

func NewTCPClient(address string, bufSize int, readTimeout time.Duration) *TCPClient

func (*TCPClient) Close

func (c *TCPClient) Close()

func (*TCPClient) Send

func (c *TCPClient) Send(req []byte) ([]byte, error)

type TestRequestOpt

type TestRequestOpt func(*http.Request, *http.Response)

func MustBindJSON

func MustBindJSON(v interface{}) TestRequestOpt

func MustHaveNoBody

func MustHaveNoBody() TestRequestOpt

type TestServerRepositories

type TestServerRepositories struct {
	Servers   repositories.ServerRepository
	Instances repositories.InstanceRepository
	Probes    repositories.ProbeRepository
}

func PrepareTestServerWithRepos

func PrepareTestServerWithRepos(
	tb fxtest.TB,
	extra ...fx.Option,
) (*httptest.Server, TestServerRepositories, func())

type UDPClient

type UDPClient struct {
	LocalAddr *net.UDPAddr
	// contains filtered or unexported fields
}

func NewUDPClient

func NewUDPClient(address string, bufSize int, readTimeout time.Duration) *UDPClient

func (*UDPClient) Close

func (c *UDPClient) Close()

func (*UDPClient) Send

func (c *UDPClient) Send(req []byte) ([]byte, error)