@@ -0,0 +76,4 @@
+	c.mu.RLock()
+	healthy := c.healthy
+	dialed := c.conn != nil
+	c.mu.RUnlock()

@@ -0,0 +186,4 @@
+	for i, nodes := range p.rebalanceParams.nodesGroup {
+		clients := make([]client, len(nodes))
+		for j, node := range nodes {
+			clients[j] = newTreeClient(node.Address(), grpc.WithTransportCredentials(insecure.NewCredentials()))

@@ -0,0 +205,4 @@
+	}
+
+	ctx, cancel := context.WithCancel(ctx)
+	p.cancel = cancel

@@ -0,0 +206,4 @@
+
+	ctx, cancel := context.WithCancel(ctx)
+	p.cancel = cancel
+	p.closedCh = make(chan struct{})

@@ -0,0 +96,4 @@
+func (c *treeClient) setHealthy(val bool) {
+	c.mu.Lock()
+	c.healthy = val
+	c.mu.Unlock()

@@ -0,0 +75,4 @@
+	logger          *zap.Logger
+
+	startIndicesMtx sync.RWMutex
+	startIndices    [2]int

@@ -0,0 +534,4 @@
+		for _, cl := range group.clients {
+			if closeErr := cl.close(); closeErr != nil {
+				p.log(zapcore.ErrorLevel, "close client connection", zap.Error(closeErr))
+				err = closeErr

@@ -0,0 +720,4 @@
+				err = fn(cl)
+			}
+			if !shouldTryAgain(err) {
+				p.setStartIndices(indexI, indexJ)

@@ -0,0 +6,4 @@
+)
+
+func (p *Pool) signData(buf []byte, f func(key, sign []byte)) error {
+	// When SDK library adopts Tree service client, this should be dropped.