balancer

package

v0.2.1 Latest Latest Go to latest Published: Nov 23, 2023 License: BSD-2-Clause Imports: 8 Imported by: 5

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/zehuamama/balancer

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
type Balancer
- func Build(algorithm string, hosts []string) (Balancer, error)
- func NewBounded(hosts []string) Balancer
- func NewConsistent(hosts []string) Balancer
- func NewIPHash(hosts []string) Balancer
- func NewLeastLoad(hosts []string) Balancer
- func NewP2C(hosts []string) Balancer
- func NewRandom(hosts []string) Balancer
- func NewRoundRobin(hosts []string) Balancer
type BaseBalancer
- func (b *BaseBalancer) Add(host string)
- func (b *BaseBalancer) Balance(key string) (string, error)
- func (b *BaseBalancer) Done(_ string)
- func (b *BaseBalancer) Inc(_ string)
- func (b *BaseBalancer) Remove(host string)
type Bounded
- func (b *Bounded) Add(host string)
- func (b *Bounded) Balance(key string) (string, error)
- func (b *Bounded) Done(host string)
- func (b *Bounded) Inc(host string)
- func (b *Bounded) Remove(host string)
type Consistent
- func (c *Consistent) Add(host string)
- func (c *Consistent) Balance(key string) (string, error)
- func (c *Consistent) Remove(host string)
type Factory
type IPHash
- func (r *IPHash) Balance(key string) (string, error)
type LeastLoad
- func (l *LeastLoad) Add(hostName string)
- func (l *LeastLoad) Balance(_ string) (string, error)
- func (l *LeastLoad) Done(hostName string)
- func (l *LeastLoad) Inc(hostName string)
- func (l *LeastLoad) Remove(hostName string)
type P2C
- func (p *P2C) Add(hostName string)
- func (p *P2C) Balance(key string) (string, error)
- func (p *P2C) Done(host string)
- func (p *P2C) Inc(host string)
- func (p *P2C) Remove(host string)
type Random
- func (r *Random) Balance(_ string) (string, error)
type RoundRobin
- func (r *RoundRobin) Balance(_ string) (string, error)

Constants ¶

View Source

const (
	IPHashBalancer         = "ip-hash"
	ConsistentHashBalancer = "consistent-hash"
	P2CBalancer            = "p2c"
	RandomBalancer         = "random"
	R2Balancer             = "round-robin"
	LeastLoadBalancer      = "least-load"
	BoundedBalancer        = "bounded"
)

View Source

const Salt = "%#!"

Variables ¶

View Source

var (
	NoHostError                = errors.New("no host")
	AlgorithmNotSupportedError = errors.New("algorithm not supported")
)

Functions ¶

This section is empty.

Types ¶

type Balancer ¶

type Balancer interface {
	Add(string)
	Remove(string)
	Balance(string) (string, error)
	Inc(string)
	Done(string)
}

Balancer interface is the load balancer for the reverse proxy

func Build ¶

func Build(algorithm string, hosts []string) (Balancer, error)

Build generates the corresponding Balancer according to the algorithm

func NewBounded ¶ added in v0.2.0

func NewBounded(hosts []string) Balancer

NewBounded create new Bounded balancer

func NewConsistent ¶

func NewConsistent(hosts []string) Balancer

NewConsistent create new Consistent balancer

func NewIPHash ¶

func NewIPHash(hosts []string) Balancer

NewIPHash create new IPHash balancer

func NewLeastLoad ¶ added in v0.2.0

func NewLeastLoad(hosts []string) Balancer

NewLeastLoad create new LeastLoad balancer

func NewP2C ¶

func NewP2C(hosts []string) Balancer

NewP2C create new P2C balancer

func NewRandom ¶

func NewRandom(hosts []string) Balancer

NewRandom create new Random balancer

func NewRoundRobin ¶

func NewRoundRobin(hosts []string) Balancer

NewRoundRobin create new RoundRobin balancer

type BaseBalancer ¶ added in v0.2.1

type BaseBalancer struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*BaseBalancer) Add ¶ added in v0.2.1

func (b *BaseBalancer) Add(host string)

Add new host to the balancer

func (*BaseBalancer) Balance ¶ added in v0.2.1

