- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 76 for reconciliation (0.19 sec)
-
pkg/registry/rbac/rest/storage_rbac.go
return false, nil } // ensure bootstrap roles are created or reconciled for _, clusterRole := range p.ClusterRoles { opts := reconciliation.ReconcileRoleOptions{ Role: reconciliation.ClusterRoleRuleOwner{ClusterRole: &clusterRole}, Client: reconciliation.ClusterRoleModifier{Client: client.RbacV1().ClusterRoles()}, Confirm: true, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 14 03:25:19 UTC 2022 - 18.5K bytes - Viewed (0) -
pkg/controller/controller_ref_manager.go
// // A non-nil error is returned if some form of reconciliation was attempted and // failed. Usually, controllers should try again later in case reconciliation // is still needed. // // If the error is nil, either the reconciliation succeeded, or no // reconciliation was necessary. The returned boolean indicates whether you now // own the object. // // No reconciliation will be attempted if the controller is being deleted.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 12:57:29 UTC 2023 - 21.5K bytes - Viewed (0) -
pkg/controller/podautoscaler/monitor/metrics.go
Name: "reconciliations_total", Help: "Number of reconciliations of HPA controller. The label 'action' should be either 'scale_down', 'scale_up', or 'none'. Also, the label 'error' should be either 'spec', 'internal', or 'none'. Note that if both spec and internal errors happen during a reconciliation, the first one to occur is reported in `error` label.", StabilityLevel: metrics.ALPHA,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 22:47:24 UTC 2023 - 3.7K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/metrics.go
clusterIPRepairReconcileErrors = metrics.NewCounter( &metrics.CounterOpts{ Namespace: namespace, Subsystem: subsystem, Name: "reconcile_errors_total", Help: "Number of reconciliation failures on the clusterip repair reconcile loop", StabilityLevel: metrics.ALPHA, }, ) ) var registerMetricsOnce sync.Once func registerMetrics() { registerMetricsOnce.Do(func() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 2K bytes - Viewed (0) -
pkg/controller/podautoscaler/monitor/monitor.go
} type monitor struct{} func New() Monitor { return &monitor{} } // ObserveReconciliationResult observes some metrics from a reconciliation result. func (r *monitor) ObserveReconciliationResult(action ActionLabel, err ErrorLabel, duration time.Duration) { reconciliationsTotal.WithLabelValues(string(action), string(err)).Inc()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 22:47:24 UTC 2023 - 2.3K bytes - Viewed (0) -
pkg/registry/core/service/portallocator/controller/metrics.go
nodePortRepairReconcileErrors = metrics.NewCounter( &metrics.CounterOpts{ Namespace: namespace, Subsystem: subsystem, Name: "reconcile_errors_total", Help: "Number of reconciliation failures on the nodeport repair reconcile loop", StabilityLevel: metrics.ALPHA, }, ) ) var registerMetricsOnce sync.Once func registerMetrics() { registerMetricsOnce.Do(func() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 2K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconciler.go
} if len(rc.volumesNeedUpdateFromNodeStatus) == 0 { // ASW is fully populated only after both devicePaths and uncertain volume attach-ability // were reconstructed from the API server. // This will start reconciliation of node.status.volumesInUse. rc.updateLastSyncTime() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:23:12 UTC 2024 - 2.1K bytes - Viewed (0) -
pkg/apis/rbac/helpers_test.go
// that have gone through conversion and defaulting. This is required because these helper functions are // used to create the bootstrap RBAC policy which is used during reconciliation. If they produced objects // that did not match, reconciliation would incorrectly add duplicate data to the cluster's RBAC policy. func TestHelpersRoundTrip(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 9.2K bytes - Viewed (0) -
pkg/controlplane/apiserver/peer.go
versionedInformer, svm, proxyRoundTripper, apiServerID, reconciler, serializer, ), nil } // CreatePeerEndpointLeaseReconciler creates a apiserver endpoint lease reconciliation loop // The peer endpoint leases are used to find network locations of apiservers for peer proxy
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 08:15:02 UTC 2024 - 3.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller.go
type controller[T runtime.Object] struct { informer Informer[T] queue workqueue.TypedRateLimitingInterface[string] // Returns an error if there was a transient error during reconciliation // and the object should be tried again later. reconciler func(namespace, name string, newObj T) error options ControllerOptions // must hold a func() bool or nil notificationsDelivered atomic.Value
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.5K bytes - Viewed (0)