modules

package

v0.0.0-...-6fc17c5 Latest Latest Go to latest Published: Dec 1, 2017 License: BSD-3-Clause Imports: 12 Imported by: 3

Details

This section is empty.

This section is empty.

This section is empty.

type Backend struct {
	config.BackendConfig
	BackendControl
	sync.RWMutex
	Close chan bool
}

func NewBackend(backendConfig config.BackendConfig) *Backend

type BackendControl struct {
	Failed        bool
	Active        bool
	InactiveTries int
	ActiveTries   int
	Score         int
}

type BackendList []*Backend

type Frontend struct {
	config.FrontendConfig
	BackendList
	sync.RWMutex
	Close chan bool
	Pos   int
}

func NewFrontend(frontendConfig config.FrontendConfig) *Frontend

func (f *Frontend) Address() string

type FrontendList []*Frontend

type SLBRequest struct {
	Header   http.Header
	Status   int
	Body     []byte
	Upgraded bool
	Backend  *Backend
}

func NewWorkerRequest(status int, header http.Header, body []byte) SLBRequest

func NewWorkerRequestErr(status int, body []byte) SLBRequest

func NewWorkerRequestUpgraded() SLBRequest

func (s *SLBRequest) HijackWebSocket(w http.ResponseWriter, r *http.Request)

type SLBRequestChan chan SLBRequest

type Worker struct {
	Idle bool
	sync.RWMutex
}

func NewWorker() *Worker

func (w *Worker) Run(r *http.Request, frontend *Frontend) SLBRequestChan

type WorkerPool struct {
	config.Configuration
	Workers
	sync.RWMutex
}

func NewWorkerPool(configuration config.Configuration) *WorkerPool

func (wp *WorkerPool) CountIdle() int

func (wp *WorkerPool) Get(r *http.Request, frontend *Frontend) SLBRequestChan

func (wp *WorkerPool) Resize()

todo experiment feature

type Workers []*Worker