- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for nodeclient (0.2 sec)
-
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) -
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) -
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) -
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) -
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)