- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 51 for reconciliation (0.27 sec)
-
pkg/webhooks/validation/controller/controller.go
whc := c.webhooks.Get(name, "") scope := scope.WithLabels("webhook", name) // Stop early if webhook is not present, rather than attempting (and failing) to reconcile permanently // If the webhook is later added a new reconciliation request will trigger it to update if whc == nil { scope.Infof("Skip patching webhook, not found") return nil } scope.Debugf("Reconcile(enter)") defer func() { scope.Debugf("Reconcile(exit)") }()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 28 16:52:19 UTC 2024 - 11.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller_test.go
wg.Wait() // TODO(alexzielenski): Find a better way to test this since the // controller drops any pending events when it shuts down. verifyNoMoreEvents() } // Shows that an object which fails reconciliation will retry func TestReconcileRetry(t *testing.T) { testContext, testCancel := context.WithTimeout(context.Background(), 2*time.Second) defer testCancel() calls := atomic.Uint64{} success := atomic.Bool{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 16.1K bytes - Viewed (0) -
common-protos/k8s.io/api/admissionregistration/v1/generated.proto
// SideEffects states whether this webhook has side effects. // Acceptable values are: None, NoneOnDryRun (webhooks created via v1beta1 may also specify Some or Unknown). // Webhooks with side effects MUST implement a reconciliation system, since a request may be // rejected by a future step in the admission chain and the side effects therefore need to be undone. // Requests with the dryRun attribute will be auto-rejected if they match a webhook with
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 24.4K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconciler_common.go
// controller. This reconciles state for the kubelet volume manager. That // reconciles state for the attach/detach controller. type Reconciler interface { // Starts running the reconciliation loop which executes periodically, checks // if volumes that should be mounted are mounted and volumes that should // be unmounted are unmounted. If not, it will trigger mount/unmount // operations to rectify.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:23:12 UTC 2024 - 14.8K bytes - Viewed (0) -
staging/src/k8s.io/api/rbac/v1alpha1/types.go
NonResourceAll = "*" GroupKind = "Group" ServiceAccountKind = "ServiceAccount" UserKind = "User" // AutoUpdateAnnotationKey is the name of an annotation which prevents reconciliation if set to "false" AutoUpdateAnnotationKey = "rbac.authorization.kubernetes.io/autoupdate" ) // Authorization is calculated against // 1. evaluation of ClusterRoleBindings - short circuit on match
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 28 22:49:19 UTC 2024 - 11.2K bytes - Viewed (0) -
operator/pkg/helmreconciler/prune.go
} } return errs.ToError() }) } // PruneControlPlaneByRevisionWithController is called to remove specific control plane revision // during reconciliation process of controller. // It returns the install status and any error encountered. func (h *HelmReconciler) PruneControlPlaneByRevisionWithController(iopSpec *v1alpha1.IstioOperatorSpec) (*v1alpha1.InstallStatus, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 08:32:06 UTC 2024 - 15.9K bytes - Viewed (0) -
staging/src/k8s.io/api/rbac/v1beta1/types.go
NonResourceAll = "*" GroupKind = "Group" ServiceAccountKind = "ServiceAccount" UserKind = "User" // AutoUpdateAnnotationKey is the name of an annotation which prevents reconciliation if set to "false" AutoUpdateAnnotationKey = "rbac.authorization.kubernetes.io/autoupdate" ) // Authorization is calculated against // 1. evaluation of ClusterRoleBindings - short circuit on match
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 28 22:49:19 UTC 2024 - 13.1K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/deploymentcontroller_test.go
wantReconcile := int32(0) expectReconciled := func() { t.Helper() wantReconcile++ assert.EventuallyEqual(t, reconciles.Load, wantReconcile, retry.Timeout(time.Second*5), retry.Message("no reconciliation")) } d.patcher = func(g schema.GroupVersionResource, name string, namespace string, data []byte, subresources ...string) error { if g == gvr.Service { reconciles.Inc() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 21:43:20 UTC 2024 - 16.5K bytes - Viewed (0) -
pkg/controller/podautoscaler/horizontal.go
// Register HPA in the hpaSelectors map if it's not present yet. Attaching the Nothing selector // that does not select objects. The actual selector is going to be updated // when it's available during the autoscaler reconciliation. a.hpaSelectorsMux.Lock() defer a.hpaSelectorsMux.Unlock() if hpaKey := selectors.Parse(key); !a.hpaSelectors.SelectorExists(hpaKey) { a.hpaSelectors.PutSelector(hpaKey, labels.Nothing()) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 63.6K bytes - Viewed (0) -
pkg/controlplane/instance.go
// CompletedConfig embeds a private pointer that cannot be instantiated outside of this package type CompletedConfig struct { *completedConfig } // EndpointReconcilerConfig holds the endpoint reconciler and endpoint reconciliation interval to be // used by the master. type EndpointReconcilerConfig struct { Reconciler reconcilers.EndpointReconciler Interval time.Duration }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 03 11:50:04 UTC 2024 - 21.2K bytes - Viewed (0)