endpointsharding

Documentation

Overview

Package endpointsharding implements a load balancing policy that manages homogeneous child policies each owning a single endpoint.

Experimental

Notice: This package is EXPERIMENTAL and may be changed or removed in a later release.

Index

• Constants
• func NewBalancer(cc balancer.ClientConn, opts balancer.BuildOptions) balancer.Balancer
• func ParseConfig(cfg json.RawMessage) (serviceconfig.LoadBalancingConfig, error)
• type ChildState
  • func ChildStatesFromPicker(picker balancer.Picker) []ChildState

Constants

const PickFirstConfig = "[{\"pick_first\": {}}]"

PickFirstConfig is a pick first config without shuffling enabled.

Functions

func NewBalancer

func NewBalancer(cc balancer.ClientConn, opts balancer.BuildOptions) balancer.Balancer

NewBalancer returns a load balancing policy that manages homogeneous child policies each owning a single endpoint.

func ParseConfig

func ParseConfig(cfg json.RawMessage) (serviceconfig.LoadBalancingConfig, error)

Types

type ChildState

type ChildState struct {
	Endpoint resolver.Endpoint
	State    balancer.State
}

ChildState is the balancer state of a child along with the endpoint which identifies the child balancer.

func ChildStatesFromPicker

func ChildStatesFromPicker(picker balancer.Picker) []ChildState

ChildStatesFromPicker returns the state of all the children managed by the endpoint sharding balancer that created this picker.