v3

package
v0.0.0-...-d3c9bd8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 21, 2024 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ConvertBandwidthToKbps 

func ConvertBandwidthToKbps(bandwidth string) (uint64, error)

func ConvertPercentage 

func ConvertPercentage(percentage *wrapperspb.DoubleValue) *envoy_type.FractionalPercent

func NewUnexpectedFilterConfigTypeError 

func NewUnexpectedFilterConfigTypeError(actual, expected proto.Message) error

func UpdateFilterConfig 

func UpdateFilterConfig(filterChain *envoy_listener.FilterChain, filterName string, updateFunc func(proto.Message) error) error

func UpdateHTTPConnectionManager 

func UpdateHTTPConnectionManager(filterChain *envoy_listener.FilterChain, updateFunc func(manager *envoy_hcm.HttpConnectionManager) error) error

func UpdateTCPProxy 

func UpdateTCPProxy(filterChain *envoy_listener.FilterChain, updateFunc func(*envoy_tcp.TcpProxy) error) error

Types

type AdditionalAddressConfigurer 

type AdditionalAddressConfigurer struct {
	Addresses []mesh_proto.OutboundInterface
}

func (*AdditionalAddressConfigurer) Configure 

func (c *AdditionalAddressConfigurer) Configure(l *listenerv3.Listener) error

type DirectResponseConfigurer 

type DirectResponseConfigurer struct {
	VirtualHostName string
	Endpoints       []DirectResponseEndpoints
}

func (*DirectResponseConfigurer) Configure 

func (c *DirectResponseConfigurer) Configure(filterChain *envoy_listener.FilterChain) error

type DirectResponseEndpoints 

type DirectResponseEndpoints struct {
	Path       string
	StatusCode uint32
	Response   string
}

type FilterChainConfigureFunc 

type FilterChainConfigureFunc func(chain *envoy_listener.FilterChain) error

FilterChainConfigureFunc adapts a FilterChain configuration function to the FilterChainConfigurer interface.

func (FilterChainConfigureFunc) Configure 

func (f FilterChainConfigureFunc) Configure(chain *envoy_listener.FilterChain) error

type FilterChainConfigurer 

type FilterChainConfigurer interface {
	// Configure configures a single aspect on a given Envoy filter chain.
	Configure(filterChain *envoy_listener.FilterChain) error
}

FilterChainConfigurer is responsible for configuring a single aspect of the entire Envoy filter chain, such as TcpProxy filter, RBAC filter, access log, etc.

type FilterChainMatchConfigurer 

type FilterChainMatchConfigurer struct {
	ServerNames          []string
	TransportProtocol    string
	ApplicationProtocols []string
}

func (*FilterChainMatchConfigurer) Configure 

func (f *FilterChainMatchConfigurer) Configure(filterChain *envoy_listener.FilterChain) error

type FilterChainMustConfigureFunc 

type FilterChainMustConfigureFunc func(chain *envoy_listener.FilterChain)

FilterChainConfigureFunc adapts a FilterChain configuration function that never fails to the FilterChainConfigurer interface.

func (FilterChainMustConfigureFunc) Configure 

func (f FilterChainMustConfigureFunc) Configure(chain *envoy_listener.FilterChain) error

type GrpcStatsConfigurer 

type GrpcStatsConfigurer struct{}

func (*GrpcStatsConfigurer) Configure 

func (g *GrpcStatsConfigurer) Configure(filterChain *envoy_listener.FilterChain) error

type HTTPRouterStartChildSpanRouter 

type HTTPRouterStartChildSpanRouter struct{}

HTTPRouterStartChildSpanRouter configures the router to start child spans.

func (*HTTPRouterStartChildSpanRouter) Configure 

func (c *HTTPRouterStartChildSpanRouter) Configure(filterChain *envoy_listener.FilterChain) error

type HttpConnectionManagerConfigureFunc 

type HttpConnectionManagerConfigureFunc func(hcm *envoy_hcm.HttpConnectionManager) error

HttpConnectionManagerConfigureFunc adapts a HttpConnectionManager configuration function to the FilterChainConfigurer interface.

func (HttpConnectionManagerConfigureFunc) Configure 

func (f HttpConnectionManagerConfigureFunc) Configure(filterChain *envoy_listener.FilterChain) error

type HttpConnectionManagerConfigurer 

type HttpConnectionManagerConfigurer struct {
	StatsName                string
	ForwardClientCertDetails bool
	NormalizePath            bool
}

func (*HttpConnectionManagerConfigurer) Configure 

func (c *HttpConnectionManagerConfigurer) Configure(filterChain *envoy_listener.FilterChain) error

type HttpConnectionManagerMustConfigureFunc 

type HttpConnectionManagerMustConfigureFunc func(hcm *envoy_hcm.HttpConnectionManager)

HttpConnectionManagerMustConfigureFunc adapts a HttpConnectionManager configuration function that never fails to the FilterChainConfigurer interface.

func (HttpConnectionManagerMustConfigureFunc) Configure 

func (f HttpConnectionManagerMustConfigureFunc) Configure(filterChain *envoy_listener.FilterChain) error

type HttpDynamicRouteConfigurer 

type HttpDynamicRouteConfigurer struct {
	// RouteName is the globally unique name for the RouteConfiguration
	// that this configures xDS client to request.
	RouteName string
}

HttpDynamicRouteConfigurer configures the HttpConnectionManager in the filter chain to accept its routes dynamically via ADS.

func (*HttpDynamicRouteConfigurer) Configure 

func (c *HttpDynamicRouteConfigurer) Configure(filterChain *envoy_listener.FilterChain) error

type HttpInboundRouteConfigurer 

