package clustermanager

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

Package clustermanager implements the cluster manager LB policy for xds.

Index ¶

• func GetPickedClusterForTesting(ctx context.Context) string
• func SetPickedCluster(ctx context.Context, cluster string) context.Context

Functions ¶

func GetPickedClusterForTesting ¶

func GetPickedClusterForTesting(ctx context.Context) string

GetPickedClusterForTesting returns the cluster in the context; to be used for testing only.

func SetPickedCluster ¶

func SetPickedCluster(ctx context.Context, cluster string) context.Context

SetPickedCluster adds the selected cluster to the context for the xds_cluster_manager LB policy to pick.

Source Files ¶

balancerstateaggregator.go clustermanager.go config.go picker.go