- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 36 for _genrule (0.14 sec)
-
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) -
src/main/java/org/codelibs/fess/helper/DocumentHelper.java
responseData.setSessionId(crawlingInfoId); final RuleManager ruleManager = SingletonLaContainer.getComponent(RuleManager.class); final Rule rule = ruleManager.getRule(responseData); if (rule == null) { throw new CrawlingAccessException("No url rule for " + url); } responseData.setRuleId(rule.getRuleId());
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 12K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerThread.java
} return true; } protected void processResponse(final UrlQueue<?> urlQueue, final ResponseData responseData) { // get a rule final Rule rule = crawlerContext.ruleManager.getRule(responseData); if (rule == null) { log(logHelper, LogType.NO_RULE, crawlerContext, urlQueue, responseData); } else { responseData.setRuleId(rule.getRuleId());
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 15.5K 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) -
src/main/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImpl.java
} final RuleManager ruleManager = SingletonLaContainer.getComponent(RuleManager.class); final Rule rule = ruleManager.getRule(responseData); if (rule == null) { logger.warn("No url rule. Data: {}", dataMap); } else { responseData.setRuleId(rule.getRuleId());
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 16.8K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/dsl/DefaultComponentMetadataProcessor.java
processClassRule(action, metadata, details); } else { processRule(wrapper.getRule(), metadata, details); } } } private void processClassRule(Action<ComponentMetadataContext> action, final ModuleComponentResolveMetadata metadata, final ComponentMetadataDetails details) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 20.2K 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) -
src/cmd/compile/internal/ssa/_gen/main.go
tasks := []func(){ genOp, genAllocators, } for _, a := range archs { a := a // the funcs are ran concurrently at a later time tasks = append(tasks, func() { genRules(a) genSplitLoadRules(a) genLateLowerRules(a) }) } var wg sync.WaitGroup for _, task := range tasks { task := task wg.Add(1) go func() { task() wg.Done() }()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jan 19 22:42:34 UTC 2023 - 16.9K bytes - Viewed (0) -
pilot/pkg/networking/core/route/route.go
if push == nil { return nil, nil } mergedDR := node.SidecarScope.DestinationRule(model.TrafficDirectionOutbound, node, svc.Hostname) destinationRule := mergedDR.GetRule() if destinationRule == nil { return nil, nil } rule := destinationRule.Spec.(*networking.DestinationRule) consistentHash := rule.GetTrafficPolicy().GetLoadBalancer().GetConsistentHash()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 14:12:39 UTC 2024 - 56.1K bytes - Viewed (0)