package xds

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

Package xds contains functions, structs, and utilities for working with handshake cluster names, as well as shared components used by xds balancers and resolvers. It is separated from the top-level /internal package to avoid circular dependencies.

Index ¶

• Variables
• func GetLocalityID(addr resolver.Address) clients.Locality
• func GetXDSHandshakeClusterName(attr *attributes.Attributes) (string, bool)
• func IsLocalityEqual(l clients.Locality, o any) bool
• func LocalityFromString(s string) (ret clients.Locality, _ error)
• func LocalityString(l clients.Locality) string
• func SetLocalityID(addr resolver.Address, l clients.Locality) resolver.Address
• func SetLocalityIDInEndpoint(endpoint resolver.Endpoint, l clients.Locality) resolver.Endpoint
• func SetXDSHandshakeClusterName(addr resolver.Address, clusterName string) resolver.Address

Variables ¶

var ResourceTypeMapForTesting map[string]any

ResourceTypeMapForTesting maps TypeUrl to corresponding ResourceType.

var UnknownCSMLabels = map[string]string{
	"csm.service_name":           "unknown",
	"csm.service_namespace_name": "unknown",
}

UnknownCSMLabels are TelemetryLabels emitted from CDS if CSM Telemetry Label data is not present in the CDS Resource.

Functions ¶

func GetLocalityID ¶

func GetLocalityID(addr resolver.Address) clients.Locality

GetLocalityID returns the locality ID of addr.

func GetXDSHandshakeClusterName ¶

func GetXDSHandshakeClusterName(attr *attributes.Attributes) (string, bool)

GetXDSHandshakeClusterName returns cluster name stored in attr.

func IsLocalityEqual ¶

func IsLocalityEqual(l clients.Locality, o any) bool

IsLocalityEqual allows the values to be compared by Attributes.Equal.

func LocalityFromString ¶

func LocalityFromString(s string) (ret clients.Locality, _ error)

LocalityFromString converts a string representation of clients.locality as specified in gRFC A76, into a LocalityID struct.

func LocalityString ¶

func LocalityString(l clients.Locality) string

LocalityString generates a string representation of clients.Locality in the format specified in gRFC A76.

func SetLocalityID ¶

func SetLocalityID(addr resolver.Address, l clients.Locality) resolver.Address

SetLocalityID sets locality ID in addr to l.

func SetLocalityIDInEndpoint ¶

func SetLocalityIDInEndpoint(endpoint resolver.Endpoint, l clients.Locality) resolver.Endpoint

SetLocalityIDInEndpoint sets locality ID in endpoint to l.

func SetXDSHandshakeClusterName ¶

func SetXDSHandshakeClusterName(addr resolver.Address, clusterName string) resolver.Address

SetXDSHandshakeClusterName returns a copy of addr in which the Attributes field is updated with the cluster name.

Source Files ¶

xds.go

Directories ¶