@@ -1868,0 +1869,4 @@
+	p.cancel = cancel
+	p.closedCh = make(chan struct{})
+
+	err := p.dial(ctx, nil)

@@ -1920,0 +1943,4 @@
+func (p *Pool) Update(ctx context.Context, prm []NodeParam) error {
+	for _, pool := range p.innerPools {
+		pool.lock.Lock()
+		defer pool.lock.Unlock()

@@ -1920,0 +1969,4 @@
+	}
+
+	for _, client := range existClients {
+		client.client.close()

@@ -1873,1 +1892,4 @@
 		for j, addr := range params.addresses {
+			if client, ok := existClients[NodeParam{address: addr, priority: params.priority}]; ok {
+				clients[j] = client.client
+				_ = p.cache.Put(formCacheKey(addr, p.key, false), client.session)

@@ -1913,4 +1933,1 @@
-	}
-	p.maxObjectSize = ni.MaxObjectSize()
-
 	go p.startRebalance(ctx)

@@ -1920,0 +1940,4 @@
+}
+
+// Update is a method that lets you refresh the list of nodes without recreating the pool.
+func (p *Pool) Update(ctx context.Context, prm []NodeParam) error {

@@ -1920,0 +1941,4 @@
+
+// Update is a method that lets you refresh the list of nodes without recreating the pool.
+func (p *Pool) Update(ctx context.Context, prm []NodeParam) error {
+	for _, pool := range p.innerPools {

@@ -1920,0 +1961,4 @@
+		return err
+	}
+
+	p.rebalanceParams.nodesParams = nodesParams

@@ -1905,4 +1937,1 @@
-	ctx, cancel := context.WithCancel(ctx)
-	p.cancel = cancel
-	p.closedCh = make(chan struct{})
 	p.innerPools = inner

@@ -1866,2 +1869,4 @@
 // See also InitParameters.SetClientRebalanceInterval.
 func (p *Pool) Dial(ctx context.Context) error {
+	ctx, cancel := context.WithCancel(ctx)
+	p.cancel = cancel

@@ -1793,0 +1984,4 @@
+func (p *Pool) Update(ctx context.Context, prm []NodeParam) error {
+	p.pool.Load().stopRebalance()
+
+	newPool := *p.pool.Load()

@@ -1793,0 +1986,4 @@
+
+	newPool := *p.pool.Load()
+	if err := newPool.Update(ctx, prm); err != nil {
+		return err

@@ -1874,0 +2087,4 @@
+			if client, ok := existClients[NodeParam{address: addr, priority: params.priority}]; ok {
+				clients[j] = client
+				delete(existClients, NodeParam{address: addr, priority: params.priority})
+				continue

@@ -1921,0 +2163,4 @@
+		return err
+	}
+
+	err = nil

@@ -1921,0 +2164,4 @@
+	}
+
+	err = nil
+	for _, client := range existClients {

@@ -1793,0 +1988,4 @@
+	p.pool.Load().stopRebalance()
+	defer p.pool.Load().startRebalance(ctx)
+
+	newPool := *p.pool.Load()

@@ -1921,0 +2140,4 @@
+}
+
+func (p *pool) Update(ctx context.Context, prm []NodeParam) error {
+	foreach(p.innerPools, func(pool *innerPool) { pool.lock.Lock() })

@@ -1793,0 +1987,4 @@
+// Use a long-lived context to avoid early rebalance stop.
+// Can interrupt an operation being performed on a node that was removed.
+func (p *Pool) Update(ctx context.Context, prm []NodeParam) error {
+	p.pool.Load().stopRebalance()

@@ -1868,0 +2084,4 @@
+	return nil
+}
+
+func (p *pool) dial(ctx context.Context, existClients map[NodeParam]client) error {

@@ -1921,0 +2141,4 @@
+	}
+
+	for i, v := range a {
+		if !reflect.DeepEqual(v, b[i]) {

@@ -1921,0 +2155,4 @@
+	existClients := make(map[NodeParam]client)
+	for i, pool := range newPool.rebalanceParams.nodesParams {
+		for j := range pool.weights {
+			existClients[NodeParam{address: pool.addresses[j], priority: pool.priority}] = newPool.innerPools[i].clients[j]

@@ -1921,0 +2175,4 @@
+		return nil, false, err
+	}
+
+	//Removing outdated clients

@@ -1921,0 +2178,4 @@
+	//Removing outdated clients
+	for _, client := range existClients {
+		if clientErr := client.close(); clientErr != nil {
+			err = clientErr

@@ -2004,0 +2271,4 @@
+	p.cancelLock.Lock()
+
+	//stop rebalance
+	if p.cancel != nil {

@@ -1789,10 +1789,230 @@ type resCreateSession struct {
 // (e.g. sdkClient.IsErrContainerNotFound, sdkClient.IsErrObjectNotFound).
 //
 // See pool package overview to get some examples.
+

@@ -1793,0 +1997,4 @@
+
+	pool := p.pool.Load()
+	pool.stopRebalance()
+	defer pool.startRebalance(ctx)

@@ -1921,0 +2193,4 @@
+		return nil, false, err
+	}
+
+	//After newPool.dial(ctx, existingClients), existingClients will contain only outdated clients.

@@ -2004,0 +2301,4 @@
+	p.cancel = cancel
+
+	go p.rebalance(rebalanceCtx)
+	p.cancelLock.Unlock()

@@ -2023,0 +2328,4 @@
+	p.cancelLock.Lock()
+	defer p.cancelLock.Unlock()
+
+	if p.cancel != nil {

@@ -1817,0 +1875,4 @@
+func (p *Pool) Dial(ctx context.Context) error {
+	pool := p.pool.Load()
+	err := pool.Dial(ctx)
+	pool.startRebalance(ctx)

@@ -1817,0 +1876,4 @@
+	pool := p.pool.Load()
+	err := pool.Dial(ctx)
+
+	if pool.cancel != nil {

@@ -1817,0 +1876,4 @@
+	pool := p.pool.Load()
+	err := pool.Dial(ctx)
+
+	if pool.cancel != nil {

@@ -1817,0 +1879,4 @@
+	if pool.cancel != nil {
+		pool.cancel()
+	}
+	pool.startRebalance(ctx)

@@ -1817,0 +2023,4 @@
+	defer p.lockUpdate.Unlock()
+
+	pool := p.pool.Load()
+	pool.stopRebalance()

@@ -1945,0 +2192,4 @@
+	return true
+}
+
+// It is necessary to prevent parallel operations on the *pool instance.

@@ -1945,0 +2193,4 @@
+}
+
+// It is necessary to prevent parallel operations on the *pool instance.
+func (p *pool) Update(ctx context.Context, prm []NodeParam) (*pool, bool, error) {

@@ -1817,0 +1876,4 @@
+	pool := p.pool.Load()
+	err := pool.Dial(ctx)
+
+	if err != nil {

@@ -1817,0 +1881,4 @@
+	}
+
+	if pool.cancel != nil {
+		pool.cancelLock.Lock()

@@ -1817,0 +1817,4 @@
+	pool atomic.Pointer[pool]
+
+	// Ensures that pool.cancel will not be lost due to concurrent calls to Update().
+	lockUpdate sync.Mutex