Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for PushReason (0.1 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top