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
}

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)