sessions

Documentation

Index

• type ProgressValues
• type Session
  • func NewSession() *Session
  • func (s *Session) Close()
  • func (s *Session) GetDatabase() string
  • func (s *Session) GetProgress() *ProgressValues
  • func (s *Session) SetDatabase(db string)
  • func (s *Session) UpdateProgress(pv *ProgressValues)

Types

type ProgressValues

type ProgressValues struct {

	// 花费了多长时间
	Cost sync2.AtomicDuration

	// 读取了多少行
	ReadRows sync2.AtomicInt64

	// 读取了多少个字节
	ReadBytes sync2.AtomicInt64

	// 总共读取了多少行
	TotalRowsToRead sync2.AtomicInt64

	// 写了多少行
	WrittenRows sync2.AtomicInt64

	// 写了多少个字节
	WrittenBytes sync2.AtomicInt64
}

ProgressValues 一些统计信息，为了成本优化的时候使用

type Session

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

查询的会话信息，用于统计做成本优化之类的

func NewSession

func NewSession() *Session

func (*Session) Close

func (s *Session) Close()

func (*Session) GetDatabase

func (s *Session) GetDatabase() string

func (*Session) GetProgress

func (s *Session) GetProgress() *ProgressValues

func (*Session) SetDatabase

func (s *Session) SetDatabase(db string)

func (*Session) UpdateProgress

func (s *Session) UpdateProgress(pv *ProgressValues)