- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 57 for Reconciled (0.16 sec)
-
pkg/registry/core/service/ipallocator/controller/metrics.go
&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() { legacyregistry.MustRegister(clusterIPRepairIPErrors)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 2K bytes - Viewed (0) -
pkg/registry/core/service/portallocator/controller/metrics.go
&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() { legacyregistry.MustRegister(nodePortRepairPortErrors)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 2K bytes - Viewed (0) -
operator/pkg/metrics/monitoring.go
// ResourceKindLabel indicates the kind of resource owned // or created or updated or deleted or pruned by operator. ResourceKindLabel = monitoring.CreateLabel("kind") // ReconcileRequestReasonLabel describes reason of reconcile request. ReconcileRequestReasonLabel = monitoring.CreateLabel("reason") ) // MergeErrorType describes the class of errors that could // occur while merging profile, user supplied YAML, values
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Aug 10 15:35:03 UTC 2023 - 7K bytes - Viewed (0) -
pkg/kube/kclient/crdwatcher.go
c := &crdWatcher{ running: make(chan struct{}), callbacks: map[string][]func(){}, } c.queue = controllers.NewQueue("crd watcher", controllers.WithReconciler(c.Reconcile)) c.crds = NewMetadata(client, gvr.CustomResourceDefinition, Filter{ ObjectFilter: kubetypes.NewStaticObjectFilter(minimumVersionFilter), }) c.crds.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject)) return c
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 5.7K bytes - Viewed (0) -
pilot/pkg/config/kube/ingress/status.go
nodes: kclient.NewFiltered[*corev1.Node](kc, kclient.Filter{ ObjectTransform: kubelib.StripNodeUnusedFields, }), } c.queue = controllers.NewQueue("ingress status", controllers.WithReconciler(c.Reconcile), controllers.WithMaxAttempts(5)) // For any ingress change, enqueue it - we may need to update the status. c.ingresses.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 7.9K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/gatewayclass_test.go
deleteClass(features.GatewayAPIDefaultGatewayClass) expectClass(features.GatewayAPIDefaultGatewayClass, features.ManagedGatewayController) // Overwrite the class, controller should not reconcile it back createClass(features.GatewayAPIDefaultGatewayClass, "different-controller") expectClass(features.GatewayAPIDefaultGatewayClass, "different-controller") // Once we delete it, it should be added back
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 08:41:13 UTC 2024 - 3K bytes - Viewed (0) -
pkg/kubelet/cm/dra/types.go
"k8s.io/kubernetes/pkg/kubelet/config" kubecontainer "k8s.io/kubernetes/pkg/kubelet/container" ) // Manager manages all the DRA resource plugins running on a node. type Manager interface { // Start starts the reconcile loop of the manager. // This will ensure that all claims are unprepared even if pods get deleted unexpectedly. Start(activePods ActivePodsFunc, sourcesReady config.SourcesReady) error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:23:29 UTC 2024 - 2.1K bytes - Viewed (0) -
pkg/kube/krt/bench_test.go
for _, service := range allServices { if labels.Instance(service.Spec.Selector).Match(pod.Labels) { services = append(services, service) } } return services } func (l *legacy) Reconcile(key types.NamespacedName) error { pod := l.pods.Get(key.Name, key.Namespace) if pod == nil || pod.Status.PodIP == "" { old := l.workloads[key] if old != nil { ev := krt.Event[Workload]{ Old: old,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 09 19:55:53 UTC 2024 - 7K bytes - Viewed (0) -
src/cmd/cgo/internal/testfortran/fortran_test.go
// TODO: This duplicates but also diverges from logic from cmd/go // itself. For example, cmd/go merely adds -lgfortran without the extra // library path work. If this is what's necessary to run gfortran, we // should reconcile the logic here and in cmd/go.. Maybe this should // become a cmd/go script test to share that logic. // Add -m32 if we're targeting 386, in case this is a cross-compile. if runtime.GOARCH == "386" {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Oct 18 01:29:16 UTC 2023 - 2.6K bytes - Viewed (0) -
pkg/zdsapi/zds.proto
} // Delete a workload from the ztunnel. Ztunnel should shutdown the workload's proxy. message DelWorkload { string uid = 2; } // Let ztunnel know that a full snapshot was sent. Ztunnel should reconcile its internal state // and remove internal entries that were not sent. message SnapshotSent { } // Ztunnel ack message. If error is not empty, this is an error message. message Ack { string error = 1; }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 22:07:03 UTC 2024 - 2.7K bytes - Viewed (0)