slbKit

Documentation

Index

• type Backend
  • func (be *Backend) HealthCheck()
  • func (be *Backend) IsAlive() (alive bool)
  • func (be *Backend) SetAlive(alive bool)
• type LoadBalancer
  • func NewLoadBalancer() *LoadBalancer
  • func (lb *LoadBalancer) AddBackend(backend *Backend)
  • func (lb *LoadBalancer) GetNextPeer() (backend *Backend)
  • func (lb *LoadBalancer) HealthCheck()
  • func (lb *LoadBalancer) NextIndex() int32
  • func (lb *LoadBalancer) UpdateIndex(i int32)

Types

type Backend

type Backend struct {
	mutexKit.Mutex

	// Alive 节点是否可用？
	Alive        bool
	URL          *url.URL
	ReverseProxy *httputil.ReverseProxy
}

func (*Backend) HealthCheck

func (be *Backend) HealthCheck()

HealthCheck 健康检查.

@return 后端服务是否可用？

func (*Backend) IsAlive

func (be *Backend) IsAlive() (alive bool)

func (*Backend) SetAlive

func (be *Backend) SetAlive(alive bool)

type LoadBalancer

type LoadBalancer struct {
	mutexKit.RWMutex
	// contains filtered or unexported fields
}

func NewLoadBalancer

func NewLoadBalancer() *LoadBalancer

func (*LoadBalancer) AddBackend

func (lb *LoadBalancer) AddBackend(backend *Backend)

func (*LoadBalancer) GetNextPeer

func (lb *LoadBalancer) GetNextPeer() (backend *Backend)

GetNextPeer

@return 可能为nil（即此时无可用后端服务）

func (*LoadBalancer) HealthCheck

func (lb *LoadBalancer) HealthCheck()

HealthCheck 健康检查.

func (*LoadBalancer) NextIndex

func (lb *LoadBalancer) NextIndex() int32

NextIndex 返回下一个下标.

PS: (1) 此方法无需加锁; (2) 需要自行对返回值先进行 其余操作(%) 才能继续使用.

func (*LoadBalancer) UpdateIndex

func (lb *LoadBalancer) UpdateIndex(i int32)

UpdateIndex 更新下标.

PS: 此方法无需加锁.