Versions in this module Expand all Collapse all v1 v1.0.0 Jun 21, 2023 Changes in this version + const ClientSideCertProviderInstance + const ServerListenerResourceNameTemplate + const ServerSideCertProviderInstance + var RouterHTTPFilter = HTTPFilter("router", &v3routerpb.Router{}) + func ClusterResourceWithOptions(opts ClusterOptions) *v3clusterpb.Cluster + func CreateClientTLSCredentials(t *testing.T) credentials.TransportCredentials + func DefaultClientListener(target, routeName string) *v3listenerpb.Listener + func DefaultCluster(clusterName, edsServiceName string, secLevel SecurityLevel) *v3clusterpb.Cluster + func DefaultEndpoint(clusterName string, host string, ports []uint32) *v3endpointpb.ClusterLoadAssignment + func DefaultFileWatcherConfig(certPath, keyPath, caPath string) json.RawMessage + func DefaultRouteConfig(routeName, ldsTarget, clusterName string) *v3routepb.RouteConfiguration + func DefaultServerListener(host string, port uint32, secLevel SecurityLevel) *v3listenerpb.Listener + func EndpointResourceWithOptions(opts EndpointOptions) *v3endpointpb.ClusterLoadAssignment + func HTTPFilter(name string, config proto.Message) *v3httppb.HttpFilter + func RouteConfigResourceWithOptions(opts RouteConfigOptions) *v3routepb.RouteConfiguration + type ClusterOptions struct + ClusterName string + Policy LoadBalancingPolicy + SecurityLevel SecurityLevel + ServiceName string + type EndpointOptions struct + ClusterName string + DropPercents map[string]int + Host string + Localities []LocalityOptions + type LoadBalancingPolicy int + const LoadBalancingPolicyRingHash + const LoadBalancingPolicyRoundRobin + type LocalityOptions struct + Ports []uint32 + Weight uint32 + type ManagementServer struct + Address string + LRSServer *fakeserver.Server + func SetupManagementServer(t *testing.T, opts ManagementServerOptions) (*ManagementServer, string, []byte, resolver.Builder, func()) + func StartManagementServer(opts ManagementServerOptions) (*ManagementServer, error) + func (s *ManagementServer) Stop() + func (s *ManagementServer) Update(ctx context.Context, opts UpdateOptions) error + type ManagementServerOptions struct + AllowResourceSubset bool + Listener net.Listener + OnStreamClosed func(int64, *v3corepb.Node) + OnStreamOpen func(context.Context, int64, string) error + OnStreamRequest func(int64, *v3discoverypb.DiscoveryRequest) error + OnStreamResponse func(context.Context, int64, *v3discoverypb.DiscoveryRequest, ...) + ServerFeaturesIgnoreResourceDeletion bool + SupportLoadReportingService bool + type ResourceParams struct + DialTarget string + Host string + NodeID string + Port uint32 + SecLevel SecurityLevel + type RouteConfigClusterSpecifierType int + const RouteConfigClusterSpecifierTypeCluster + const RouteConfigClusterSpecifierTypeClusterSpecifierPlugin + const RouteConfigClusterSpecifierTypeWeightedCluster + type RouteConfigOptions struct + ClusterName string + ClusterSpecifierPluginConfig *anypb.Any + ClusterSpecifierPluginName string + ClusterSpecifierType RouteConfigClusterSpecifierType + ListenerName string + RouteConfigName string + WeightedClusters map[string]int + type SecurityLevel int + const SecurityLevelMTLS + const SecurityLevelNone + const SecurityLevelTLS + type UpdateOptions struct + Clusters []*v3clusterpb.Cluster + Endpoints []*v3endpointpb.ClusterLoadAssignment + Listeners []*v3listenerpb.Listener + NodeID string + Routes []*v3routepb.RouteConfiguration + SkipValidation bool + func DefaultClientResources(params ResourceParams) UpdateOptions
Go to main page