- Sort Score
- Result 10 results
- Languages All
Results 191 - 200 of 393 for Implementation (0.38 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/plugin/namespace/lifecycle/admission.go
plugins.Register(PluginName, func(config io.Reader) (admission.Interface, error) { return NewLifecycle(sets.NewString(metav1.NamespaceDefault, metav1.NamespaceSystem, metav1.NamespacePublic)) }) } // Lifecycle is an implementation of admission.Interface. // It enforces life-cycle constraints around a Namespace depending on its Phase type Lifecycle struct { *admission.Handler client kubernetes.Interface immortalNamespaces sets.String
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 15 09:52:18 UTC 2021 - 8.6K 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) -
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/discovery/token/token.go
return retrieveValidatedConfigInfo(nil, cfg, constants.DiscoveryRetryInterval, timeout) } // retrieveValidatedConfigInfo is a private implementation of RetrieveValidatedConfigInfo. // It accepts an optional clientset that can be used for testing purposes.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 14 13:07:56 UTC 2024 - 10.1K 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) -
plugin/pkg/admission/gc/gc_admission.go
}, } return &gcPermissionsEnforcement{ Handler: admission.NewHandler(admission.Create, admission.Update), whiteList: whiteList, }, nil }) } // gcPermissionsEnforcement is an implementation of admission.Interface. type gcPermissionsEnforcement struct { *admission.Handler authorizer authorizer.Authorizer restMapper meta.RESTMapper // items in this whitelist are ignored upon admission.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 05 02:24:38 UTC 2023 - 10.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/httplog/httplog.go
// Addf logs info immediately. func (passthroughLogger) Addf(format string, data ...interface{}) { klog.V(2).Info(fmt.Sprintf(format, data...)) } // DefaultStacktracePred is the default implementation of StacktracePred. func DefaultStacktracePred(status int) bool { return (status < http.StatusOK || status >= http.StatusInternalServerError) && status != http.StatusSwitchingProtocols } const withLoggingLevel = 3
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 07 10:10:35 UTC 2023 - 9.7K bytes - Viewed (0) -
pkg/controller/controller_utils.go
// controller1: expects 2 adds in 2 minutes // controller2: expects 2 dels in 2 minutes // controller3: expects -1 adds in 2 minutes => controller3's expectations have already been met // } // // Implementation: // ControlleeExpectation = pair of atomic counters to track controllee's creation/deletion // ControllerExpectationsStore = TTLStore + a ControlleeExpectation per controller //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 12 15:34:44 UTC 2024 - 47.6K bytes - Viewed (0) -
staging/src/k8s.io/api/networking/v1beta1/types_swagger_doc_generated.go
*/ package v1beta1 // This file contains a collection of methods that can be used from go-restful to // generate Swagger API documentation for its models. Please read this PR for more // information on the implementation: https://github.com/emicklei/go-restful/pull/215 // // TODOs are ignored from the parser (e.g. TODO(andronat):... || TODO:...) if and only if // they are on one line! For multiple line or blocks that you want to ignore use ---.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 22 00:51:25 UTC 2023 - 14.3K bytes - Viewed (0)