- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 22 for nodev1client (0.41 sec)
-
plugin/pkg/admission/runtimeclass/admission.go
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apiserver/pkg/admission" genericadmissioninitailizer "k8s.io/apiserver/pkg/admission/initializer" "k8s.io/client-go/informers" "k8s.io/client-go/kubernetes" nodev1client "k8s.io/client-go/kubernetes/typed/node/v1" nodev1listers "k8s.io/client-go/listers/node/v1" api "k8s.io/kubernetes/pkg/apis/core" node "k8s.io/kubernetes/pkg/apis/node" apinodev1 "k8s.io/kubernetes/pkg/apis/node/v1"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 05 05:53:38 UTC 2024 - 8.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/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/volume/csi/csi_metrics_test.go
driverName: "com.google.gcepd", nodeV1ClientCreator: func(addr csiAddr, m *MetricsManager) (csipbv1.NodeClient, io.Closer, error) { nodeClient := fake.NewNodeClientWithVolumeStats(true /* VolumeStatsCapable */) fakeCloser := fake.NewCloser(t) nodeClient.SetNodeVolumeStatsResp(getRawVolumeInfo()) return nodeClient, fakeCloser, nil }, } metrics, err := metricsGetter.GetMetrics() if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 11 06:07:40 UTC 2023 - 5.8K bytes - Viewed (0) -
istioctl/pkg/util/handlers/handlers.go
for i := range podList.Items { pods = append(pods, podList.Items[i].Name) } return pods, namespace, nil } func getClientForResource(resname, ns string, factory cmdutil.Factory) (*corev1client.CoreV1Client, string, string, string, error) { // Pod is referred to using something like "deployment/httpbin". Use the kubectl // libraries to look up the resource name, find the pods it selects, and return // one of those pods.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Feb 06 15:01:41 UTC 2024 - 6.2K bytes - Viewed (0) -
pkg/volume/csi/csi_block_test.go
pubs := csiUnmapper.csiClient.(*fakeCsiDriverClient).nodeClient.GetNodePublishedVolumes() if _, ok := pubs[csiUnmapper.volumeID]; ok { t.Error("csi server may not have received NodeUnpublishVolume call") } // ensure csi client call and node unstaged vols := csiUnmapper.csiClient.(*fakeCsiDriverClient).nodeClient.GetNodeStagedVolumes() if _, ok := vols[csiUnmapper.volumeID]; ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 11 06:07:40 UTC 2023 - 26.5K 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/registry/core/service/portallocator/controller/repair.go
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/util/net" "k8s.io/apimachinery/pkg/util/runtime" "k8s.io/apimachinery/pkg/util/sets" "k8s.io/apimachinery/pkg/util/wait" corev1client "k8s.io/client-go/kubernetes/typed/core/v1" eventsv1client "k8s.io/client-go/kubernetes/typed/events/v1" "k8s.io/client-go/tools/events" "k8s.io/client-go/util/retry" "k8s.io/kubernetes/pkg/api/legacyscheme"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 10.4K bytes - Viewed (0)