Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for NewDynamic (0.1 sec)

  1. staging/src/k8s.io/apiserver/pkg/authentication/request/headerrequest/requestheader.go

    	}
    	trimmedExtraHeaderPrefixes, err := trimHeaders(extraHeaderPrefixes...)
    	if err != nil {
    		return nil, err
    	}
    
    	return NewDynamic(
    		StaticStringSlice(trimmedNameHeaders),
    		StaticStringSlice(trimmedGroupHeaders),
    		StaticStringSlice(trimmedExtraHeaderPrefixes),
    	), nil
    }
    
    func NewDynamic(nameHeaders, groupHeaders, extraHeaderPrefixes StringSliceProvider) authenticator.Request {
    	return &requestHeaderAuthRequestHandler{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 18:19:54 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/authentication/request/x509/x509.go

    func New(opts x509.VerifyOptions, user UserConversion) *Authenticator {
    	return NewDynamic(StaticVerifierFn(opts), user)
    }
    
    // NewDynamic returns a request.Authenticator that verifies client certificates using the provided
    // VerifyOptionFunc (which may be dynamic), and converts valid certificate chains into user.Info using the provided UserConversion
    func NewDynamic(verifyOptionsFn VerifyOptionFunc, user UserConversion) *Authenticator {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 18 01:31:22 UTC 2023
    - 10.3K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/authentication/authenticatorfactory/delegating.go

    		)
    		authenticators = append(authenticators, requestHeaderAuthenticator)
    	}
    
    	// x509 client cert auth
    	if c.ClientCertificateCAContentProvider != nil {
    		authenticators = append(authenticators, x509.NewDynamic(c.ClientCertificateCAContentProvider.VerifyOptions, x509.CommonNameUserConversion))
    	}
    
    	if c.TokenAccessReviewClient != nil {
    		if c.WebhookRetryBackoff == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 29 07:49:14 UTC 2021
    - 5.1K bytes
    - Viewed (0)
  4. pkg/kube/kclient/client.go

    	inf := kubeclient.GetInformerFilteredFromGVR(c, ToOpts(c, gvr, filter), gvr)
    	return newInformerClient[controllers.Object](gvr, inf, filter)
    }
    
    // NewDynamic returns a dynamic client for a given GVR. This is read-only.
    func NewDynamic(c kube.Client, gvr schema.GroupVersionResource, filter Filter) Untyped {
    	opts := ToOpts(c, gvr, filter)
    	opts.InformerType = kubetypes.DynamicInformer
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 17 07:14:28 UTC 2024
    - 13K bytes
    - Viewed (0)
  5. pkg/kube/krt/informer.go

    			}, false)
    		},
    	}
    }
    
    // WrapClient is the base entrypoint that enables the creation
    // of a collection from an API Server client.
    //
    // Generic types can use kclient.NewDynamic to create an
    // informer for a Collection of type controllers.Object
    func WrapClient[I controllers.ComparableObject](c kclient.Informer[I], opts ...CollectionOption) Collection[I] {
    	o := buildCollectionOptions(opts...)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 10 11:01:46 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  6. pkg/kubeapiserver/authenticator/config.go

    		authenticators = append(authenticators, authenticator.WrapAudienceAgnosticRequest(config.APIAudiences, requestHeaderAuthenticator))
    	}
    
    	// X509 methods
    	if config.ClientCAContentProvider != nil {
    		certAuth := x509.NewDynamic(config.ClientCAContentProvider.VerifyOptions, x509.CommonNameUserConversion)
    		authenticators = append(authenticators, certAuth)
    	}
    
    	// Bearer token methods, local first, then remote
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 09 19:29:33 UTC 2024
    - 15.4K bytes
    - Viewed (0)
Back to top