mirror of
https://github.com/go-kratos/kratos.git
synced 2025-02-09 13:36:57 +02:00
* add balancer * add p2c balancer * add http client selector filter Co-authored-by: yuemoxi <99347745@qq.com> Co-authored-by: chenzhihui <zhihui_chen@foxmail.com>
50 lines
1.1 KiB
Go
50 lines
1.1 KiB
Go
package selector
|
|
|
|
import (
|
|
"context"
|
|
"sync"
|
|
)
|
|
|
|
// Default is composite selector.
|
|
type Default struct {
|
|
NodeBuilder WeightedNodeBuilder
|
|
Balancer Balancer
|
|
|
|
lk sync.RWMutex
|
|
weightedNodes []Node
|
|
}
|
|
|
|
// Select select one node.
|
|
func (d *Default) Select(ctx context.Context, opts ...SelectOption) (selected Node, done DoneFunc, err error) {
|
|
d.lk.RLock()
|
|
weightedNodes := d.weightedNodes
|
|
d.lk.RUnlock()
|
|
var options SelectOptions
|
|
for _, o := range opts {
|
|
o(&options)
|
|
}
|
|
for _, f := range options.Filters {
|
|
weightedNodes = f(ctx, weightedNodes)
|
|
}
|
|
candidates := make([]WeightedNode, 0, len(weightedNodes))
|
|
for _, n := range weightedNodes {
|
|
candidates = append(candidates, n.(WeightedNode))
|
|
}
|
|
if len(candidates) == 0 {
|
|
return nil, nil, ErrNoAvailable
|
|
}
|
|
return d.Balancer.Pick(ctx, candidates)
|
|
}
|
|
|
|
// Apply update nodes info.
|
|
func (d *Default) Apply(nodes []Node) {
|
|
weightedNodes := make([]Node, 0, len(nodes))
|
|
for _, n := range nodes {
|
|
weightedNodes = append(weightedNodes, d.NodeBuilder.Build(n))
|
|
}
|
|
d.lk.Lock()
|
|
// TODO: Do not delete unchanged nodes
|
|
d.weightedNodes = weightedNodes
|
|
d.lk.Unlock()
|
|
}
|