session

Documentation

Index

• Variables
• type Config
• type Session
  • func CreateSession(ctx context.Context, qsc Ydb_Query_V1.QueryServiceClient, logger logger.Logger, ...) (*Session, error)
  • func (s *Session) Alive() bool
  • func (s *Session) Close() error
  • func (s *Session) CommitTX(ctx context.Context, txID string) error
  • func (s *Session) Exec(ctx context.Context, query string, params map[string]*Ydb.TypedValue, ...) (Ydb_Query_V1.QueryService_ExecuteQueryClient, context.CancelFunc, error)
  • func (s *Session) ID() uint64
  • func (s *Session) RollbackTX(ctx context.Context, txID string) error

Variables

var (
	ErrExec       = errors.New("exec error")
	ErrTxRollback = errors.New("transaction rollback error")
	ErrTxCommit   = errors.New("transaction commit error")
	ErrShutdown   = errors.New("session is shut down")
)

var (
	ErrSessionCreate    = errors.New("session create failed")
	ErrSessionTransport = errors.New("session transport was not provided")
	ErrSessionAttach    = errors.New("session attach failed")
	ErrSessionDelete    = errors.New("session delete failed")
)

Types

type Config

type Config struct {
	Transport      grpc.ClientConnInterface
	CreateResponse *Ydb_Query.CreateSessionResponse
	Logger         logger.Logger
}

type Session

type Session struct {
	// contains filtered or unexported fields
}

func CreateSession

func CreateSession(
	ctx context.Context,
	qsc Ydb_Query_V1.QueryServiceClient,
	logger logger.Logger,
	timeout time.Duration,
) (*Session, error)

func (*Session) Alive

func (s *Session) Alive() bool

func (*Session) Close

func (s *Session) Close() error

func (*Session) CommitTX

func (s *Session) CommitTX(ctx context.Context, txID string) error

func (*Session) Exec

func (s *Session) Exec(
	ctx context.Context,
	query string,
	params map[string]*Ydb.TypedValue,
	txControl *Ydb_Query.TransactionControl,
) (Ydb_Query_V1.QueryService_ExecuteQueryClient, context.CancelFunc, error)

func (*Session) ID

func (s *Session) ID() uint64

func (*Session) RollbackTX

func (s *Session) RollbackTX(ctx context.Context, txID string) error