type HttpInboundRouteConfigurer struct {
	Service string
	Routes  envoy_common.Routes
}

func (*HttpInboundRouteConfigurer) Configure 

func (c *HttpInboundRouteConfigurer) Configure(filterChain *envoy_listener.FilterChain) error

type HttpOutboundRouteConfigurer 

type HttpOutboundRouteConfigurer struct {
	Service string
	Routes  envoy_common.Routes
	DpTags  mesh_proto.MultiValueTagSet
}

func (*HttpOutboundRouteConfigurer) Configure 

func (c *HttpOutboundRouteConfigurer) Configure(filterChain *envoy_listener.FilterChain) error

type HttpScopedRouteConfigurer 

type HttpScopedRouteConfigurer struct{}

HttpScopedRouteConfigurer configures a set of scoped routes into the HttpConnectionManager in the filter chain.

func (*HttpScopedRouteConfigurer) Configure 

func (c *HttpScopedRouteConfigurer) Configure(filterChain *envoy_listener.FilterChain) error

type HttpStaticRouteConfigurer 

type HttpStaticRouteConfigurer struct {
	Builder *envoy_routes.RouteConfigurationBuilder
}

HttpStaticRouteConfigurer configures a static set of routes into the HttpConnectionManager in the filter chain.

func (*HttpStaticRouteConfigurer) Configure 

func (c *HttpStaticRouteConfigurer) Configure(filterChain *envoy_listener.FilterChain) error

type InboundListenerConfigurer 

type InboundListenerConfigurer struct {
	Protocol core_xds.SocketAddressProtocol
	Address  string
	Port     uint32
}

func (*InboundListenerConfigurer) Configure 

func (c *InboundListenerConfigurer) Configure(l *envoy_listener.Listener) error

type KafkaConfigurer 

type KafkaConfigurer struct {
	StatsName string
}

func (*KafkaConfigurer) Configure 

func (c *KafkaConfigurer) Configure(filterChain *envoy_listener.FilterChain) error

type ListenerConfigureFunc 

type ListenerConfigureFunc func(listener *envoy_listener.Listener) error

ListenerConfigureFunc adapts a configuration function to the ListenerConfigurer interface.

func (ListenerConfigureFunc) Configure 

func (f ListenerConfigureFunc) Configure(listener *envoy_listener.Listener) error

type ListenerConfigurer 

type ListenerConfigurer interface {
	// Configure configures a single aspect on a given Envoy listener.
	Configure(listener *envoy_listener.Listener) error
}

ListenerConfigurer is responsible for configuring a single aspect of the entire Envoy listener, such as filter chain, transparent proxying, etc.

type ListenerMustConfigureFunc 

type ListenerMustConfigureFunc func(listener *envoy_listener.Listener)

ListenerMustConfigureFunc adapts a configuration function that never fails to the ListenerConfigurer interface.

func (ListenerMustConfigureFunc) Configure 

func (f ListenerMustConfigureFunc) Configure(listener *envoy_listener.Listener) error

type OriginalDstForwarderConfigurer 

type OriginalDstForwarderConfigurer struct{}

func (*OriginalDstForwarderConfigurer) Configure 

func (c *OriginalDstForwarderConfigurer) Configure(l *envoy_listener.Listener) error

type OutboundListenerConfigurer 

type OutboundListenerConfigurer struct {
	Address  string
	Port     uint32
	Protocol core_xds.SocketAddressProtocol
}

func (*OutboundListenerConfigurer) Configure 

func (c *OutboundListenerConfigurer) Configure(l *envoy_api.Listener) error

type PipeListenerConfigurer 

type PipeListenerConfigurer struct {
	SocketPath string
}

func (*PipeListenerConfigurer) Configure 

func (c *PipeListenerConfigurer) Configure(l *envoy_api.Listener) error

type StaticEndpointsConfigurer 

type StaticEndpointsConfigurer struct {
	VirtualHostName string
	Paths           []*envoy_common.StaticEndpointPath
}

func (*StaticEndpointsConfigurer) Configure 

func (c *StaticEndpointsConfigurer) Configure(filterChain *envoy_listener.FilterChain) error

type TLSInspectorConfigurer 

type TLSInspectorConfigurer struct{}

func (*TLSInspectorConfigurer) Configure 

func (c *TLSInspectorConfigurer) Configure(l *envoy_listener.Listener) error

type TagsMetadataConfigurer 

type TagsMetadataConfigurer struct {
	Tags map[string]string
}

func (*TagsMetadataConfigurer) Configure 

func (c *TagsMetadataConfigurer) Configure(l *envoy_api.Listener) error

type TcpProxyConfigurer 

type TcpProxyConfigurer struct {
	StatsName string
	// Splits to forward traffic to.
	Splits      []envoy_common.Split
	UseMetadata bool
}

func (*TcpProxyConfigurer) Configure 

func (c *TcpProxyConfigurer) Configure(filterChain *envoy_listener.FilterChain) error

type TransparentProxyingConfigurer 

type TransparentProxyingConfigurer struct{}

func (*TransparentProxyingConfigurer) Configure 

func (c *TransparentProxyingConfigurer) Configure(l *envoy_listener.Listener) error

type TripleConfigurer 

type TripleConfigurer struct{}

func (*TripleConfigurer) Configure 

func (c *TripleConfigurer) Configure(filterChain *envoy_listener.FilterChain) error

type UnexpectedFilterConfigTypeError 

type UnexpectedFilterConfigTypeError struct {
	// contains filtered or unexported fields
}

func (*UnexpectedFilterConfigTypeError) Error 

func (e *UnexpectedFilterConfigTypeError) Error() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.