package edsbalancer

import "google.golang.org/grpc/xds/internal/balancer/edsbalancer"

Package edsbalancer implements a balancer to handle EDS responses.

Index ¶

• type EDSBalancer
• func NewXDSBalancer(cc balancer.ClientConn, loadStore lrs.Store) *EDSBalancer
• func (xdsB *EDSBalancer) Close()
• func (xdsB *EDSBalancer) HandleChildPolicy(name string, config json.RawMessage)
• func (xdsB *EDSBalancer) HandleEDSResponse(edsResp *edspb.ClusterLoadAssignment)
• func (xdsB *EDSBalancer) HandleSubConnStateChange(sc balancer.SubConn, s connectivity.State)
• func (xdsB *EDSBalancer) UpdateBalancerState(s connectivity.State, p balancer.Picker)

Types ¶

type EDSBalancer ¶

type EDSBalancer struct {
	balancer.ClientConn
	// contains filtered or unexported fields
}

EDSBalancer does load balancing based on the EDS responses. Note that it doesn't implement the balancer interface. It's intended to be used by a high level balancer implementation.

The localities are picked as weighted round robin. A configurable child policy is used to manage endpoints in each locality.

func NewXDSBalancer ¶

func NewXDSBalancer(cc balancer.ClientConn, loadStore lrs.Store) *EDSBalancer

NewXDSBalancer create a new EDSBalancer.

func (*EDSBalancer) Close ¶

func (xdsB *EDSBalancer) Close()

Close closes the balancer.

func (*EDSBalancer) HandleChildPolicy ¶

func (xdsB *EDSBalancer) HandleChildPolicy(name string, config json.RawMessage)

HandleChildPolicy updates the child balancers handling endpoints. Child policy is roundrobin by default. If the specified balancer is not installed, the old child balancer will be used.

HandleChildPolicy and HandleEDSResponse must be called by the same goroutine.

func (*EDSBalancer) HandleEDSResponse ¶

func (xdsB *EDSBalancer) HandleEDSResponse(edsResp *edspb.ClusterLoadAssignment)

HandleEDSResponse handles the EDS response and creates/deletes localities and SubConns. It also handles drops.

HandleCDSResponse and HandleEDSResponse must be called by the same goroutine.

func (*EDSBalancer) HandleSubConnStateChange ¶

func (xdsB *EDSBalancer) HandleSubConnStateChange(sc balancer.SubConn, s connectivity.State)

HandleSubConnStateChange handles the state change and update pickers accordingly.

func (*EDSBalancer) UpdateBalancerState ¶

func (xdsB *EDSBalancer) UpdateBalancerState(s connectivity.State, p balancer.Picker)

UpdateBalancerState overrides balancer.ClientConn to wrap the picker in a dropPicker.

Source Files ¶

balancergroup.go edsbalancer.go util.go