From b58a029c471f282d5f1ddb24fa7ac841c9769385 Mon Sep 17 00:00:00 2001 From: Slach Date: Fri, 7 Feb 2025 15:58:43 +0500 Subject: [PATCH] improve logging keeper->Walk Signed-off-by: Slach --- pkg/keeper/keeper.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/pkg/keeper/keeper.go b/pkg/keeper/keeper.go index a910c178..583cb4ce 100644 --- a/pkg/keeper/keeper.go +++ b/pkg/keeper/keeper.go @@ -225,23 +225,23 @@ type WalkCallBack = func(node DumpNode) (bool, error) func (k *Keeper) Walk(prefix, relativePath string, recursive bool, callback WalkCallBack) error { nodePath := path.Join(prefix, relativePath) value, stat, err := k.conn.Get(nodePath) - log.Debug().Msgf("Walk->get(%s) = %v, err = %v", nodePath, string(value), err) + log.Debug().Msgf("k.Walk->get(%s) = %v, err = %v", nodePath, string(value), err) if err != nil { - return fmt.Errorf("Walk->get(%s) = %v, err = %v", nodePath, string(value), err) + return fmt.Errorf("k.Walk->get(%s) = %v, err = %v", nodePath, string(value), err) } var isDone bool callbackNode := DumpNode{Path: nodePath, Value: string(value)} if isDone, err = callback(callbackNode); err != nil { - return fmt.Errorf("Walk->callback(%v) error: %v", callbackNode, err) + return fmt.Errorf("k.Walk->callback(%v) error: %v", callbackNode, err) } if isDone { return nil } if recursive && stat.NumChildren > 0 { children, _, err := k.conn.Children(path.Join(prefix, relativePath)) - log.Debug().Msgf("Walk->Children(%s) = %v, err = %v", path.Join(prefix, relativePath), children, err) + log.Debug().Msgf("k.Walk->Children(%s) = %v, err = %v", path.Join(prefix, relativePath), children, err) if err != nil { - return fmt.Errorf("Walk->Children(%s) = %v, err = %v", path.Join(prefix, relativePath), children, err) + return fmt.Errorf("k.Walk->Children(%s) = %v, err = %v", path.Join(prefix, relativePath), children, err) } for _, childPath := range children { if childErr := k.Walk(prefix, path.Join(relativePath, childPath), recursive, callback); childErr != nil {