balancer: remove deprecated type aliases as planned (#3742)
This commit is contained in:
@ -312,16 +312,6 @@ type Balancer interface {
|
|||||||
Close()
|
Close()
|
||||||
}
|
}
|
||||||
|
|
||||||
// V2Balancer is temporarily defined for backward compatibility reasons.
|
|
||||||
//
|
|
||||||
// Deprecated: use Balancer directly instead.
|
|
||||||
type V2Balancer = Balancer
|
|
||||||
|
|
||||||
// V2Picker is temporarily defined for backward compatibility reasons.
|
|
||||||
//
|
|
||||||
// Deprecated: use Picker directly instead.
|
|
||||||
type V2Picker = Picker
|
|
||||||
|
|
||||||
// SubConnState describes the state of a SubConn.
|
// SubConnState describes the state of a SubConn.
|
||||||
type SubConnState struct {
|
type SubConnState struct {
|
||||||
// ConnectivityState is the connectivity state of the SubConn.
|
// ConnectivityState is the connectivity state of the SubConn.
|
||||||
|
@ -69,14 +69,3 @@ func NewBalancerBuilder(name string, pb PickerBuilder, config Config) balancer.B
|
|||||||
config: config,
|
config: config,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// NewBalancerBuilderV2 is temporarily defined for backward compatibility
|
|
||||||
// reasons.
|
|
||||||
//
|
|
||||||
// Deprecated: use NewBalancerBuilder instead.
|
|
||||||
var NewBalancerBuilderV2 = NewBalancerBuilder
|
|
||||||
|
|
||||||
// V2PickerBuilder is temporarily defined for backward compatibility reasons.
|
|
||||||
//
|
|
||||||
// Deprecated: use PickerBuilder instead.
|
|
||||||
type V2PickerBuilder = PickerBuilder
|
|
||||||
|
@ -97,7 +97,7 @@ func (lb *rlsBalancer) handleClientConnUpdate(ccs *balancer.ClientConnState) {
|
|||||||
|
|
||||||
// UpdateClientConnState pushes the received ClientConnState update on the
|
// UpdateClientConnState pushes the received ClientConnState update on the
|
||||||
// update channel which will be processed asynchronously by the run goroutine.
|
// update channel which will be processed asynchronously by the run goroutine.
|
||||||
// Implements balancer.V2Balancer interface.
|
// Implements balancer.Balancer interface.
|
||||||
func (lb *rlsBalancer) UpdateClientConnState(ccs balancer.ClientConnState) error {
|
func (lb *rlsBalancer) UpdateClientConnState(ccs balancer.ClientConnState) error {
|
||||||
select {
|
select {
|
||||||
case lb.ccUpdateCh <- &ccs:
|
case lb.ccUpdateCh <- &ccs:
|
||||||
@ -106,14 +106,14 @@ func (lb *rlsBalancer) UpdateClientConnState(ccs balancer.ClientConnState) error
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// ResolverErr implements balancer.V2Balancer interface.
|
// ResolverErr implements balancer.Balancer interface.
|
||||||
func (lb *rlsBalancer) ResolverError(error) {
|
func (lb *rlsBalancer) ResolverError(error) {
|
||||||
// ResolverError is called by gRPC when the name resolver reports an error.
|
// ResolverError is called by gRPC when the name resolver reports an error.
|
||||||
// TODO(easwars): How do we handle this?
|
// TODO(easwars): How do we handle this?
|
||||||
logger.Fatal("rls: ResolverError is not yet unimplemented")
|
logger.Fatal("rls: ResolverError is not yet unimplemented")
|
||||||
}
|
}
|
||||||
|
|
||||||
// UpdateSubConnState implements balancer.V2Balancer interface.
|
// UpdateSubConnState implements balancer.Balancer interface.
|
||||||
func (lb *rlsBalancer) UpdateSubConnState(_ balancer.SubConn, _ balancer.SubConnState) {
|
func (lb *rlsBalancer) UpdateSubConnState(_ balancer.SubConn, _ balancer.SubConnState) {
|
||||||
logger.Fatal("rls: UpdateSubConnState is not yet implemented")
|
logger.Fatal("rls: UpdateSubConnState is not yet implemented")
|
||||||
}
|
}
|
||||||
|
@ -231,7 +231,6 @@ func edsCCS(service string, enableLRS bool, xdsClient interface{}) balancer.Clie
|
|||||||
func setup() (*cdsBalancer, *testEDSBalancer, *testClientConn, func()) {
|
func setup() (*cdsBalancer, *testEDSBalancer, *testClientConn, func()) {
|
||||||
builder := cdsBB{}
|
builder := cdsBB{}
|
||||||
tcc := newTestClientConn()
|
tcc := newTestClientConn()
|
||||||
// cdsB := builder.Build(tcc, balancer.BuildOptions{}).(balancer.V2Balancer)
|
|
||||||
cdsB := builder.Build(tcc, balancer.BuildOptions{})
|
cdsB := builder.Build(tcc, balancer.BuildOptions{})
|
||||||
|
|
||||||
edsB := newTestEDSBalancer()
|
edsB := newTestEDSBalancer()
|
||||||
|
Reference in New Issue
Block a user