profiling

type DefaultProfiling struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type EmptyProfiling struct {
	Profiling
}

type Profiling interface {
	StartExecution()
	StartExecutionWithTime(time time.Time)
	FinishExecution(save bool) error
	FinishExecutionWithTime(save bool, finishTime time.Time) error
	AddCheckpoint(name string) error
	AddCheckpointWithTime(name string, time time.Time) error
	GetCount() int
	Clear()
	GetTimeStatistics() *TimeStatistics
	GetQPSStatistics() (*QPSStatistics, error)
}

type ProfilingCache struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type QPSStatistics struct {
	FromTime  time.Time
	ToTime    time.Time
	Count     int
	StagesQPS map[string]*StageQPS
}

type StageQPS struct {
	From string
	To   string
	// qps per second between from-time and to-time
	Samples []int
	AvgQPS  float64
	MaxQPS  int
}

type StageTime struct {
	From       string
	To         string
	Count      int
	TotalTime  time.Duration
	AvgTime    time.Duration
	Percentage float64
}

type TimeStatistics struct {
	StartTime  time.Time
	FinishTime time.Time
	Count      int
	TotalTime  time.Duration
	AvgTime    time.Duration
	StagesTime []*StageTime
}