luxolus
/
open-consul
2
0
Fork 0
Code Issues 1 Pull Requests Packages Releases Wiki Activity

state: disable streaming connect topic

This commit is contained in:
Daniel Nephin 2020-10-26 11:42:27 -04:00
parent 1dcbfd17c3
commit abd8cfcfe9
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
agent/consul/state/memdb.go
View File

@ -3,9 +3,10 @@ package state
import ( import (
"fmt" "fmt"
"github.com/hashicorp/go-memdb"
"github.com/hashicorp/consul/agent/consul/stream" "github.com/hashicorp/consul/agent/consul/stream"
"github.com/hashicorp/consul/proto/pbsubscribe" "github.com/hashicorp/consul/proto/pbsubscribe"
"github.com/hashicorp/go-memdb"
) )
// ReadTxn is implemented by memdb.Txn to perform read operations. // 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 { func newSnapshotHandlers(s *Store) stream.SnapshotHandlers {
return stream.SnapshotHandlers{ return stream.SnapshotHandlers{
topicServiceHealth: serviceHealthSnapshot(s, topicServiceHealth), topicServiceHealth: serviceHealthSnapshot(s, topicServiceHealth),
topicServiceHealthConnect: serviceHealthSnapshot(s, topicServiceHealthConnect), // The connect topic is temporarily disabled until the correct events are
// created for terminating gateway changes.
//topicServiceHealthConnect: serviceHealthSnapshot(s, topicServiceHealthConnect),
} }
} }