Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for NewGenericWebhook (0.35 sec)

  1. staging/src/k8s.io/apiserver/pkg/util/webhook/webhook.go

    	if _, shouldRetry := apierrors.SuggestsClientDelay(err); shouldRetry {
    		return true
    	}
    	return false
    }
    
    // NewGenericWebhook creates a new GenericWebhook from the provided rest.Config.
    func NewGenericWebhook(scheme *runtime.Scheme, codecFactory serializer.CodecFactory, config *rest.Config, groupVersions []schema.GroupVersion, retryBackoff wait.Backoff) (*GenericWebhook, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 20 19:02:55 UTC 2023
    - 6.3K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/util/webhook/webhook_test.go

    					return err
    				}
    
    				defer os.Remove(kubeConfigFile)
    
    				config, err := LoadKubeconfig(kubeConfigFile, nil)
    				if err != nil {
    					return err
    				}
    
    				_, err = NewGenericWebhook(runtime.NewScheme(), scheme.Codecs, config, groupVersions, retryBackoff)
    				return err
    			}()
    
    			if err == nil {
    				if tt.errRegex != "" {
    					t.Errorf("%s: expected an error", tt.test)
    				}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 29 15:48:39 UTC 2023
    - 25.8K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/webhook/webhook.go

    		groupVersions := []schema.GroupVersion{authenticationv1.SchemeGroupVersion}
    		if err := localScheme.SetVersionPriority(groupVersions...); err != nil {
    			return nil, err
    		}
    		gw, err := webhook.NewGenericWebhook(localScheme, scheme.Codecs, config, groupVersions, retryBackoff)
    		if err != nil {
    			return nil, err
    		}
    		return &tokenReviewV1ClientGW{gw.RestClient}, nil
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 18 00:47:42 UTC 2022
    - 11.5K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/plugin/pkg/audit/webhook/webhook.go

    	clientConfig, err := webhook.LoadKubeconfig(configFile, customDial)
    	if err != nil {
    		return nil, err
    	}
    	w, err := webhook.NewGenericWebhook(audit.Scheme, audit.Codecs, clientConfig,
    		[]schema.GroupVersion{groupVersion}, retryBackoff)
    	if err != nil {
    		return nil, err
    	}
    
    	w.ShouldRetry = retryOnError
    	return w, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Nov 07 21:13:31 UTC 2022
    - 4.5K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/plugin/pkg/authorizer/webhook/webhook.go

    		groupVersions := []schema.GroupVersion{authorizationv1.SchemeGroupVersion}
    		if err := localScheme.SetVersionPriority(groupVersions...); err != nil {
    			return nil, err
    		}
    		gw, err := webhook.NewGenericWebhook(localScheme, scheme.Codecs, config, groupVersions, retryBackoff)
    		if err != nil {
    			return nil, err
    		}
    		return &subjectAccessReviewV1ClientGW{gw.RestClient}, nil
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 04 19:01:15 UTC 2024
    - 18.4K bytes
    - Viewed (0)
  6. plugin/pkg/admission/imagepolicy/admission.go

    	if err != nil {
    		return nil, err
    	}
    	retryBackoff := webhook.DefaultRetryBackoffWithInitialDelay(whConfig.RetryBackoff)
    	gw, err := webhook.NewGenericWebhook(legacyscheme.Scheme, legacyscheme.Codecs, clientConfig, groupVersions, retryBackoff)
    	if err != nil {
    		return nil, err
    	}
    	return &Plugin{
    		Handler:       admission.NewHandler(admission.Create, admission.Update),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 02 06:05:06 UTC 2023
    - 9.8K bytes
    - Viewed (0)
Back to top