- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for AudiencesFrom (0.17 sec)
-
staging/src/k8s.io/apiserver/pkg/authentication/authenticator/audiences.go
func WithAudiences(ctx context.Context, auds Audiences) context.Context { return context.WithValue(ctx, audiencesKey, auds) } // AudiencesFrom returns a request's expected audiences stored in the request context. func AudiencesFrom(ctx context.Context) (Audiences, bool) { auds, ok := ctx.Value(audiencesKey).(Audiences) return auds, ok } // Has checks if Audiences contains a specific audiences.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 31 21:50:11 UTC 2018 - 1.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/request/anonymous/anonymous.go
) func NewAuthenticator() authenticator.Request { return authenticator.RequestFunc(func(req *http.Request) (*authenticator.Response, bool, error) { auds, _ := authenticator.AudiencesFrom(req.Context()) return &authenticator.Response{ User: &user.DefaultInfo{ Name: anonymousUser, Groups: []string{unauthenticatedGroup}, }, Audiences: auds, }, true, nil })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 31 21:50:11 UTC 2018 - 1.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/authenticator/audagnostic.go
import ( "context" "fmt" "net/http" ) func authenticate(ctx context.Context, implicitAuds Audiences, authenticate func() (*Response, bool, error)) (*Response, bool, error) { targetAuds, ok := AudiencesFrom(ctx) // We can remove this once api audiences is never empty. That will probably // be N releases after TokenRequest is GA. if !ok { return authenticate() } auds := implicitAuds.Intersect(targetAuds)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 31 22:31:49 UTC 2018 - 2.8K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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)