Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for EnqueueStatusUpdateResource (0.27 sec)

  1. 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)
  2. 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)
  3. 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)
  4. pilot/pkg/config/kube/gateway/controller.go

    	if statusController == nil {
    		return
    	}
    	for _, cfg := range configs {
    		ws := cfg.Status.(*kstatus.WrappedStatus)
    		if ws.Dirty {
    			res := status.ResourceFromModelConfig(cfg)
    			statusController.EnqueueStatusUpdateResource(ws.Unwrap(), res)
    		}
    	}
    }
    
    func (c *Controller) Create(config config.Config) (revision string, err error) {
    	return "", errUnsupportedOp
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Mar 30 05:26:03 UTC 2024
    - 13.5K bytes
    - Viewed (0)
Back to top