Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 88 for admitPV (0.13 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. src/net/sockopt_aix.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.4K bytes
    - Viewed (0)
  10. 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)
Back to top