func ClusterResourceWithOptions(optsClusterOptions) *v3clusterpb.Cluster

func DefaultBootstrapContents(t *testing.T, nodeID, serverURIstring) []byte

func DefaultClientListener(target, routeNamestring) *v3listenerpb.Listener

func DefaultCluster(clusterName, edsServiceNamestring, secLevelSecurityLevel) *v3clusterpb.Cluster

func DefaultEndpoint(clusterNamestring, hoststring, ports []uint32) *v3endpointpb.ClusterLoadAssignment

func DefaultFileWatcherConfig(certPath, keyPath, caPathstring)json.RawMessage

func DefaultRouteConfig(routeName, vhDomain, clusterNamestring) *v3routepb.RouteConfiguration

func DefaultServerListener(hoststring, portuint32, secLevelSecurityLevel, routeNamestring) *v3listenerpb.Listener

func DefaultServerListenerWithRouteConfigName(hoststring, portuint32, secLevelSecurityLevel, routeNamestring) *v3listenerpb.Listener

func EndpointResourceWithOptions(optsEndpointOptions) *v3endpointpb.ClusterLoadAssignment

func HTTPFilter(namestring, configproto.Message) *v3httppb.HttpFilter

func RouteConfigFilterAction(routeNamestring) *v3routepb.RouteConfiguration

func RouteConfigNoRouteMatch(routeNamestring) *v3routepb.RouteConfiguration

func RouteConfigNonForwardingAction(routeNamestring) *v3routepb.RouteConfiguration

func RouteConfigResourceWithOptions(optsRouteConfigOptions) *v3routepb.RouteConfiguration

func SPIFFEBootstrapContents(t *testing.T, nodeID, serverURIstring) []byte

func SPIFFEFileWatcherConfig(certPath, keyPath, caPath, spiffeBundleMapPathstring)json.RawMessage

