Merge branch 'master' into transactions-topic-query

Author: rekby

CHANGELOG.md

@@ -1,4 +1,5 @@
 * Added traces and logs for read messages from topic within transaction
+* Changed result type of `query.Session.NodeID()` from `int64` to `uint32` for compatibility with table session and discovery
 * Removed experimental method `query.Result.Err()`
 * Added the finishing reading the grpc stream on `query.Result.Close()` call
 * Renamed experimental method `query.Result.Range()` to `query.Result.ResultSets()`

internal/query/session.go

@@ -24,8 +24,8 @@ var _ query.Session = (*Session)(nil)
 type Session struct {
 	cfg        *config.Config
 	id         string
-	nodeID     int64
 	grpcClient Ydb_Query_V1.QueryServiceClient
+	nodeID     uint32
 	statusCode statusCode
 	closeOnce  func(ctx context.Context) error
 	checks     []func(s *Session) bool
@@ -108,7 +108,7 @@ func createSession(ctx context.Context, client Ydb_Query_V1.QueryServiceClient,
 	}
 
 	s.id = response.GetSessionId()
-	s.nodeID = response.GetNodeId()
+	s.nodeID = uint32(response.GetNodeId())
 
 	err = s.attach(ctx)
 	if err != nil {
@@ -278,7 +278,7 @@ func (s *Session) ID() string {
 	return s.id
 }
 
-func (s *Session) NodeID() int64 {
+func (s *Session) NodeID() uint32 {
 	return s.nodeID
 }
 

query/session.go

@@ -13,7 +13,7 @@ import (
 type (
 	SessionInfo interface {
 		ID() string
-		NodeID() int64
+		NodeID() uint32
 		Status() string
 	}
 

trace/query.go

@@ -13,7 +13,7 @@ import (
 type (
 	querySessionInfo interface {
 		ID() string
-		NodeID() int64
+		NodeID() uint32
 		Status() string
 	}
 	queryTransactionInfo interface {