Documentation
¶
Index ¶
- func DestinationUpstreams(snap *v1snap.ApiSnapshot, in *v1.RouteAction) ([]core.ResourceRef, error)
- func EnvoyEndpoint(address string, port uint32) *envoy_config_endpoint_v3.Endpoint
- func EnvoySingleEndpointLoadAssignment(out *envoy_config_cluster_v3.Cluster, address string, port uint32)
- func IsDestinationNotFoundErr(err error) bool
- func MarkHeaders(ctx context.Context, snap *v1snap.ApiSnapshot, in *v1.Route, ...) error
- func MarkPerFilterConfig(ctx context.Context, snap *v1snap.ApiSnapshot, in *v1.Route, ...) error
- func ModifyPerFilterConfig(ctx context.Context, snap *v1snap.ApiSnapshot, in *v1.Route, ...) error
- func ModifyRoutePerFilterConfig(out *envoy_config_route_v3.Route, filterName string, mod ModifyFunc) error
- func ModifyVhostPerFilterConfig(out *envoy_config_route_v3.VirtualHost, filterName string, mod ModifyFunc) error
- func ModifyWeightedClusterPerFilterConfig(out *envoy_config_route_v3.WeightedCluster_ClusterWeight, filterName string, ...) error
- func SetExtensionProtocolOptions(out *envoy_config_cluster_v3.Cluster, filterName string, ...) error
- func SetRoutePerFilterConfig(out *envoy_config_route_v3.Route, filterName string, protoext proto.Message) error
- func SetVhostPerFilterConfig(out *envoy_config_route_v3.VirtualHost, filterName string, ...) error
- func SetWeightedClusterPerFilterConfig(out *envoy_config_route_v3.WeightedCluster_ClusterWeight, filterName string, ...) error
- type DestinationNotFoundError
- type HeadersToAddFunc
- type ModifyFunc
- type PerFilterConfigFunc
- type PerFilterConfigModifyFunc
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DestinationUpstreams ¶
func DestinationUpstreams(snap *v1snap.ApiSnapshot, in *v1.RouteAction) ([]core.ResourceRef, error)
func EnvoyEndpoint ¶
func EnvoyEndpoint(address string, port uint32) *envoy_config_endpoint_v3.Endpoint
func EnvoySingleEndpointLoadAssignment ¶
func EnvoySingleEndpointLoadAssignment(out *envoy_config_cluster_v3.Cluster, address string, port uint32)
func IsDestinationNotFoundErr ¶ added in v0.20.2
func MarkHeaders ¶
func MarkHeaders(ctx context.Context, snap *v1snap.ApiSnapshot, in *v1.Route, out *envoy_config_route_v3.Route, headers HeadersToAddFunc) error
Allows you add extra headers for specific destination. The provided callback will be called for all the destinations on the route. Any headers returned will be added to requests going to that destination
func MarkPerFilterConfig ¶
func MarkPerFilterConfig( ctx context.Context, snap *v1snap.ApiSnapshot, in *v1.Route, out *envoy_config_route_v3.Route, filterName string, perFilterConfig PerFilterConfigFunc, ) error
call this from
func ModifyPerFilterConfig ¶ added in v1.9.25
func ModifyPerFilterConfig( ctx context.Context, snap *v1snap.ApiSnapshot, in *v1.Route, out *envoy_config_route_v3.Route, filterName string, perFilterConfig PerFilterConfigModifyFunc, ) error
func ModifyRoutePerFilterConfig ¶ added in v1.9.25
func ModifyRoutePerFilterConfig(out *envoy_config_route_v3.Route, filterName string, mod ModifyFunc) error
func ModifyVhostPerFilterConfig ¶ added in v1.9.25
func ModifyVhostPerFilterConfig(out *envoy_config_route_v3.VirtualHost, filterName string, mod ModifyFunc) error
func ModifyWeightedClusterPerFilterConfig ¶ added in v1.9.25
func ModifyWeightedClusterPerFilterConfig( out *envoy_config_route_v3.WeightedCluster_ClusterWeight, filterName string, mod ModifyFunc, ) error
func SetExtensionProtocolOptions ¶ added in v1.8.0
func SetRoutePerFilterConfig ¶ added in v0.11.1
func SetVhostPerFilterConfig ¶ added in v0.11.1
func SetVhostPerFilterConfig(out *envoy_config_route_v3.VirtualHost, filterName string, protoext proto.Message) error
func SetWeightedClusterPerFilterConfig ¶ added in v0.11.1
func SetWeightedClusterPerFilterConfig( out *envoy_config_route_v3.WeightedCluster_ClusterWeight, filterName string, protoext proto.Message, ) error
Types ¶
type DestinationNotFoundError ¶ added in v0.20.2
type DestinationNotFoundError struct {
Ref core.ResourceRef
ResourceType resources.Resource
}
func NewDestinationNotFoundErr ¶ added in v0.20.2
func NewDestinationNotFoundErr(ref core.ResourceRef, resourceType resources.Resource) *DestinationNotFoundError
func NewUpstreamGroupNotFoundErr ¶ added in v0.20.2
func NewUpstreamGroupNotFoundErr(ref core.ResourceRef) *DestinationNotFoundError
func NewUpstreamNotFoundErr ¶ added in v0.20.2
func NewUpstreamNotFoundErr(ref core.ResourceRef) *DestinationNotFoundError
func (*DestinationNotFoundError) Error ¶ added in v0.20.2
func (e *DestinationNotFoundError) Error() string
type HeadersToAddFunc ¶
type HeadersToAddFunc func(spec *v1.Destination) ([]*envoy_config_core_v3.HeaderValueOption, error)
type PerFilterConfigFunc ¶
type PerFilterConfigFunc func(spec *v1.Destination) (proto.Message, error)
Return Per-Filter config for destinations, we put them on the Route (single dest) or WeightedCluster (multi dest)
type PerFilterConfigModifyFunc ¶ added in v1.9.25
Source Files
Click to show internal directories.
Click to hide internal directories.