...

Package clustermanager

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

Overview ▹

Overview ▾

Package clustermanager implements the cluster manager LB policy for xds.

Index ▹

Index ▾

func GetPickedClusterForTesting(ctx context.Context) string

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

Package files

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

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.