- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 81 for Reconciled (0.29 sec)
-
pilot/pkg/model/status/helper_test.go
}, { Type: "Reconciled", Status: "False", Message: "1/2 proxies up to date.", }, }, }, { name: "New conditions", args: args{ conditions: []*v1alpha1.IstioCondition{ { Type: "PassedValidation", Status: "True", Message: "just a test, here", }, { Type: "Reconciled", Status: "False",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 21 15:06:10 UTC 2023 - 3.7K bytes - Viewed (0) -
tests/integration/pilot/analysis/analysis_test.go
} statusConds := x.Status.Conditions // todo for some reason when a WorkloadEntry is created a "Reconciled" Condition isn't added. for i, cond := range x.Status.Conditions { // remove reconciled conditions for when WorkloadEntry starts initializing // with a reconciled status. if cond.Type == "Reconciled" { statusConds = append(statusConds[:i], statusConds[i+1:]...) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 8.7K bytes - Viewed (0) -
pilot/pkg/status/distribution/state_test.go
Type: "PassedValidation", Status: "True", Message: "just a test, here", }, { Type: "Reconciled", Status: "False", Message: "1/3 proxies up to date.", }, }, ValidationMessages: nil, }, }, { name: "Simple Reconcile to false", args: args{ current: &config.Config{Status: statusStillPropagating}, desired: Progress{2, 2}, },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 22 22:47:47 UTC 2022 - 4.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/interface.go
Run(ctx context.Context) error // Retrieves the informer used to back this controller Informer() Informer[T] // Returns true if the informer cache has synced, and all the objects from // the initial list have been reconciled at least once. HasSynced() bool } type NamespacedLister[T any] interface { // List lists all ValidationRuleSets in the indexer for a given namespace. // Objects returned here must be treated as read-only.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 1.9K bytes - Viewed (0) -
pkg/controlplane/apiserver/peer.go
config, err := storageFactory.NewConfig(api.Resource("apiServerPeerIPInfo")) if err != nil { return nil, fmt.Errorf("error creating storage factory config: %w", err) } reconciler, err := reconcilers.NewPeerEndpointLeaseReconciler(config, "/peerserverleases/", ttl) return reconciler, err } // utility function to get the apiserver address that is used by peer apiservers to 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) -
pilot/pkg/status/distribution/state.go
} func ReconcileStatuses(current *v1alpha1.IstioStatus, desired Progress) (bool, *v1alpha1.IstioStatus) { needsReconcile := false desiredCondition := v1alpha1.IstioCondition{ Type: "Reconciled", Status: boolToConditionStatus(desired.AckedInstances == desired.TotalInstances), LastProbeTime: timestamppb.Now(), LastTransitionTime: timestamppb.Now(),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7.7K bytes - Viewed (0) -
pkg/controlplane/controller/kubernetesservice/controller.go
func (c *Controller) UpdateKubernetesService(reconcile bool) error { // Update service & endpoint records. servicePorts, serviceType := createPortAndServiceSpec(c.ServicePort, c.PublicServicePort, c.KubernetesServiceNodePort, "https") if err := c.CreateOrUpdateMasterServiceIfNeeded(kubernetesServiceName, c.ServiceIP, servicePorts, serviceType, reconcile); err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 16 16:33:01 UTC 2023 - 9.3K bytes - Viewed (0) -
pkg/kube/controllers/example_test.go
// * errors can be retried c.queue = controllers.NewQueue("pods", controllers.WithReconciler(c.Reconcile), controllers.WithMaxAttempts(5)) // Register a handler for pods. For each pod event, we will add it to the queue. c.pods.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject)) return c } // Reconcile is the main work function for our controller. As input, we get a name of an object; with
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconciler.go
limitations under the License. */ package reconciler import ( "k8s.io/apimachinery/pkg/util/wait" "k8s.io/klog/v2" ) func (rc *reconciler) Run(stopCh <-chan struct{}) { rc.reconstructVolumes() klog.InfoS("Reconciler: start to sync state") wait.Until(rc.reconcile, rc.loopSleepDuration, stopCh) } func (rc *reconciler) reconcile() { readyToUnmount := rc.readyToUnmount() if readyToUnmount {
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/kubelet/pluginmanager/reconciler/reconciler.go
handlers map[string]cache.PluginHandler sync.RWMutex } var _ Reconciler = &reconciler{} func (rc *reconciler) Run(stopCh <-chan struct{}) { wait.Until(func() { rc.reconcile() }, rc.loopSleepDuration, stopCh) } func (rc *reconciler) AddHandler(pluginType string, pluginHandler cache.PluginHandler) { rc.Lock() defer rc.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 18 04:27:38 UTC 2022 - 6.2K bytes - Viewed (0)