testing_test

Documentation

Index

• Constants
• Variables
• func GetDelayedRequestPayload(second int) string
• func GetNumberedHandler(testserver *TestServer, ReplicaNumber int, defaultDelayInterval time.Duration) func(http.ResponseWriter, *http.Request)
• func StartTestServers(replicasCount int)
• func StopTestServers()
• func TestServerCheckState(requestURL string, TestServerSync *sync.WaitGroup)
• type TestRequest
  • func Request(URL string) *TestRequest
  • func (tr *TestRequest) Get() (*http.Response, *TestServerDummyResponse)
  • func (tr *TestRequest) GetWG(endWG *sync.WaitGroup) (*http.Response, *TestServerDummyResponse)
  • func (tr *TestRequest) Post(data string) (*http.Response, *TestServerDummyResponse)
• type TestServer
  • func NewTestServer(ReplicaNumber int) *TestServer
  • func (ts *TestServer) Start()
  • func (ts *TestServer) Stop()
• type TestServerDummyResponse

Constants

const (
	LISTENER_8080_URL = "http://localhost:8080/"
	LISTENER_8081_URL = "http://localhost:8081/"

	TestServerPortStart = 8090
)

Variables

var AllTestServersSync *sync.WaitGroup

var DebugMode bool = true

var TestServersPool []*TestServer

Functions

func GetDelayedRequestPayload

func GetDelayedRequestPayload(second int) string

func GetNumberedHandler

func GetNumberedHandler(testserver *TestServer, ReplicaNumber int, defaultDelayInterval time.Duration) func(http.ResponseWriter, *http.Request)

func StartTestServers

func StartTestServers(replicasCount int)

func StopTestServers

func StopTestServers()

func TestServerCheckState

func TestServerCheckState(requestURL string, TestServerSync *sync.WaitGroup)

Types

type TestRequest

type TestRequest struct {
	Address string
	Req     *http.Request
	Method  string
}

func Request

func Request(URL string) *TestRequest

func (*TestRequest) Get

func (tr *TestRequest) Get() (*http.Response, *TestServerDummyResponse)

func (*TestRequest) GetWG

func (tr *TestRequest) GetWG(endWG *sync.WaitGroup) (*http.Response, *TestServerDummyResponse)

func (*TestRequest) Post

func (tr *TestRequest) Post(data string) (*http.Response, *TestServerDummyResponse)

type TestServer

type TestServer struct {
	Srv           *http.Server
	ReplicaNumber int
	Port          int
}

func NewTestServer

func NewTestServer(ReplicaNumber int) *TestServer

func (*TestServer) Start

func (ts *TestServer) Start()

func (*TestServer) Stop

func (ts *TestServer) Stop()

type TestServerDummyResponse

type TestServerDummyResponse struct {
	Message   string            `json:"message"`
	ReplicaId int               `json:"replicaId"`
	Headers   map[string]string `json:"_headers"`
}