Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for alwaysRespond (0.17 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. pkg/xds/server_test.go

    			},
    			response: false,
    		},
    		{
    			name: "ack forced",
    			proxy: &TestProxy{
    				WatchedResources: map[string]*WatchedResource{
    					model.EndpointType: {
    						NonceSent:     "nonce",
    						AlwaysRespond: true,
    						ResourceNames: []string{"my-resource"},
    					},
    				},
    			},
    			request: &discovery.DiscoveryRequest{
    				TypeUrl:       model.EndpointType,
    				VersionInfo:   "v1",
    				ResponseNonce: "nonce",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 00:26:45 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  4. 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 (0)
Back to top