Documentation ¶
Index ¶
- Constants
- func DowngradeBackendRef(old gwapiv1.BackendRef) gwapiv1a2.BackendRef
- func DowngradeParentReference(old gwapiv1.ParentReference) gwapiv1a2.ParentReference
- func DowngradeRouteParentStatuses(routeParentStatuses []gwapiv1.RouteParentStatus) []gwapiv1a2.RouteParentStatus
- func FromNamespacesPtr(fromNamespaces gwapiv1.FromNamespaces) *gwapiv1.FromNamespaces
- func GRPCMethodMatchTypeDerefOr(matchType *v1alpha2.GRPCMethodMatchType, ...) v1alpha2.GRPCMethodMatchType
- func GatewayClassOwnerLabel(name string) map[string]string
- func GatewayOwnerLabels(namespace, name string) map[string]string
- func GetHostnames(route RouteContext) []string
- func GetParentReferences(route RouteContext) []gwapiv1.ParentReference
- func GetRouteStatus(route RouteContext) *gwapiv1.RouteStatus
- func GetRouteType(route RouteContext) gwapiv1.Kind
- func GroupDerefOr(group *gwapiv1.Group, defaultGroup string) string
- func GroupPtr(name string) *gwapiv1.Group
- func GroupPtrV1Alpha2(group string) *gwapiv1a2.Group
- func HasReadyListener(listeners []*ListenerContext) bool
- func HeaderMatchTypeDerefOr(matchType *gwapiv1.HeaderMatchType, defaultType gwapiv1.HeaderMatchType) gwapiv1.HeaderMatchType
- func IsRefToGateway(parentRef gwapiv1.ParentReference, gateway types.NamespacedName) bool
- func KindDerefOr(kind *gwapiv1.Kind, defaultKind string) string
- func KindPtr(name string) *gwapiv1.Kind
- func KindPtrV1Alpha2(kind string) *gwapiv1a2.Kind
- func NamespaceDerefOr(namespace *gwapiv1.Namespace, defaultNamespace string) string
- func NamespaceDerefOrAlpha(namespace *gwapiv1a2.Namespace, defaultNamespace string) string
- func NamespacePtr(name string) *gwapiv1.Namespace
- func NamespacePtrV1Alpha2(namespace string) *gwapiv1a2.Namespace
- func ObjectNamePtr(val string) *v1alpha2.ObjectName
- func PathMatchTypeDerefOr(matchType *gwapiv1.PathMatchType, defaultType gwapiv1.PathMatchType) gwapiv1.PathMatchType
- func PortNumPtr(val int32) *gwapiv1.PortNumber
- func PortNumPtrV1Alpha2(port int) *gwapiv1a2.PortNumber
- func ProcessClientTrafficPolicies(clientTrafficPolicies []*egv1a1.ClientTrafficPolicy, ...) []*egv1a1.ClientTrafficPolicy
- func QueryParamMatchTypeDerefOr(matchType *gwapiv1.QueryParamMatchType, ...) gwapiv1.QueryParamMatchType
- func SectionNamePtr(name string) *gwapiv1.SectionName
- func SectionNamePtrV1Alpha2(sectionName string) *gwapiv1a2.SectionName
- func UpgradeBackendRef(old gwapiv1a2.BackendRef) gwapiv1.BackendRef
- func UpgradeParentReference(old gwapiv1a2.ParentReference) gwapiv1.ParentReference
- func UpgradeParentReferences(old []gwapiv1a2.ParentReference) []gwapiv1.ParentReference
- func UpgradeRouteParentStatuses(routeParentStatuses []gwapiv1a2.RouteParentStatus) []gwapiv1.RouteParentStatus
- func ValidateGRPCRouteFilter(filter *v1alpha2.GRPCRouteFilter, extGKs ...schema.GroupKind) error
- func ValidateHTTPRouteFilter(filter *gwapiv1.HTTPRouteFilter, extGKs ...schema.GroupKind) error
- type AddressesTranslator
- type FiltersTranslator
- type GRPCRouteContext
- type GatewayContext
- type HTTPFilterIR
- type HTTPFiltersContext
- type HTTPFiltersTranslator
- type HTTPRouteContext
- type InfraIRMap
- type ListenerContext
- func (l *ListenerContext) AllowsKind(kind gwapiv1.RouteGroupKind) bool
- func (l *ListenerContext) AllowsNamespace(namespace *v1.Namespace) bool
- func (l *ListenerContext) AttachedRoutes() int32
- func (l *ListenerContext) GetConditions() []metav1.Condition
- func (l *ListenerContext) IncrementAttachedRoutes()
- func (l *ListenerContext) IsReady() bool
- func (l *ListenerContext) SetCondition(conditionType gwapiv1.ListenerConditionType, status metav1.ConditionStatus, ...)
- func (l *ListenerContext) SetSupportedKinds(kinds ...gwapiv1.RouteGroupKind)
- func (l *ListenerContext) SetTLSSecrets(tlsSecrets []*v1.Secret)
- type ListenersTranslator
- type Resources
- func (in *Resources) DeepCopy() *Resources
- func (in *Resources) DeepCopyInto(out *Resources)
- func (r *Resources) GetEndpointSlicesForBackend(svcNamespace, svcName string, backendKind string) []*discoveryv1.EndpointSlice
- func (r *Resources) GetNamespace(name string) *v1.Namespace
- func (r *Resources) GetSecret(namespace, name string) *v1.Secret
- func (r *Resources) GetService(namespace, name string) *v1.Service
- func (r *Resources) GetServiceImport(namespace, name string) *mcsapi.ServiceImport
- type RouteContext
- type RouteParentContext
- func (r *RouteParentContext) HasCondition(route RouteContext, condType gwapiv1.RouteConditionType, ...) bool
- func (r *RouteParentContext) ResetConditions(route RouteContext)
- func (r *RouteParentContext) SetCondition(route RouteContext, conditionType gwapiv1.RouteConditionType, ...)
- func (r *RouteParentContext) SetListeners(listeners ...*ListenerContext)
- type RoutesTranslator
- type TCPRouteContext
- type TLSRouteContext
- type TranslateResult
- type Translator
- func (t *Translator) GetRelevantGateways(gateways []*gwapiv1.Gateway) []*GatewayContext
- func (t *Translator) InitIRs(gateways []*GatewayContext, resources *Resources) (map[string]*ir.Xds, map[string]*ir.Infra)
- func (t *Translator) ProcessAddresses(gateways []*GatewayContext, xdsIR XdsIRMap, infraIR InfraIRMap, ...)
- func (t *Translator) ProcessBackendTrafficPolicies(backendTrafficPolicies []*egv1a1.BackendTrafficPolicy, ...) []*egv1a1.BackendTrafficPolicy
- func (t *Translator) ProcessEnvoyPatchPolicies(envoyPatchPolicies []*egv1a1.EnvoyPatchPolicy, xdsIR XdsIRMap)
- func (t *Translator) ProcessGRPCFilters(parentRef *RouteParentContext, route RouteContext, ...) *HTTPFiltersContext
- func (t *Translator) ProcessGRPCRoutes(grpcRoutes []*gwapiv1a1.GRPCRoute, gateways []*GatewayContext, ...) []*GRPCRouteContext
- func (t *Translator) ProcessHTTPFilters(parentRef *RouteParentContext, route RouteContext, ...) *HTTPFiltersContext
- func (t *Translator) ProcessHTTPRoutes(httpRoutes []*gwapiv1.HTTPRoute, gateways []*GatewayContext, ...) []*HTTPRouteContext
- func (t *Translator) ProcessListeners(gateways []*GatewayContext, xdsIR XdsIRMap, infraIR InfraIRMap, ...)
- func (t *Translator) ProcessSecurityPolicies(securityPolicies []*egv1a1.SecurityPolicy, gateways []*GatewayContext, ...) []*egv1a1.SecurityPolicy
- func (t *Translator) ProcessTCPRoutes(tcpRoutes []*gwapiv1a1.TCPRoute, gateways []*GatewayContext, ...) []*TCPRouteContext
- func (t *Translator) ProcessTLSRoutes(tlsRoutes []*gwapiv1a1.TLSRoute, gateways []*GatewayContext, ...) []*TLSRouteContext
- func (t *Translator) ProcessUDPRoutes(udpRoutes []*gwapiv1a1.UDPRoute, gateways []*GatewayContext, ...) []*UDPRouteContext
- func (t *Translator) Translate(resources *Resources) *TranslateResult
- type TranslatorManager
- type UDPRouteContext
- type XdsIRMap
- type XdsIRRoutes
Constants ¶
const ( TCPProtocol = "TCP" UDPProtocol = "UDP" L4Protocol = "L4" L7Protocol = "L7" )
const ( KindEnvoyProxy = "EnvoyProxy" KindGateway = "Gateway" KindGatewayClass = "GatewayClass" KindGRPCRoute = "GRPCRoute" KindHTTPRoute = "HTTPRoute" KindNamespace = "Namespace" KindTLSRoute = "TLSRoute" KindTCPRoute = "TCPRoute" KindUDPRoute = "UDPRoute" KindService = "Service" KindServiceImport = "ServiceImport" KindSecret = "Secret" GroupMultiClusterService = "multicluster.x-k8s.io" // OwningGatewayNamespaceLabel is the owner reference label used for managed infra. // The value should be the namespace of the accepted Envoy Gateway. OwningGatewayNamespaceLabel = "gateway.envoyproxy.io/owning-gateway-namespace" OwningGatewayClassLabel = "gateway.envoyproxy.io/owning-gatewayclass" // OwningGatewayNameLabel is the owner reference label used for managed infra. // The value should be the name of the accepted Envoy Gateway. OwningGatewayNameLabel = "gateway.envoyproxy.io/owning-gateway-name" )
const (
// Use an invalid string to represent all sections (listeners) within a Gateway
AllSections = "/"
)
Variables ¶
This section is empty.
Functions ¶
func DowngradeBackendRef ¶ added in v0.3.0
func DowngradeBackendRef(old gwapiv1.BackendRef) gwapiv1a2.BackendRef
func DowngradeParentReference ¶
func DowngradeParentReference(old gwapiv1.ParentReference) gwapiv1a2.ParentReference
func DowngradeRouteParentStatuses ¶
func DowngradeRouteParentStatuses(routeParentStatuses []gwapiv1.RouteParentStatus) []gwapiv1a2.RouteParentStatus
func FromNamespacesPtr ¶
func FromNamespacesPtr(fromNamespaces gwapiv1.FromNamespaces) *gwapiv1.FromNamespaces
func GRPCMethodMatchTypeDerefOr ¶ added in v0.4.0
func GRPCMethodMatchTypeDerefOr(matchType *v1alpha2.GRPCMethodMatchType, defaultType v1alpha2.GRPCMethodMatchType) v1alpha2.GRPCMethodMatchType
func GatewayClassOwnerLabel ¶ added in v0.6.0
GatewayClassOwnerLabel returns the GatewayCLass Owner label using the provided name as the value.
func GatewayOwnerLabels ¶
GatewayOwnerLabels returns the Gateway Owner labels using the provided namespace and name as the values.
func GetHostnames ¶ added in v0.5.0
func GetHostnames(route RouteContext) []string
TODO: [v1alpha2-gwapiv1] This should not be required once all Route objects being implemented are of type gwapiv1. GetHostnames returns the hosts targeted by the Route object.
func GetParentReferences ¶ added in v0.5.0
func GetParentReferences(route RouteContext) []gwapiv1.ParentReference
TODO: [v1alpha2-gwapiv1] This should not be required once all Route objects being implemented are of type gwapiv1. GetParentReferences returns the ParentReference of the Route object.
func GetRouteStatus ¶ added in v0.5.0
func GetRouteStatus(route RouteContext) *gwapiv1.RouteStatus
GetRouteStatus returns the RouteStatus object associated with the Route.
func GetRouteType ¶ added in v0.5.0
func GetRouteType(route RouteContext) gwapiv1.Kind
GetRouteType returns the Kind of the Route object, HTTPRoute, TLSRoute, TCPRoute, UDPRoute etc.
func GroupPtrV1Alpha2 ¶
func HasReadyListener ¶
func HasReadyListener(listeners []*ListenerContext) bool
HasReadyListener returns true if at least one Listener in the provided list has a condition of "Ready: true", and false otherwise.
func HeaderMatchTypeDerefOr ¶
func HeaderMatchTypeDerefOr(matchType *gwapiv1.HeaderMatchType, defaultType gwapiv1.HeaderMatchType) gwapiv1.HeaderMatchType
func IsRefToGateway ¶
func IsRefToGateway(parentRef gwapiv1.ParentReference, gateway types.NamespacedName) bool
IsRefToGateway returns whether the provided parent ref is a reference to a Gateway with the given namespace/name, irrespective of whether a section/listener name has been specified (i.e. a parent ref to a listener on the specified gateway will return "true").
func KindPtrV1Alpha2 ¶
func NamespaceDerefOr ¶
func NamespaceDerefOrAlpha ¶
func NamespacePtr ¶
func NamespacePtrV1Alpha2 ¶
func ObjectNamePtr ¶
func ObjectNamePtr(val string) *v1alpha2.ObjectName
func PathMatchTypeDerefOr ¶
func PathMatchTypeDerefOr(matchType *gwapiv1.PathMatchType, defaultType gwapiv1.PathMatchType) gwapiv1.PathMatchType
func PortNumPtr ¶
func PortNumPtr(val int32) *gwapiv1.PortNumber
func PortNumPtrV1Alpha2 ¶
func PortNumPtrV1Alpha2(port int) *gwapiv1a2.PortNumber
func ProcessClientTrafficPolicies ¶ added in v0.6.0
func ProcessClientTrafficPolicies(clientTrafficPolicies []*egv1a1.ClientTrafficPolicy, gateways []*GatewayContext, xdsIR XdsIRMap) []*egv1a1.ClientTrafficPolicy
func QueryParamMatchTypeDerefOr ¶ added in v0.3.0
func QueryParamMatchTypeDerefOr(matchType *gwapiv1.QueryParamMatchType, defaultType gwapiv1.QueryParamMatchType) gwapiv1.QueryParamMatchType
func SectionNamePtr ¶
func SectionNamePtr(name string) *gwapiv1.SectionName
func SectionNamePtrV1Alpha2 ¶
func SectionNamePtrV1Alpha2(sectionName string) *gwapiv1a2.SectionName
func UpgradeBackendRef ¶ added in v0.3.0
func UpgradeBackendRef(old gwapiv1a2.BackendRef) gwapiv1.BackendRef
UpgradeBackendRef converts gwapiv1a2.BackendRef to gwapiv1.BackendRef
func UpgradeParentReference ¶
func UpgradeParentReference(old gwapiv1a2.ParentReference) gwapiv1.ParentReference
UpgradeParentReference converts gwapiv1a2.ParentReference to gwapiv1.ParentReference
func UpgradeParentReferences ¶
func UpgradeParentReferences(old []gwapiv1a2.ParentReference) []gwapiv1.ParentReference
func UpgradeRouteParentStatuses ¶
func UpgradeRouteParentStatuses(routeParentStatuses []gwapiv1a2.RouteParentStatus) []gwapiv1.RouteParentStatus
func ValidateGRPCRouteFilter ¶ added in v0.3.0
func ValidateGRPCRouteFilter(filter *v1alpha2.GRPCRouteFilter, extGKs ...schema.GroupKind) error
ValidateGRPCRouteFilter validates the provided filter within GRPCRoute.
func ValidateHTTPRouteFilter ¶ added in v0.3.0
func ValidateHTTPRouteFilter(filter *gwapiv1.HTTPRouteFilter, extGKs ...schema.GroupKind) error
ValidateHTTPRouteFilter validates the provided filter within HTTPRoute.
Types ¶
type AddressesTranslator ¶ added in v0.5.0
type AddressesTranslator interface {
ProcessAddresses(gateways []*GatewayContext, xdsIR XdsIRMap, infraIR InfraIRMap, resources *Resources)
}
type FiltersTranslator ¶ added in v0.3.0
type FiltersTranslator interface { HTTPFiltersTranslator }
type GRPCRouteContext ¶ added in v0.3.0
type GRPCRouteContext struct { // GatewayControllerName is the name of the Gateway API controller. GatewayControllerName string *v1alpha2.GRPCRoute ParentRefs map[gwapiv1.ParentReference]*RouteParentContext }
GRPCRouteContext wraps a GRPCRoute and provides helper methods for accessing the route's parents.
type GatewayContext ¶
GatewayContext wraps a Gateway and provides helper methods for setting conditions, accessing Listeners, etc.
func (*GatewayContext) ResetListeners ¶ added in v0.3.0
func (g *GatewayContext) ResetListeners()
ResetListeners resets the listener statuses and re-generates the GatewayContext ListenerContexts from the Gateway spec.
type HTTPFilterIR ¶ added in v0.3.0
type HTTPFilterIR struct { DirectResponse *ir.DirectResponse RedirectResponse *ir.Redirect URLRewrite *ir.URLRewrite AddRequestHeaders []ir.AddHeader RemoveRequestHeaders []string AddResponseHeaders []ir.AddHeader RemoveResponseHeaders []string Mirrors []*ir.RouteDestination ExtensionRefs []*ir.UnstructuredRef }
HTTPFilterIR contains the ir processing results.
type HTTPFiltersContext ¶ added in v0.3.0
type HTTPFiltersContext struct { *HTTPFilterIR ParentRef *RouteParentContext Route RouteContext RuleIdx int }
HTTPFiltersContext is the context of http filters processing.
type HTTPFiltersTranslator ¶ added in v0.3.0
type HTTPFiltersTranslator interface {
// contains filtered or unexported methods
}
type HTTPRouteContext ¶
type HTTPRouteContext struct { // GatewayControllerName is the name of the Gateway API controller. GatewayControllerName string *gwapiv1.HTTPRoute ParentRefs map[gwapiv1.ParentReference]*RouteParentContext }
HTTPRouteContext wraps an HTTPRoute and provides helper methods for accessing the route's parents.
type InfraIRMap ¶
type ListenerContext ¶
ListenerContext wraps a Listener and provides helper methods for setting conditions and other status information on the associated Gateway, etc.
func GetReferencedListeners ¶
func GetReferencedListeners(parentRef gwapiv1.ParentReference, gateways []*GatewayContext) (bool, []*ListenerContext)
GetReferencedListeners returns whether a given parent ref references a Gateway in the given list, and if so, a list of the Listeners within that Gateway that are included by the parent ref (either one specific Listener, or all Listeners in the Gateway, depending on whether section name is specified or not).
func (*ListenerContext) AllowsKind ¶
func (l *ListenerContext) AllowsKind(kind gwapiv1.RouteGroupKind) bool
func (*ListenerContext) AllowsNamespace ¶
func (l *ListenerContext) AllowsNamespace(namespace *v1.Namespace) bool
func (*ListenerContext) AttachedRoutes ¶ added in v0.3.0
func (l *ListenerContext) AttachedRoutes() int32
func (*ListenerContext) GetConditions ¶
func (l *ListenerContext) GetConditions() []metav1.Condition
func (*ListenerContext) IncrementAttachedRoutes ¶
func (l *ListenerContext) IncrementAttachedRoutes()
func (*ListenerContext) IsReady ¶
func (l *ListenerContext) IsReady() bool
func (*ListenerContext) SetCondition ¶
func (l *ListenerContext) SetCondition(conditionType gwapiv1.ListenerConditionType, status metav1.ConditionStatus, reason gwapiv1.ListenerConditionReason, message string)
func (*ListenerContext) SetSupportedKinds ¶
func (l *ListenerContext) SetSupportedKinds(kinds ...gwapiv1.RouteGroupKind)
func (*ListenerContext) SetTLSSecrets ¶ added in v0.4.0
func (l *ListenerContext) SetTLSSecrets(tlsSecrets []*v1.Secret)
type ListenersTranslator ¶ added in v0.3.0
type ListenersTranslator interface {
ProcessListeners(gateways []*GatewayContext, xdsIR XdsIRMap, infraIR InfraIRMap, resources *Resources)
}
type Resources ¶
type Resources struct { // This field is only used for marshalling/unmarshalling purposes and is not used by // the translator GatewayClass *gwapiv1.GatewayClass `json:"gatewayClass,omitempty" yaml:"gatewayClass,omitempty"` Gateways []*gwapiv1.Gateway `json:"gateways,omitempty" yaml:"gateways,omitempty"` HTTPRoutes []*gwapiv1.HTTPRoute `json:"httpRoutes,omitempty" yaml:"httpRoutes,omitempty"` GRPCRoutes []*gwapiv1a2.GRPCRoute `json:"grpcRoutes,omitempty" yaml:"grpcRoutes,omitempty"` TLSRoutes []*gwapiv1a2.TLSRoute `json:"tlsRoutes,omitempty" yaml:"tlsRoutes,omitempty"` TCPRoutes []*gwapiv1a2.TCPRoute `json:"tcpRoutes,omitempty" yaml:"tcpRoutes,omitempty"` UDPRoutes []*gwapiv1a2.UDPRoute `json:"udpRoutes,omitempty" yaml:"udpRoutes,omitempty"` ReferenceGrants []*gwapiv1b1.ReferenceGrant `json:"referenceGrants,omitempty" yaml:"referenceGrants,omitempty"` Namespaces []*v1.Namespace `json:"namespaces,omitempty" yaml:"namespaces,omitempty"` Services []*v1.Service `json:"services,omitempty" yaml:"services,omitempty"` ServiceImports []*mcsapi.ServiceImport `json:"serviceImports,omitempty" yaml:"serviceImports,omitempty"` EndpointSlices []*discoveryv1.EndpointSlice `json:"endpointSlices,omitempty" yaml:"endpointSlices,omitempty"` Secrets []*v1.Secret `json:"secrets,omitempty" yaml:"secrets,omitempty"` EnvoyProxy *egv1a1.EnvoyProxy `json:"envoyProxy,omitempty" yaml:"envoyProxy,omitempty"` ExtensionRefFilters []unstructured.Unstructured `json:"extensionRefFilters,omitempty" yaml:"extensionRefFilters,omitempty"` EnvoyPatchPolicies []*egv1a1.EnvoyPatchPolicy `json:"envoyPatchPolicies,omitempty" yaml:"envoyPatchPolicies,omitempty"` ClientTrafficPolicies []*egv1a1.ClientTrafficPolicy `json:"clientTrafficPolicies,omitempty" yaml:"clientTrafficPolicies,omitempty"` BackendTrafficPolicies []*egv1a1.BackendTrafficPolicy `json:"backendTrafficPolicies,omitempty" yaml:"backendTrafficPolicies,omitempty"` SecurityPolicies []*egv1a1.SecurityPolicy `json:"securityPolicies,omitempty" yaml:"securityPolicies,omitempty"` }
Resources holds the Gateway API and related resources that the translators needs as inputs. +k8s:deepcopy-gen=true
func NewResources ¶ added in v0.3.0
func NewResources() *Resources
func (*Resources) DeepCopy ¶ added in v0.3.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Resources.
func (*Resources) DeepCopyInto ¶ added in v0.3.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Resources) GetEndpointSlicesForBackend ¶ added in v0.6.0
func (r *Resources) GetEndpointSlicesForBackend(svcNamespace, svcName string, backendKind string) []*discoveryv1.EndpointSlice
func (*Resources) GetServiceImport ¶ added in v0.6.0
func (r *Resources) GetServiceImport(namespace, name string) *mcsapi.ServiceImport
type RouteContext ¶
RouteContext represents a generic Route object (HTTPRoute, TLSRoute, etc.) that can reference Gateway objects.
type RouteParentContext ¶
type RouteParentContext struct { *gwapiv1.ParentReference // TODO: [v1alpha2-gwapiv1] This can probably be replaced with // a single field pointing to *gwapiv1.RouteStatus. HTTPRoute *gwapiv1.HTTPRoute GRPCRoute *v1alpha2.GRPCRoute TLSRoute *v1alpha2.TLSRoute TCPRoute *v1alpha2.TCPRoute UDPRoute *v1alpha2.UDPRoute // contains filtered or unexported fields }
RouteParentContext wraps a ParentReference and provides helper methods for setting conditions and other status information on the associated HTTPRoute, TLSRoute etc.
func GetRouteParentContext ¶ added in v0.5.0
func GetRouteParentContext(route RouteContext, forParentRef gwapiv1.ParentReference) *RouteParentContext
GetRouteParentContext returns RouteParentContext by using the Route objects' ParentReference.
func (*RouteParentContext) HasCondition ¶ added in v0.4.0
func (r *RouteParentContext) HasCondition(route RouteContext, condType gwapiv1.RouteConditionType, status metav1.ConditionStatus) bool
func (*RouteParentContext) ResetConditions ¶
func (r *RouteParentContext) ResetConditions(route RouteContext)
func (*RouteParentContext) SetCondition ¶
func (r *RouteParentContext) SetCondition(route RouteContext, conditionType gwapiv1.RouteConditionType, status metav1.ConditionStatus, reason gwapiv1.RouteConditionReason, message string)
func (*RouteParentContext) SetListeners ¶
func (r *RouteParentContext) SetListeners(listeners ...*ListenerContext)
type RoutesTranslator ¶ added in v0.3.0
type RoutesTranslator interface { ProcessHTTPRoutes(httpRoutes []*gwapiv1.HTTPRoute, gateways []*GatewayContext, resources *Resources, xdsIR XdsIRMap) []*HTTPRouteContext ProcessGRPCRoutes(grpcRoutes []*gwapiv1a1.GRPCRoute, gateways []*GatewayContext, resources *Resources, xdsIR XdsIRMap) []*GRPCRouteContext ProcessTLSRoutes(tlsRoutes []*gwapiv1a1.TLSRoute, gateways []*GatewayContext, resources *Resources, xdsIR XdsIRMap) []*TLSRouteContext ProcessTCPRoutes(tcpRoutes []*gwapiv1a1.TCPRoute, gateways []*GatewayContext, resources *Resources, xdsIR XdsIRMap) []*TCPRouteContext ProcessUDPRoutes(udpRoutes []*gwapiv1a1.UDPRoute, gateways []*GatewayContext, resources *Resources, xdsIR XdsIRMap) []*UDPRouteContext }
type TCPRouteContext ¶ added in v0.3.0
type TCPRouteContext struct { // GatewayControllerName is the name of the Gateway API controller. GatewayControllerName string *v1alpha2.TCPRoute ParentRefs map[gwapiv1.ParentReference]*RouteParentContext }
TCPRouteContext wraps a TCPRoute and provides helper methods for accessing the route's parents.
type TLSRouteContext ¶
type TLSRouteContext struct { // GatewayControllerName is the name of the Gateway API controller. GatewayControllerName string *v1alpha2.TLSRoute ParentRefs map[gwapiv1.ParentReference]*RouteParentContext }
TLSRouteContext wraps a TLSRoute and provides helper methods for accessing the route's parents.
type TranslateResult ¶
type TranslateResult struct { Resources XdsIR XdsIRMap `json:"xdsIR" yaml:"xdsIR"` InfraIR InfraIRMap `json:"infraIR" yaml:"infraIR"` }
type Translator ¶
type Translator struct { // GatewayControllerName is the name of the Gateway API controller GatewayControllerName string // GatewayClassName is the name of the GatewayClass // to process Gateways for. GatewayClassName gwapiv1.ObjectName // GlobalRateLimitEnabled is true when global // ratelimiting has been configured by the admin. GlobalRateLimitEnabled bool // EndpointRoutingDisabled can be set to true to use // the Service Cluster IP for routing to the backend // instead. EndpointRoutingDisabled bool // MergeGateways is true when all Gateway Listeners // should be merged under the parent GatewayClass. MergeGateways bool // ExtensionGroupKinds stores the group/kind for all resources // introduced by an Extension so that the translator can // store referenced resources in the IR for later use. ExtensionGroupKinds []schema.GroupKind }
Translator translates Gateway API resources to IRs and computes status for Gateway API resources.
func (*Translator) GetRelevantGateways ¶
func (t *Translator) GetRelevantGateways(gateways []*gwapiv1.Gateway) []*GatewayContext
GetRelevantGateways returns GatewayContexts, containing a copy of the original Gateway with the Listener statuses reset.
func (*Translator) InitIRs ¶ added in v0.6.0
func (t *Translator) InitIRs(gateways []*GatewayContext, resources *Resources) (map[string]*ir.Xds, map[string]*ir.Infra)
InitIRs checks if mergeGateways is enabled in EnvoyProxy config and initializes XdsIR and InfraIR maps with adequate keys.
func (*Translator) ProcessAddresses ¶ added in v0.5.0
func (t *Translator) ProcessAddresses(gateways []*GatewayContext, xdsIR XdsIRMap, infraIR InfraIRMap, resources *Resources)
func (*Translator) ProcessBackendTrafficPolicies ¶ added in v0.6.0
func (t *Translator) ProcessBackendTrafficPolicies(backendTrafficPolicies []*egv1a1.BackendTrafficPolicy, gateways []*GatewayContext, routes []RouteContext, xdsIR XdsIRMap) []*egv1a1.BackendTrafficPolicy
func (*Translator) ProcessEnvoyPatchPolicies ¶ added in v0.5.0
func (t *Translator) ProcessEnvoyPatchPolicies(envoyPatchPolicies []*egv1a1.EnvoyPatchPolicy, xdsIR XdsIRMap)
func (*Translator) ProcessGRPCFilters ¶ added in v0.3.0
func (t *Translator) ProcessGRPCFilters(parentRef *RouteParentContext, route RouteContext, filters []v1alpha2.GRPCRouteFilter, resources *Resources) *HTTPFiltersContext
ProcessGRPCFilters translates gateway api grpc filters to IRs.
func (*Translator) ProcessGRPCRoutes ¶ added in v0.3.0
func (t *Translator) ProcessGRPCRoutes(grpcRoutes []*gwapiv1a1.GRPCRoute, gateways []*GatewayContext, resources *Resources, xdsIR XdsIRMap) []*GRPCRouteContext
func (*Translator) ProcessHTTPFilters ¶ added in v0.3.0
func (t *Translator) ProcessHTTPFilters(parentRef *RouteParentContext, route RouteContext, filters []gwapiv1.HTTPRouteFilter, ruleIdx int, resources *Resources) *HTTPFiltersContext
ProcessHTTPFilters translates gateway api http filters to IRs.
func (*Translator) ProcessHTTPRoutes ¶
func (t *Translator) ProcessHTTPRoutes(httpRoutes []*gwapiv1.HTTPRoute, gateways []*GatewayContext, resources *Resources, xdsIR XdsIRMap) []*HTTPRouteContext
func (*Translator) ProcessListeners ¶
func (t *Translator) ProcessListeners(gateways []*GatewayContext, xdsIR XdsIRMap, infraIR InfraIRMap, resources *Resources)
func (*Translator) ProcessSecurityPolicies ¶ added in v0.6.0
func (t *Translator) ProcessSecurityPolicies(securityPolicies []*egv1a1.SecurityPolicy, gateways []*GatewayContext, routes []RouteContext, xdsIR XdsIRMap) []*egv1a1.SecurityPolicy
func (*Translator) ProcessTCPRoutes ¶ added in v0.3.0
func (t *Translator) ProcessTCPRoutes(tcpRoutes []*gwapiv1a1.TCPRoute, gateways []*GatewayContext, resources *Resources, xdsIR XdsIRMap) []*TCPRouteContext
func (*Translator) ProcessTLSRoutes ¶
func (t *Translator) ProcessTLSRoutes(tlsRoutes []*gwapiv1a1.TLSRoute, gateways []*GatewayContext, resources *Resources, xdsIR XdsIRMap) []*TLSRouteContext
func (*Translator) ProcessUDPRoutes ¶ added in v0.3.0
func (t *Translator) ProcessUDPRoutes(udpRoutes []*gwapiv1a1.UDPRoute, gateways []*GatewayContext, resources *Resources, xdsIR XdsIRMap) []*UDPRouteContext
func (*Translator) Translate ¶
func (t *Translator) Translate(resources *Resources) *TranslateResult
type TranslatorManager ¶ added in v0.3.0
type TranslatorManager interface { Translate(resources *Resources) *TranslateResult GetRelevantGateways(gateways []*gwapiv1.Gateway) []*GatewayContext RoutesTranslator ListenersTranslator AddressesTranslator FiltersTranslator }
type UDPRouteContext ¶ added in v0.3.0
type UDPRouteContext struct { // GatewayControllerName is the name of the Gateway API controller. GatewayControllerName string *v1alpha2.UDPRoute ParentRefs map[gwapiv1.ParentReference]*RouteParentContext }
UDPRouteContext wraps a UDPRoute and provides helper methods for accessing the route's parents.
type XdsIRRoutes ¶
func (XdsIRRoutes) Len ¶
func (x XdsIRRoutes) Len() int
func (XdsIRRoutes) Less ¶
func (x XdsIRRoutes) Less(i, j int) bool
func (XdsIRRoutes) Swap ¶
func (x XdsIRRoutes) Swap(i, j int)