session

type ColumnInfo struct {
	Schema             string
	Table              string
	OrgTable           string
	Name               string
	OrgName            string
	ColumnLength       uint32
	Decimal            uint8
	Type               uint8
	DefaultValueLength uint64
	DefaultValue       []byte
}

type ProcessInfo struct {
}

type RecordSet interface {
	Columns() []*tspb.ColumnMeta
	// Next(context.Context )
	Next(context.Context) (interface{}, error)

	LastErr() error
	Close() error
}

type ResultSet interface {
	Columns() []*ColumnInfo
	NewChunk() *chunk.Chunk
	Next(context.Context, *chunk.Chunk) error
	StoreFetchedRows(rows []chunk.Row)
	GetFetchedRows() []chunk.Row
	Close() error
}

type RetrieveTxnOpt struct {
	Committable bool
	IsRawKV     bool
}

type Session interface {
	sessionctx.Context

	Close()

	SetLabels(map[string]string)
	Labels() map[string]string

	HandleRead(context.Context, rpc.ReadRequest, kv.Transaction) (RecordSet, error)
	HandleMutate(context.Context, rpc.MutationRequest, kv.Transaction) (rpc.Response, error)

	RetrieveTxn(context.Context, *tspb.TransactionSelector, *RetrieveTxnOpt) (*TxnState, error)

	RawkvAccess(context.Context, string) (bool, error)

	CommitTxn(context.Context, kv.Transaction) error
	RollbackTxn(context.Context, kv.Transaction) error

	SetDB(db string)
	GetName() string
	ToProto() *tspb.Session

	SetLastActive(time.Time)
	LastActive() time.Time
	Active() bool
}

type SessionManager interface {
	ShowProcessList() map[uint64]*ProcessInfo
	GetProcessInfo(id uint64) (*ProcessInfo, bool)
	Kill(connectionID uint64, query bool)
}

type TxnState struct {
	// States of a TxnState should be one of the followings:
	// Invalid: kv.Transaction == nil && txnFuture == nil
	// Pending: kv.Transaction == nil && txnFuture != nil
	// Valid:	kv.Transaction != nil && txnFuture == nil
	ID string

	kv.Transaction

	TxnOpt TxnStateOption
	// contains filtered or unexported fields
}

type TxnStateOption struct {
	ReadOnly bool
	Single   bool
	// contains filtered or unexported fields
}