reorderer

type Metric struct {
	TotalOp    uint64
	TotalDepth uint64
	QueueSize  uint64
}

type Monitor struct {
	// contains filtered or unexported fields
}

type Opts struct {
	QueueSize       uint64        // size of the chan where the perf data are pushed
	Rate            time.Duration // delay between two time based iterations
	Retention       uint64        // bucket to keep before dequeueing
	MetricRate      time.Duration // delay between two metric samples
	HeapShrinkDelta int           // delta between cap and len between releasing heap array
}

type OrderedPerfMap struct {
	// contains filtered or unexported fields
}

type QuickInfo struct {
	CPU       uint64
	Timestamp uint64
}

type QuickInfoExtractor = func(record *perf.Record) (QuickInfo, error)

type ReOrderer struct {
	Metrics chan Metric
	// contains filtered or unexported fields
}

type RecordPool struct {
	// contains filtered or unexported fields
}