Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 88 for admitPV (0.13 sec)

  1. staging/src/k8s.io/apiserver/pkg/admission/testing/helpers.go

    	admission admission.MutationInterface
    }
    
    // Admit reinvokes the admission handler and reports a test error if the admission handler performs
    // non-idempotent mutatations to the admission object.
    func (r *reinvoker) Admit(ctx context.Context, a admission.Attributes, o admission.ObjectInterfaces) error {
    	r.t.Helper()
    	outputs := []runtime.Object{}
    	for i := 0; i < 2; i++ {
    		err := r.admission.Admit(ctx, a, o)
    		if err != nil {
    			return err
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 12 15:48:03 UTC 2023
    - 2.7K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/fieldmanager/admission_test.go

    	}
    }
    
    type mockAdmissionController struct {
    	admit func(ctx context.Context, a admission.Attributes, o admission.ObjectInterfaces) error
    }
    
    func (c *mockAdmissionController) Handles(operation admission.Operation) bool {
    	return true
    }
    
    func (c *mockAdmissionController) Admit(ctx context.Context, a admission.Attributes, o admission.ObjectInterfaces) error {
    	return c.admit(ctx, a, o)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jan 12 21:32:54 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  3. plugin/pkg/admission/admit/admission_test.go

    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    See the License for the specific language governing permissions and
    limitations under the License.
    */
    
    package admit
    
    import (
    	"context"
    	"testing"
    
    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	"k8s.io/apiserver/pkg/admission"
    	admissiontesting "k8s.io/apiserver/pkg/admission/testing"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 20 15:11:00 UTC 2019
    - 1.8K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/topologymanager/fake_topology_manager_test.go

    		podAttr := lifecycle.PodAdmitAttributes{}
    		pod := v1.Pod{}
    		pod.Status.QOSClass = tc.qosClass
    		podAttr.Pod = &pod
    		actual := fm.Admit(&podAttr)
    		if reflect.DeepEqual(actual, tc.result) {
    			t.Errorf("Error occurred, expected Admit in result to be %v got %v", tc.result, actual.Admit)
    		}
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 10 11:44:15 UTC 2021
    - 2.8K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/admission/chain.go

    func NewChainHandler(handlers ...Interface) chainAdmissionHandler {
    	return chainAdmissionHandler(handlers)
    }
    
    // Admit performs an admission control check using a chain of handlers, and returns immediately on first error
    func (admissionHandler chainAdmissionHandler) Admit(ctx context.Context, a Attributes, o ObjectInterfaces) error {
    	for _, handler := range admissionHandler {
    		if !handler.Handles(a.GetOperation()) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 20 15:11:00 UTC 2019
    - 2.2K bytes
    - Viewed (0)
  6. pkg/kubelet/cm/topologymanager/policy_best_effort.go

    	filteredHints := filterProvidersHints(providersHints)
    	merger := NewHintMerger(p.numaInfo, filteredHints, p.Name(), p.opts)
    	bestHint := merger.Merge()
    	admit := p.canAdmitPodResult(&bestHint)
    	return bestHint, admit
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 09 16:52:08 UTC 2022
    - 1.5K bytes
    - Viewed (0)
  7. pkg/webhooks/validation/server/server_test.go

    	extraKeyConfig := makePilotConfig(t, 0, true, true)
    
    	wh := createTestWebhook(t)
    
    	cases := []struct {
    		name    string
    		admit   admitFunc
    		in      *kube.AdmissionRequest
    		allowed bool
    	}{
    		{
    			name:  "valid create",
    			admit: wh.validate,
    			in: &kube.AdmissionRequest{
    				Kind:      metav1.GroupVersionKind{Kind: collections.Mock.Kind()},
    				Object:    runtime.RawExtension{Raw: valid},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Mar 01 01:34:15 UTC 2023
    - 9.6K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/admission/audit.go

    // of attribute into the audit event. Attributes passed to the Admit and
    // Validate function must be instance of privateAnnotationsGetter or
    // AnnotationsGetter, otherwise an error is returned.
    func WithAudit(i Interface) Interface {
    	if i == nil {
    		return i
    	}
    	return &auditHandler{Interface: i}
    }
    
    func (handler *auditHandler) Admit(ctx context.Context, a Attributes, o ObjectInterfaces) error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 29 00:03:53 UTC 2022
    - 2.8K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/admission/initializer/initializer_test.go

    	sf informers.SharedInformerFactory
    }
    
    func (self *WantExternalKubeInformerFactory) SetExternalKubeInformerFactory(sf informers.SharedInformerFactory) {
    	self.sf = sf
    }
    func (self *WantExternalKubeInformerFactory) Admit(ctx context.Context, a admission.Attributes, o admission.ObjectInterfaces) error {
    	return nil
    }
    func (self *WantExternalKubeInformerFactory) Handles(o admission.Operation) bool { return false }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  10. pkg/kubelet/cm/admission/errors.go

    	if err == nil {
    		return lifecycle.PodAdmitResult{Admit: true}
    	}
    
    	var admissionErr Error
    	if !errors.As(err, &admissionErr) {
    		admissionErr = &unexpectedAdmissionError{err}
    	}
    
    	return lifecycle.PodAdmitResult{
    		Message: admissionErr.Error(),
    		Reason:  admissionErr.Type(),
    		Admit:   false,
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jul 08 21:15:37 UTC 2021
    - 1.4K bytes
    - Viewed (0)
Back to top