Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 70 for _get_node (0.12 sec)

  1. istioctl/pkg/writer/envoy/configdump/configdump.go

    	const (
    		istioVersionKey  = "ISTIO_VERSION"
    		istioProxyShaKey = "ISTIO_PROXY_SHA"
    	)
    
    	md := bootstrapDump.GetBootstrap().GetNode().GetMetadata().GetFields()
    
    	if versionPB, ok := md[istioVersionKey]; ok {
    		version = versionPB.GetStringValue()
    	}
    	if shaPB, ok := md[istioProxyShaKey]; ok {
    		sha = shaPB.GetStringValue()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Feb 29 20:46:41 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  2. platforms/core-configuration/model-core/src/main/java/org/gradle/model/internal/registry/UnboundRulesProcessor.java

            UnboundRuleInput.Builder builder = UnboundRuleInput.type(reference.getType());
            ModelPath path;
            if (binding.isBound()) {
                builder.bound();
                path = binding.getNode().getPath();
            } else {
                path = reference.getPath();
                if (path != null) {
                    builder.suggestions(CollectionUtils.stringize(suggestionsProvider.transform(path)));
                }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Sep 28 09:51:04 UTC 2023
    - 3.5K bytes
    - Viewed (0)
  3. 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)
  4. platforms/core-execution/snapshots/src/main/java/org/gradle/internal/snapshot/SnapshotUtil.java

                @Override
                public Optional<FileSystemNode> handleAsDescendantOfChild(VfsRelativePath pathInChild, T child) {
                    return child.getNode(pathInChild, caseSensitivity);
                }
    
                @Override
                public Optional<FileSystemNode> handleAsAncestorOfChild(String childPath, T child) {
                    return Optional.of(child);
                }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Apr 26 16:02:34 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  5. platforms/core-execution/snapshots/src/main/java/org/gradle/internal/snapshot/AbstractFileSystemLocationSnapshot.java

            return Optional.of(missingSnapshotForAbsolutePath(relativePath.getAbsolutePath()));
        }
    
        @Override
        public Optional<FileSystemNode> getNode(VfsRelativePath relativePath, CaseSensitivity caseSensitivity) {
            return Optional.of(getChildNode(relativePath, caseSensitivity));
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Nov 23 13:19:32 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  6. pkg/registry/registrytest/node.go

    	r.Lock()
    	defer r.Unlock()
    	for i, item := range r.Nodes.Items {
    		if item.Name == node.Name {
    			r.Nodes.Items[i] = *node
    			return r.Err
    		}
    	}
    	return r.Err
    }
    
    func (r *NodeRegistry) GetNode(ctx context.Context, nodeID string, options *metav1.GetOptions) (*api.Node, error) {
    	r.Lock()
    	defer r.Unlock()
    	if r.Err != nil {
    		return nil, r.Err
    	}
    	for _, node := range r.Nodes.Items {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 23:13:50 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  7. pkg/controller/serviceaccount/tokengetter.go

    	if secret, err := c.secretLister.Secrets(namespace).Get(name); err == nil {
    		return secret, nil
    	}
    	return c.client.CoreV1().Secrets(namespace).Get(context.TODO(), name, metav1.GetOptions{})
    }
    
    func (c clientGetter) GetNode(name string) (*v1.Node, error) {
    	// handle the case where the node lister isn't set due to feature being disabled
    	if c.nodeLister == nil {
    		return nil, apierrors.NewNotFound(v1.Resource("nodes"), name)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 21:15:10 UTC 2023
    - 3K bytes
    - Viewed (0)
  8. pkg/kubelet/util/manager/cache_based_manager.go

    		}
    	}
    }
    
    // GetObjectTTLFromNodeFunc returns a function that returns TTL value
    // from a given Node object.
    func GetObjectTTLFromNodeFunc(getNode func() (*v1.Node, error)) GetObjectTTLFunc {
    	return func() (time.Duration, bool) {
    		node, err := getNode()
    		if err != nil {
    			return time.Duration(0), false
    		}
    		if node != nil && node.Annotations != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  9. pkg/kubelet/server/stats/summary_windows_test.go

    		}
    	)
    
    	assert := assert.New(t)
    
    	mockCtrl := gomock.NewController(t)
    	defer mockCtrl.Finish()
    
    	mockStatsProvider := statstest.NewMockProvider(mockCtrl)
    	mockStatsProvider.EXPECT().GetNode().Return(node, nil).AnyTimes()
    	mockStatsProvider.EXPECT().GetNodeConfig().Return(nodeConfig).AnyTimes()
    	mockStatsProvider.EXPECT().GetPodCgroupRoot().Return(cgroupRoot).AnyTimes()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  10. platforms/core-execution/snapshots/src/main/java/org/gradle/internal/snapshot/AbstractIncompleteFileSystemNode.java

        public AbstractIncompleteFileSystemNode(ChildMap<? extends FileSystemNode> children) {
            this.children = (ChildMap<FileSystemNode>) children;
        }
    
        @Override
        public Optional<FileSystemNode> getNode(VfsRelativePath targetPath, CaseSensitivity caseSensitivity) {
            return SnapshotUtil.getChild(children, targetPath, caseSensitivity);
        }
    
        @Override
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:34:50 UTC 2023
    - 6.5K bytes
    - Viewed (0)
Back to top