Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 60 for Implementation (0.17 sec)

  1. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/schema/validation.go

    		return nil
    	}
    
    	allErrs := field.ErrorList{}
    
    	// We still unconditionally forbid XValidations in quantifiers, the only
    	// quantifier that is allowed to have right now is AllOf. This is due to
    	// implementation constraints - the SchemaValidator would need to become
    	// aware of CEL to properly implement the other quantifiers.
    	optsWithCELDisabled := opts
    	optsWithCELDisabled.AllowNestedXValidations = false
    
    	if !skipAnyOf {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 20 18:21:31 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  2. cmd/kube-proxy/app/server_linux_test.go

    			logger, _ := ktesting.NewTestContext(t)
    			r := getLocalDetectors(logger, c.primaryIPFamily, c.config, c.nodePodCIDRs)
    			if !reflect.DeepEqual(r, c.expected) {
    				t.Errorf("Unexpected detect-local implementation, expected: %q, got: %q", c.expected, r)
    			}
    		})
    	}
    }
    
    func makeNodeWithPodCIDRs(cidrs ...string) *v1.Node {
    	if len(cidrs) == 0 {
    		return &v1.Node{}
    	}
    	return &v1.Node{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  3. cmd/kubeadm/app/cmd/token.go

    }
    
    // tokenTextPrinter prints bootstrap token in a text form
    type tokenTextPrinter struct {
    	output.TextPrinter
    	columns         []string
    	headerIsPrinted bool
    }
    
    // PrintObj is an implementation of ResourcePrinter.PrintObj for plain text output
    func (ttp *tokenTextPrinter) PrintObj(obj runtime.Object, writer io.Writer) error {
    	tabw := tabwriter.NewWriter(writer, 10, 4, 3, ' ', 0)
    
    	// Print header
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 23 05:47:48 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  4. staging/src/k8s.io/api/policy/v1/types.go

    	// UnhealthyPodEvictionPolicy defines the criteria for when unhealthy pods
    	// should be considered for eviction. Current implementation considers healthy pods,
    	// as pods that have status.conditions item with type="Ready",status="True".
    	//
    	// Valid policies are IfHealthyBudget and AlwaysAllow.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 23 17:42:49 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  5. pkg/kubelet/logs/container_log_manager.go

    	compressSuffix = ".gz"
    	// tmpSuffix is the suffix for temporary file.
    	tmpSuffix = ".tmp"
    )
    
    // ContainerLogManager manages lifecycle of all container logs.
    //
    // Implementation is thread-safe.
    type ContainerLogManager interface {
    	// TODO(random-liu): Add RotateLogs function and call it under disk pressure.
    	// Start container log manager.
    	Start()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 15K bytes
    - Viewed (0)
  6. cmd/kubeadm/app/cmd/config.go

    type ImagesList struct {
    	cfg *kubeadmapi.InitConfiguration
    }
    
    // imageTextPrinter prints image info in a text form
    type imageTextPrinter struct {
    	output.TextPrinter
    }
    
    // PrintObj is an implementation of ResourcePrinter.PrintObj for plain text output
    func (itp *imageTextPrinter) PrintObj(obj runtime.Object, writer io.Writer) error {
    	var err error
    	if imgs, ok := obj.(*outputapiv1alpha3.Images); ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 06:58:01 UTC 2024
    - 18.9K bytes
    - Viewed (0)
  7. plugin/pkg/admission/serviceaccount/admission.go

    var _ = genericadmissioninitializer.WantsExternalKubeClientSet(&Plugin{})
    var _ = genericadmissioninitializer.WantsExternalKubeInformerFactory(&Plugin{})
    
    // NewServiceAccount returns an admission.Interface implementation which limits admission of Pod CREATE requests based on the pod's ServiceAccount:
    // 1. If the pod does not specify a ServiceAccount, it sets the pod's ServiceAccount to "default"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 12 17:49:30 UTC 2024
    - 18.6K bytes
    - Viewed (0)
  8. pkg/kubelet/util/manager/watch_based_manager.go

    	return store
    }
    
    func (c *objectCache) newStore() *cacheStore {
    	// TODO: We may consider created a dedicated store keeping just a single
    	// item, instead of using a generic store implementation for this purpose.
    	// However, simple benchmarks show that memory overhead in that case is
    	// decrease from ~600B to ~300B per object. So we are not optimizing it
    	// until we will see a good reason for that.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  9. pkg/proxy/util/nfacct/nfacct_linux_test.go

    */
    
    package nfacct
    
    import (
    	"syscall"
    	"testing"
    
    	"github.com/stretchr/testify/assert"
    	"github.com/vishvananda/netlink/nl"
    	"golang.org/x/sys/unix"
    )
    
    // fakeHandler is a mock implementation of the handler interface, designed for testing.
    type fakeHandler struct {
    	// requests stores instances of fakeRequest, capturing new requests.
    	requests []*fakeRequest
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 06:47:50 UTC 2024
    - 18.8K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/storage/interfaces.go

    	// current version of the object to avoid read operation from storage to get it.
    	// However, the implementations have to retry in case suggestion is stale.
    	//
    	// Example:
    	//
    	// s := /* implementation of Interface */
    	// err := s.GuaranteedUpdate(
    	//     "myKey", &MyType{}, true, preconditions,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 07:53:48 UTC 2024
    - 14.8K bytes
    - Viewed (0)
Back to top