- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 33 for genrule (0.13 sec)
-
pilot/pkg/networking/core/cluster_waypoint.go
clusters = append(clusters, cb.buildWaypointInboundVIPCluster(proxy, svc, *port, "http").build()) } cfg := cb.sidecarScope.DestinationRule(model.TrafficDirectionInbound, proxy, svc.Hostname).GetRule() if cfg != nil { destinationRule := cfg.Spec.(*networking.DestinationRule) for _, ss := range destinationRule.Subsets { if port.Protocol.IsUnsupported() || port.Protocol.IsTCP() {
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/model/destination_rule.go
if len(l.from) != len(r.from) { return false } for i, v := range l.from { if v != r.from[i] { return false } } return true } func (l *ConsolidatedDestRule) GetRule() *config.Config { if l == nil { return nil } return l.rule } func (l *ConsolidatedDestRule) GetFrom() []types.NamespacedName { if l == nil { return nil } return l.from
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 07:22:29 UTC 2024 - 6.1K bytes - Viewed (0) -
pilot/pkg/networking/core/networkfilter.go
var destinationRule *networking.DestinationRule if service != nil { destinationRule = CastDestinationRule(node.SidecarScope.DestinationRule(model.TrafficDirectionOutbound, node, service.Hostname).GetRule()) } if len(routes) == 1 { clusterName := istioroute.GetDestinationCluster(routes[0].Destination, service, port.Port) statPrefix := clusterName
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_builder.go
// choice of inbound cluster is arbitrary. So the connection pool settings may not apply cleanly. cfg := proxy.SidecarScope.DestinationRule(model.TrafficDirectionInbound, proxy, instance.Service.Hostname).GetRule() if cfg != nil { destinationRule := CastDestinationRule(cfg) opts.isDrWithSelector = destinationRule.GetWorkloadSelector() != nil if destinationRule.TrafficPolicy != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 31.6K bytes - Viewed (0) -
pilot/pkg/xds/endpoints/endpoint_builder.go
b.subsetName = strings.TrimPrefix(b.subsetName, "http/") b.subsetName = strings.TrimPrefix(b.subsetName, "tcp/") } b.mtlsChecker = newMtlsChecker(b.push, b.port, b.destinationRule.GetRule(), b.subsetName) b.subsetLabels = getSubSetLabels(b.DestinationRule(), b.subsetName) } func (b *EndpointBuilder) populateFailoverPriorityLabels() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 02:18:19 UTC 2024 - 26.1K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier_test.go
} if (epRule.MatchSet == "" && rule.MatchSet != nil) || (epRule.MatchSet != "" && (rule.MatchSet == nil || rule.MatchSet.Value != epRule.MatchSet)) { t.Errorf("Expected MatchSet=%s JumpChain=%s, got %s", epRule.MatchSet, epRule.JumpChain, rule.Raw) } } } } // checkIPSet to check expected ipset and entries
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 186.8K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolutionstrategy/DefaultResolutionStrategy.java
out.preferProjectModules(); } out.setForcedModules(forcedModules); for (SpecRuleAction<? super ComponentSelection> ruleAction : componentSelectionRules.getRules()) { out.getComponentSelection().addRule(ruleAction); } if (isDependencyLockingEnabled()) { out.activateDependencyLocking(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 22 19:04:04 UTC 2024 - 15.9K bytes - Viewed (0) -
platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/ivyservice/ivyresolve/DefaultVersionedComponentChooserTest.groovy
when: chooser.selectNewestMatchingComponent([c, a, d, b], selectedComponentResult, versionSelectorScheme.parseSelector(notation), null, consumerAttributes) then: 1 * componentSelectionRules.getRules() >> [] 1 * selectedComponentResult.getContentFilter() >> null if (notation.indexOf('+') > 0) { 1 * selectedComponentResult.notMatched(d.id, _) } else {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 17:38:42 UTC 2024 - 17.1K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster.go
}, } } subsetClusters := cb.applyDestinationRule(defaultCluster, DefaultClusterMode, service, port, clusterKey.endpointBuilder, clusterKey.destinationRule.GetRule(), clusterKey.serviceAccounts) if patched := cp.patch(nil, defaultCluster.build()); patched != nil { resources = append(resources, patched) if features.EnableCDSCaching {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 33K bytes - Viewed (0) -
build-logic/binary-compatibility/src/test/kotlin/gradlebuild/binarycompatibility/AbstractBinaryCompatibilityTest.kt
import org.junit.Assert.assertTrue import org.junit.Rule import org.junit.rules.TemporaryFolder import java.io.File import java.nio.file.Files abstract class AbstractBinaryCompatibilityTest { @get:Rule val tmpDir = TemporaryFolder() private val rootDir: File get() = tmpDir.root internal
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 04 14:00:46 UTC 2024 - 16.4K bytes - Viewed (0)