- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 82 for nodestore (0.17 sec)
-
okhttp/src/test/java/okhttp3/KotlinDeprecationErrorTest.kt
} @Test @Disabled fun cacheControl() { val cacheControl: CacheControl = CacheControl.Builder().build() val noCache: Boolean = cacheControl.noCache() val noStore: Boolean = cacheControl.noStore() val maxAgeSeconds: Int = cacheControl.maxAgeSeconds() val sMaxAgeSeconds: Int = cacheControl.sMaxAgeSeconds() val mustRevalidate: Boolean = cacheControl.mustRevalidate()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 13.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/graph/AbstractGraphTest.java
assertThat(graphString).contains("allowsSelfLoops: " + graph.allowsSelfLoops()); int nodeStart = graphString.indexOf("nodes:"); int edgeStart = graphString.indexOf("edges:"); String nodeString = graphString.substring(nodeStart, edgeStart); Set<EndpointPair<N>> allEndpointPairs = new HashSet<>(); for (N node : sanityCheckSet(graph.nodes())) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jan 22 17:29:38 UTC 2024 - 16.6K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/policy_static.go
for _, nodeID := range b.NUMAAffinity { nodeState, ok := expectedMachineState[nodeID] if !ok { return fmt.Errorf("[memorymanager] (pod: %s, container: %s) the memory assignment uses the NUMA that does not exist", pod, containerName) } nodeState.NumberOfAssignments++ nodeState.Cells = b.NUMAAffinity memoryState, ok := nodeState.MemoryMap[b.Type] if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Nov 12 07:34:55 UTC 2023 - 34K bytes - Viewed (0) -
pkg/registry/core/serviceaccount/storage/storage_test.go
StorageConfig: etcdStorage, Decorator: generic.UndecoratedStorage, DeleteCollectionWorkers: 1, ResourcePrefix: "serviceaccounts", } // set issuer, podStore and secretStore to allow the token endpoint to be initialised rest, err := NewREST(restOptions, fakeTokenGenerator{"fake"}, nil, 0, panicGetter{}, panicGetter{}, nil, false) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 6.7K bytes - Viewed (0) -
pkg/scheduler/framework/interface.go
"k8s.io/kubernetes/pkg/scheduler/framework/parallelize" ) // NodeScoreList declares a list of nodes and their scores. type NodeScoreList []NodeScore // NodeScore is a struct with node name and score. type NodeScore struct { Name string Score int64 } // NodeToStatusMap contains the statuses of the Nodes where the incoming Pod was not schedulable.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 35.4K bytes - Viewed (0) -
pkg/scheduler/schedule_one.go
// Additional details logged at level 10 if enabled. loggerVTen := logger.V(10) if loggerVTen.Enabled() { for _, nodeScore := range nodesScores { for _, pluginScore := range nodeScore.Scores { loggerVTen.Info("Plugin scored node for pod", "pod", klog.KObj(pod), "plugin", pluginScore.Name, "node", nodeScore.Name, "score", pluginScore.Score) } } } if len(extenders) != 0 && nodes != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:28:08 UTC 2024 - 43.4K bytes - Viewed (0) -
pkg/scheduler/schedule_one_test.go
var maxScore float64 minScore := math.MaxFloat64 for _, hostPriority := range nodeScores { maxScore = math.Max(maxScore, float64(hostPriority.Score)) minScore = math.Min(minScore, float64(hostPriority.Score)) } for i, hostPriority := range nodeScores { nodeScores[i] = framework.NodeScore{ Name: hostPriority.Name,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 128.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/KotlinSourceModernTest.kt
} @Test fun cacheControl() { val cacheControl: CacheControl = CacheControl.Builder().build() val noCache: Boolean = cacheControl.noCache val noStore: Boolean = cacheControl.noStore val maxAgeSeconds: Int = cacheControl.maxAgeSeconds val sMaxAgeSeconds: Int = cacheControl.sMaxAgeSeconds val mustRevalidate: Boolean = cacheControl.mustRevalidate
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 01 14:21:25 UTC 2024 - 46.5K bytes - Viewed (0) -
pkg/volume/csi/csi_attacher.go
if err != nil { return volumetypes.NewTransientOperationFailure(err.Error()) } nodeStageSecrets := map[string]string{} // we only require secrets if csiSource has them and volume has NodeStage capability if csiSource.NodeStageSecretRef != nil && stageUnstageSet { nodeStageSecrets, err = getCredentialsFromSecret(c.k8s, csiSource.NodeStageSecretRef) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 03 07:38:14 UTC 2023 - 25.9K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
finalizerExpectations *uidTrackingExpectations // A store of jobs jobLister batchv1listers.JobLister // A store of pods, populated by the podController podStore corelisters.PodLister // Jobs that need to be updated queue workqueue.TypedRateLimitingInterface[string] // Orphan deleted pods that still have a Job tracking finalizer to be removed
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0)