- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for EnqueueStatusUpdateResource (0.62 sec)
-
pilot/pkg/status/manager.go
fn UpdateFunc workers WorkerQueue } // EnqueueStatusUpdateResource informs the manager that this controller would like to // update the status of target, using the information in context. Once the status // workers are ready to perform this update, the controller's UpdateFunc // will be called with target and context as input. func (c *Controller) EnqueueStatusUpdateResource(context any, target Resource) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 24 04:04:42 UTC 2023 - 4.2K bytes - Viewed (0) -
pkg/config/analysis/incluster/controller.go
for r, m := range index { // don't try to write status for non-istio types if strings.HasSuffix(r.Group, "istio.io") { log.Debugf("enqueueing update for %s/%s", r.Namespace, r.Name) c.statusctl.EnqueueStatusUpdateResource(m, r) } } oldmsgs[a] = res.MappedMessages[a] } log.Debugf("finished enqueueing all statuses") } db.Run(chKind, stop, 1*time.Second, features.AnalysisInterval, pushFn)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 17:36:47 UTC 2024 - 4.7K bytes - Viewed (0) -
pilot/pkg/status/distribution/state.go
delete(fractions, staleReporter) } c.CurrentState[key] = fractions } } func (c *Controller) queueWriteStatus(config status.Resource, state Progress) { c.workers.EnqueueStatusUpdateResource(state, config) } func (c *Controller) configDeleted(res config.Config) { r := status.ResourceFromModelConfig(res) c.workers.Delete(r) } func boolToConditionStatus(b bool) string {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7.7K bytes - Viewed (0)