xdstest

package

v0.0.0-...-dea2efb Latest Latest Go to latest Published: Apr 25, 2024 License: Apache-2.0 Imports: 33 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/istio/istio

Links

Open Source Insights

Documentation ¶

Index ¶

func CompareEndpoints(cluster string, got []*endpointv3.LocalityLbEndpoints, want []LocLbEpInfo) error
func CompareEndpointsOrFail(t *testing.T, cluster string, got []*endpointv3.LocalityLbEndpoints, ...)
func Dump(t test.Failer, p proto.Message) string
func DumpList[T any](t test.Failer, protoList []T) []string
func EvaluateListenerFilterPredicates(predicate *listener.ListenerFilterChainMatchPredicate, port int) bool
func ExtractCluster(name string, cc []*cluster.Cluster) *cluster.Cluster
func ExtractClusterEndpoints(clusters []*cluster.Cluster) map[string][]string
func ExtractClusterSecretResources(t test.Failer, c *cluster.Cluster) []string
func ExtractClusters(cc []*cluster.Cluster) map[string]*cluster.Cluster
func ExtractEdsClusterNames(cl []*cluster.Cluster) []string
func ExtractEndpoints(cla *endpoint.ClusterLoadAssignment) []string
func ExtractFilterChain(name string, l *listener.Listener) *listener.FilterChain
func ExtractFilterChainNames(l *listener.Listener) []string
func ExtractFilterNames(t test.Failer, fcs *listener.FilterChain) ([]string, []string)
func ExtractHTTPConnectionManager(t test.Failer, fcs *listener.FilterChain) *hcm.HttpConnectionManager
func ExtractHealthEndpoints(cla *endpoint.ClusterLoadAssignment) ([]string, []string)
func ExtractListener(name string, ll []*listener.Listener) *listener.Listener
func ExtractListenerFilters(l *listener.Listener) map[string]*listener.ListenerFilter
func ExtractListenerNames(ll []*listener.Listener) []string
func ExtractListenerSecretResources(t test.Failer, l *listener.Listener) []string
func ExtractLoadAssignments(cla []*endpoint.ClusterLoadAssignment) map[string][]string
func ExtractLocalityLbEndpoints(cla []*endpoint.ClusterLoadAssignment) map[string][]*endpoint.LocalityLbEndpoints
func ExtractResource(res model.Resources) sets.String
func ExtractRouteConfigurations(rc []*route.RouteConfiguration) map[string]*route.RouteConfiguration
func ExtractRoutesFromListeners(ll []*listener.Listener) []string
func ExtractSecretResources(t test.Failer, rs []*anypb.Any) []string
func ExtractTCPProxy(t test.Failer, fcs *listener.FilterChain) *tcpproxy.TcpProxy
func ExtractTLSSecrets(t test.Failer, secrets []*anypb.Any) map[string]*tls.Secret
func ExtractVirtualHosts(rc *route.RouteConfiguration) map[string][]string
func FilterClusters(cl []*cluster.Cluster, f func(c *cluster.Cluster) bool) []*cluster.Cluster
func MapKeys[M ~map[string]V, V any](mp M) []string
func SilentlyUnmarshalAny[T any](a *anypb.Any) *T
func SlowClientInterceptor(recv, send time.Duration) grpc.StreamClientInterceptor
func SlowServerInterceptor(recv, send time.Duration) grpc.StreamServerInterceptor
func ToDiscoveryResponse[T proto.Message](p []T) *discovery.DiscoveryResponse
func TypeName[T proto.Message]() string
func UnmarshalAny[T any](t test.Failer, a *anypb.Any) *T
func UnmarshalClusterLoadAssignment(t test.Failer, resp []*anypb.Any) []*endpoint.ClusterLoadAssignment
func UnmarshalRouteConfiguration(t test.Failer, resp []*anypb.Any) []*route.RouteConfiguration
func ValidateCluster(t testing.TB, c *cluster.Cluster)
func ValidateClusterLoadAssignment(t testing.TB, l *endpoint.ClusterLoadAssignment)
func ValidateClusterLoadAssignments(t testing.TB, ls []*endpoint.ClusterLoadAssignment)
func ValidateClusters(t testing.TB, ls []*cluster.Cluster)
func ValidateListener(t testing.TB, l *listener.Listener)
func ValidateListeners(t testing.TB, ls []*listener.Listener)
func ValidateRoute(t testing.TB, r *route.Route)
func ValidateRouteConfiguration(t testing.TB, l *route.RouteConfiguration)
func ValidateRouteConfigurations(t testing.TB, ls []*route.RouteConfiguration)
func ValidateRoutes(t testing.TB, ls []*route.Route)
type LbEpInfo
type LocLbEpInfo
- func (i LocLbEpInfo) GetAddrs() []string

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CompareEndpoints ¶