func (b *BaseBalancer) Balance(key string) (string, error)

Balance selects a suitable host according

func (*BaseBalancer) Done ¶ added in v0.2.1

func (b *BaseBalancer) Done(_ string)

Done .

func (*BaseBalancer) Inc ¶ added in v0.2.1

func (b *BaseBalancer) Inc(_ string)

Inc .

func (*BaseBalancer) Remove ¶ added in v0.2.1

func (b *BaseBalancer) Remove(host string)

Remove new host from the balancer

type Bounded ¶ added in v0.2.0

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

Bounded refers to consistent hash with bounded

func (*Bounded) Add ¶ added in v0.2.0

func (b *Bounded) Add(host string)

Add new host to the balancer

func (*Bounded) Balance ¶ added in v0.2.0

func (b *Bounded) Balance(key string) (string, error)

Balance selects a suitable host according to the key value

func (*Bounded) Done ¶ added in v0.2.0

func (b *Bounded) Done(host string)

Done refers to the number of connections to the server `-1`

func (*Bounded) Inc ¶ added in v0.2.0

func (b *Bounded) Inc(host string)

Inc refers to the number of connections to the server `+1`

func (*Bounded) Remove ¶ added in v0.2.0

func (b *Bounded) Remove(host string)

Remove new host from the balancer

type Consistent ¶

type Consistent struct {
	BaseBalancer
	// contains filtered or unexported fields
}

Consistent refers to consistent hash

func (*Consistent) Add ¶

func (c *Consistent) Add(host string)

Add new host to the balancer

func (*Consistent) Balance ¶

func (c *Consistent) Balance(key string) (string, error)

Balance selects a suitable host according to the key value

func (*Consistent) Remove ¶

func (c *Consistent) Remove(host string)

Remove new host from the balancer

type Factory ¶

type Factory func([]string) Balancer

Factory is the factory that generates Balancer, and the factory design pattern is used here

type IPHash ¶

type IPHash struct {
	BaseBalancer
}

IPHash will choose a host based on the client's IP address

func (*IPHash) Balance ¶

func (r *IPHash) Balance(key string) (string, error)

Balance selects a suitable host according

type LeastLoad ¶ added in v0.2.0

type LeastLoad struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

LeastLoad will choose a host based on the least load host

func (*LeastLoad) Add ¶ added in v0.2.0

func (l *LeastLoad) Add(hostName string)

Add new host to the balancer

func (*LeastLoad) Balance ¶ added in v0.2.0

func (l *LeastLoad) Balance(_ string) (string, error)

Balance selects a suitable host according

func (*LeastLoad) Done ¶ added in v0.2.0

func (l *LeastLoad) Done(hostName string)

Done refers to the number of connections to the server `-1`

func (*LeastLoad) Inc ¶ added in v0.2.0

func (l *LeastLoad) Inc(hostName string)

Inc refers to the number of connections to the server `+1`

func (*LeastLoad) Remove ¶ added in v0.2.0

func (l *LeastLoad) Remove(hostName string)

Remove new host from the balancer

type P2C ¶

type P2C struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

P2C refer to the power of 2 random choice

func (*P2C) Add ¶

func (p *P2C) Add(hostName string)

Add new host to the balancer

func (*P2C) Balance ¶

func (p *P2C) Balance(key string) (string, error)

Balance selects a suitable host according to the key value

func (*P2C) Done ¶

func (p *P2C) Done(host string)

Done refers to the number of connections to the server `-1`

func (*P2C) Inc ¶

func (p *P2C) Inc(host string)

Inc refers to the number of connections to the server `+1`

func (*P2C) Remove ¶

func (p *P2C) Remove(host string)

Remove new host from the balancer

type Random ¶

type Random struct {
	BaseBalancer
	// contains filtered or unexported fields
}

Random will randomly select a http server from the server

func (*Random) Balance ¶

func (r *Random) Balance(_ string) (string, error)

Balance selects a suitable host according

type RoundRobin ¶

type RoundRobin struct {
	BaseBalancer
	// contains filtered or unexported fields
}

RoundRobin will select the server in turn from the server to proxy

func (*RoundRobin) Balance ¶

func (r *RoundRobin) Balance(_ string) (string, error)

Balance selects a suitable host according

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL