lb

Documentation

Overview

Package lb is default LoadBalance implements.

Index

• Constants
• func NewWeightLbFunc(newLb motan.NewLbFunc) motan.NewLbFunc
• func RegistDefaultLb(extFactory motan.ExtentionFactory)
• func SelectArrayFromIndex(endpoints []motan.EndPoint, fromIndex int) []motan.EndPoint
• func SelectOneAtRandom(endpoints []motan.EndPoint) (int, motan.EndPoint)
• type RandomLB
  • func (r *RandomLB) OnRefresh(endpoints []motan.EndPoint)
  • func (r *RandomLB) Select(request motan.Request) motan.EndPoint
  • func (r *RandomLB) SelectArray(request motan.Request) []motan.EndPoint
  • func (r *RandomLB) SetWeight(weight string)
• type RoundrobinLB
  • func (r *RoundrobinLB) OnRefresh(endpoints []motan.EndPoint)
  • func (r *RoundrobinLB) Select(request motan.Request) motan.EndPoint
  • func (r *RoundrobinLB) SelectArray(request motan.Request) []motan.EndPoint
  • func (r *RoundrobinLB) SetWeight(weight string)
• type WeightedLbWraper
  • func (w *WeightedLbWraper) OnRefresh(endpoints []motan.EndPoint)
  • func (w *WeightedLbWraper) Select(request motan.Request) motan.EndPoint
  • func (w *WeightedLbWraper) SelectArray(request motan.Request) []motan.EndPoint
  • func (w *WeightedLbWraper) SetWeight(weight string)

Constants

const (
	Random     = "random"
	Roundrobin = "roundrobin"
)

ext name

const (
	MaxSelectArraySize = 3
)

Functions

func NewWeightLbFunc

func NewWeightLbFunc(newLb motan.NewLbFunc) motan.NewLbFunc

func RegistDefaultLb

func RegistDefaultLb(extFactory motan.ExtentionFactory)

func SelectArrayFromIndex

func SelectArrayFromIndex(endpoints []motan.EndPoint, fromIndex int) []motan.EndPoint

func SelectOneAtRandom

func SelectOneAtRandom(endpoints []motan.EndPoint) (int, motan.EndPoint)

SelectOneAtRandom to prevent put pressure to the next node when a node being unavailable, then need to do two random

Types

type RandomLB

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

func (*RandomLB) OnRefresh

func (r *RandomLB) OnRefresh(endpoints []motan.EndPoint)

func (*RandomLB) Select

func (r *RandomLB) Select(request motan.Request) motan.EndPoint

func (*RandomLB) SelectArray

func (r *RandomLB) SelectArray(request motan.Request) []motan.EndPoint

func (*RandomLB) SetWeight

func (r *RandomLB) SetWeight(weight string)

type RoundrobinLB

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

func (*RoundrobinLB) OnRefresh

func (r *RoundrobinLB) OnRefresh(endpoints []motan.EndPoint)

func (*RoundrobinLB) Select

func (r *RoundrobinLB) Select(request motan.Request) motan.EndPoint

func (*RoundrobinLB) SelectArray

func (r *RoundrobinLB) SelectArray(request motan.Request) []motan.EndPoint

func (*RoundrobinLB) SetWeight

func (r *RoundrobinLB) SetWeight(weight string)

type WeightedLbWraper

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

WeightedLbWraper support multi group weighted LB

func (*WeightedLbWraper) OnRefresh

func (w *WeightedLbWraper) OnRefresh(endpoints []motan.EndPoint)

func (*WeightedLbWraper) Select

func (w *WeightedLbWraper) Select(request motan.Request) motan.EndPoint

func (*WeightedLbWraper) SelectArray

func (w *WeightedLbWraper) SelectArray(request motan.Request) []motan.EndPoint

func (*WeightedLbWraper) SetWeight

func (w *WeightedLbWraper) SetWeight(weight string)