- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for recordSendError (0.13 sec)
-
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) -
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) -
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)