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