- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for nodev1client (0.29 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) -
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/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)