Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for AudiencesFrom (0.3 sec)

  1. staging/src/k8s.io/apiserver/pkg/server/deprecated_insecure_serving.go

    type InsecureSuperuser struct{}
    
    func (InsecureSuperuser) AuthenticateRequest(req *http.Request) (*authenticator.Response, bool, error) {
    	auds, _ := authenticator.AudiencesFrom(req.Context())
    	return &authenticator.Response{
    		User: &user.DefaultInfo{
    			Name:   "system:unsecured",
    			Groups: []string{user.SystemPrivilegedGroup, user.AllAuthenticated},
    		},
    		Audiences: auds,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 27 15:58:45 UTC 2021
    - 3.2K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/authentication/token/cache/cached_token_authenticator_test.go

    	resultUsers := make(map[string]user.Info)
    	fakeAuth := authenticator.TokenFunc(func(ctx context.Context, token string) (*authenticator.Response, bool, error) {
    		auds, _ := authenticator.AudiencesFrom(ctx)
    		return &authenticator.Response{User: resultUsers[auds[0]+token]}, true, nil
    	})
    	fakeClock := testingclock.NewFakeClock(time.Now())
    
    	a := newWithClock(fakeAuth, true, time.Minute, 0, fakeClock)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 03 16:16:51 UTC 2023
    - 20.3K bytes
    - Viewed (0)
  3. pkg/serviceaccount/jwt.go

    		audit.AddAuditAnnotation(ctx, "authentication.k8s.io/legacy-token", public.Subject)
    		legacyTokensTotal.WithContext(ctx).Inc()
    		tokenAudiences = j.implicitAuds
    	}
    
    	requestedAudiences, ok := authenticator.AudiencesFrom(ctx)
    	if !ok {
    		// default to apiserver audiences
    		requestedAudiences = j.implicitAuds
    	}
    
    	auds := authenticator.Audiences(tokenAudiences).Intersect(requestedAudiences)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Feb 27 22:16:08 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/authentication/token/cache/cached_token_authenticator.go

    }
    
    func (a *cachedTokenAuthenticator) doAuthenticateToken(ctx context.Context, token string) *cacheRecord {
    	doneAuthenticating := stats.authenticating(ctx)
    
    	auds, audsOk := authenticator.AudiencesFrom(ctx)
    
    	key := keyFunc(a.hashPool, auds, token)
    	if record, ok := a.cache.get(key); ok {
    		// Record cache hit
    		doneAuthenticating(true)
    		return record
    	}
    
    	// Record cache miss
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 03 16:16:51 UTC 2023
    - 9.8K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/webhook/webhook.go

    	//     the ctx audiences intersect with the implicit audiences, and set the
    	//     intersection in the response.
    	//   * otherwise return unauthenticated.
    	wantAuds, checkAuds := authenticator.AudiencesFrom(ctx)
    	r := &authenticationv1.TokenReview{
    		Spec: authenticationv1.TokenReviewSpec{
    			Token:     token,
    			Audiences: wantAuds,
    		},
    	}
    	var (
    		result *authenticationv1.TokenReview
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 18 00:47:42 UTC 2022
    - 11.5K bytes
    - Viewed (0)
Back to top