balancer

package

v1.0.0 Latest Latest Go to latest Published: Jan 15, 2018 License: MIT Imports: 9 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

type Balancer struct {
	Scheduler *Scheduler
	// contains filtered or unexported fields
}

func NewBalancer(httpListenCfg string, httpsListenCfg string) *Balancer

func (b *Balancer) HandleClientConnect(ctx *core.Context)

func (b *Balancer) HandleClientDisconnect(client net.Conn)

func (b *Balancer) ListenHttp() (err error)

func (b *Balancer) ListenHttps() (err error)

func (b *Balancer) Start() error

func (b *Balancer) Stop()

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

type ElectRequest struct {
	Context  core.Context
	Response chan core.RouterHost
	Err      chan error
}

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

type Scheduler struct {
	StatsHandler *stats.StatsHandler

	ResetStats chan bool
	// contains filtered or unexported fields
}

Scheduler handles: - The overall state (clusters, router hosts) - Health-Check-Results - Election of target router hosts

func NewScheduler() *Scheduler

func (s *Scheduler) AddOrUpdateCluster(clusterKey string, data core.ClusterUpdate)

func (s *Scheduler) ElectRouterHostRequest(ctx core.Context) (*core.RouterHost, error)

func (s *Scheduler) Start()

func (s *Scheduler) Stop()

func (s *Scheduler) UpdateRouterStats(clusterKey string, routerHostKey string, action StatsOperationAction)

type StatsOperationAction int

const (
	IncrementConnection StatsOperationAction = iota
	DecrementConnection
	IncrementRefused
)