Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for nodeclient (0.2 sec)

  1. pkg/volume/csi/nodeinfomanager/nodeinfomanager.go

    	// existing changes are not overwritten.
    
    	kubeClient := nim.volumeHost.GetKubeClient()
    	if kubeClient == nil {
    		return fmt.Errorf("error getting kube client")
    	}
    
    	nodeClient := kubeClient.CoreV1().Nodes()
    	originalNode, err := nodeClient.Get(context.TODO(), string(nim.nodeName), metav1.GetOptions{})
    	if err != nil {
    		return err
    	}
    	node := originalNode.DeepCopy()
    
    	needUpdate := false
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 11 09:02:45 UTC 2024
    - 20.1K bytes
    - Viewed (0)
  2. src/crypto/tls/handshake_client.go

    		return nil, nil, nil, errors.New("tls: NextProtos values too large")
    	}
    
    	supportedVersions := config.supportedVersions(roleClient)
    	if len(supportedVersions) == 0 {
    		return nil, nil, nil, errors.New("tls: no supported versions satisfy MinVersion and MaxVersion")
    	}
    	maxVersion := config.maxSupportedVersion(roleClient)
    
    	hello := &clientHelloMsg{
    		vers:                         maxVersion,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 03:10:12 UTC 2024
    - 38.6K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/kube/controller/controller.go

    	registerHandlers[*v1.Node](c, c.nodes, "Nodes", c.onNodeEvent, nil)
    
    	c.podsClient = kclient.NewFiltered[*v1.Pod](kubeClient, kclient.Filter{
    		ObjectFilter:    kubeClient.ObjectFilter(),
    		ObjectTransform: kubelib.StripPodUnusedFields,
    	})
    	c.pods = newPodCache(c, c.podsClient, func(key types.NamespacedName) {
    		c.queue.Push(func() error {
    			return c.endpoints.podArrived(key.Name, key.Namespace)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 41.2K bytes
    - Viewed (0)
  4. src/crypto/tls/common.go

    }
    
    var supportedVersions = []uint16{
    	VersionTLS13,
    	VersionTLS12,
    	VersionTLS11,
    	VersionTLS10,
    }
    
    // roleClient and roleServer are meant to call supportedVersions and parents
    // with more readability at the callsite.
    const roleClient = true
    const roleServer = false
    
    var tls10server = godebug.New("tls10server")
    
    func (c *Config) supportedVersions(isClient bool) []uint16 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 03:10:12 UTC 2024
    - 59.1K bytes
    - Viewed (0)
  5. pilot/pkg/serviceregistry/kube/controller/controller_test.go

    			return false
    		}
    	}
    	return true
    }
    
    func addPods(t *testing.T, controller *FakeController, fx *xdsfake.Updater, pods ...*corev1.Pod) {
    	pc := clienttest.Wrap(t, controller.podsClient)
    	for _, pod := range pods {
    		newPod := pc.CreateOrUpdate(pod)
    		setPodReady(newPod)
    		// Apiserver doesn't allow Create/Update to modify the pod status. Creating doesn't result in
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 85K bytes
    - Viewed (0)
Back to top