Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for GetServiceAccount (0.19 sec)

  1. plugin/pkg/admission/serviceaccount/admission.go

    		enforceMountableSecretCheck, _ := strconv.ParseBool(value)
    		return enforceMountableSecretCheck
    	}
    
    	return false
    }
    
    // getServiceAccount returns the ServiceAccount for the given namespace and name if it exists
    func (s *Plugin) getServiceAccount(namespace string, name string) (*corev1.ServiceAccount, error) {
    	serviceAccount, err := s.serviceAccountLister.ServiceAccounts(namespace).Get(name)
    	if err == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 12 17:49:30 UTC 2024
    - 18.6K bytes
    - Viewed (0)
  2. pkg/controller/serviceaccount/tokens_controller.go

    	}()
    
    	saInfo, err := parseServiceAccountKey(key)
    	if err != nil {
    		logger.Error(err, "Parsing service account key")
    		return
    	}
    
    	sa, err := e.getServiceAccount(saInfo.namespace, saInfo.name, saInfo.uid, false)
    	switch {
    	case err != nil:
    		logger.Error(err, "Getting service account")
    		retry = true
    	case sa == nil:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 20.5K bytes
    - Viewed (0)
  3. pkg/controller/serviceaccount/tokengetter.go

    	return clientGetter{c, secretLister, serviceAccountLister, podLister, nodeLister}
    }
    
    func (c clientGetter) GetServiceAccount(namespace, name string) (*v1.ServiceAccount, error) {
    	if serviceAccount, err := c.serviceAccountLister.ServiceAccounts(namespace).Get(name); err == nil {
    		return serviceAccount, nil
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 21:15:10 UTC 2023
    - 3K bytes
    - Viewed (0)
  4. pkg/controller/serviceaccount/legacy_serviceaccount_token_cleaner.go

    				logger.Error(err, "Parsing lastUsed time", "secret", klog.KRef(secret.Namespace, secret.Name))
    				continue
    			}
    			if lastUsed >= preserveUsedOnOrAfter {
    				continue
    			}
    		}
    
    		sa, saErr := tc.getServiceAccount(secret)
    
    		if saErr != nil {
    			logger.Error(saErr, "Getting service account", "secret", klog.KRef(secret.Namespace, secret.Name))
    			continue
    		}
    		if sa == nil || !hasSecretReference(sa, secret.Name) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 27 03:52:06 UTC 2023
    - 10K bytes
    - Viewed (0)
  5. cmd/ftp-server-driver.go

    	stopFn := globalFtpMetrics.log(c, username)
    	defer stopFn(0, err)
    
    	if globalIAMSys.LDAPConfig.Enabled() {
    		sa, _, err := globalIAMSys.getServiceAccount(context.Background(), username)
    		if err != nil && !errors.Is(err, errNoSuchServiceAccount) {
    			return false, err
    		}
    		if errors.Is(err, errNoSuchServiceAccount) {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 03 15:45:54 UTC 2024
    - 14K bytes
    - Viewed (0)
  6. pkg/serviceaccount/legacy.go

    			return nil, errors.New("Token does not match server's copy")
    		}
    
    		// Make sure service account still exists (name and UID)
    		serviceAccount, err := v.getter.GetServiceAccount(namespace, serviceAccountName)
    		if err != nil {
    			klog.V(4).Infof("Could not retrieve service account %s/%s: %v", namespace, serviceAccountName, err)
    			return nil, err
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 08:32:23 UTC 2023
    - 8.4K bytes
    - Viewed (0)
  7. pkg/serviceaccount/jwt.go

    	apiserverserviceaccount "k8s.io/apiserver/pkg/authentication/serviceaccount"
    )
    
    // ServiceAccountTokenGetter defines functions to retrieve a named service account and secret
    type ServiceAccountTokenGetter interface {
    	GetServiceAccount(namespace, name string) (*v1.ServiceAccount, error)
    	GetPod(namespace, name string) (*v1.Pod, error)
    	GetSecret(namespace, name string) (*v1.Secret, error)
    	GetNode(name string) (*v1.Node, error)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Feb 27 22:16:08 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  8. cmd/admin-handlers-users.go

    	}
    
    	accessKey := mux.Vars(r)["accessKey"]
    	if accessKey == "" {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInvalidRequest), r.URL)
    		return
    	}
    
    	svcAccount, _, err := globalIAMSys.GetServiceAccount(ctx, accessKey)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	password := cred.SecretKey
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue May 28 17:19:04 UTC 2024
    - 78.6K bytes
    - Viewed (0)
  9. cmd/iam.go

    	case <-ctx.Done():
    		return nil, ctx.Err()
    	}
    }
    
    // GetServiceAccount - wrapper method to get information about a service account
    func (sys *IAMSys) GetServiceAccount(ctx context.Context, accessKey string) (auth.Credentials, *policy.Policy, error) {
    	sa, embeddedPolicy, err := sys.getServiceAccount(ctx, accessKey)
    	if err != nil {
    		return auth.Credentials{}, nil, err
    	}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 22:26:38 UTC 2024
    - 71.9K bytes
    - Viewed (0)
  10. pkg/serviceaccount/claims.go

    	podref := private.Kubernetes.Pod
    	noderef := private.Kubernetes.Node
    	secref := private.Kubernetes.Secret
    	// Make sure service account still exists (name and UID)
    	serviceAccount, err := v.getter.GetServiceAccount(namespace, saref.Name)
    	if err != nil {
    		klog.V(4).Infof("Could not retrieve service account %s/%s: %v", namespace, saref.Name, err)
    		return nil, err
    	}
    
    	if string(serviceAccount.UID) != saref.UID {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 21:15:10 UTC 2023
    - 11.3K bytes
    - Viewed (0)
Back to top