fix require in lambdas

Author: asmyasnikov

internal/coordination/client.go

@@ -45,7 +45,7 @@ func (c *Client) CreateNode(ctx context.Context, path string, config coordinatio
 	if !c.config.AutoRetry() {
 		return call(ctx)
 	}
-	return retry.Retry(ctx, call, retry.WithStackTrace())
+	return retry.Retry(ctx, call, retry.WithStackTrace(), retry.WithIdempotent(true))
 }
 
 func (c *Client) createNode(ctx context.Context, path string, config coordination.NodeConfig) (err error) {
@@ -82,7 +82,7 @@ func (c *Client) AlterNode(ctx context.Context, path string, config coordination
 	if !c.config.AutoRetry() {
 		return call(ctx)
 	}
-	return retry.Retry(ctx, call, retry.WithStackTrace())
+	return retry.Retry(ctx, call, retry.WithStackTrace(), retry.WithIdempotent(true))
 }
 
 func (c *Client) alterNode(ctx context.Context, path string, config coordination.NodeConfig) (err error) {
@@ -119,7 +119,7 @@ func (c *Client) DropNode(ctx context.Context, path string) (err error) {
 	if !c.config.AutoRetry() {
 		return call(ctx)
 	}
-	return retry.Retry(ctx, call, retry.WithStackTrace())
+	return retry.Retry(ctx, call, retry.WithStackTrace(), retry.WithIdempotent(true))
 }
 
 func (c *Client) dropNode(ctx context.Context, path string) (err error) {
@@ -158,7 +158,7 @@ func (c *Client) DescribeNode(
 		err = call(ctx)
 		return
 	}
-	err = retry.Retry(ctx, call, retry.WithStackTrace())
+	err = retry.Retry(ctx, call, retry.WithStackTrace(), retry.WithIdempotent(true))
 	return
 }
 

internal/ratelimiter/client.go

@@ -58,7 +58,7 @@ func (c *Client) CreateResource(
 	if !c.config.AutoRetry() {
 		return call(ctx)
 	}
-	return retry.Retry(ctx, call, retry.WithStackTrace())
+	return retry.Retry(ctx, call, retry.WithStackTrace(), retry.WithIdempotent(true))
 }
 
 func (c *Client) createResource(
@@ -101,7 +101,7 @@ func (c *Client) AlterResource(
 	if !c.config.AutoRetry() {
 		return call(ctx)
 	}
-	return retry.Retry(ctx, call, retry.WithStackTrace())
+	return retry.Retry(ctx, call, retry.WithStackTrace(), retry.WithIdempotent(true))
 }
 
 func (c *Client) alterResource(
@@ -144,7 +144,7 @@ func (c *Client) DropResource(
 	if !c.config.AutoRetry() {
 		return call(ctx)
 	}
-	return retry.Retry(ctx, call, retry.WithStackTrace())
+	return retry.Retry(ctx, call, retry.WithStackTrace(), retry.WithIdempotent(true))
 }
 
 func (c *Client) dropResource(

internal/scheme/client.go

@@ -51,7 +51,7 @@ func (c *Client) MakeDirectory(ctx context.Context, path string) (err error) {
 	if !c.config.AutoRetry() {
 		return call(ctx)
 	}
-	return retry.Retry(ctx, call, retry.WithStackTrace())
+	return retry.Retry(ctx, call, retry.WithStackTrace(), retry.WithIdempotent(true))
 }
 
 func (c *Client) makeDirectory(ctx context.Context, path string) (err error) {
@@ -80,7 +80,7 @@ func (c *Client) RemoveDirectory(ctx context.Context, path string) (err error) {
 	if !c.config.AutoRetry() {
 		return call(ctx)
 	}
-	return retry.Retry(ctx, call, retry.WithStackTrace())
+	return retry.Retry(ctx, call, retry.WithStackTrace(), retry.WithIdempotent(true))
 }
 
 func (c *Client) removeDirectory(ctx context.Context, path string) (err error) {
@@ -207,7 +207,7 @@ func (c *Client) ModifyPermissions(ctx context.Context, path string, opts ...sch
 	if !c.config.AutoRetry() {
 		return call(ctx)
 	}
-	return retry.Retry(ctx, call, retry.WithStackTrace())
+	return retry.Retry(ctx, call, retry.WithStackTrace(), retry.WithIdempotent(true))
 }
 
 func (c *Client) modifyPermissions(ctx context.Context, path string, opts ...scheme.PermissionsOption) (err error) {

internal/scripting/client.go

@@ -120,7 +120,7 @@ func (c *Client) Explain(
 		err = call(ctx)
 		return
 	}
-	err = retry.Retry(ctx, call, retry.WithStackTrace())
+	err = retry.Retry(ctx, call, retry.WithStackTrace(), retry.WithIdempotent(true))
 	return
 }
 

internal/table/client.go

@@ -501,8 +501,8 @@ func (c *Client) internalPoolGet(ctx context.Context, opts ...getOption) (s *ses
 		})
 		return s, xerrors.WithStackTrace(
 			fmt.Errorf("failed to get session from pool ("+
-				"attempts: %d, latency: %v, stats: {index: %d, idle: %d, create_in_progress: %d}"+
-				"): %w", i, time.Since(start), index, idle, createInProgress, err,
+				"attempts: %d, latency: %v, pool have %d sessions (%d busy, %d idle, %d create_in_progress): %w",
+				i, time.Since(start), index, index-idle, idle, createInProgress, err,
 			),
 		)
 	}

internal/table/scanner/result.go

@@ -9,17 +9,13 @@ import (
 	"github.com/ydb-platform/ydb-go-genproto/protos/Ydb"
 	"github.com/ydb-platform/ydb-go-genproto/protos/Ydb_TableStats"
 
-	"github.com/ydb-platform/ydb-go-sdk/v3/internal/value"
 	"github.com/ydb-platform/ydb-go-sdk/v3/internal/xerrors"
 	"github.com/ydb-platform/ydb-go-sdk/v3/internal/xsync"
 	"github.com/ydb-platform/ydb-go-sdk/v3/table/result"
 	"github.com/ydb-platform/ydb-go-sdk/v3/table/stats"
 )
 
-var (
-	errAlreadyClosed     = xerrors.Wrap(errors.New("result closed early"))
-	errMissingCurrentRow = xerrors.Wrap(errors.New("missing current row"))
-)
+var errAlreadyClosed = xerrors.Wrap(errors.New("result closed early"))
 
 type baseResult struct {
 	scanner
@@ -60,17 +56,6 @@ func (r *baseResult) isClosed() bool {
 	return atomic.LoadUint32(&r.closed) != 0
 }
 
-func (r *baseResult) RowValues() (_ []value.Value, err error) {
-	if r.row == nil {
-		return nil, xerrors.WithStackTrace(errMissingCurrentRow)
-	}
-	values := make([]value.Value, len(r.row.GetItems()))
-	for i, item := range r.row.GetItems() {
-		values[i] = value.FromYDB(r.set.GetColumns()[i].GetType(), item)
-	}
-	return values, nil
-}
-
 type resultWithError interface {
 	SetErr(err error)
 }