func CompareEndpoints(cluster string, got []*endpointv3.LocalityLbEndpoints, want []LocLbEpInfo) error

func CompareEndpointsOrFail ¶

func CompareEndpointsOrFail(t *testing.T, cluster string, got []*endpointv3.LocalityLbEndpoints, want []LocLbEpInfo)

func Dump ¶

func Dump(t test.Failer, p proto.Message) string

func DumpList ¶

func DumpList[T any](t test.Failer, protoList []T) []string

DumpList will dump a list of protos.

func EvaluateListenerFilterPredicates ¶

func EvaluateListenerFilterPredicates(predicate *listener.ListenerFilterChainMatchPredicate, port int) bool

EvaluateListenerFilterPredicates runs through the ListenerFilterChainMatchPredicate logic This is exposed for testing only, and should not be used in XDS generation code

func ExtractCluster ¶

func ExtractCluster(name string, cc []*cluster.Cluster) *cluster.Cluster

func ExtractClusterEndpoints ¶

func ExtractClusterEndpoints(clusters []*cluster.Cluster) map[string][]string

func ExtractClusterSecretResources ¶

func ExtractClusterSecretResources(t test.Failer, c *cluster.Cluster) []string

func ExtractClusters ¶

func ExtractClusters(cc []*cluster.Cluster) map[string]*cluster.Cluster

func ExtractEdsClusterNames ¶

func ExtractEdsClusterNames(cl []*cluster.Cluster) []string

func ExtractEndpoints ¶

func ExtractEndpoints(cla *endpoint.ClusterLoadAssignment) []string

ExtractEndpoints returns all endpoints in the load assignment (including unhealthy endpoints)

func ExtractFilterChain ¶

func ExtractFilterChain(name string, l *listener.Listener) *listener.FilterChain

func ExtractFilterChainNames ¶

func ExtractFilterChainNames(l *listener.Listener) []string

func ExtractFilterNames ¶

func ExtractFilterNames(t test.Failer, fcs *listener.FilterChain) ([]string, []string)

func ExtractHTTPConnectionManager ¶

func ExtractHTTPConnectionManager(t test.Failer, fcs *listener.FilterChain) *hcm.HttpConnectionManager

func ExtractHealthEndpoints ¶

func ExtractHealthEndpoints(cla *endpoint.ClusterLoadAssignment) ([]string, []string)

ExtractHealthEndpoints returns all health and unhealth endpoints

func ExtractListener ¶

func ExtractListener(name string, ll []*listener.Listener) *listener.Listener

func ExtractListenerFilters ¶

func ExtractListenerFilters(l *listener.Listener) map[string]*listener.ListenerFilter

func ExtractListenerNames ¶

func ExtractListenerNames(ll []*listener.Listener) []string

func ExtractListenerSecretResources ¶

func ExtractListenerSecretResources(t test.Failer, l *listener.Listener) []string

func ExtractLoadAssignments ¶

func ExtractLoadAssignments(cla []*endpoint.ClusterLoadAssignment) map[string][]string

func ExtractLocalityLbEndpoints ¶

func ExtractLocalityLbEndpoints(cla []*endpoint.ClusterLoadAssignment) map[string][]*endpoint.LocalityLbEndpoints

