- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 84 for logic (0.05 sec)
-
pilot/pkg/networking/core/route/route.go
// VirtualHostWrapper is a context-dependent virtual host entry with guarded routes. // Note: Currently we are not fully utilizing this structure. We could invoke this logic // once for all sidecars in the cluster to compute all RDS for inside the mesh and arrange // it by listener port. However to properly use such an optimization, we need to have an
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 14:12:39 UTC 2024 - 56.1K bytes - Viewed (0) -
pkg/volume/testing/testing.go
return plugin.LimitKey } // FakeBasicVolumePlugin implements a basic volume plugin. It wrappers on // FakeVolumePlugin but implements VolumePlugin interface only. // It is useful to test logic involving plugin interfaces. type FakeBasicVolumePlugin struct { Plugin FakeVolumePlugin } func (f *FakeBasicVolumePlugin) GetPluginName() string { return f.Plugin.GetPluginName() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 53.3K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/groovy/scripts/internal/GradleResolveVisitor.java
* '.' with a '$' for the package part, only for the class name part. There is also the case of a imported class, so this logic can't be done in these cases... */ private static class ConstructedClassWithPackage extends ClassNode { private final String prefix; private String className;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 26 14:58:23 UTC 2024 - 67.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go
// This is required to ensure we won't be leaking goroutines that wait for context // cancelling (e.g. in queueset::StartRequest method). // Even though in production we are not using httptest.Server, this logic is shared // across these two. func TestContextClosesOnRequestProcessed(t *testing.T) { epmetrics.Register() fcmetrics.Register() wg := sync.WaitGroup{} wg.Add(1)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 52.6K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller.go
} for i := 0; i < podUpdateWorkerSize; i++ { go wait.UntilWithContext(ctx, nc.doPodProcessingWorker, time.Second) } // Handling taint based evictions. Because we don't want a dedicated logic in TaintManager for NC-originated // taints and we normally don't rate limit evictions caused by taints, we need to rate limit adding taints. go wait.UntilWithContext(ctx, nc.doNoExecuteTaintingPass, scheduler.NodeEvictionPeriod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.6K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/configurations/DefaultConfiguration.java
} else if (observedState == GRAPH_RESOLVED) { // The configuration has been used in a resolution, and it is an error for build logic to change any dependencies, // exclude rules or parent configurations (values that will affect the resolved graph). if (type != MutationType.STRATEGY) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 17:36:01 UTC 2024 - 85.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset_test.go
}.exercise(t) } // TestContextCancel tests cancellation of a request's context. // The outline is: // 1. Use a concurrency limit of 1. // 2. Start request 1. // 3. Use a fake clock for the following logic, to insulate from scheduler noise. // 4. The exec fn of request 1 starts request 2, which should wait // in its queue. // 5. The exec fn of request 1 also forks a goroutine that waits 1 second
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 26 12:55:23 UTC 2023 - 58.4K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller.go
errCh <- err utilruntime.HandleError(err) } } }(i) } deleteWait.Wait() // collect errors if any for proper reporting/retry logic in the controller errors := []error{} close(errCh) for err := range errCh { errors = append(errors, err) } return utilerrors.NewAggregate(errors) } func storeDaemonSetStatus(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
pkg/proxy/winkernel/proxier.go
// b) Node IP of the current node // // For L2Bridge network the Source VIP is always the NodeIP of the current node and the same // would be configured on kube-proxy as SourceVIP // // The logic for choosing the SourceVIP in Overlay networks is based on the backend endpoints: // a) Endpoints are any IP's outside the cluster ==> Choose NodeIP as the SourceVIP
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 59K bytes - Viewed (0) -
tensorflow/compiler/jit/deadness_analysis.cc
// `pred` implies that `n` is live whenever `pred` is true. Then we can deduce // mismatching liveness in the inputs to node by comparing the predicate those // inputs are mapped to. The core logic of this pass resides in creating the // map from TensorFlow nodes to predicates. // // // MAPPING NODES TO PREDICATES, MODULO CYCLES // ------------------------------------------ //
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Mar 12 06:33:33 UTC 2024 - 60.4K bytes - Viewed (0)