route

Documentation

Index

• Constants
• func BuildDefaultHTTPInboundRoute(clusterName string, operation string) *route.Route
• func BuildDefaultHTTPOutboundRoute(clusterName string, operation string, mesh *meshconfig.MeshConfig) *route.Route
• func BuildHTTPRoutesForVirtualService(node *model.Proxy, virtualService config.Config, ...) ([]*route.Route, error)
• func CombineVHostRoutes(routeSets ...[]*route.Route) []*route.Route
• func GetConsistentHashForVirtualService(push *model.PushContext, node *model.Proxy, virtualService config.Config, ...) ...
• func GetDestinationCluster(destination *networking.Destination, service *model.Service, listenerPort int) string
• func GetHashForHTTPDestination(push *model.PushContext, node *model.Proxy, ...) (*networking.LoadBalancerSettings_ConsistentHashLB, *config.Config)
• type Cache
  • func (r *Cache) Cacheable() bool
  • func (r *Cache) DependentConfigs() []model.ConfigKey
  • func (r *Cache) DependentTypes() []config.GroupVersionKind
  • func (r *Cache) Key() string
• type SortHeaderValueOption
  • func (b SortHeaderValueOption) Len() int
  • func (b SortHeaderValueOption) Less(i, j int) bool
  • func (b SortHeaderValueOption) Swap(i, j int)
• type VirtualHostWrapper
  • func BuildSidecarVirtualHostWrapper(routeCache *Cache, node *model.Proxy, push *model.PushContext, ...) []VirtualHostWrapper

Constants

const (
	HeaderMethod    = ":method"
	HeaderAuthority = ":authority"
	HeaderScheme    = ":scheme"
)

Headers with special meaning in Envoy

const DefaultRouteName = "default"

DefaultRouteName is the name assigned to a route generated by default in absence of a virtual service.

Functions

func BuildDefaultHTTPInboundRoute

func BuildDefaultHTTPInboundRoute(clusterName string, operation string) *route.Route

BuildDefaultHTTPInboundRoute builds a default inbound route.

func BuildDefaultHTTPOutboundRoute

func BuildDefaultHTTPOutboundRoute(clusterName string, operation string, mesh *meshconfig.MeshConfig) *route.Route

BuildDefaultHTTPOutboundRoute builds a default outbound route, including a retry policy.

func BuildHTTPRoutesForVirtualService

func BuildHTTPRoutesForVirtualService(
	node *model.Proxy,
	virtualService config.Config,
	serviceRegistry map[host.Name]*model.Service,
	hashByDestination map[*networking.HTTPRouteDestination]*networking.LoadBalancerSettings_ConsistentHashLB,
	listenPort int,
	gatewayNames map[string]bool,
	isHTTP3AltSvcHeaderNeeded bool,
	mesh *meshconfig.MeshConfig,
) ([]*route.Route, error)

BuildHTTPRoutesForVirtualService creates data plane HTTP routes from the virtual service spec. The rule should be adapted to destination names (outbound clusters). Each rule is guarded by source labels.

This is called for each port to compute virtual hosts. Each VirtualService is tried, with a list of Services that listen on the port. Error indicates the given virtualService can't be used on the port. This function is used by both the gateway and the sidecar

func CombineVHostRoutes

func CombineVHostRoutes(routeSets ...[]*route.Route) []*route.Route

CombineVHostRoutes semi concatenates Vhost's routes into a single route set. Moves the catch all routes alone to the end, while retaining the relative order of other routes in the concatenated route. Assumes that the virtual Services that generated first and second are ordered by time.

func GetConsistentHashForVirtualService

func GetConsistentHashForVirtualService(push *model.PushContext, node *model.Proxy,
	virtualService config.Config,
	serviceRegistry map[host.Name]*model.Service,
) map[*networking.HTTPRouteDestination]*networking.LoadBalancerSettings_ConsistentHashLB

func GetDestinationCluster

func GetDestinationCluster(destination *networking.Destination, service *model.Service, listenerPort int) string

