- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for _get_node (0.25 sec)
-
pkg/kubelet/server/stats/testing/mock_stats_provider.go
} // GetNode mocks base method. func (m *MockProvider) GetNode() (*v10.Node, error) { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "GetNode") ret0, _ := ret[0].(*v10.Node) ret1, _ := ret[1].(error) return ret0, ret1 } // GetNode indicates an expected call of GetNode. func (mr *MockProviderMockRecorder) GetNode() *gomock.Call { mr.mock.ctrl.T.Helper()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 11.8K bytes - Viewed (0) -
platforms/core-execution/snapshots/src/test/groovy/org/gradle/internal/snapshot/AbstractIncompleteFileSystemNodeTest.groovy
} def "querying for non-existing child #vfsSpec.searchedPath finds nothings (#vfsSpec)"() { setupTest(vfsSpec) when: def resultRoot = initialRoot.getNode(searchedPath, CASE_SENSITIVE) then: !resultRoot.present interaction { noMoreInteractions() } where:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:34:50 UTC 2023 - 13.3K bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/noderesources.go
if kubeClient == nil { return nil } logger := klog.FromContext(ctx) logger = klog.LoggerWithName(logger, "node resources controller") ctx = klog.NewContext(ctx, logger) c := &nodeResourcesController{ ctx: ctx, kubeClient: kubeClient, getNode: getNode,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 20:12:53 UTC 2024 - 16.6K bytes - Viewed (0) -
pkg/kubelet/server/stats/summary_test.go
"/pods": {cs: getContainerStats(), ns: getNetworkStats()}, } mockCtrl := gomock.NewController(t) defer mockCtrl.Finish() mockStatsProvider := statstest.NewMockProvider(mockCtrl) mockStatsProvider.EXPECT().GetNode().Return(node, nil) mockStatsProvider.EXPECT().GetNodeConfig().Return(nodeConfig) mockStatsProvider.EXPECT().GetPodCgroupRoot().Return(cgroupRoot) mockStatsProvider.EXPECT().ListPodStats(ctx).Return(podStats, nil).AnyTimes()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 15.1K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/graph/conflicts/DefaultCapabilitiesConflictHandler.java
Collection<NodeState> implicitCapabilityProviders = candidate.getImplicitCapabilityProviders(); nodes.addAll(implicitCapabilityProviders); NodeState node = candidate.getNode(); if (nodes.add(node) && nodes.size() > 1) { // The registered nodes may contain nodes which are no longer selected. // We don't remove them from the list in the first place because it proved to be
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 14:19:34 UTC 2024 - 12.1K bytes - Viewed (0) -
pkg/kubelet/volume_host.go
node, err := kvh.kubelet.GetNode() if err != nil { return nil, fmt.Errorf("error retrieving node: %v", err) } return node.Labels, nil } func (kvh *kubeletVolumeHost) GetAttachedVolumesFromNodeStatus() (map[v1.UniqueVolumeName]string, error) { node, err := kvh.kubelet.GetNode() if err != nil { return nil, fmt.Errorf("error retrieving node: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 10K bytes - Viewed (0) -
pkg/kubelet/kubelet_getters.go
// getRuntime returns the current Runtime implementation in use by the kubelet. func (kl *Kubelet) getRuntime() kubecontainer.Runtime { return kl.containerRuntime } // GetNode returns the node info for the configured node name of this Kubelet. func (kl *Kubelet) GetNode() (*v1.Node, error) { if kl.kubeClient == nil { return kl.initialNode(context.TODO()) } return kl.nodeLister.Get(string(kl.nodeName)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 00:48:07 UTC 2024 - 17.9K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/AbstractSession.java
return allRepositories.computeIfAbsent(repository, DefaultRemoteRepository::new); } @Override public Node getNode(org.eclipse.aether.graph.DependencyNode node) { return getNode(node, false); } @Override public Node getNode(org.eclipse.aether.graph.DependencyNode node, boolean verbose) { return allNodes.computeIfAbsent(node, n -> new DefaultNode(this, n, verbose)); }
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 07:23:04 UTC 2024 - 27.5K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/main/java/org/gradle/model/internal/registry/DefaultModelRegistry.java
ModelBinding subjectBinding = boundMutator.getSubjectBinding(); final ModelNodeInternal node = subjectBinding.getNode(); final ModelAction mutator = boundMutator.getAction(); ModelRuleDescriptor descriptor = mutator.getDescriptor();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri May 24 15:40:00 UTC 2024 - 45.7K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/execution/plan/DefaultExecutionPlan.java
public String getDisplayName() { return displayName; } @Override public QueryableExecutionPlan getContents() { return this; } @Override public TaskNode getNode(Task task) { return nodeMapping.get(task); } @Override public void setScheduledWork(ScheduledWork work) { if (scheduledNodes != null) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 13.6K bytes - Viewed (0)