Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 46 for admitPV (0.17 sec)

  1. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/update.go

    			scope.err(err, w, req)
    			return
    		}
    		span.AddEvent("Conversion done")
    
    		audit.LogRequestObject(req.Context(), obj, objGV, scope.Resource, scope.Subresource, scope.Serializer)
    		admit = admission.WithAudit(admit)
    
    		// if this object supports namespace info
    		if objectMeta, err := meta.Accessor(obj); err == nil {
    			// ensure namespace on the object is correct, or error if a conflicting namespace was set in the object
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 01 20:19:46 UTC 2023
    - 11.5K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/delete.go

    		// timeout inside the parent context is lower than requestTimeoutUpperBound.
    		ctx, cancel := context.WithTimeout(ctx, requestTimeoutUpperBound)
    		defer cancel()
    
    		ctx = request.WithNamespace(ctx, namespace)
    		admit = admission.WithAudit(admit)
    
    		outputMediaType, _, err := negotiation.NegotiateOutputMediaType(req, scope.Serializer, scope)
    		if err != nil {
    			scope.err(err, w, req)
    			return
    		}
    
    		options := &metav1.DeleteOptions{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 01 10:00:32 UTC 2023
    - 11.4K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/mutating/plugin_test.go

    			}
    
    			b.ResetTimer()
    			b.RunParallel(func(pb *testing.PB) {
    				for pb.Next() {
    					wh.Admit(context.TODO(), attr, objectInterfaces)
    				}
    			})
    		})
    	}
    }
    
    // TestAdmit tests that MutatingWebhook#Admit works as expected
    func TestAdmit(t *testing.T) {
    	testServer := webhooktesting.NewTestServer(t)
    	testServer.StartTLS()
    	defer testServer.Close()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:52 UTC 2024
    - 11K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/create.go

    			obj = scope.FieldManager.UpdateNoErrors(liveObj, obj, managerOrUserAgent(options.FieldManager, req.UserAgent()))
    			admit = fieldmanager.NewManagedFieldsValidatingAdmissionController(admit)
    
    			if mutatingAdmission, ok := admit.(admission.MutationInterface); ok && mutatingAdmission.Handles(admission.Create) {
    				if err := mutatingAdmission.Admit(ctx, admissionAttributes, scope); err != nil {
    					return nil, err
    				}
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 01 20:19:46 UTC 2023
    - 10.1K bytes
    - Viewed (0)
  5. istioctl/pkg/checkinject/checkinject_test.go

    		"testdata/check-inject/rev-16-injector.yaml",
    		"testdata/check-inject/never-match-injector.yaml",
    	}
    	var whs []admitv1.MutatingWebhookConfiguration
    	for _, whName := range whFiles {
    		file, err := os.ReadFile(whName)
    		if err != nil {
    			t.Fatal(err)
    		}
    		var wh *admitv1.MutatingWebhookConfiguration
    		if err := yaml.Unmarshal(file, &wh); err != nil {
    			t.Fatal(err)
    		}
    		whs = append(whs, *wh)
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 15 15:02:17 UTC 2023
    - 10.6K bytes
    - Viewed (0)
  6. pkg/kubelet/eviction/eviction_manager.go

    	}
    	return manager, manager
    }
    
    // Admit rejects a pod if its not safe to admit for node stability.
    func (m *managerImpl) Admit(attrs *lifecycle.PodAdmitAttributes) lifecycle.PodAdmitResult {
    	m.RLock()
    	defer m.RUnlock()
    	if len(m.nodeConditions) == 0 {
    		return lifecycle.PodAdmitResult{Admit: true}
    	}
    	// Admit Critical pods even under resource pressure since they are required for system stability.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 27 18:55:56 UTC 2024
    - 24.6K bytes
    - Viewed (0)
  7. plugin/pkg/admission/limitranger/admission.go

    		return fmt.Errorf("missing client")
    	}
    	return nil
    }
    
    // Admit admits resources into cluster that do not violate any defined LimitRange in the namespace
    func (l *LimitRanger) Admit(ctx context.Context, a admission.Attributes, o admission.ObjectInterfaces) (err error) {
    	return l.runLimitFunc(a, l.actions.MutateLimit)
    }
    
    // Validate admits resources into cluster that do not violate any defined LimitRange in the namespace
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 24 13:04:39 UTC 2023
    - 25.8K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/mutating/dispatcher.go

    				admissionmetrics.Metrics.ObserveWebhook(ctx, hook.Name, time.Since(t), rejected, versionedAttr.Attributes, "admit", int(err.Status.ErrStatus.Code))
    			default:
    				rejected = true
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/rest.go

    		ctx = request.WithNamespace(ctx, namespace)
    		admit = admission.WithAudit(admit)
    
    		opts, subpath, subpathKey := connecter.NewConnectOptions()
    		if err := getRequestOptions(req, scope, opts, subpath, subpathKey, isSubresource); err != nil {
    			err = errors.NewBadRequest(err.Error())
    			scope.err(err, w, req)
    			return
    		}
    		if admit != nil && admit.Handles(admission.Connect) {
    			userInfo, _ := request.UserFrom(ctx)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 17K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/patch.go

    			scope.Resource,
    			scope.Subresource,
    			admission.Update,
    			patchToUpdateOptions(options),
    			dryrun.IsDryRun(options.DryRun),
    			userInfo,
    		)
    
    		admit = fieldmanager.NewManagedFieldsValidatingAdmissionController(admit)
    
    		mutatingAdmission, _ := admit.(admission.MutationInterface)
    		createAuthorizerAttributes := authorizer.AttributesRecord{
    			User:            userInfo,
    			ResourceRequest: true,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 28.5K bytes
    - Viewed (0)
Back to top