- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 120 for Implementation (0.27 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_interval.go
// copied over. // // The source of events for the interval is typically either // the watchCache circular buffer, if events being retrieved // need to be for resource versions > 0 or the underlying // implementation of Store, if resource version = 0. // // Furthermore, an interval can be either valid or invalid at // any given point of time. The notion of validity makes sense // only in cases where the window of events in the underlying
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 8.2K bytes - Viewed (0) -
cmd/kube-scheduler/app/server.go
resources. The scheduler then ranks each valid Node and binds the Pod to a suitable Node. Multiple different schedulers may be used within a cluster; kube-scheduler is the reference implementation. See [scheduling](https://kubernetes.io/docs/concepts/scheduling-eviction/) for more information about scheduling and the kube-scheduler component.`, RunE: func(cmd *cobra.Command, args []string) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 19:11:24 UTC 2024 - 14.3K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control.go
// as an interface to allow for extensions that provide different semantics. Currently, there is only one implementation. type StatefulSetControlInterface interface { // UpdateStatefulSet implements the control logic for Pod creation, update, and deletion, and // persistent volume creation, update, and deletion. // If an implementation returns a non-nil error, the invocation will be retried using a rate-limited strategy.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 08:03:46 UTC 2024 - 30.9K bytes - Viewed (0) -
cmd/kubeadm/app/util/apiclient/wait.go
WaitForKubelet(healthzAddress string, healthzPort int32) error // SetTimeout adjusts the timeout to the specified duration SetTimeout(timeout time.Duration) } // KubeWaiter is an implementation of Waiter that is backed by a Kubernetes client type KubeWaiter struct { client clientset.Interface timeout time.Duration writer io.Writer }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 13.3K bytes - Viewed (0) -
pkg/kubelet/volume_host.go
"k8s.io/kubernetes/pkg/volume/util/hostutil" "k8s.io/kubernetes/pkg/volume/util/subpath" ) // NewInitializedVolumePluginMgr returns a new instance of // volume.VolumePluginMgr initialized with kubelets implementation of the // volume.VolumeHost interface. // // kubelet - used by VolumeHost methods to expose kubelet specific parameters // plugins - used to initialize volumePluginMgr func NewInitializedVolumePluginMgr(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 10K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go
if err != nil { t.Fatalf("Unexpected error: %v", err) } // Depending on the implementation, different number of events that // should be delivered to the watcher can be created before it will // block the implementation and as a result force the watcher to be // closed (as otherwise events would have to be dropped).
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 63.8K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/upgrade/common.go
// return the fake clientset used for dry-running return fakeclient, nil } return kubeconfigutil.ClientSetFromFile(file) } // getWaiter gets the right waiter implementation func getWaiter(dryRun bool, client clientset.Interface, timeout time.Duration) apiclient.Waiter { if dryRun { return dryrunutil.NewWaiter() } return apiclient.NewKubeWaiter(client, timeout, os.Stdout)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 08:34:39 UTC 2024 - 10.1K bytes - Viewed (0) -
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) -
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) -
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)