mocks

Documentation

Index

• Variables
• func CreateNewMockProxy(b config.Backend, h map[string]string) proxy.IProxyClient
• type MockProxy
  • func (m *MockProxy) PendingRequests() int
  • func (m *MockProxy) ReverseProxyHandler(ctx *fasthttp.RequestCtx) error
  • func (m *MockProxy) Stat() types.ProxyStat

Variables

var TestCases = []testCaseStruct{
	{
		Config: config.Config{
			Host: "localhost",
			Port: "8000",
			Backends: []config.Backend{
				{
					Url:    "localhost:8080",
					Weight: 1,
				},
				{
					Url:    "localhost:80",
					Weight: 1,
				},
			},
			HealthCheckerTime: time.Second * 5,
			HealthCheckerFunc: func(string) bool {
				return true
			},
			HashFunc: func(b []byte) uint32 {
				return uint32(len(b))
			},
		},
		ExpectedServerCount: 2,
		ProxyFunc:           CreateNewMockProxy,
	},
	{
		Config: config.Config{
			Host: "localhost",
			Port: "8000",
			Backends: []config.Backend{
				{
					Url:    "localhost:8080",
					Weight: 1,
				},
			},
			HealthCheckerTime: time.Second * 5,
			HealthCheckerFunc: func(string) bool {
				return true
			},
			HashFunc: func(b []byte) uint32 {
				return uint32(len(b))
			},
		},
		ExpectedServerCount: 1,
		ProxyFunc:           CreateNewMockProxy,
	},
	{
		Config: config.Config{
			Host: "localhost",
			Port: "8000",
			Backends: []config.Backend{
				{
					Url:    "localhost:8080",
					Weight: 1,
				},
				{
					Url:    "localhost:80",
					Weight: 1,
				},
			},
			HealthCheckerTime: time.Second * 5,
			HealthCheckerFunc: func(string) bool {
				return false
			},
			HashFunc: func(b []byte) uint32 {
				return uint32(len(b))
			},
		},
		ExpectedServerCount: 0,
		ProxyFunc:           CreateNewMockProxy,
	},
	{
		Config: config.Config{
			Host:              "localhost",
			Port:              "8000",
			Backends:          []config.Backend{},
			HealthCheckerTime: time.Second * 5,
			HealthCheckerFunc: func(s string) bool {
				return false

			},
			HashFunc: func(b []byte) uint32 {
				return uint32(len(b))
			},
		},
		ExpectedServerCount: 0,
		ProxyFunc:           CreateNewMockProxy,
	},
	{
		Config: config.Config{
			Host: "localhost",
			Port: "8000",
			Backends: []config.Backend{
				{
					Url:    "localhost:7070",
					Weight: 1,
				},
				{
					Url:    "localhost:80",
					Weight: 1,
				},
			},
			HealthCheckerTime: time.Second * 5,
			HealthCheckerFunc: func(string) bool {
				return true
			},
			HashFunc: func(b []byte) uint32 {
				return uint32(len(b))
			},
		},
		ExpectedServerCount: 2,
		ProxyFunc:           CreateNewMockProxy,
	},
}

Functions

func CreateNewMockProxy

func CreateNewMockProxy(b config.Backend, h map[string]string) proxy.IProxyClient

Types

type MockProxy

type MockProxy struct {
	Addr     string
	IsCalled bool
	// contains filtered or unexported fields
}

func (*MockProxy) PendingRequests

func (m *MockProxy) PendingRequests() int

func (*MockProxy) ReverseProxyHandler

func (m *MockProxy) ReverseProxyHandler(ctx *fasthttp.RequestCtx) error

func (*MockProxy) Stat

func (m *MockProxy) Stat() types.ProxyStat