etcd-io
/
dbtester
mirror of https://github.com/etcd-io/dbtester.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

analyze: add 'BytesDeltaSum'

This commit is contained in:
Gyu-Ho Lee 2017-02-13 14:17:20 -08:00
parent 78d4b7df73
commit 403ebab012
No known key found for this signature in database
GPG Key ID: 1DDD39C7EB70C24C
2 changed files with 20 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
analyze/01_read_raw_data_to_test_data.go
View File

@ -38,6 +38,8 @@ var sysMetricsColumnsToRead = []string{
"WRITES-COMPLETED-DELTA", "WRITES-COMPLETED-DELTA",
"SECTORS-WRITTEN", "SECTORS-WRITTEN",
"SECTORS-WRITTEN-DELTA", "SECTORS-WRITTEN-DELTA",
"READ-BYTES-DELTA",
"WRITE-BYTES-DELTA",
"RECEIVE-BYTES-NUM", "RECEIVE-BYTES-NUM",
"RECEIVE-BYTES-NUM-DELTA", "RECEIVE-BYTES-NUM-DELTA",
"TRANSMIT-BYTES-NUM", "TRANSMIT-BYTES-NUM",

18
analyze/04_aggregate_all_analyze_data.go
View File

@ -133,6 +133,8 @@ func (data *analyzeData) aggregateAll(memoryByKeyPath string, totalRequests int6
avgWritesCompletedDeltaCol = dataframe.NewColumn("AVG-WRITES-COMPLETED-DELTA") // from WRITES-COMPLETED-DELTA avgWritesCompletedDeltaCol = dataframe.NewColumn("AVG-WRITES-COMPLETED-DELTA") // from WRITES-COMPLETED-DELTA
avgSectorsWrittenCol = dataframe.NewColumn("AVG-SECTORS-WRITTEN") // from SECTORS-WRITTEN avgSectorsWrittenCol = dataframe.NewColumn("AVG-SECTORS-WRITTEN") // from SECTORS-WRITTEN
avgSectorsWrittenDeltaCol = dataframe.NewColumn("AVG-SECTORS-WRITTEN-DELTA") // from SECTORS-WRITTEN-DELTA avgSectorsWrittenDeltaCol = dataframe.NewColumn("AVG-SECTORS-WRITTEN-DELTA") // from SECTORS-WRITTEN-DELTA
avgReadBytesNumDeltaCol = dataframe.NewColumn("AVG-READ-BYTES-NUM-DELTA") // from READ-BYTES-DELTA
avgWriteBytesNumDeltaCol = dataframe.NewColumn("AVG-WRITE-BYTES-NUM-DELTA") // from WRITE-BYTES-DELTA
avgReceiveBytesNumCol = dataframe.NewColumn("AVG-RECEIVE-BYTES-NUM") // from RECEIVE-BYTES-NUM avgReceiveBytesNumCol = dataframe.NewColumn("AVG-RECEIVE-BYTES-NUM") // from RECEIVE-BYTES-NUM
avgReceiveBytesNumDeltaCol = dataframe.NewColumn("AVG-RECEIVE-BYTES-NUM-DELTA") // from RECEIVE-BYTES-NUM-DELTA avgReceiveBytesNumDeltaCol = dataframe.NewColumn("AVG-RECEIVE-BYTES-NUM-DELTA") // from RECEIVE-BYTES-NUM-DELTA
avgTransmitBytesNumCol = dataframe.NewColumn("AVG-TRANSMIT-BYTES-NUM") // from TRANSMIT-BYTES-NUM avgTransmitBytesNumCol = dataframe.NewColumn("AVG-TRANSMIT-BYTES-NUM") // from TRANSMIT-BYTES-NUM
@ -160,6 +162,8 @@ func (data *analyzeData) aggregateAll(memoryByKeyPath string, totalRequests int6
writesCompletedDeltaSum float64 writesCompletedDeltaSum float64
sectorsWrittenSum float64 sectorsWrittenSum float64
sectorsWrittenDeltaSum float64 sectorsWrittenDeltaSum float64
readBytesDeltaSum float64
writeBytesDeltaSum float64
receiveBytesNumSum float64 receiveBytesNumSum float64
receiveBytesNumDeltaSum float64 receiveBytesNumDeltaSum float64
transmitBytesNumSum float64 transmitBytesNumSum float64
@ -230,6 +234,10 @@ func (data *analyzeData) aggregateAll(memoryByKeyPath string, totalRequests int6
sectorsWrittenDeltaSum += vv sectorsWrittenDeltaSum += vv
case strings.HasPrefix(hd, "SECTORS-WRITTEN-"): case strings.HasPrefix(hd, "SECTORS-WRITTEN-"):
sectorsWrittenSum += vv sectorsWrittenSum += vv
case strings.HasPrefix(hd, "READ-BYTES-DELTA-"):
readBytesDeltaSum += vv
case strings.HasPrefix(hd, "WRITE-BYTES-DELTA-"):
writeBytesDeltaSum += vv
case strings.HasPrefix(hd, "RECEIVE-BYTES-NUM-DELTA-"): case strings.HasPrefix(hd, "RECEIVE-BYTES-NUM-DELTA-"):
receiveBytesNumDeltaSum += vv receiveBytesNumDeltaSum += vv
case strings.HasPrefix(hd, "RECEIVE-BYTES-NUM-"): case strings.HasPrefix(hd, "RECEIVE-BYTES-NUM-"):
@ -255,6 +263,8 @@ func (data *analyzeData) aggregateAll(memoryByKeyPath string, totalRequests int6
avgWritesCompletedDeltaCol.PushBack(dataframe.NewStringValue(fmt.Sprintf("%.2f", writesCompletedDeltaSum/sampleSize))) avgWritesCompletedDeltaCol.PushBack(dataframe.NewStringValue(fmt.Sprintf("%.2f", writesCompletedDeltaSum/sampleSize)))
avgSectorsWrittenCol.PushBack(dataframe.NewStringValue(fmt.Sprintf("%.2f", sectorsWrittenSum/sampleSize))) avgSectorsWrittenCol.PushBack(dataframe.NewStringValue(fmt.Sprintf("%.2f", sectorsWrittenSum/sampleSize)))
avgSectorsWrittenDeltaCol.PushBack(dataframe.NewStringValue(fmt.Sprintf("%.2f", sectorsWrittenDeltaSum/sampleSize))) avgSectorsWrittenDeltaCol.PushBack(dataframe.NewStringValue(fmt.Sprintf("%.2f", sectorsWrittenDeltaSum/sampleSize)))
avgReadBytesNumDeltaCol.PushBack(dataframe.NewStringValue(fmt.Sprintf("%.2f", readBytesDeltaSum/sampleSize)))
avgWriteBytesNumDeltaCol.PushBack(dataframe.NewStringValue(fmt.Sprintf("%.2f", writeBytesDeltaSum/sampleSize)))
avgReceiveBytesNumCol.PushBack(dataframe.NewStringValue(fmt.Sprintf("%.2f", receiveBytesNumSum/sampleSize))) avgReceiveBytesNumCol.PushBack(dataframe.NewStringValue(fmt.Sprintf("%.2f", receiveBytesNumSum/sampleSize)))
avgReceiveBytesNumDeltaCol.PushBack(dataframe.NewStringValue(fmt.Sprintf("%.2f", receiveBytesNumDeltaSum/sampleSize))) avgReceiveBytesNumDeltaCol.PushBack(dataframe.NewStringValue(fmt.Sprintf("%.2f", receiveBytesNumDeltaSum/sampleSize)))
avgTransmitBytesNumCol.PushBack(dataframe.NewStringValue(fmt.Sprintf("%.2f", transmitBytesNumSum/sampleSize))) avgTransmitBytesNumCol.PushBack(dataframe.NewStringValue(fmt.Sprintf("%.2f", transmitBytesNumSum/sampleSize)))
@ -307,6 +317,12 @@ func (data *analyzeData) aggregateAll(memoryByKeyPath string, totalRequests int6
if err = data.aggregated.AddColumn(avgSectorsWrittenDeltaCol); err != nil { if err = data.aggregated.AddColumn(avgSectorsWrittenDeltaCol); err != nil {
return err return err
} }
if err = data.aggregated.AddColumn(avgReadBytesNumDeltaCol); err != nil {
return err
}
if err = data.aggregated.AddColumn(avgWriteBytesNumDeltaCol); err != nil {
return err
}
if err = data.aggregated.AddColumn(avgReceiveBytesNumCol); err != nil { if err = data.aggregated.AddColumn(avgReceiveBytesNumCol); err != nil {
return err return err
} }
@ -366,6 +382,8 @@ func (data *analyzeData) aggregateAll(memoryByKeyPath string, totalRequests int6
"AVG-READS-COMPLETED-DELTA", "AVG-READS-COMPLETED-DELTA",
"AVG-SECTORS-READ", "AVG-SECTORS-READ",
"AVG-SECTORS-READ-DELTA", "AVG-SECTORS-READ-DELTA",
"AVG-READ-BYTES-NUM-DELTA",
"AVG-WRITE-BYTES-NUM-DELTA",
"AVG-RECEIVE-BYTES-NUM", "AVG-RECEIVE-BYTES-NUM",
"AVG-RECEIVE-BYTES-NUM-DELTA", "AVG-RECEIVE-BYTES-NUM-DELTA",
"AVG-TRANSMIT-BYTES-NUM", "AVG-TRANSMIT-BYTES-NUM",