Function init

internal/utils/dbs/query_stat_manager.go:17–42

()

)

func init() {
	if !teaconst.IsMain {
		return
	}

	var ticker = time.NewTicker(5 * time.Second)

	events.On(events.EventLoaded, func() {
		if teaconst.EnableDBStat {
			goman.New(func() {
				for range ticker.C {
					var stats = []string{}
					for _, stat := range SharedQueryStatManager.TopN(10) {
						var avg = stat.CostTotal / float64(stat.Calls)
						var query = stat.Query
						if len(query) > 128 {
							query = query[:128]
						}
						stats = append(stats, fmt.Sprintf("%.2fms/%.2fms/%.2fms - %d - %s", stat.CostMin*1000, stat.CostMax*1000, avg*1000, stat.Calls, query))
					}
					logs.Println("\n========== DB STATS ==========\n" + strings.Join(stats, "\n") + "\n=============================")
				}
			})
		}
	})
}

var SharedQueryStatManager = NewQueryStatManager()