Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for AuthenticateToken (0.37 sec)

  1. staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/oidc/metrics.go

    	delegate      AuthenticatorTokenWithHealthCheck
    	clock         clock.PassiveClock
    }
    
    func (a *instrumentedAuthenticator) AuthenticateToken(ctx context.Context, token string) (*authenticator.Response, bool, error) {
    	start := a.clock.Now()
    	response, ok, err := a.delegate.AuthenticateToken(ctx, token)
    	// this only happens when issuer doesn't match the authenticator
    	// we don't want to record metrics for this case
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 09 19:29:33 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/authentication/token/cache/cached_token_authenticator.go

    		hashPool: &sync.Pool{
    			New: func() interface{} {
    				return hmac.New(sha256.New, randomCacheKey)
    			},
    		},
    	}
    }
    
    // AuthenticateToken implements authenticator.Token
    func (a *cachedTokenAuthenticator) AuthenticateToken(ctx context.Context, token string) (*authenticator.Response, bool, error) {
    	record := a.doAuthenticateToken(ctx, token)
    	if !record.ok || record.err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 03 16:16:51 UTC 2023
    - 9.8K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/oidc/metrics_test.go

    		t.Run(tt.name, func(t *testing.T) {
    			jwtAuthenticatorLatencyMetric.Reset()
    			RegisterMetrics()
    
    			a := newInstrumentedAuthenticatorWithClock(testIssuer, tt.authenticator, dummyClock{})
    			_, _, _ = a.AuthenticateToken(context.Background(), "token")
    
    			if err := testutil.GatherAndCompare(legacyregistry.DefaultGatherer, strings.NewReader(tt.expectedValue), "apiserver_authentication_jwt_authenticator_latency_seconds"); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 09 19:29:33 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  4. plugin/pkg/auth/authenticator/token/bootstrap/bootstrap.go

    func tokenErrorf(s *corev1.Secret, format string, i ...interface{}) {
    	format = fmt.Sprintf("Bootstrap secret %s/%s matching bearer token ", s.Namespace, s.Name) + format
    	klog.V(3).Infof(format, i...)
    }
    
    // AuthenticateToken tries to match the provided token to a bootstrap token secret
    // in a given namespace. If found, it authenticates the token in the
    // "system:bootstrappers" group and with the "system:bootstrap:(token-id)" username.
    //
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 30 20:38:15 UTC 2023
    - 5.1K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/authentication/request/websocket/protocol.go

    	if len(token) > 0 && len(filteredProtocols) == 0 {
    		return nil, false, errors.New("missing additional subprotocol")
    	}
    
    	if len(token) == 0 {
    		return nil, false, nil
    	}
    
    	resp, ok, err := a.auth.AuthenticateToken(req.Context(), token)
    
    	// on success, remove the protocol with the token
    	if ok {
    		// https://tools.ietf.org/html/rfc6455#section-11.3.4 indicates the Sec-WebSocket-Protocol header may appear multiple times
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 07 18:21:43 UTC 2023
    - 3.4K bytes
    - Viewed (0)
Back to top