- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 277 for subset16 (0.1 sec)
-
pilot/pkg/networking/core/networkfilter.go
for _, subset := range destinationRule.Subsets { if subset.Name != subsetName { continue } // If subset has load balancer - see if it is also consistent hash source IP if subset.TrafficPolicy != nil && subset.TrafficPolicy.LoadBalancer != nil { if subset.TrafficPolicy.LoadBalancer.GetConsistentHash() != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 13.7K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_waypoint.go
func (cb *ClusterBuilder) buildWaypointInboundVIPCluster(proxy *model.Proxy, svc *model.Service, port model.Port, subset string) *clusterWrapper { clusterName := model.BuildSubsetKey(model.TrafficDirectionInboundVIP, subset, svc.Hostname, port.Port) discoveryType := convertResolution(cb.proxyType, svc) var lbEndpoints []*endpoint.LocalityLbEndpoints
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 9K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_builder.go
// and returns them along with allFound=True, or returns allFound=False indicating a cache miss. In either case, // the cache tokens are returned to allow future writes to the cache. // This code will only trigger a cache hit if all subset clusters are present. This simplifies the code a bit,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 31.6K bytes - Viewed (0) -
guava/src/com/google/common/collect/Sets.java
} } /** * Returns the set of all possible subsets of {@code set}. For example, {@code * powerSet(ImmutableSet.of(1, 2))} returns the set {@code {{}, {1}, {2}, {1, 2}}}. * * <p>Elements appear in these subsets in the same iteration order as they appeared in the input * set. The order in which these subsets appear in the outer set is undefined. Note that the power
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 78.8K bytes - Viewed (0) -
pilot/pkg/xds/endpoints/ep_filters_test.go
}, Subsets: []*networking.Subset{{ Name: "disable-tls", Labels: map[string]string{"app": "example"}, TrafficPolicy: &networking.TrafficPolicy{ Tls: &networking.ClientTLSSettings{Mode: networking.ClientTLSSettings_DISABLE}, }, }}, }, }, IsMtlsDisabled: true, SubsetName: "disable-tls", }, "mtls-on-subset-level": {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 01:17:58 UTC 2024 - 26.8K bytes - Viewed (0) -
pkg/registry/core/service/storage/storage.go
} eps := obj.(*api.Endpoints) if len(eps.Subsets) == 0 { return nil, nil, errors.NewServiceUnavailable(fmt.Sprintf("no endpoints available for service %q", svcName)) } // Pick a random Subset to start searching from. ssSeed := rand.Intn(len(eps.Subsets)) // Find a Subset that has the port. for ssi := 0; ssi < len(eps.Subsets); ssi++ { ss := &eps.Subsets[(ssSeed+ssi)%len(eps.Subsets)] if len(ss.Addresses) == 0 { continue
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 13:09:33 UTC 2024 - 22.3K bytes - Viewed (0) -
pkg/controlplane/reconcilers/endpointsadapter_test.go
} epSlice.Labels = map[string]string{discovery.LabelServiceName: name} subset := corev1.EndpointSubset{} for i, port := range ports { endpointPort := corev1.EndpointPort{ Name: fmt.Sprintf("port-%d", i), Port: int32(port), Protocol: corev1.ProtocolTCP, } subset.Ports = append(subset.Ports, endpointPort) epSlice.Ports = append(epSlice.Ports, discovery.EndpointPort{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 15.4K bytes - Viewed (0) -
pilot/pkg/xds/mesh_network_test.go
}, }) for subset, eps := range tc.expectations { client.ExpectWithWeight(&workload{kind: sc.expectKind, name: name, namespace: "test", port: port}, subset, eps...) } configObjects := ` --- apiVersion: networking.istio.io/v1alpha3 kind: DestinationRule metadata: name: subset-se namespace: test spec: host: "*" subsets: - name: v1 labels:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 24.6K bytes - Viewed (0) -
tests/integration/security/reachability_test.go
// Create a custom echo deployment in NS1 with subsets that allows us to test the // migration of a workload to istio (from no sidecar to sidecar). migrationApp = deployment.New(t). WithClusters(t.Clusters()...).WithConfig(echo.Config{ Namespace: echo1NS, Service: migrationServiceName, ServiceAccount: true, Ports: ports.All(), Subsets: []echo.SubsetConfig{ {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 02 21:29:40 UTC 2024 - 20.6K bytes - Viewed (0) -
pilot/pkg/networking/core/route/route_test.go
GroupVersionKind: gvk.DestinationRule, Name: "acme", Namespace: "istio-system", }, Spec: &networking.DestinationRule{ Host: "*.example.org", Subsets: []*networking.Subset{networkingSubset}, }, }, }, }) proxy := node(cg) hashByDestination := route.GetConsistentHashForVirtualService(cg.PushContext(), proxy, virtualService)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 14:12:39 UTC 2024 - 88.1K bytes - Viewed (0)