Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 26 for admitPV (0.14 sec)

  1. plugin/pkg/admission/serviceaccount/admission_test.go

    	err := admissiontesting.WithReinvocationTesting(t, admit).Admit(context.TODO(), attrs, nil)
    	if err == nil {
    		t.Errorf("Expected error for missing service account, got none")
    	}
    }
    
    func TestAutomountsAPIToken(t *testing.T) {
    
    	admit := NewServiceAccount()
    	informerFactory := informers.NewSharedInformerFactory(nil, controller.NoResyncPeriodFunc())
    	admit.SetExternalKubeInformerFactory(informerFactory)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 12 17:49:30 UTC 2024
    - 36.9K bytes
    - Viewed (0)
  2. 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)
  3. pkg/kubelet/eviction/eviction_manager_test.go

    			t.Errorf("Admit pod: %v, expected: %v, actual: %v", pod, expected[i], result.Admit)
    		}
    	}
    
    	manager.nodeConditions = []v1.NodeConditionType{v1.NodeMemoryPressure, v1.NodeDiskPressure}
    	expected = []bool{false, false, false}
    	for i, pod := range pods {
    		if result := manager.Admit(&lifecycle.PodAdmitAttributes{Pod: pod}); expected[i] != result.Admit {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 15 23:14:12 UTC 2024
    - 119.9K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/accessors.go

    	// GetValidatingWebhook if the accessor contains a ValidatingWebhook, returns it and true, else returns false.
    	GetValidatingWebhook() (*v1.ValidatingWebhook, bool)
    
    	// GetType returns the type of the accessor (validate or admit)
    	GetType() string
    }
    
    // NewMutatingWebhookAccessor creates an accessor for a MutatingWebhook.
    func NewMutatingWebhookAccessor(uid, configurationName string, h *v1.MutatingWebhook) WebhookAccessor {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 22:07:40 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. 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)
Back to top