- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 81 for Reconciled (0.13 sec)
-
cmd/kube-controller-manager/app/options/attachdetachcontroller.go
return } fs.BoolVar(&o.DisableAttachDetachReconcilerSync, "disable-attach-detach-reconcile-sync", false, "Disable volume attach detach reconciler sync. Disabling this may cause volumes to be mismatched with pods. Use wisely.")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 22 18:31:52 UTC 2024 - 2.8K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/config/types.go
type AttachDetachControllerConfiguration struct { // Reconciler runs a periodic loop to reconcile the desired state of the with // the actual state of the world by triggering attach detach operations. // This flag enables or disables reconcile. Is false by default, and thus enabled. DisableAttachDetachReconcilerSync bool // ReconcilerSyncLoopPeriod is the amount of time the reconciler sync states loop
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 22 18:31:52 UTC 2024 - 1.4K bytes - Viewed (0) -
pkg/controlplane/reconcilers/reconcilers.go
Destroy() } // Type the reconciler type type Type string const ( // MasterCountReconcilerType will select the original reconciler MasterCountReconcilerType Type = "master-count" // LeaseEndpointReconcilerType will select a storage based reconciler LeaseEndpointReconcilerType Type = "lease" // NoneEndpointReconcilerType will turn off the endpoint reconciler NoneEndpointReconcilerType Type = "none" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 26 13:49:31 UTC 2022 - 2.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller.go
informer Informer[T], reconciler func(namepace, name string, newObj T) error, options ControllerOptions, ) Controller[T] { if options.Workers == 0 { options.Workers = 2 } if len(options.Name) == 0 { options.Name = fmt.Sprintf("%T-controller", *new(T)) } c := &controller[T]{ options: options, informer: informer, reconciler: reconciler, queue: nil, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.5K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconstruct.go
limitations under the License. */ package reconciler import ( "context" v1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/types" "k8s.io/klog/v2" "k8s.io/kubernetes/pkg/volume/util/operationexecutor" ) // readyToUnmount returns true when reconciler can start unmounting volumes. func (rc *reconciler) readyToUnmount() bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:23:12 UTC 2024 - 8.9K bytes - Viewed (0) -
pkg/controller/validatingadmissionpolicystatus/controller.go
return nil } return err } return c.reconcile(ctx, policy) }() if err == nil { c.policyQueue.Forget(key) return true } utilruntime.HandleError(err) c.policyQueue.AddRateLimited(key) return true } func (c *Controller) reconcile(ctx context.Context, policy *v1.ValidatingAdmissionPolicy) error { if policy == nil { return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 5.3K bytes - Viewed (0) -
pkg/controlplane/reconcilers/instancecount.go
*/ // Package reconcilers master count based reconciler package reconcilers import ( "net" "sync" corev1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/api/errors" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/client-go/util/retry" "k8s.io/klog/v2" endpointsv1 "k8s.io/kubernetes/pkg/api/v1/endpoints" ) // masterCountEndpointReconciler reconciles endpoints based on a specified expected number of
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 7.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/namespacecontroller.go
// // 5ms, 10ms, 20ms, 40ms, 80ms maxRetries = 5 ) var configMapLabel = map[string]string{"istio.io/config": "true"} // NamespaceController manages reconciles a configmap in each namespace with a desired set of data. type NamespaceController struct { caBundleWatcher *keycertbundle.Watcher queue controllers.Queue namespaces kclient.Client[*v1.Namespace]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 5.4K bytes - Viewed (0) -
operator/cmd/operator/server.go
maxConcurrentReconciles int monitoring monitoringArgs } func addServerFlags(cmd *cobra.Command, args *serverArgs) { cmd.PersistentFlags().BoolVar(&args.force, "force", false, root.ForceFlagHelpStr) cmd.PersistentFlags().IntVar(&args.maxConcurrentReconciles, "max-concurrent-reconciles", 1, root.MaxConcurrentReconcilesFlagHelpStr)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 30 21:09:08 UTC 2023 - 7.6K bytes - Viewed (0) -
releasenotes/notes/operator-max-concurrent-reconcile-40810.yaml
deveshkandpal1224 <******@****.***> 1664341212 -0700
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Sep 28 05:00:12 UTC 2022 - 211 bytes - Viewed (0)