mirror of https://github.com/status-im/consul.git
xds: prevent LDS flaps in mesh gateways due to unstable datacenter lists (#9651)
Also fix a similar issue in Terminating Gateways that was masked by an overzealous test.
This commit is contained in:
parent
ddf292caf6
commit
43193a35c6
|
@ -0,0 +1,3 @@
|
|||
```release-note:bug
|
||||
xds: prevent LDS flaps in mesh gateways due to unstable datacenter lists; also prevent some flaps in terminating gateways as well
|
||||
```
|
|
@ -3,6 +3,7 @@ package proxycfg
|
|||
import (
|
||||
"context"
|
||||
"fmt"
|
||||
"sort"
|
||||
|
||||
"github.com/hashicorp/consul/agent/structs"
|
||||
"github.com/mitchellh/copystructure"
|
||||
|
@ -245,6 +246,10 @@ func (c *configSnapshotMeshGateway) Datacenters() []string {
|
|||
dcs = append(dcs, dc)
|
||||
}
|
||||
}
|
||||
|
||||
// Always sort the results to ensure we generate deterministic things over
|
||||
// xDS, such as mesh-gateway listener filter chains.
|
||||
sort.Strings(dcs)
|
||||
return dcs
|
||||
}
|
||||
|
||||
|
|
|
@ -777,6 +777,16 @@ func (s *Server) makeTerminatingGatewayListener(
|
|||
}
|
||||
}
|
||||
|
||||
// Before we add the fallback, sort these chains by the matched name. All
|
||||
// of these filter chains are independent, but envoy requires them to be in
|
||||
// some order. If we put them in a random order then every xDS iteration
|
||||
// envoy will force the listener to be replaced. Sorting these has no
|
||||
// effect on how they operate, but it does mean that we won't churn
|
||||
// listeners at idle.
|
||||
sort.Slice(l.FilterChains, func(i, j int) bool {
|
||||
return l.FilterChains[i].FilterChainMatch.ServerNames[0] < l.FilterChains[j].FilterChainMatch.ServerNames[0]
|
||||
})
|
||||
|
||||
// This fallback catch-all filter ensures a listener will be present for health checks to pass
|
||||
// Envoy will reset these connections since known endpoints are caught by filter chain matches above
|
||||
tcpProxy, err := makeTCPProxyFilter(name, "", "terminating_gateway.")
|
||||
|
|
|
@ -525,24 +525,14 @@ func TestListenersFromSnapshot(t *testing.T) {
|
|||
ProxyFeatures: sf,
|
||||
}
|
||||
listeners, err := s.listenersFromSnapshot(cInfo, snap)
|
||||
require.NoError(err)
|
||||
|
||||
// The order of listeners returned via LDS isn't relevant, so it's safe
|
||||
// to sort these for the purposes of test comparisons.
|
||||
sort.Slice(listeners, func(i, j int) bool {
|
||||
return listeners[i].(*envoy.Listener).Name < listeners[j].(*envoy.Listener).Name
|
||||
})
|
||||
|
||||
// For terminating gateways we create filter chain matches for services/subsets from the ServiceGroups map
|
||||
for i := 0; i < len(listeners); i++ {
|
||||
l := listeners[i].(*envoy.Listener)
|
||||
|
||||
if l.FilterChains != nil {
|
||||
// Sort chains by the matched name with the exception of the last one
|
||||
// The last chain is a fallback and does not have a FilterChainMatch
|
||||
sort.Slice(l.FilterChains[:len(l.FilterChains)-1], func(i, j int) bool {
|
||||
return l.FilterChains[i].FilterChainMatch.ServerNames[0] < l.FilterChains[j].FilterChainMatch.ServerNames[0]
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
require.NoError(err)
|
||||
r, err := createResponse(ListenerType, "00000001", "00000001", listeners)
|
||||
require.NoError(err)
|
||||
|
||||
|
|
Loading…
Reference in New Issue