- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for nodeclient (0.18 sec)
-
pkg/kubelet/cm/dra/plugin/client.go
conn, err := p.getOrCreateGRPCConn() if err != nil { return nil, err } ctx, cancel := context.WithTimeout(ctx, p.clientTimeout) defer cancel() nodeClient := drapb.NewNodeClient(conn) response, err := nodeClient.NodePrepareResources(ctx, req) logger.V(4).Info(log("done calling NodePrepareResources rpc"), "response", response, "err", err) return response, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 19 16:27:05 UTC 2024 - 2.9K bytes - Viewed (0) -
pkg/volume/csi/csi_client_test.go
client := &csiDriverClient{ driverName: "Fake Driver Name", nodeV1ClientCreator: func(addr csiAddr, m *MetricsManager) (csipbv1.NodeClient, io.Closer, error) { nodeClient := fake.NewNodeClient(false /* stagingCapable */) nodeClient.SetNextError(tc.err) nodeClient.SetNodeGetInfoResp(&csipbv1.NodeGetInfoResponse{ NodeId: tc.expectedNodeID, MaxVolumesPerNode: tc.expectedMaxVolumePerNode,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 33.9K bytes - Viewed (0) -
pkg/volume/csi/csi_mounter_test.go
} else { t.Errorf("SetUp() failed: %v", err) } } // ensure call went all the way pubs := csiMounter.csiClient.(*fakeCsiDriverClient).nodeClient.GetNodePublishedVolumes() vol, ok := pubs[csiMounter.volumeID] if !ok { t.Error("csi server may not have received NodePublishVolume call") } if vol.Path != csiMounter.GetPath() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 50.1K bytes - Viewed (0) -
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) -
pkg/volume/csi/csi_attacher_test.go
} // Verify call goes through all the way numStaged := 1 if !tc.stageUnstageSet { numStaged = 0 } cdc := csiAttacher.csiClient.(*fakeCsiDriverClient) staged := cdc.nodeClient.GetNodeStagedVolumes() if len(staged) != numStaged { t.Errorf("got wrong number of staged volumes, expecting %v got: %v", numStaged, len(staged)) } if tc.stageUnstageSet {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 58.1K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/rbac/bootstrappolicy/policy.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 19:25:10 UTC 2024 - 34.4K bytes - Viewed (0) -
pilot/pkg/controllers/untaint/nodeuntainter.go
kubelib.WaitForCacheSync("node untainer", stop, n.nodesClient.HasSynced, n.podsClient.HasSynced) n.queue.Run(stop) n.podsClient.ShutdownHandlers() n.nodesClient.ShutdownHandlers() } func (n *NodeUntainter) reconcileNode(key types.NamespacedName) error { log.Debugf("reconciling node %s", key.Name) node := n.nodesClient.Get(key.Name, key.Namespace) if node == nil { return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 00:50:31 UTC 2024 - 6.9K bytes - Viewed (0) -
pilot/pkg/controllers/untaint/nodeuntainter_test.go
go nodeUntainter.Run(stop) client.RunAndWait(stop) kubelib.WaitForCacheSync("test", stop, nodeUntainter.HasSynced) pc := clienttest.Wrap(t, nodeUntainter.podsClient) nc := clienttest.Wrap(t, nodeUntainter.nodesClient) return &nodeTainterTestServer{ client: client, t: t, pc: pc, nc: nc, } } func TestNodeUntainter(t *testing.T) { setupLogging()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 00:50:31 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/controller/disruption/disruption_test.go
} func newFakeDisruptionControllerWithTime(ctx context.Context, now time.Time) (*disruptionController, *pdbStates) { ps := &pdbStates{} coreClient := fake.NewSimpleClientset() informerFactory := informers.NewSharedInformerFactory(coreClient, controller.NoResyncPeriodFunc()) scheme := runtime.NewScheme() scheme.AddKnownTypeWithName(customGVK, &v1.Service{}) fakeScaleClient := &scalefake.FakeScaleClient{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 50K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod_test.go
got := c.pods.getPodsByIP("128.0.0.1") assert.Equal(t, got != nil, true) assert.Equal(t, map[string]string{"app": "test", "foo": "bar"}, got[0].Labels) pod.Labels["foo"] = "not-bar" clienttest.Wrap(t, c.podsClient).CreateOrUpdate(pod) fx.StrictMatchOrFail(t, xdsfake.Event{ Type: "proxy", ID: "128.0.0.1", }, xdsfake.Event{ Type: "xds", ID: "ratings.nsa.svc.company.com", })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 18:27:40 UTC 2024 - 12.3K bytes - Viewed (0)