zoneproxy

Documentation

Index

• func AddFilterChains(availableServices []*mesh_proto.ZoneIngress_AvailableService, ...) envoy_common.Services
• func BuildMeshDestinations(availableServices []*mesh_proto.ZoneIngress_AvailableService, ...) map[string][]envoy_tags.Tags
• func GenerateCDS(destinationsPerService map[string][]envoy_tags.Tags, ...) ([]*core_xds.Resource, error)
• func GenerateEDS(services envoy_common.Services, endpointMap core_xds.EndpointMap, ...) ([]*core_xds.Resource, error)

Functions

func AddFilterChains

func AddFilterChains(
	availableServices []*mesh_proto.ZoneIngress_AvailableService,
	apiVersion core_xds.APIVersion,
	listenerBuilder *envoy_listeners.ListenerBuilder,
	destinationsPerService map[string][]envoy_tags.Tags,
	endpointMap core_xds.EndpointMap,
) envoy_common.Services

AddFilterChains adds filter chains to a listener. We generate FilterChainsMatcher for each unique destination. This approach has a limitation: additional tags on outbound in Universal mode won't work across different zones.

func BuildMeshDestinations

func BuildMeshDestinations(
	availableServices []*mesh_proto.ZoneIngress_AvailableService,
	res xds_context.Resources,
) map[string][]envoy_tags.Tags

func GenerateCDS

func GenerateCDS(
	destinationsPerService map[string][]envoy_tags.Tags,
	services envoy_common.Services,
	apiVersion core_xds.APIVersion,
	meshName string,
	origin string,
) ([]*core_xds.Resource, error)

func GenerateEDS

func GenerateEDS(
	services envoy_common.Services,
	endpointMap core_xds.EndpointMap,
	apiVersion core_xds.APIVersion,
	meshName string,
	origin string,
) ([]*core_xds.Resource, error)