Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 151 for admitPV (0.19 sec)

  1. plugin/pkg/admission/namespace/autoprovision/admission.go

    var _ = genericadmissioninitializer.WantsExternalKubeInformerFactory(&Provision{})
    var _ = genericadmissioninitializer.WantsExternalKubeClientSet(&Provision{})
    
    // Admit makes an admission decision based on the request attributes
    func (p *Provision) Admit(ctx context.Context, a admission.Attributes, o admission.ObjectInterfaces) error {
    	// Don't create a namespace if the request is for a dry-run.
    	if a.IsDryRun() {
    		return nil
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Feb 08 17:30:21 UTC 2020
    - 4.1K bytes
    - Viewed (0)
  2. plugin/pkg/admission/network/defaultingressclass/admission.go

    func (a *classDefaulterPlugin) ValidateInitialization() error {
    	if a.lister == nil {
    		return fmt.Errorf("missing lister")
    	}
    	return nil
    }
    
    // Admit sets the default value of a Ingress's class if the user did not specify
    // a class.
    func (a *classDefaulterPlugin) Admit(ctx context.Context, attr admission.Attributes, o admission.ObjectInterfaces) error {
    	if attr.GetResource().GroupResource() != networkingv1.Resource("ingresses") {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 11 01:48:45 UTC 2022
    - 4.9K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/topologymanager/scope_none.go

    			name:             noneTopologyScope,
    			podTopologyHints: podTopologyHints{},
    			policy:           NewNonePolicy(),
    			podMap:           containermap.NewContainerMap(),
    		},
    	}
    }
    
    func (s *noneScope) Admit(pod *v1.Pod) lifecycle.PodAdmitResult {
    	return s.admitPolicyNone(pod)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 14 14:44:24 UTC 2023
    - 1.2K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/topologymanager/topology_manager.go

    	return m.scope.RemoveContainer(containerID)
    }
    
    func (m *manager) Admit(attrs *lifecycle.PodAdmitAttributes) lifecycle.PodAdmitResult {
    	klog.InfoS("Topology Admit Handler", "podUID", attrs.Pod.UID, "podNamespace", attrs.Pod.Namespace, "podName", attrs.Pod.Name)
    	metrics.TopologyManagerAdmissionRequestsTotal.Inc()
    
    	startTime := time.Now()
    	podAdmitResult := m.scope.Admit(attrs.Pod)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jul 15 12:43:16 UTC 2023
    - 7.6K bytes
    - Viewed (0)
  5. 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)
  6. plugin/pkg/admission/alwayspullimages/admission_test.go

    				{Name: "ctr3", Image: "image", ImagePullPolicy: api.PullIfNotPresent},
    				{Name: "ctr4", Image: "image", ImagePullPolicy: api.PullAlways},
    			},
    		},
    	}
    	err := handler.Admit(context.TODO(), admission.NewAttributesRecord(&pod, nil, api.Kind("Pod").WithVersion("version"), pod.Namespace, pod.Name, api.Resource("pods").WithVersion("version"), "", admission.Create, &metav1.CreateOptions{}, false, nil), nil)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Nov 30 22:59:57 UTC 2020
    - 8.5K bytes
    - Viewed (0)
  7. src/net/sockopt_linux.go

    	if family == syscall.AF_INET6 && sotype != syscall.SOCK_RAW {
    		// Allow both IP versions even if the OS default
    		// is otherwise. Note that some operating systems
    		// never admit this option.
    		syscall.SetsockoptInt(s, syscall.IPPROTO_IPV6, syscall.IPV6_V6ONLY, boolint(ipv6only))
    	}
    	if (sotype == syscall.SOCK_DGRAM || sotype == syscall.SOCK_RAW) && family != syscall.AF_UNIX {
    		// Allow broadcast.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sat May 09 00:33:27 UTC 2020
    - 1.3K bytes
    - Viewed (0)
  8. src/net/sockopt_solaris.go

    	if family == syscall.AF_INET6 && sotype != syscall.SOCK_RAW {
    		// Allow both IP versions even if the OS default
    		// is otherwise. Note that some operating systems
    		// never admit this option.
    		syscall.SetsockoptInt(s, syscall.IPPROTO_IPV6, syscall.IPV6_V6ONLY, boolint(ipv6only))
    	}
    	if (sotype == syscall.SOCK_DGRAM || sotype == syscall.SOCK_RAW) && family != syscall.AF_UNIX {
    		// Allow broadcast.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sat May 09 00:33:27 UTC 2020
    - 1.3K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/admission/attributes.go

    	}
    	if msgs := validation.IsQualifiedName(key); len(msgs) != 0 {
    		return fmt.Errorf("annotation key has invalid format %s. A qualified name like 'podsecuritypolicy.admission.k8s.io/admit-policy' is required.", strings.Join(msgs, ","))
    	}
    	return nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Aug 07 17:53:14 UTC 2019
    - 6.2K bytes
    - Viewed (0)
  10. src/net/sockopt_windows.go

    	if family == syscall.AF_INET6 && sotype != syscall.SOCK_RAW {
    		// Allow both IP versions even if the OS default
    		// is otherwise. Note that some operating systems
    		// never admit this option.
    		syscall.SetsockoptInt(s, syscall.IPPROTO_IPV6, syscall.IPV6_V6ONLY, boolint(ipv6only))
    	}
    	if (sotype == syscall.SOCK_DGRAM || sotype == syscall.SOCK_RAW) && family != syscall.AF_UNIX && family != syscall.AF_INET6 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sat May 09 00:33:27 UTC 2020
    - 1.5K bytes
    - Viewed (0)
Back to top