Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 80 for Implementation (0.18 sec)

  1. pkg/apis/core/v1/defaults.go

    // SetDefaults_Namespace adds a default label for all namespaces
    func SetDefaults_Namespace(obj *v1.Namespace) {
    	// we can't SetDefaults for nameless namespaces (generateName).
    	// This code needs to be kept in sync with the implementation that exists
    	// in Namespace Canonicalize strategy (pkg/registry/core/namespace)
    
    	// note that this can result in many calls to feature enablement in some cases, but
    	// we assume that there's no real cost there.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 19 22:24:15 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/cel/library/cost.go

    				// Dont have access to underlying regex, estimate a long regexp
    				regexSize := format.MaxRegexSize
    
    				// Copied from CEL implementation for regex cost
    				//
    				// https://swtch.com/~rsc/regexp/regexp1.html applies to RE2 implementation supported by CEL
    				// Add one to string length for purposes of cost calculation to prevent product of string and regex to be 0
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 23 17:22:44 UTC 2024
    - 20.6K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/typechecking.go

    	}
    	return opts
    }
    
    type typeCheckingCompiler struct {
    	compositionEnv *plugincel.CompositionEnv
    	typeOverwrite  typeOverwrite
    }
    
    // CompileCELExpression compiles the given expression.
    // The implementation is the same as that of staging/src/k8s.io/apiserver/pkg/admission/plugin/cel/compile.go
    // except that:
    // - object, oldObject, and params are typed instead of Dyn
    // - compiler does not enforce the output type
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 22:07:40 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/storage/etcd3/store_test.go

    	ctx, store, _ := testSetup(t)
    	storagetesting.RunTestCount(ctx, t, store)
    }
    
    // =======================================================================
    // Implementation-specific tests are following.
    // The following tests are exercising the details of the implementation
    // not the actual user-facing contract of storage interface.
    // As such, they may focus e.g. on non-functional aspects like performance
    // impact.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 12:45:33 UTC 2024
    - 26.5K bytes
    - Viewed (0)
  5. pkg/scheduler/util/assumecache/assume_cache.go

    		return -1, err
    	}
    
    	objResourceVersion, err := strconv.ParseInt(objAccessor.GetResourceVersion(), 10, 64)
    	if err != nil {
    		//nolint:errorlint // Intentionally not wrapping the error, the underlying error is an implementation detail.
    		return -1, fmt.Errorf("error parsing ResourceVersion %q for %v %q: %v", objAccessor.GetResourceVersion(), c.description, name, err)
    	}
    	return objResourceVersion, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 09:46:58 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top