slbKit

package

v3.0.919 Latest Latest Go to latest Published: Jul 31, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Backend struct {
	mutexKit.Mutex

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

func (be *Backend) HealthCheck()

HealthCheck 健康检查（此方法会修改 Alive 字段）.

@return 后端服务是否可用？

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

func (be *Backend) SetAlive(alive bool)

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

func NewLoadBalancer() (lb *LoadBalancer)

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

func (lb *LoadBalancer) Dispose()

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

GetNextPeer

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

func (lb *LoadBalancer) HandleRequest(w http.ResponseWriter, r *http.Request) error

func (lb *LoadBalancer) HealthCheck()

HealthCheck 对目前所有的后端服务，进行1次健康检查.

func (lb *LoadBalancer) NextIndex() int32

NextIndex 返回下一个下标.

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

func (lb *LoadBalancer) Start() (err error)

func (lb *LoadBalancer) UpdateIndex(i int32)

UpdateIndex 更新下标.

PS: 此方法无需加锁.