Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
var (
// DumpStatsDeltaRatio is the lower bound of `Modify Count / Table Count` for stats delta to be dumped.
DumpStatsDeltaRatio = 1 / 10000.0
)
Functions ¶
func NewStatsUsageImpl ¶
func NewStatsUsageImpl(statsHandle statstypes.StatsHandle) statstypes.StatsUsage
NewStatsUsageImpl creates a statstypes.StatsUsage.
func UpdateTableDeltaMap ¶
func UpdateTableDeltaMap(m map[int64]variable.TableDelta, id int64, delta int64, count int64, colSize *map[int64]int64)
UpdateTableDeltaMap updates the delta of the table.
Types ¶
type SessionStatsItem ¶
SessionStatsItem is a list item that holds the delta mapper. If you want to write or read mapper, you must lock it.
func (*SessionStatsItem) ClearForTest ¶
func (s *SessionStatsItem) ClearForTest()
ClearForTest clears the mapper for test.
func (*SessionStatsItem) Delete ¶
func (s *SessionStatsItem) Delete()
Delete only sets the deleted flag true, it will be deleted from list when DumpStatsDeltaToKV is called.
func (*SessionStatsItem) UpdateColStatsUsage ¶
func (s *SessionStatsItem) UpdateColStatsUsage(colItems iter.Seq[model.TableItemID], updateTime time.Time)
UpdateColStatsUsage updates the last time when the column stats are used(needed).
type SessionStatsList ¶
type SessionStatsList struct {
// contains filtered or unexported fields
}
SessionStatsList is a list of SessionStatsItem, which is used to collect stats usage and table delta information from sessions. TODO: merge SessionIndexUsage into this list.
[session1] [session2] [sessionN]
| | |
update into update into update into
| | |
v v v
[StatsList.Head] --> [session1.StatsItem] --> [session2.StatsItem] --> ... --> [sessionN.StatsItem]
| | |
+-------------------------+---------------------------------+
|
collect and dump into storage periodically
|
v
[storage]
func NewSessionStatsList ¶
func NewSessionStatsList() *SessionStatsList
NewSessionStatsList initializes a new SessionStatsList.
func (*SessionStatsList) NewSessionStatsItem ¶
func (sl *SessionStatsList) NewSessionStatsItem() *SessionStatsItem
NewSessionStatsItem allocates a stats collector for a session.
func (*SessionStatsList) ResetSessionStatsList ¶
func (sl *SessionStatsList) ResetSessionStatsList()
ResetSessionStatsList resets this list.
func (*SessionStatsList) SessionStatsUsage ¶
func (sl *SessionStatsList) SessionStatsUsage() *StatsUsage
SessionStatsUsage returns the current *StatsUsage.
func (*SessionStatsList) SessionTableDelta ¶
func (sl *SessionStatsList) SessionTableDelta() *TableDelta
SessionTableDelta returns the current *TableDelta.
func (*SessionStatsList) SweepSessionStatsList ¶
func (sl *SessionStatsList) SweepSessionStatsList()
SweepSessionStatsList will loop over the list, merge each session's local stats into handle and remove closed session's collector.
type StatsUsage ¶
type StatsUsage struct {
// contains filtered or unexported fields
}
StatsUsage maps (tableID, columnID) to the last time when the column stats are used(needed). All methods of it are thread-safe.
func (*StatsUsage) GetUsageAndReset ¶
func (m *StatsUsage) GetUsageAndReset() map[model.TableItemID]time.Time
GetUsageAndReset gets the usage and resets the StatsUsage.
func (*StatsUsage) Merge ¶
func (m *StatsUsage) Merge(other map[model.TableItemID]time.Time)
Merge merges the usageMap into the StatsUsage.
func (*StatsUsage) MergeRawData ¶
func (m *StatsUsage) MergeRawData(raw iter.Seq[model.TableItemID], updateTime time.Time)
MergeRawData merges the new data passed by iterator.
type TableDelta ¶
type TableDelta struct {
// contains filtered or unexported fields
}
TableDelta is used to collect tables' change information. All methods of it are thread-safe.
func (*TableDelta) GetDeltaAndReset ¶
func (m *TableDelta) GetDeltaAndReset() map[int64]variable.TableDelta
GetDeltaAndReset gets the delta and resets the TableDelta.
func (*TableDelta) Merge ¶
func (m *TableDelta) Merge(deltaMap map[int64]variable.TableDelta)
Merge merges the deltaMap into the TableDelta.
Source Files
Directories