Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for alwaysRespond (0.15 sec)

  1. pkg/xds/server.go

    	// If it comes here, that means nonce match.
    	var previousResources []string
    	var alwaysRespond bool
    	w.UpdateWatchedResource(request.TypeUrl, func(wr *WatchedResource) *WatchedResource {
    		previousResources = wr.ResourceNames
    		wr.NonceAcked = request.ResponseNonce
    		wr.ResourceNames = request.ResourceNames
    		alwaysRespond = wr.AlwaysRespond
    		wr.AlwaysRespond = false
    		return wr
    	})
    
    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

    	var alwaysRespond bool
    	con.proxy.UpdateWatchedResource(request.TypeUrl, func(wr *model.WatchedResource) *model.WatchedResource {
    		previousResources = wr.ResourceNames
    		currentResources, _ = deltaWatchedResources(previousResources, request)
    		wr.NonceAcked = request.ResponseNonce
    		wr.ResourceNames = currentResources
    		alwaysRespond = wr.AlwaysRespond
    		wr.AlwaysRespond = false
    		return wr
    	})
    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/context.go

    	// Refer to https://github.com/envoyproxy/envoy/issues/13009 for more details.
    	for _, dependent := range WarmingDependencies(typeURL) {
    		if dwr, exists := node.WatchedResources[dependent]; exists {
    			dwr.AlwaysRespond = true
    		}
    	}
    }
    
    // WarmingDependencies returns the dependent typeURLs that need to be responded with
    // for warming of this typeURL.
    func WarmingDependencies(typeURL string) []string {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 03 08:29:05 UTC 2024
    - 33.6K bytes
    - Viewed (1)
Back to top