type BackendOptions struct {// Ports on which the backend is accepting connections. All backends// are expected to run on localhost, hence host name is not stored here.Ports []uint32// Health status of the backend. Default is UNKNOWN which is treated the// same as HEALTHY.HealthStatusv3corepb.HealthStatus// Weight sets the backend weight. Defaults to 1.Weightuint32// Metadata sets the LB endpoint metadata (envoy.lb FilterMetadata field).// Seehttps://www.envoyproxy.io/docs/envoy/latest/api-v3/config/core/v3/base.proto#envoy-v3-api-msg-config-core-v3-metadataMetadata map[string]any}

type ClusterOptions struct {TypeClusterType// ClusterName is the name of the Cluster resource.ClusterNamestring// ServiceName is the EDS service name of the Cluster. Applicable only when// cluster type is EDS.ServiceNamestring// ChildNames is the list of child Cluster names. Applicable only when// cluster type is Aggregate.ChildNames []string// DNSHostName is the dns host name of the Cluster. Applicable only when the// cluster type is DNS.DNSHostNamestring// DNSPort is the port number of the Cluster. Applicable only when the// cluster type is DNS.DNSPortuint32// Policy is the LB policy to be used.PolicyLoadBalancingPolicy// SecurityLevel determines the security configuration for the Cluster.SecurityLevelSecurityLevel// EnableLRS adds a load reporting configuration with a config source// pointing to self.EnableLRSbool}

type ClusterTypeint

type EndpointOptions struct {// ClusterName is the name of the Cluster resource (or EDS service name)// containing the endpoints specified below.ClusterNamestring// Host is the hostname of the endpoints. In our e2e tests, hostname must// always be "localhost".Hoststring// Localities is a set of localities belonging to this resource.Localities []LocalityOptions// DropPercents is a map from drop category to a drop percentage. If unset,// no drops are configured.DropPercents map[string]int}

type LoadBalancingPolicyint

type LocalityID struct {RegionstringZonestringSubZonestring}

type LocalityOptions struct {// Name is the unique locality name.Namestring// Weight is the weight of the locality, used for load balancing.Weightuint32// Backends is a set of backends belonging to this locality.Backends []BackendOptions// Priority is the priority of the locality. Defaults to 0.Priorityuint32// Locality is the locality identifier. If not specified, a random// identifier is generated.LocalityLocalityID}

type ManagementServer struct {// Address is the host:port on which the management server is listening for// new connections.Addressstring// LRSServer points to the fake LRS server implementation. Set only if the// SupportLoadReportingService option was set to true when creating this// management server.LRSServer *fakeserver.Server// contains filtered or unexported fields}

funcStartManagementServer¶

func StartManagementServer(t *testing.T, optsManagementServerOptions) *ManagementServer

StartManagementServer initializes a management server which implements theAggregatedDiscoveryService endpoint. The management server is initializedwith no resources. Tests should call the Update() method to change theresource snapshot held by the management server, as per by the test logic.

Registers a cleanup function on t to stop the management server.

func (*ManagementServer)Stop¶

func (s *ManagementServer) Stop()

Stop stops the management server.

func (*ManagementServer)Update¶

func (s *ManagementServer) Update(ctxcontext.Context, optsUpdateOptions)error

Update changes the resource snapshot held by the management server, whichupdates connected clients as required.

type ManagementServerOptions struct {// Listener to accept connections on. If nil, a TPC listener on a local port// will be created and used.Listenernet.Listener// SupportLoadReportingService, if set, results in the load reporting// service being registered on the same port as that of ADS.SupportLoadReportingServicebool// AllowResourceSubSet allows the management server to respond to requests// before all configured resources are explicitly named in the request. The// default behavior that we want is for the management server to wait for// all configured resources to be requested before responding to any of// them, since this is how we have run our tests historically, and should be// set to true only for tests which explicitly require the other behavior.AllowResourceSubsetbool// ServerFeaturesIgnoreResourceDeletion, if set, results in a bootstrap config// where the server features list contains `ignore_resource_deletion`. This// results in gRPC ignoring resource deletions from the management server, as// per A53.ServerFeaturesIgnoreResourceDeletionbool// OnStreamOpen is called when an xDS stream is opened. The callback is// invoked with the assigned stream ID and the type URL from the incoming// request (or "" for ADS).//// Returning an error from this callback will end processing and close the// stream. OnStreamClosed will still be called.OnStreamOpen func(context.Context,int64,string)error// OnStreamClosed is called immediately prior to closing an xDS stream. The// callback is invoked with the stream ID of the stream being closed.OnStreamClosed func(int64, *v3corepb.Node)// OnStreamRequest is called when a request is received on the stream. The// callback is invoked with the stream ID of the stream on which the request// was received and the received request.//// Returning an error from this callback will end processing and close the// stream. OnStreamClosed will still be called.OnStreamRequest func(int64, *v3discoverypb.DiscoveryRequest)error// OnStreamResponse is called immediately prior to sending a response on the// stream. The callback is invoked with the stream ID of the stream on which// the response is being sent along with the incoming request and the outgoing// response.OnStreamResponse func(context.Context,int64, *v3discoverypb.DiscoveryRequest, *v3discoverypb.DiscoveryResponse)}

type ResourceParams struct {// DialTarget is the client's dial target. This is used as the name of the// Listener resource.DialTargetstring// NodeID is the id of the xdsClient to which this update is to be pushed.NodeIDstring// Host is the host of the default Endpoint resource.Hoststring// port is the port of the default Endpoint resource.Portuint32// SecLevel controls the security configuration in the Cluster resource.SecLevelSecurityLevel}

type RouteConfigClusterSpecifierTypeint

type RouteConfigOptions struct {// RouteConfigName is the name of the RouteConfiguration resource.RouteConfigNamestring// ListenerName is the name of the Listener resource which uses this// RouteConfiguration.ListenerNamestring// ClusterSpecifierType determines the cluster specifier type.ClusterSpecifierTypeRouteConfigClusterSpecifierType// ClusterName is name of the cluster resource used when the cluster// specifier type is set to RouteConfigClusterSpecifierTypeCluster.//// Default value of "A" is used if left unspecified.ClusterNamestring// WeightedClusters is a map from cluster name to weights, and is used when// the cluster specifier type is set to// RouteConfigClusterSpecifierTypeWeightedCluster.//// Default value of {"A": 75, "B": 25} is used if left unspecified.WeightedClusters map[string]int// The below two fields specify the name of the cluster specifier plugin and// its configuration, and are used when the cluster specifier type is set to// RouteConfigClusterSpecifierTypeClusterSpecifierPlugin. Tests are expected// to provide valid values for these fields when appropriate.ClusterSpecifierPluginNamestringClusterSpecifierPluginConfig *anypb.Any}

type SecurityLevelint

type UpdateOptions struct {// NodeID is the id of the client to which this update is to be pushed.NodeIDstring// Endpoints, Clusters, Routes, and Listeners are the updated list of xds// resources for the server.  All must be provided with each Update.Endpoints []*v3endpointpb.ClusterLoadAssignmentClusters  []*v3clusterpb.ClusterRoutes    []*v3routepb.RouteConfigurationListeners []*v3listenerpb.Listener// SkipValidation indicates whether we want to skip validation (by not// calling snapshot.Consistent()). It can be useful for negative tests,// where we send updates that the client will NACK.SkipValidationbool}

funcDefaultClientResources¶

func DefaultClientResources(paramsResourceParams)UpdateOptions

DefaultClientResources returns a set of resources (LDS, RDS, CDS, EDS) for aclient to generically connect to one server.