- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for nodev1client (0.25 sec)
-
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/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) -
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) -
pkg/controlplane/controller/legacytokentracking/controller.go
"k8s.io/apimachinery/pkg/fields" utilruntime "k8s.io/apimachinery/pkg/util/runtime" "k8s.io/apimachinery/pkg/util/wait" corev1informers "k8s.io/client-go/informers/core/v1" "k8s.io/client-go/kubernetes" corev1client "k8s.io/client-go/kubernetes/typed/core/v1" "k8s.io/client-go/tools/cache" "k8s.io/client-go/util/workqueue" "k8s.io/klog/v2" "k8s.io/utils/clock" ) const (
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6K bytes - Viewed (0) -
pkg/controlplane/controller/clusterauthenticationtrust/cluster_authentication_trust_controller.go
type Controller struct { requiredAuthenticationData ClusterAuthenticationInfo configMapLister corev1listers.ConfigMapLister configMapClient corev1client.ConfigMapsGetter namespaceClient corev1client.NamespacesGetter // queue is where incoming work is placed to de-dup and to allow "easy" rate limited requeues on errors.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18.2K bytes - Viewed (0) -
pkg/controlplane/instance.go
serverstorage "k8s.io/apiserver/pkg/server/storage" utilfeature "k8s.io/apiserver/pkg/util/feature" clientdiscovery "k8s.io/client-go/discovery" "k8s.io/client-go/kubernetes" corev1client "k8s.io/client-go/kubernetes/typed/core/v1" discoveryclient "k8s.io/client-go/kubernetes/typed/discovery/v1" "k8s.io/klog/v2" api "k8s.io/kubernetes/pkg/apis/core" flowcontrolv1 "k8s.io/kubernetes/pkg/apis/flowcontrol/v1"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 03 11:50:04 UTC 2024 - 21.2K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_controller.go
"k8s.io/apimachinery/pkg/util/sets" "k8s.io/apimachinery/pkg/util/wait" quota "k8s.io/apiserver/pkg/quota/v1" "k8s.io/client-go/discovery" coreinformers "k8s.io/client-go/informers/core/v1" corev1client "k8s.io/client-go/kubernetes/typed/core/v1" corelisters "k8s.io/client-go/listers/core/v1" "k8s.io/client-go/tools/cache" "k8s.io/client-go/util/workqueue" "k8s.io/controller-manager/pkg/informerfactory"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 21.3K 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) -
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/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)