Documentation
¶
Index ¶
- Constants
- Variables
- func CheckForDuplicateFilterChainMatches(filterChains []*envoy_config_listener_v3.FilterChain, ...)
- func ClusterToUpstreamRef(cluster string) (*core.ResourceRef, error)
- func ConsolidateSslConfigurations(sslConfigurations []*v1.SslConfig) []*v1.SslConfig
- func DataSourceFromString(str string) *envoy_config_core_v3.DataSource
- func EnvoyCacheResourcesListToFnvHash(resources []envoycache.Resource) (uint64, error)
- func GlooMatcherToEnvoyMatcher(ctx context.Context, matcher *matchers.Matcher) envoy_config_route_v3.RouteMatch
- func IsIpv4Address(bindAddress string) (validIpv4, strictIPv4 bool, err error)
- func MakeRdsResources(routeConfigs []*envoy_config_route_v3.RouteConfiguration) envoycache.Resources
- func MergeSslConfig(dst, src *v1.SslConfig) *v1.SslConfig
- func MustEnvoyCacheResourcesListToFnvHash(resources []envoycache.Resource) uint64
- func MustEnvoyCacheResourcesListToHash(resources []envoycache.Resource) uint64
- func NewAccessLogWithConfig(name string, config proto.Message) (envoyal.AccessLog, error)
- func NewFilterWithTypedConfig(name string, config proto.Message) (*envoy_config_listener_v3.Filter, error)
- func NewHttpListenerNetworkFilterTranslator(parentListener *v1.Listener, listener *v1.HttpListener, ...) *httpNetworkFilterTranslator
- func NewTranslatorWithHasher(sslConfigTranslator utils.SslConfigTranslator, settings *v1.Settings, ...) *translatorInstance
- func ParseTypedConfig(c typedConfigObject, config proto.Message) error
- func UpstreamToClusterName(upstream *core.ResourceRef) string
- func ValidateRouteDestinations(snap *v1snap.ApiSnapshot, action *v1.RouteAction) error
- func ValidateTcpRouteDestinations(snap *v1snap.ApiSnapshot, action *v1.TcpHost_TcpAction) error
- func ValidateVirtualHostDomains(virtualHosts []*v1.VirtualHost, ...)
- type FilterChainTranslator
- type ListenerSubsystemTranslatorFactory
- func (l *ListenerSubsystemTranslatorFactory) GetAggregateListenerTranslators(ctx context.Context, proxy *v1.Proxy, listener *v1.Listener, ...) (ListenerTranslator, RouteConfigurationTranslator)
- func (l *ListenerSubsystemTranslatorFactory) GetHttpListenerTranslators(ctx context.Context, proxy *v1.Proxy, listener *v1.Listener, ...) (ListenerTranslator, RouteConfigurationTranslator)
- func (l *ListenerSubsystemTranslatorFactory) GetHybridListenerTranslators(ctx context.Context, proxy *v1.Proxy, listener *v1.Listener, ...) (ListenerTranslator, RouteConfigurationTranslator)
- func (l *ListenerSubsystemTranslatorFactory) GetTcpListenerTranslators(ctx context.Context, listener *v1.Listener, ...) (ListenerTranslator, RouteConfigurationTranslator)
- func (l *ListenerSubsystemTranslatorFactory) GetTranslators(ctx context.Context, proxy *v1.Proxy, listener *v1.Listener, ...) (ListenerTranslator, RouteConfigurationTranslator)
- type ListenerTranslator
- type NetworkFilterTranslator
- type RouteConfigurationTranslator
- type Translator
Constants ¶
const (
DefaultHttpStatPrefix = "http"
)
const EnvoyLb = "envoy.lb"
const SoloAnnotations = "io.solo.annotations"
Variables ¶
var ( DefaultHealthCheckTimeout = &duration.Duration{Seconds: 5} DefaultHealthCheckInterval = prototime.DurationToProto(time.Millisecond * 100) DefaultThreshold = &wrappers.UInt32Value{ Value: 5, } NilFieldError = func(fieldName string) error { return eris.Errorf("The field %s cannot be nil", fieldName) } )
var ( NoDestinationSpecifiedError = errors.New("must specify at least one weighted destination for multi destination routes") SubsetsMisconfiguredErr = errors.New("route has a subset config, but the upstream does not") )
var (
ClusterConnectionTimeout = time.Second * 5
)
Functions ¶
func CheckForDuplicateFilterChainMatches ¶ added in v1.4.13
func CheckForDuplicateFilterChainMatches(filterChains []*envoy_config_listener_v3.FilterChain, listenerReport *validationapi.ListenerReport)
Check for identical FilterChains to avoid the envoy error that occurs here: https://github.com/envoyproxy/envoy/blob/v1.15.0/source/server/filter_chain_manager_impl.cc#L162-L166 Note: this is NOT address non-equal but overlapping FilterChainMatches, which is a separate check here: https://github.com/envoyproxy/envoy/blob/50ef0945fa2c5da4bff7627c3abf41fdd3b7cffd/source/server/filter_chain_manager_impl.cc#L218-L354 Given the complexity of the overlap detection implementation, we don't want to duplicate that behavior here. We may want to consider invoking envoy from a library to detect overlapping and other issues, which would build off this discussion: https://github.com/solo-io/gloo/issues/2114 Visible for testing
func ClusterToUpstreamRef ¶ added in v1.6.10
func ClusterToUpstreamRef(cluster string) (*core.ResourceRef, error)
returns the ref of the upstream for a given cluster
func ConsolidateSslConfigurations ¶ added in v1.9.25
func DataSourceFromString ¶
func DataSourceFromString(str string) *envoy_config_core_v3.DataSource
func EnvoyCacheResourcesListToFnvHash ¶ added in v1.6.3
func EnvoyCacheResourcesListToFnvHash(resources []envoycache.Resource) (uint64, error)
func GlooMatcherToEnvoyMatcher ¶ added in v1.0.0
func GlooMatcherToEnvoyMatcher(ctx context.Context, matcher *matchers.Matcher) envoy_config_route_v3.RouteMatch
utility function to transform gloo matcher to envoy route matcher
func IsIpv4Address ¶ added in v1.9.25
IsIpv4Address returns whether the provided address is valid IPv4, is pure(unmapped) IPv4, and if there was an error in the bindaddr This is used to distinguish between IPv4 and IPv6 addresses
func MakeRdsResources ¶ added in v1.0.0
func MakeRdsResources(routeConfigs []*envoy_config_route_v3.RouteConfiguration) envoycache.Resources
func MergeSslConfig ¶ added in v1.9.25
Merges the fields of src into dst. The fields in dst that have non-zero values will not be overwritten.
func MustEnvoyCacheResourcesListToFnvHash ¶ added in v1.9.25
func MustEnvoyCacheResourcesListToFnvHash(resources []envoycache.Resource) uint64
deprecated, use EnvoyCacheResourcesListToFnvHash
func MustEnvoyCacheResourcesListToHash ¶ added in v1.9.25
func MustEnvoyCacheResourcesListToHash(resources []envoycache.Resource) uint64
deprecated, slower than MustEnvoyCacheResourcesListToFnvHash
func NewAccessLogWithConfig ¶ added in v0.18.1
func NewFilterWithTypedConfig ¶ added in v1.5.0
func NewHttpListenerNetworkFilterTranslator ¶ added in v1.9.25
func NewHttpListenerNetworkFilterTranslator( parentListener *v1.Listener, listener *v1.HttpListener, report *validationapi.HttpListenerReport, plugins []plugins.HttpFilterPlugin, hcmPlugins []plugins.HttpConnectionManagerPlugin, routeConfigName string, ) *httpNetworkFilterTranslator
func NewTranslatorWithHasher ¶ added in v1.6.3
func NewTranslatorWithHasher( sslConfigTranslator utils.SslConfigTranslator, settings *v1.Settings, pluginRegistry plugins.PluginRegistry, hasher func(resources []envoycache.Resource) (uint64, error), ) *translatorInstance
func ParseTypedConfig ¶ added in v1.5.0
func UpstreamToClusterName ¶
func UpstreamToClusterName(upstream *core.ResourceRef) string
returns the name of the cluster created for a given upstream
func ValidateRouteDestinations ¶ added in v0.18.0
func ValidateRouteDestinations(snap *v1snap.ApiSnapshot, action *v1.RouteAction) error
func ValidateTcpRouteDestinations ¶ added in v1.4.2
func ValidateTcpRouteDestinations(snap *v1snap.ApiSnapshot, action *v1.TcpHost_TcpAction) error
func ValidateVirtualHostDomains ¶ added in v1.2.5
func ValidateVirtualHostDomains(virtualHosts []*v1.VirtualHost, httpListenerReport *validationapi.HttpListenerReport)
returns an error if any of the virtualhost domains overlap Visible for testing
Types ¶
type FilterChainTranslator ¶ added in v1.9.25
type FilterChainTranslator interface {
ComputeFilterChains(params plugins.Params) []*envoy_config_listener_v3.FilterChain
}
type ListenerSubsystemTranslatorFactory ¶ added in v1.9.25
type ListenerSubsystemTranslatorFactory struct {
// contains filtered or unexported fields
}
The Listener subsystem handles downstream request processing. https://www.envoyproxy.io/docs/envoy/latest/intro/life_of_a_request.html?#high-level-architecture Gloo sends resources to Envoy via xDS. The components of the Listener subsystem that Gloo configures are: 1. Listeners 2. RouteConfiguration Given that Gloo exposes a variety of ListenerTypes (HttpListener, TcpListener, HybridListener, AggregateListener), and each of these types affect how resources are generated, we abstract those implementation details behind abstract translators. The ListenerSubsystemTranslatorFactory returns a ListenerTranslator and RouteConfigurationTranslator for a given Gloo Listener
func NewListenerSubsystemTranslatorFactory ¶ added in v1.9.25
func NewListenerSubsystemTranslatorFactory( pluginRegistry plugins.PluginRegistry, sslConfigTranslator utils.SslConfigTranslator, ) *ListenerSubsystemTranslatorFactory
func (*ListenerSubsystemTranslatorFactory) GetAggregateListenerTranslators ¶ added in v1.9.25
func (l *ListenerSubsystemTranslatorFactory) GetAggregateListenerTranslators(ctx context.Context, proxy *v1.Proxy, listener *v1.Listener, listenerReport *validationapi.ListenerReport) ( ListenerTranslator, RouteConfigurationTranslator, )
func (*ListenerSubsystemTranslatorFactory) GetHttpListenerTranslators ¶ added in v1.9.25
func (l *ListenerSubsystemTranslatorFactory) GetHttpListenerTranslators(ctx context.Context, proxy *v1.Proxy, listener *v1.Listener, listenerReport *validationapi.ListenerReport) ( ListenerTranslator, RouteConfigurationTranslator, )
func (*ListenerSubsystemTranslatorFactory) GetHybridListenerTranslators ¶ added in v1.9.25
func (l *ListenerSubsystemTranslatorFactory) GetHybridListenerTranslators(ctx context.Context, proxy *v1.Proxy, listener *v1.Listener, listenerReport *validationapi.ListenerReport) ( ListenerTranslator, RouteConfigurationTranslator, )
func (*ListenerSubsystemTranslatorFactory) GetTcpListenerTranslators ¶ added in v1.9.25
func (l *ListenerSubsystemTranslatorFactory) GetTcpListenerTranslators(ctx context.Context, listener *v1.Listener, listenerReport *validationapi.ListenerReport) ( ListenerTranslator, RouteConfigurationTranslator, )
func (*ListenerSubsystemTranslatorFactory) GetTranslators ¶ added in v1.9.25
func (l *ListenerSubsystemTranslatorFactory) GetTranslators(ctx context.Context, proxy *v1.Proxy, listener *v1.Listener, listenerReport *validationapi.ListenerReport) ( ListenerTranslator, RouteConfigurationTranslator, )
type ListenerTranslator ¶ added in v1.9.25
type ListenerTranslator interface { // A single Gloo Listener produces a single Envoy listener // https://www.envoyproxy.io/docs/envoy/latest/intro/arch_overview/listeners/listeners#arch-overview-listeners ComputeListener(params plugins.Params) *envoy_config_listener_v3.Listener }
type NetworkFilterTranslator ¶ added in v1.9.25
type NetworkFilterTranslator interface {
ComputeNetworkFilters(params plugins.Params) ([]*envoy_config_listener_v3.Filter, error)
}
type RouteConfigurationTranslator ¶ added in v1.9.25
type RouteConfigurationTranslator interface { // A Gloo listener may produce multiple filter chains. Each one may contain its own route configuration // https://www.envoyproxy.io/docs/envoy/latest/intro/arch_overview/http/http_routing#arch-overview-http-routing ComputeRouteConfiguration(params plugins.Params) []*envoy_config_route_v3.RouteConfiguration }
type Translator ¶
type Translator interface { // Translate converts a Proxy CR into an xDS Snapshot // Any errors that are encountered during translation are appended to the ResourceReports // It is invalid for us to return an error here, since translation of resources always needs // to results in an xDS Snapshot so we are resilient to pod restarts Translate( params plugins.Params, proxy *v1.Proxy, ) (envoycache.Snapshot, reporter.ResourceReports, *validationapi.ProxyReport) }