grpc: google.golang.org/grpc/xds/internal/balancer/edsbalancer Index | Files

package edsbalancer

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

Package edsbalancer implements a balancer to handle EDS responses.

Index

Package Files

balancergroup.go edsbalancer.go util.go

type EDSBalancer Uses

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 Uses

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

NewXDSBalancer create a new EDSBalancer.

func (*EDSBalancer) Close Uses

func (xdsB *EDSBalancer) Close()

Close closes the balancer.

func (*EDSBalancer) HandleChildPolicy Uses

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 Uses

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 Uses

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

HandleSubConnStateChange handles the state change and update pickers accordingly.

func (*EDSBalancer) UpdateBalancerState Uses

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

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

Package edsbalancer imports 22 packages (graph) and is imported by 1 packages. Updated 2019-08-12. Refresh now. Tools for package owners.