Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for recordSendError (0.13 sec)

  1. pilot/pkg/xds/monitoring.go

    	isError := s.Code() != codes.Unavailable && s.Code() != codes.Canceled
    	return !ok || isError
    }
    
    // recordSendError records a metric indicating that a push failed. It returns true if this was an unexpected
    // error
    func recordSendError(xdsType string, err error) bool {
    	if isUnexpectedError(err) {
    		// TODO use a single metric with a type tag
    		switch xdsType {
    		case v3.ListenerType:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 00:26:45 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  2. pilot/pkg/xds/xdsgen.go

    	configSizeBytes.With(typeTag.Value(w.TypeUrl)).Record(float64(configSize))
    
    	ptype := "PUSH"
    	if logdata.Incremental {
    		ptype = "PUSH INC"
    	}
    
    	if err := xds.Send(con, resp); err != nil {
    		if recordSendError(w.TypeUrl, err) {
    			log.Warnf("%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
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 13 20:55:20 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  3. pilot/pkg/xds/delta.go

    		info = " " + logdata.AdditionalInfo
    	}
    	if len(logFiltered) > 0 {
    		info += logFiltered
    	}
    
    	if err := con.sendDelta(resp, newResourceNames); err != nil {
    		logger := deltaLog.Debugf
    		if recordSendError(w.TypeUrl, err) {
    			logger = deltaLog.Warnf
    		}
    		if deltaLog.DebugEnabled() {
    			logger("%s: Send failure for node:%s resources:%d size:%s%s: %v",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 25.6K bytes
    - Viewed (0)
Back to top