Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for admitPV (0.11 sec)

  1. istioctl/pkg/checkinject/checkinject.go

    				return matched, fmt.Sprintf("%s=%s", me.Key, v)
    			}
    		}
    	}
    	return matched, ""
    }
    
    func extractRevision(wh *admitv1.MutatingWebhookConfiguration) string {
    	return wh.GetLabels()[label.IoIstioRev.Name]
    }
    
    func isIstioWebhook(wh *admitv1.MutatingWebhookConfiguration) bool {
    	for _, w := range wh.Webhooks {
    		if strings.HasSuffix(w.Name, "istio.io") {
    			return true
    		}
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Apr 13 05:23:38 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  2. pkg/kubeapiserver/options/plugins.go

    // given binary target.
    import (
    	validatingadmissionpolicy "k8s.io/apiserver/pkg/admission/plugin/policy/validating"
    	// Admission policies
    	"k8s.io/kubernetes/plugin/pkg/admission/admit"
    	"k8s.io/kubernetes/plugin/pkg/admission/alwayspullimages"
    	"k8s.io/kubernetes/plugin/pkg/admission/antiaffinity"
    	certapproval "k8s.io/kubernetes/plugin/pkg/admission/certificates/approval"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 20 17:20:46 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  3. pkg/kubeapiserver/admission/initializer_test.go

    limitations under the License.
    */
    
    package admission
    
    import (
    	"context"
    	"testing"
    
    	"k8s.io/apiserver/pkg/admission"
    )
    
    type doNothingAdmission struct{}
    
    func (doNothingAdmission) Admit(ctx context.Context, a admission.Attributes, o admission.ObjectInterfaces) error {
    	return nil
    }
    func (doNothingAdmission) Handles(o admission.Operation) bool { return false }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:28:42 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  4. pkg/controlplane/apiserver/admission/initializer_test.go

    	"context"
    	"testing"
    
    	"k8s.io/apimachinery/pkg/runtime/schema"
    	"k8s.io/apiserver/pkg/admission"
    	quota "k8s.io/apiserver/pkg/quota/v1"
    )
    
    type doNothingAdmission struct{}
    
    func (doNothingAdmission) Admit(ctx context.Context, a admission.Attributes, o admission.ObjectInterfaces) error {
    	return nil
    }
    func (doNothingAdmission) Handles(o admission.Operation) bool { return false }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:28:42 UTC 2024
    - 2K bytes
    - Viewed (0)
  5. src/runtime/pprof/label.go

    		return labelMap(nil)
    	}
    	return *labels
    }
    
    // labelMap is the representation of the label set held in the context type.
    // This is an initial implementation, but it will be replaced with something
    // that admits incremental immutable modification more efficiently.
    type labelMap map[string]string
    
    // String satisfies Stringer and returns key, value pairs in a consistent
    // order.
    func (l *labelMap) String() string {
    	if l == nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 3K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/generic/webhook.go

    	webhookutil "k8s.io/apiserver/pkg/util/webhook"
    	"k8s.io/client-go/informers"
    	clientset "k8s.io/client-go/kubernetes"
    )
    
    // Webhook is an abstract admission plugin with all the infrastructure to define Admit or Validate on-top.
    type Webhook struct {
    	*admission.Handler
    
    	sourceFactory sourceFactory
    
    	hookSource       Source
    	clientManager    *webhookutil.ClientManager
    	namespaceMatcher *namespace.Matcher
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 22:07:40 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  7. pkg/webhooks/validation/server/server.go

    	return &kube.AdmissionResponse{Result: &metav1.Status{Message: err.Error()}}
    }
    
    type admitFunc func(*kube.AdmissionRequest) *kube.AdmissionResponse
    
    func serve(w http.ResponseWriter, r *http.Request, admit admitFunc) {
    	var body []byte
    	if r.Body != nil {
    		if data, err := kube.HTTPConfigReader(r); err == nil {
    			body = data
    		} else {
    			http.Error(w, err.Error(), http.StatusBadRequest)
    			return
    		}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat May 04 06:13:56 UTC 2024
    - 9.3K bytes
    - Viewed (0)
Back to top