github-mirrors/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2024-12-31 15:06:26 +00:00
Code Issues Projects Releases Packages Wiki Activity

wip

Browse source
This commit is contained in:
Aliaksandr Valialkin 2024-04-24 11:35:11 +02:00
parent 8534ca0f88
commit e7685164f5
No known key found for this signature in database
GPG key ID: 52C003EE2BCDB9EB
2 changed files with 6 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
app/logsgenerator/main.go
View file

@ -114,7 +114,8 @@ func main() {
currBytes := bytesGenerated.Load() currBytes := bytesGenerated.Load()
deltaBytes := currBytes - prevBytes deltaBytes := currBytes - prevBytes
rateBytes := float64(deltaBytes) / statInterval.Seconds() rateBytes := float64(deltaBytes) / statInterval.Seconds()
logger.Infof("generated %d log entries at %.0fK entries/sec, %d bytes at %.0fMB/sec", deltaEntries, rateEntries/1e3, deltaBytes, rateBytes/1e6) logger.Infof("generated %dK log entries (%dK total) at %.0fK entries/sec, %dMB (%dMB total) at %.0fMB/sec",
deltaEntries/1e3, currEntries/1e3, rateEntries/1e3, deltaBytes/1e6, currBytes/1e6, rateBytes/1e6)
prevEntries = currEntries prevEntries = currEntries
prevBytes = currBytes prevBytes = currBytes
@ -128,7 +129,7 @@ func main() {
currBytes := bytesGenerated.Load() currBytes := bytesGenerated.Load()
rateEntries := float64(currEntries) / dSecs rateEntries := float64(currEntries) / dSecs
rateBytes := float64(currBytes) / dSecs rateBytes := float64(currBytes) / dSecs
logger.Infof("ingested %d log entries (%d bytes) in %.3f seconds; avg ingestion rate: %.0fK entries/sec, %.0fMB/sec", currEntries, currBytes, dSecs, rateEntries/1e3, rateBytes/1e6) logger.Infof("ingested %dK log entries (%dMB) in %.3f seconds; avg ingestion rate: %.0fK entries/sec, %.0fMB/sec", currEntries/1e3, currBytes/1e6, dSecs, rateEntries/1e3, rateBytes/1e6)
} }
var logEntriesCount atomic.Uint64 var logEntriesCount atomic.Uint64
@ -198,8 +199,8 @@ func generateLogsAtTimestamp(bw *bufio.Writer, workerID int, ts int64, firstStre
streamID := firstStreamID streamID := firstStreamID
timeStr := toRFC3339(ts) timeStr := toRFC3339(ts)
for i := 0; i < activeStreams; i++ { for i := 0; i < activeStreams; i++ {
fmt.Fprintf(bw, `{"_time":%q,"_msg":"some message %d for the stream %d; some foo bar baz error warn 1.2.3.4","host":"host_%d","worker_id":"%d"`, fmt.Fprintf(bw, `{"_time":%q,"_msg":"message #%d (%d) for the stream %d and worker %d; some foo bar baz error warn 1.2.3.4","host":"host_%d","worker_id":"%d"`,
timeStr, i, streamID, streamID, workerID) timeStr, ts, i, streamID, workerID, streamID, workerID)
for j := 0; j < varFieldsPerEntry; j++ { for j := 0; j < varFieldsPerEntry; j++ {
fmt.Fprintf(bw, `,"var_field_%d":"value_%d_%d_%d"`, j, i, j, streamID) fmt.Fprintf(bw, `,"var_field_%d":"value_%d_%d_%d"`, j, i, j, streamID)
} }

2
lib/logstorage/block_search.go
View file

@ -14,7 +14,7 @@ type blockSearchWork struct {
// p is the part where the block belongs to. // p is the part where the block belongs to.
p *part p *part
// so contains search options for the block search // so contains search options for the block search.
so *searchOptions so *searchOptions
// bh is the header of the block to search. // bh is the header of the block to search.