Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for RecordSendTime (0.16 sec)

  1. pkg/xds/server.go

    }
    
    func Send(ctx ConnectionContext, res *discovery.DiscoveryResponse) error {
    	conn := ctx.XdsConnection()
    	sendResponse := func() error {
    		start := time.Now()
    		defer func() { RecordSendTime(time.Since(start)) }()
    		return conn.stream.Send(res)
    	}
    	err := sendResponse()
    	if err == nil {
    		if res.Nonce != "" && !strings.HasPrefix(res.TypeUrl, model.DebugType) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 13 20:55:20 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  2. pilot/pkg/xds/delta.go

    			return
    		}
    	}
    }
    
    func (conn *Connection) sendDelta(res *discovery.DeltaDiscoveryResponse, newResourceNames []string) error {
    	sendResonse := func() error {
    		start := time.Now()
    		defer func() { xds.RecordSendTime(time.Since(start)) }()
    		return conn.deltaStream.Send(res)
    	}
    	err := sendResonse()
    	if err == nil {
    		if !strings.HasPrefix(res.TypeUrl, v3.DebugType) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 25.6K bytes
    - Viewed (0)
Back to top