[#1759] services/tree: Make logs more descriptive

Signed-off-by: Evgenii Stratonikov <evgeniy@morphbits.ru>

pkg/services/tree/cache.go

@@ -2,6 +2,7 @@ package tree
 
 import (
 	"context"
+	"errors"
 	"fmt"
 	"strings"
 	"sync"
@@ -30,6 +31,8 @@ const (
 	defaultReconnectInterval    = time.Second * 15
 )
 
+var errRecentlyFailed = errors.New("client has recently failed")
+
 func (c *clientCache) init() {
 	l, _ := simplelru.NewLRU(defaultClientCacheSize, func(key, value interface{}) {
 		_ = value.(*grpc.ClientConn).Close()
@@ -46,8 +49,8 @@ func (c *clientCache) get(ctx context.Context, netmapAddr string) (TreeServiceCl
 		item := ccInt.(cacheItem)
 		if item.cc == nil {
 			if d := time.Since(item.lastTry); d < defaultReconnectInterval {
-				return nil, fmt.Errorf("skip connecting to %s (time since last error %s)",
-					netmapAddr, d)
+				return nil, fmt.Errorf("%w: %s till the next reconnection to %s",
+					errRecentlyFailed, d, netmapAddr)
 			}
 		} else {
 			if s := item.cc.GetState(); s == connectivity.Idle || s == connectivity.Ready {

pkg/services/tree/replicator.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"crypto/sha256"
 	"encoding/hex"
+	"errors"
 	"fmt"
 	"time"
 
@@ -56,6 +57,10 @@ func (s *Service) replicationWorker() {
 			})
 
 			if lastErr != nil {
+				if errors.Is(lastErr, errRecentlyFailed) {
+					s.log.Debug("do not send update to the node",
+						zap.String("last_error", lastErr.Error()))
+				} else {
 					s.log.Warn("failed to sent update to the node",
 						zap.String("last_error", lastErr.Error()),
 						zap.String("address", lastAddr),
@@ -64,6 +69,7 @@ func (s *Service) replicationWorker() {
 			}
 		}
 	}
+}
 
 func (s *Service) replicateLoop(ctx context.Context) {
 	for i := 0; i < s.replicatorWorkerCount; i++ {