topology

Documentation

Index

• func BuildEdsEndpoint(localZone string, dataplanes []*core_mesh.DataplaneResource, ...) core_xds.EndpointMap
• func GetLocality(localZone string, otherZone *string, localityAwareness bool) *core_xds.Locality
• func ResolveDataplaneAddress(lookupIPFunc lookup.LookupIPFunc, dataplane *core_mesh.DataplaneResource) (*core_mesh.DataplaneResource, error)
• func ResolveZoneIngressPublicAddress(lookupIPFunc lookup.LookupIPFunc, zoneIngress *core_mesh.ZoneIngressResource) (*core_mesh.ZoneIngressResource, error)

Functions

func BuildEdsEndpoint

func BuildEdsEndpoint(
	localZone string,
	dataplanes []*core_mesh.DataplaneResource,
	zoneIngresses []*core_mesh.ZoneIngressResource,
) core_xds.EndpointMap

func GetLocality

func GetLocality(localZone string, otherZone *string, localityAwareness bool) *core_xds.Locality

func ResolveDataplaneAddress

func ResolveDataplaneAddress(lookupIPFunc lookup.LookupIPFunc, dataplane *core_mesh.DataplaneResource) (*core_mesh.DataplaneResource, error)

ResolveDataplaneAddress resolves 'dataplane.networking.address' if it has DNS name in it. This is a crucial feature for some environments specifically AWS ECS. Dataplane resource has to be created before running Dubbo DP, but IP address will be assigned only after container's start. Envoy EDS doesn't support DNS names, that's why Dubbo CP resolves addresses before sending resources to the proxy.

func ResolveZoneIngressPublicAddress

func ResolveZoneIngressPublicAddress(lookupIPFunc lookup.LookupIPFunc, zoneIngress *core_mesh.ZoneIngressResource) (*core_mesh.ZoneIngressResource, error)