selector

Sep 13, 2021

Changes in this version

+ const Error

+ const OK

+ const Timeout

+ type DebugReporter interface

+ ReportWeights func()

+ type LVSWRRSelector struct

+ func NewLVSWRRSelector(timeout time.Duration) *LVSWRRSelector

+ func (ls *LVSWRRSelector) Add(url string, upstreamType UpstreamType, weight int32) (err error)

+ func (ls *LVSWRRSelector) Get() *Upstream

+ func (ls *LVSWRRSelector) ReportUpstreamStatus(upstream *Upstream, upstreamStatus upstreamStatus)

+ func (ls *LVSWRRSelector) ReportWeights()

+ func (ls *LVSWRRSelector) StartEvaluate()

+ type NginxWRRSelector struct

+ func NewNginxWRRSelector(timeout time.Duration) *NginxWRRSelector

+ func (ws *NginxWRRSelector) Add(url string, upstreamType UpstreamType, weight int32) (err error)

+ func (ws *NginxWRRSelector) Get() *Upstream

+ func (ws *NginxWRRSelector) ReportUpstreamStatus(upstream *Upstream, upstreamStatus upstreamStatus)

+ func (ws *NginxWRRSelector) ReportWeights()

+ func (ws *NginxWRRSelector) StartEvaluate()

+ type RandomSelector struct

+ func NewRandomSelector() *RandomSelector

+ func (rs *RandomSelector) Add(url string, upstreamType UpstreamType) (err error)

+ func (rs *RandomSelector) Get() *Upstream

+ func (rs *RandomSelector) ReportUpstreamStatus(upstream *Upstream, upstreamStatus upstreamStatus)

+ func (rs *RandomSelector) StartEvaluate()

+ type Selector interface

+ Get func() *Upstream

+ ReportUpstreamStatus func(upstream *Upstream, upstreamStatus upstreamStatus)

+ StartEvaluate func()

+ type Upstream struct

+ RequestType string

+ Type UpstreamType

+ URL string

+ func (u Upstream) String() string

+ type UpstreamType int

+ const Google

+ const IETF