remove create session options

Author: asmyasnikov

internal/query/client.go

@@ -304,11 +304,7 @@ func New(ctx context.Context, balancer grpc.ClientConnInterface, cfg *config.Con
 			}
 			defer cancelCreate()
 
-			s, err := createSession(createCtx, client.grpcClient, cfg,
-				withSessionCheck(func(s *Session) bool {
-					return true
-				}),
-			)
+			s, err := createSession(createCtx, client.grpcClient, cfg)
 			if err != nil {
 				return nil, xerrors.WithStackTrace(err)
 			}

internal/query/session.go

@@ -21,18 +21,15 @@ import (
 
 var _ query.Session = (*Session)(nil)
 
-type (
-	Session struct {
-		cfg        *config.Config
-		id         string
-		nodeID     int64
-		grpcClient Ydb_Query_V1.QueryServiceClient
-		statusCode statusCode
-		closeOnce  func(ctx context.Context) error
-		checks     []func(s *Session) bool
-	}
-	sessionOption func(session *Session)
-)
+type Session struct {
+	cfg        *config.Config
+	id         string
+	nodeID     int64
+	grpcClient Ydb_Query_V1.QueryServiceClient
+	statusCode statusCode
+	closeOnce  func(ctx context.Context) error
+	checks     []func(s *Session) bool
+}
 
 func (s *Session) ReadRow(ctx context.Context, q string, opts ...options.ExecuteOption) (row query.Row, _ error) {
 	_, r, err := s.Execute(ctx, q, opts...)
@@ -74,15 +71,9 @@ func (s *Session) ReadResultSet(ctx context.Context, q string, opts ...options.E
 	return rs, nil
 }
 
-func withSessionCheck(f func(*Session) bool) sessionOption {
-	return func(s *Session) {
-		s.checks = append(s.checks, f)
-	}
-}
-
-func createSession(
-	ctx context.Context, client Ydb_Query_V1.QueryServiceClient, cfg *config.Config, opts ...sessionOption,
-) (s *Session, finalErr error) {
+func createSession(ctx context.Context, client Ydb_Query_V1.QueryServiceClient, cfg *config.Config) (
+	s *Session, finalErr error,
+) {
 	s = &Session{
 		cfg:        cfg,
 		grpcClient: client,
@@ -94,10 +85,6 @@ func createSession(
 		}
 	}()
 
-	for _, opt := range opts {
-		opt(s)
-	}
-
 	onDone := trace.QueryOnSessionCreate(s.cfg.Trace(), &ctx,
 		stack.FunctionID("github.com/ydb-platform/ydb-go-sdk/3/internal/query.createSession"),
 	)