Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 27 for nodeclient (0.4 sec)

  1. 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)
  2. 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)
  3. plugin/pkg/auth/authorizer/rbac/bootstrappolicy/testdata/cluster-roles.yaml

        name: system:certificates.k8s.io:certificatesigningrequests:nodeclient
      rules:
      - apiGroups:
        - certificates.k8s.io
        resources:
        - certificatesigningrequests/nodeclient
        verbs:
        - create
    - apiVersion: rbac.authorization.k8s.io/v1
      kind: ClusterRole
      metadata:
        annotations:
          rbac.authorization.kubernetes.io/autoupdate: "true"
        creationTimestamp: null
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 18 08:11:08 UTC 2023
    - 24.1K bytes
    - Viewed (0)
  4. plugin/pkg/auth/authorizer/rbac/bootstrappolicy/policy.go

    			Rules: []rbacv1.PolicyRule{
    				rbacv1helpers.NewRule("create").Groups(certificatesGroup).Resources("certificatesigningrequests/nodeclient").RuleOrDie(),
    			},
    		},
    		{
    			// a role making the csrapprover controller approve a node client CSR requested by the node itself
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 19:25:10 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. staging/src/k8s.io/apiserver/pkg/authentication/serviceaccount/util.go

    	if len(uid) > 0 && uid != string(sa.UID) {
    		// If UID is specified, it must match
    		return false
    	}
    
    	return true
    }
    
    func GetOrCreateServiceAccount(coreClient v1core.CoreV1Interface, namespace, name string) (*v1.ServiceAccount, error) {
    	sa, err := coreClient.ServiceAccounts(namespace).Get(context.TODO(), name, metav1.GetOptions{})
    	if err == nil {
    		return sa, nil
    	}
    	if !apierrors.IsNotFound(err) {
    		return nil, err
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 05 10:24:31 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  8. pilot/pkg/leaderelection/k8sleaderelection/k8sresourcelock/interface.go

    // nolint: lll
    func New(lockType string, ns string, name string, coreClient corev1.CoreV1Interface, coordinationClient coordinationv1.CoordinationV1Interface, rlc ResourceLockConfig) (Interface, error) {
    	endpointsLock := &EndpointsLock{
    		EndpointsMeta: metav1.ObjectMeta{
    			Namespace: ns,
    			Name:      name,
    		},
    		Client:     coreClient,
    		LockConfig: rlc,
    	}
    	configmapLock := &ConfigMapLock{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jul 25 19:30:47 UTC 2022
    - 6K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top