- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for alwaysRespond (0.17 sec)
-
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) -
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) -
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) -
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)