func ExtractResource ¶

func ExtractResource(res model.Resources) sets.String

func ExtractRouteConfigurations ¶

func ExtractRouteConfigurations(rc []*route.RouteConfiguration) map[string]*route.RouteConfiguration

func ExtractRoutesFromListeners ¶

func ExtractRoutesFromListeners(ll []*listener.Listener) []string

func ExtractSecretResources ¶

func ExtractSecretResources(t test.Failer, rs []*anypb.Any) []string

ExtractSecretResources fetches all referenced SDS resource names from a list of clusters and listeners

func ExtractTCPProxy ¶

func ExtractTCPProxy(t test.Failer, fcs *listener.FilterChain) *tcpproxy.TcpProxy

func ExtractTLSSecrets ¶

func ExtractTLSSecrets(t test.Failer, secrets []*anypb.Any) map[string]*tls.Secret

func ExtractVirtualHosts ¶

func ExtractVirtualHosts(rc *route.RouteConfiguration) map[string][]string

func FilterClusters ¶

func FilterClusters(cl []*cluster.Cluster, f func(c *cluster.Cluster) bool) []*cluster.Cluster

func MapKeys ¶

func MapKeys[M ~map[string]V, V any](mp M) []string

func SilentlyUnmarshalAny ¶

func SilentlyUnmarshalAny[T any](a *anypb.Any) *T

func SlowClientInterceptor ¶

func SlowClientInterceptor(recv, send time.Duration) grpc.StreamClientInterceptor

SlowClientInterceptor is an interceptor that allows injecting delays on Send and Recv

func SlowServerInterceptor ¶

func SlowServerInterceptor(recv, send time.Duration) grpc.StreamServerInterceptor

SlowServerInterceptor is an interceptor that allows injecting delays on Send and Recv

func ToDiscoveryResponse ¶

func ToDiscoveryResponse[T proto.Message](p []T) *discovery.DiscoveryResponse

func TypeName ¶

func TypeName[T proto.Message]() string

func UnmarshalAny ¶

func UnmarshalAny[T any](t test.Failer, a *anypb.Any) *T

func UnmarshalClusterLoadAssignment ¶

func UnmarshalClusterLoadAssignment(t test.Failer, resp []*anypb.Any) []*endpoint.ClusterLoadAssignment

func UnmarshalRouteConfiguration ¶

func UnmarshalRouteConfiguration(t test.Failer, resp []*anypb.Any) []*route.RouteConfiguration

func ValidateCluster ¶

func ValidateCluster(t testing.TB, c *cluster.Cluster)

func ValidateClusterLoadAssignment ¶

func ValidateClusterLoadAssignment(t testing.TB, l *endpoint.ClusterLoadAssignment)

func ValidateClusterLoadAssignments ¶

func ValidateClusterLoadAssignments(t testing.TB, ls []*endpoint.ClusterLoadAssignment)

func ValidateClusters ¶

func ValidateClusters(t testing.TB, ls []*cluster.Cluster)

func ValidateListener ¶

func ValidateListener(t testing.TB, l *listener.Listener)

func ValidateListeners ¶

func ValidateListeners(t testing.TB, ls []*listener.Listener)

func ValidateRoute ¶

func ValidateRoute(t testing.TB, r *route.Route)

func ValidateRouteConfiguration ¶

func ValidateRouteConfiguration(t testing.TB, l *route.RouteConfiguration)

func ValidateRouteConfigurations ¶

func ValidateRouteConfigurations(t testing.TB, ls []*route.RouteConfiguration)

func ValidateRoutes ¶

func ValidateRoutes(t testing.TB, ls []*route.Route)

Types ¶

type LbEpInfo ¶

type LbEpInfo struct {
	Address string
	// nolint: structcheck
	Weight uint32
}

type LocLbEpInfo ¶

type LocLbEpInfo struct {
	LbEps  []LbEpInfo
	Weight uint32
}

func (LocLbEpInfo) GetAddrs ¶

func (i LocLbEpInfo) GetAddrs() []string

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL