package clusterimpl

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

Package clusterimpl implements the xds_cluster_impl balancing policy. It handles the cluster features (e.g. circuit_breaking, RPC dropping).

Note that it doesn't handle name resolution, which is done by policy xds_cluster_resolver.

Index ¶

• Constants
• Variables
• func AutoHostRewriteEnabledForTesting(ctx context.Context) bool
• func EnableAutoHostRewrite(ctx context.Context) context.Context
• type DropConfig
• type LBConfig

Constants ¶

const (
	// Name is the name of the cluster_impl balancer.
	Name = "xds_cluster_impl_experimental"
)

Variables ¶

var NewRandomWRR = wrr.NewRandom

NewRandomWRR is used when calculating drops. It's exported so that tests can override it.

Functions ¶

func AutoHostRewriteEnabledForTesting ¶

func AutoHostRewriteEnabledForTesting(ctx context.Context) bool

AutoHostRewriteEnabledForTesting returns the value of autoHostRewrite field; to be used for testing only.

func EnableAutoHostRewrite ¶

func EnableAutoHostRewrite(ctx context.Context) context.Context

EnableAutoHostRewrite adds the autoHostRewrite value to the context for the xds_cluster_impl LB policy to pick.

Types ¶

type DropConfig ¶

type DropConfig struct {
	Category           string
	RequestsPerMillion uint32
}

DropConfig contains the category, and drop ratio.

type LBConfig ¶

type LBConfig struct {
	serviceconfig.LoadBalancingConfig `json:"-"`

	Cluster     string                                `json:"cluster,omitempty"`
	ChildPolicy *internalserviceconfig.BalancerConfig `json:"childPolicy,omitempty"`
}

LBConfig is the balancer config for cluster_impl balancer.

Source Files ¶

clusterimpl.go config.go logging.go picker.go

Directories ¶