- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 42 for _get_node (0.14 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) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/InternalSession.java
} } RemoteRepository getRemoteRepository(org.eclipse.aether.repository.RemoteRepository repository); Node getNode(org.eclipse.aether.graph.DependencyNode node); Node getNode(org.eclipse.aether.graph.DependencyNode node, boolean verbose); @Nonnull Artifact getArtifact(@Nonnull org.eclipse.aether.artifact.Artifact artifact); @Nonnull
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Apr 23 12:55:57 UTC 2024 - 3.4K bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns_linux.go
// See the License for the specific language governing permissions and // limitations under the License. package nodeagent import ( "fmt" "io/fs" "syscall" ) func GetInode(fi fs.FileInfo) (uint64, error) { if stat, ok := fi.Sys().(*syscall.Stat_t); ok { return stat.Ino, nil } return 0, fmt.Errorf("unable to get inode")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 26 20:34:28 UTC 2024 - 814 bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns_other.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 26 20:34:28 UTC 2024 - 781 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) -
platforms/core-configuration/model-core/src/main/java/org/gradle/model/internal/registry/RuleBinder.java
@Override public void execute(ModelBinding modelBinding) { ModelNodeInternal node = modelBinding.getNode(); BindingPredicate predicate = modelBinding.getPredicate(); if (node.isAtLeast(predicate.getState())) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 06 21:54:37 UTC 2024 - 5.1K bytes - Viewed (0) -
istioctl/pkg/writer/pilot/status.go
err := resource.UnmarshalTo(&clientConfig) if err != nil { return nil, nil, fmt.Errorf("could not unmarshal ClientConfig: %w", err) } meta, err := model.ParseMetadata(clientConfig.GetNode().GetMetadata()) if err != nil { return nil, nil, fmt.Errorf("could not parse node metadata: %w", err) } if s.Namespace != "" && meta.Namespace != s.Namespace { continue }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 15 04:16:55 UTC 2024 - 6.1K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/graph/conflicts/CapabilitiesConflictHandler.java
* This is needed to determine if also implicit capabilities need to enter conflict detection. */ boolean hasSeenCapability(Capability capability); interface Candidate { NodeState getNode(); Capability getCapability(); Collection<NodeState> getImplicitCapabilityProviders(); } interface ResolutionDetails extends ConflictResolutionResult {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Feb 07 23:54:34 UTC 2024 - 2K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/DefaultDependencyResolver.java
session.getRepositorySystem().collectDependencies(systemSession, collectRequest); return new DefaultDependencyResolverResult( null, result.getExceptions(), session.getNode(result.getRoot(), request.getVerbose()), 0); } catch (DependencyCollectionException e) { throw new DependencyResolverException("Unable to collect dependencies", e); } } @Override
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 07:23:04 UTC 2024 - 8.5K bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/plugin.go
func NewRegistrationHandler(kubeClient kubernetes.Interface, getNode func() (*v1.Node, error)) *RegistrationHandler { handler := &RegistrationHandler{} // If kubelet ever gets an API for stopping registration handlers, then // that would need to be hooked up with stopping the controller. handler.controller = startNodeResourcesController(context.TODO(), kubeClient, getNode) return handler }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 19 16:27:05 UTC 2024 - 6.2K bytes - Viewed (0)