From c398a6b272b8bcc693601b5be29b41f1b8be4716 Mon Sep 17 00:00:00 2001 From: Daniel Nephin Date: Mon, 26 Oct 2020 11:42:27 -0400 Subject: [PATCH] state: disable streaming connect topic --- agent/consul/state/memdb.go | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/agent/consul/state/memdb.go b/agent/consul/state/memdb.go index 5e6bbb604a..ded68636fd 100644 --- a/agent/consul/state/memdb.go +++ b/agent/consul/state/memdb.go @@ -3,9 +3,10 @@ package state import ( "fmt" + "github.com/hashicorp/go-memdb" + "github.com/hashicorp/consul/agent/consul/stream" "github.com/hashicorp/consul/proto/pbsubscribe" - "github.com/hashicorp/go-memdb" ) // ReadTxn is implemented by memdb.Txn to perform read operations. @@ -179,7 +180,9 @@ func processDBChanges(tx ReadTxn, changes Changes) ([]stream.Event, error) { func newSnapshotHandlers(s *Store) stream.SnapshotHandlers { return stream.SnapshotHandlers{ - topicServiceHealth: serviceHealthSnapshot(s, topicServiceHealth), - topicServiceHealthConnect: serviceHealthSnapshot(s, topicServiceHealthConnect), + topicServiceHealth: serviceHealthSnapshot(s, topicServiceHealth), + // The connect topic is temporarily disabled until the correct events are + // created for terminating gateway changes. + //topicServiceHealthConnect: serviceHealthSnapshot(s, topicServiceHealthConnect), } }