From f498e76defe1e37a943ea9d7b500ac99cf473975 Mon Sep 17 00:00:00 2001 From: kevin Date: Thu, 30 Jul 2020 22:56:13 +0800 Subject: [PATCH] add roundrobin --- rpcx/internal/balancer/roundrobin.go | 13 ++++++++++++- 1 file changed, 12 insertions(+), 1 deletion(-) diff --git a/rpcx/internal/balancer/roundrobin.go b/rpcx/internal/balancer/roundrobin.go index 2621c1f5..7a7a4bf1 100644 --- a/rpcx/internal/balancer/roundrobin.go +++ b/rpcx/internal/balancer/roundrobin.go @@ -1,8 +1,11 @@ package balancer import ( + "context" + "google.golang.org/grpc/balancer" "google.golang.org/grpc/balancer/base" + "google.golang.org/grpc/resolver" ) const ( @@ -20,6 +23,14 @@ func newBuilder() balancer.Builder { return base.NewBalancerBuilder(Name, new(roundRobinPickerBuilder)) } -func (b *roundRobinPickerBuilder) Build(info base.PickerBuildInfo) balancer.Picker { +func (b *roundRobinPickerBuilder) Build(readySCs map[resolver.Address]balancer.SubConn) balancer.Picker { + panic("implement me") +} + +type roundRobinPicker struct { +} + +func (p *roundRobinPicker) Pick(ctx context.Context, info balancer.PickInfo) ( + conn balancer.SubConn, done func(balancer.DoneInfo), err error) { panic("implement me") }