topology

Documentation

Index

• Constants
• func BuildCircuitBreakerMap(dataplane *mesh_core.DataplaneResource, destinations core_xds.DestinationMap, ...) core_xds.CircuitBreakerMap
• func BuildDestinationMap(dataplane *mesh_core.DataplaneResource, routes core_xds.RouteMap) core_xds.DestinationMap
• func BuildEndpointMap(destinations core_xds.DestinationMap, ...) core_xds.EndpointMap
• func BuildHealthCheckMap(dataplane *mesh_core.DataplaneResource, destinations core_xds.DestinationMap, ...) core_xds.HealthCheckMap
• func BuildRouteMap(dataplane *mesh_core.DataplaneResource, ...) core_xds.RouteMap
• func GetCircuitBreakers(ctx context.Context, dataplane *mesh_core.DataplaneResource, ...) (core_xds.CircuitBreakerMap, error)
• func GetDataplanes(ctx context.Context, rm manager.ReadOnlyResourceManager, mesh string) (*core_mesh.DataplaneResourceList, error)
• func GetHealthChecks(ctx context.Context, dataplane *mesh_core.DataplaneResource, ...) (core_xds.HealthCheckMap, error)
• func GetOutboundTargets(destinations core_xds.DestinationMap, ...) (core_xds.EndpointMap, error)
• func GetRoutes(ctx context.Context, dataplane *mesh_core.DataplaneResource, ...) (core_xds.RouteMap, error)
• func GetTrafficTrace(ctx context.Context, dataplane *mesh_core.DataplaneResource, ...) (*mesh_core.TrafficTraceResource, error)
• func PatchDataplaneWithVIPOutbounds(dataplane *mesh_core.DataplaneResource, ...) (errs error)

Constants

const VIPListenPort = uint32(80)

Functions

func BuildCircuitBreakerMap

func BuildCircuitBreakerMap(dataplane *mesh_core.DataplaneResource, destinations core_xds.DestinationMap, circuitBreakers []*mesh_core.CircuitBreakerResource) core_xds.CircuitBreakerMap

BuildCircuitBreakerMap creates a map with circuit-breaking configuration per reachable service.

func BuildDestinationMap

func BuildDestinationMap(dataplane *mesh_core.DataplaneResource, routes core_xds.RouteMap) core_xds.DestinationMap

BuildDestinationMap creates a map of selectors to match other dataplanes reachable from a given one via given routes.

func BuildEndpointMap

func BuildEndpointMap(destinations core_xds.DestinationMap, dataplanes []*mesh_core.DataplaneResource, zone, mesh string) core_xds.EndpointMap

BuildEndpointMap creates a map of all endpoints that match given selectors.

func BuildHealthCheckMap

func BuildHealthCheckMap(dataplane *mesh_core.DataplaneResource, destinations core_xds.DestinationMap, healthChecks []*mesh_core.HealthCheckResource) core_xds.HealthCheckMap

BuildHealthCheckMap creates a map with health-checking configuration per reachable service.

func BuildRouteMap

func BuildRouteMap(dataplane *mesh_core.DataplaneResource, routes []*mesh_core.TrafficRouteResource) core_xds.RouteMap

BuildRouteMap picks a single the most specific route for each outbound interface of a given Dataplane.

func GetCircuitBreakers

func GetCircuitBreakers(ctx context.Context, dataplane *mesh_core.DataplaneResource, destinations core_xds.DestinationMap, manager core_manager.ReadOnlyResourceManager) (core_xds.CircuitBreakerMap, error)

GetCircuitBreakers resolves all CircuitBreakers applicable to a given Dataplane.

func GetDataplanes

func GetDataplanes(ctx context.Context, rm manager.ReadOnlyResourceManager, mesh string) (*core_mesh.DataplaneResourceList, error)

GetDataplanes returs list of Dataplane in provided Mesh and Ingresses (which are cluster-scoped, not mesh-scoped)

func GetHealthChecks

func GetHealthChecks(ctx context.Context, dataplane *mesh_core.DataplaneResource, destinations core_xds.DestinationMap, manager core_manager.ReadOnlyResourceManager) (core_xds.HealthCheckMap, error)

GetHealthChecks resolves all HealthChecks applicable to a given Dataplane.

func GetOutboundTargets

func GetOutboundTargets(destinations core_xds.DestinationMap, dataplanes *mesh_core.DataplaneResourceList, localClusterName, mesh string) (core_xds.EndpointMap, error)

GetOutboundTargets resolves all endpoints reachable from a given dataplane.

func GetRoutes

func GetRoutes(ctx context.Context, dataplane *mesh_core.DataplaneResource, manager core_manager.ReadOnlyResourceManager) (core_xds.RouteMap, error)

GetRoutes picks a single the most specific route for each outbound interface of a given Dataplane.

func GetTrafficTrace

func GetTrafficTrace(ctx context.Context, dataplane *mesh_core.DataplaneResource, manager core_manager.ReadOnlyResourceManager) (*mesh_core.TrafficTraceResource, error)

func PatchDataplaneWithVIPOutbounds

func PatchDataplaneWithVIPOutbounds(dataplane *mesh_core.DataplaneResource,
	dataplanes *mesh_core.DataplaneResourceList, resolver dns.DNSResolver) (errs error)