Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 51 for reconciliation (0.27 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top