GetDestinationCluster generates a cluster name for the route, or error if no cluster can be found. Called by translateRule to determine if

func GetHashForHTTPDestination

func GetHashForHTTPDestination(push *model.PushContext, node *model.Proxy, dst *networking.HTTPRouteDestination,
	configNamespace string,
) (*networking.LoadBalancerSettings_ConsistentHashLB, *config.Config)

GetHashForHTTPDestination return the ConsistentHashLB and the DestinationRule associated with HTTP route destination.

Types

type Cache

type Cache struct {
	RouteName string

	ProxyVersion string
	// proxy cluster ID
	ClusterID string
	// proxy dns domain
	DNSDomain string
	// DNSCapture indicates whether the workload has enabled dns capture
	DNSCapture bool
	// DNSAutoAllocate indicates whether the workload should have auto allocated addresses for ServiceEntry
	// This allows resolving ServiceEntries, which is especially useful for distinguishing TCP traffic
	// This depends on DNSCapture.
	DNSAutoAllocate bool
	// AllowAny indicates if the proxy should allow all outbound traffic or only known registries
	AllowAny bool

	ListenerPort            int
	Services                []*model.Service
	VirtualServices         []config.Config
	DelegateVirtualServices []model.ConfigKey
	DestinationRules        []*config.Config
	EnvoyFilterKeys         []string
}

Cache includes the variables that can influence a Route Configuration. Implements XdsCacheEntry interface.

func (*Cache) Cacheable

func (r *Cache) Cacheable() bool

func (*Cache) DependentConfigs

func (r *Cache) DependentConfigs() []model.ConfigKey

func (*Cache) DependentTypes

func (r *Cache) DependentTypes() []config.GroupVersionKind

func (*Cache) Key

func (r *Cache) Key() string

type SortHeaderValueOption

type SortHeaderValueOption []*core.HeaderValueOption

SortHeaderValueOption type and the functions below (Len, Less and Swap) are for sort.Stable for type HeaderValueOption

func (SortHeaderValueOption) Len

func (b SortHeaderValueOption) Len() int

Len is i the sort.Interface for SortHeaderValueOption

func (SortHeaderValueOption) Less

func (b SortHeaderValueOption) Less(i, j int) bool

Less is in the sort.Interface for SortHeaderValueOption

func (SortHeaderValueOption) Swap

func (b SortHeaderValueOption) Swap(i, j int)

Swap is in the sort.Interface for SortHeaderValueOption

type VirtualHostWrapper

type VirtualHostWrapper struct {
	// Port is the listener port for outbound sidecar (e.g. service port)
	Port int

	// Services are the Services from the registry. Each service
	// in this list should have a virtual host entry
	Services []*model.Service

	// VirtualServiceHosts is a list of hosts defined in the virtual service
	// if virtual service hostname is same as a the service registry host, then
	// the host would appear in Services as we need to generate all variants of the
	// service's hostname within a platform (e.g., foo, foo.default, foo.default.svc, etc.)
	VirtualServiceHosts []string

	// Routes in the virtual host
	Routes []*route.Route
}

VirtualHostWrapper is a context-dependent virtual host entry with guarded routes. Note: Currently we are not fully utilizing this structure. We could invoke this logic once for all sidecars in the cluster to compute all RDS for inside the mesh and arrange it by listener port. However to properly use such an optimization, we need to have an eventing subsystem to invalidate the computed routes if any service changes/virtual Services change.

func BuildSidecarVirtualHostWrapper

func BuildSidecarVirtualHostWrapper(routeCache *Cache, node *model.Proxy, push *model.PushContext, serviceRegistry map[host.Name]*model.Service,
	virtualServices []config.Config, listenPort int,
) []VirtualHostWrapper

BuildSidecarVirtualHostWrapper creates virtual hosts from the given set of virtual Services and a list of Services from the service registry. Services are indexed by FQDN hostnames. The list of Services is also passed to allow maintaining consistent ordering.