Add message for ignored queries and fix full gtid at healthcheck

yandex · Dec 17, 2024 · 8eb8c36 · 8eb8c36
1 parent 7ad0f48
commit 8eb8c36
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/internal/app/app.go b/internal/app/app.go
@@ -2068,6 +2068,7 @@ func (app *App) getNodeState(host string) *NodeState {
 		node = app.cluster.Get(host)
 	}
 	nodeState := new(NodeState)
+	nodeState.ShowOnlyGTIDDiff = app.config.ShowOnlyGTIDDiff
 	err := func() error {
 		nodeState.CheckAt = time.Now()
 		nodeState.CheckBy = app.config.Hostname

diff --git a/internal/mysql/node.go b/internal/mysql/node.go
@@ -148,6 +148,7 @@ func (n *Node) getQuery(name string) string {
 func (n *Node) traceQuery(query string, arg interface{}, result interface{}, err error) {
 	query = queryOnliner.ReplaceAllString(query, " ")
 	if n.config.ShowOnlyGTIDDiff && IsGtidQuery(query) {
+		n.logger.Debug("<gtid query was ignored>")
 		return
 	}
 	msg := fmt.Sprintf("node %s running query '%s' with args %#v, result: %#v, error: %v", n.host, query, arg, result, err)