offline_stat

type BinlogFile struct {
	StartLogFile string `json:"start_log_file"`
	StartLogPos  uint32 `json:"start_log_pos"`
}

type DmlStat struct {
	InsertCount int `json:"insert_count"`
	UpdateCount int `json:"update_count"`
	DeleteCount int `json:"delete_count"`
}

type OfflineStat struct {
	OfflineStatCfg         *config.OfflineStatConfig
	TotalTableStatMap      map[string]*TableBinlogStat
	TotalThreadStatMap     map[uint32]*ThreadBinlogStat
	TotalTransactionStats  []*TransactionBinlogStat
	TotalTimestampStats    []*TimestampBinlogStat
	CurrentTimestampStat   *TimestampBinlogStat
	CurrentTransactionStat *TransactionBinlogStat
	CurrentTreadId         uint32
	CurrentXid             uint64
	CurrentTimestamp       uint32
	CurrentSchemaName      string
	CurrentTableName       string
	CurrentLogFile         string
	CurrentLogPos          uint32
}

type TableBinlogStat struct {
	DmlStat
	SchemaName  string `json:"schema_name"`
	TableName   string `json:"table_name"`
	AppearCount int64  `json:"appear_count"`
}

type ThreadBinlogStat struct {
	DmlStat
	ThreadId    uint32 `json:"thread_id"`
	AppearCount int64  `json:"appear_count"`
}

type TimestampBinlogStat struct {
	DmlStat
	BinlogFile
	Timestamp uint32 `json:"timestamp"`
	TxCount   int64  `json:"tx_count"`
}

type TransactionBinlogStat struct {
	DmlStat
	BinlogFile
	Xid       uint64 `json:"xid"`
	Timestamp uint32 `json:"timestamp"`
}