()
| 308 | var testingTaskInitOnce = &sync.Once{} |
| 309 | |
| 310 | func initTestingTask() { |
| 311 | testingTask = metrics.NewKVTask(&serverconfigs.MetricItemConfig{ |
| 312 | Id: 1, |
| 313 | IsOn: false, |
| 314 | Category: "tcp", |
| 315 | Period: 1, |
| 316 | PeriodUnit: serverconfigs.MetricItemPeriodUnitDay, |
| 317 | Keys: []string{"${remoteAddr}"}, |
| 318 | Value: "${countRequest}", |
| 319 | }) |
| 320 | |
| 321 | err := testingTask.Init() |
| 322 | if err != nil { |
| 323 | log.Fatal(err) |
| 324 | } |
| 325 | |
| 326 | err = testingTask.Start() |
| 327 | if err != nil { |
| 328 | log.Fatal(err) |
| 329 | } |
| 330 | } |
| 331 | |
| 332 | func BenchmarkKVTask_Add(b *testing.B) { |
| 333 | runtime.GOMAXPROCS(1) |
no test coverage detected