- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for recordPushTime (0.2 sec)
-
pilot/pkg/xds/monitoring.go
cdsSendErrPushes.Increment() case v3.EndpointType: edsSendErrPushes.Increment() case v3.RouteType: rdsSendErrPushes.Increment() } return true } return false } func recordPushTime(xdsType string, duration time.Duration) { pushTime.With(typeTag.Value(v3.GetMetricType(xdsType))).Record(duration.Seconds()) pushes.With(typeTag.Value(v3.GetMetricType(xdsType))).Increment()
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
} if log.DebugEnabled() { log.Debugf("%s: SKIP%s for node:%s%s", v3.GetShortType(w.TypeUrl), req.PushReason(), con.proxy.ID, info) } return err } defer func() { recordPushTime(w.TypeUrl, time.Since(t0)) }() resp := &discovery.DiscoveryResponse{ ControlPlane: ControlPlane(), TypeUrl: w.TypeUrl, // TODO: send different version for incremental eds
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 6.3K bytes - Viewed (0)