fix

ydb-platform · Nov 1, 2024 · 4d57263 · 4d57263
1 parent 65a8374
commit 4d57263
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/internal/table/client.go b/internal/table/client.go
@@ -219,7 +219,7 @@ func (c *Client) Do(ctx context.Context, op table.Operation, opts ...table.Optio
 
 	err := do(ctx, c.pool, c.config, op, func(err error) {
 		attempts++
-	}, config.preferredNodeID, config.RetryOptions...)
+	}, config.PreferredNodeID, config.RetryOptions...)
 	if err != nil {
 		return xerrors.WithStackTrace(err)
 	}
@@ -270,7 +270,7 @@ func (c *Client) DoTx(ctx context.Context, op table.TxOperation, opts ...table.O
 		}
 
 		return nil
-	}, config.preferredNodeID, config.RetryOptions...)
+	}, config.PreferredNodeID, config.RetryOptions...)
 }
 
 func (c *Client) BulkUpsert(

diff --git a/table/table.go b/table/table.go
@@ -505,7 +505,7 @@ type Options struct {
 	TxCommitOptions []options.CommitTransactionOption
 	RetryOptions    []retry.Option
 	Trace           *trace.Table
-	preferredNodeID uint32
+	PreferredNodeID uint32
 }
 
 type Option interface {
@@ -517,7 +517,7 @@ type SessionOption struct {
 }
 
 func (o SessionOption) ApplyTableOption(opts *Options) {
-	opts.preferredNodeID = o.preferredNodeID
+	opts.PreferredNodeID = o.preferredNodeID
 }
 
 var _ Option = labelOption("")
@@ -557,7 +557,7 @@ func WithIdempotent() retryOptionsOption {
 	return []retry.Option{retry.WithIdempotent(true)}
 }
 
-func WithpreferredNodeID(nodeId uint32) SessionOption {
+func WithPreferredNodeID(nodeId uint32) SessionOption {
 	return SessionOption{preferredNodeID: nodeId}
 }