Offline Cross Profiler ((full)) Official

if idx%1024 == 0 // Flush every 1024 events r.flush()

package offlineprofiler import ( "os" "sync/atomic" "time" "github.com/segmentio/kafka-go/snappy" ) offline cross profiler

func (r *RingRecorder) flush() // Snappy compress and write to offline file // No analysis happens here. if idx%1024 == 0 // Flush every 1024 events r