- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for PushReason (0.1 sec)
-
pilot/pkg/xds/xdsgen.go
if s.StatusReporter != nil { s.StatusReporter.RegisterEvent(con.ID(), w.TypeUrl, req.Push.LedgerVersion) } 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(),
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
} return err } switch { case !req.Full: if deltaLog.DebugEnabled() { deltaLog.Debugf("%s: %s%s for node:%s resources:%d size:%s%s", v3.GetShortType(w.TypeUrl), ptype, req.PushReason(), con.proxy.ID, len(res), util.ByteCount(configSize), info) } default: debug := "" if deltaLog.DebugEnabled() { // Add additional information to logs when debug mode enabled.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
pilot/pkg/model/push_context.go
return len(pr.Reason) == 1 && pr.Reason.Has(ProxyRequest) } func (pr *PushRequest) IsProxyUpdate() bool { return pr.Reason.Has(ProxyUpdate) } func (pr *PushRequest) PushReason() string { if pr.IsRequest() { return " request" } return "" } // ProxyPushStatus represents an event captured during config push to proxies.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 09:02:11 UTC 2024 - 91.8K bytes - Viewed (0)