Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for DebugEnabled (0.21 sec)

  1. pkg/kube/krt/collection.go

    				}
    
    				if h.log.DebugEnabled() {
    					h.log.WithLabels("res", key, "type", e.Event).Debugf("handled")
    				}
    				events = append(events, e)
    			}
    		}
    	}
    	h.mu.Unlock()
    
    	// Short circuit if we have nothing to do
    	if len(events) == 0 {
    		return
    	}
    	handlers := h.eventHandlers.Get()
    
    	if h.log.DebugEnabled() {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 10 23:33:56 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  2. pilot/pkg/xds/delta.go

    		if recordSendError(w.TypeUrl, err) {
    			logger = deltaLog.Warnf
    		}
    		if deltaLog.DebugEnabled() {
    			logger("%s: Send failure for node:%s resources:%d size:%s%s: %v",
    				v3.GetShortType(w.TypeUrl), con.proxy.ID, len(res), util.ByteCount(configSize), info, err)
    		}
    		return err
    	}
    
    	switch {
    	case !req.Full:
    		if deltaLog.DebugEnabled() {
    			deltaLog.Debugf("%s: %s%s for node:%s resources:%d size:%s%s",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  3. pilot/pkg/security/authz/builder/extauthz.go

    		}
    		if parsed == nil {
    			parsed = &builtExtAuthz{}
    		}
    		parsed.err = errs
    		resolved[config.Name] = parsed
    	}
    
    	if authzLog.DebugEnabled() {
    		authzLog.Debugf("Resolved extension providers: %v", spew.Sdump(resolved))
    	}
    	return resolved
    }
    
    func notAllTheSame(names []string) bool {
    	for i := 1; i < len(names); i++ {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 20:06:41 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  4. platforms/ide/tooling-api/src/testFixtures/groovy/org/gradle/integtests/tooling/fixture/ToolingApi.groovy

        private DefaultServiceRegistry isolatedToolingClient
        private context = new IntegrationTestBuildContext()
    
        private final List<Closure> connectorConfigurers = []
        boolean verboseLogging = LOGGER.debugEnabled
        private final OutputStream stdout
        private final OutputStream stderr
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 14 10:07:23 UTC 2024
    - 12K bytes
    - Viewed (0)
  5. pilot/pkg/xds/ads.go

    			connection = v
    			break
    		}
    	}
    
    	// It is possible that the envoy has not connected to this pilot, maybe connected to another pilot
    	if connection == nil {
    		return
    	}
    	if log.DebugEnabled() {
    		currentlyPending := s.pushQueue.Pending()
    		if currentlyPending != 0 {
    			log.Debugf("Starting new push while %v were still pending", currentlyPending)
    		}
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 03 08:29:05 UTC 2024
    - 23.4K bytes
    - Viewed (0)
  6. pkg/kube/inject/inject.go

    			required = false
    		} else {
    			required = inject
    		}
    	case InjectionPolicyEnabled:
    		if useDefault {
    			required = true
    		} else {
    			required = inject
    		}
    	}
    
    	if log.DebugEnabled() {
    		// Build a log message for the annotations.
    		annotationStr := ""
    		for name := range AnnotationValidation {
    			value, ok := annos[name]
    			if !ok {
    				value = "(unset)"
    			}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 31 20:35:11 UTC 2024
    - 28.8K bytes
    - Viewed (0)
Back to top