Function TestKVTask_CleanExpired

internal/metrics/task_kv_test.go:200–234

(t *testing.T)

}

func TestKVTask_CleanExpired(t *testing.T) {
	var task = metrics.NewKVTask(&serverconfigs.MetricItemConfig{
		Id:         1,
		IsOn:       false,
		Category:   "",
		Period:     1,
		PeriodUnit: serverconfigs.MetricItemPeriodUnitDay,
		Keys:       []string{"${remoteAddr}"},
		Value:      "${countRequest}",
		Version:    1,
	})
	err := task.Init()
	if err != nil {
		t.Fatal(err)
	}
	err = task.Start()
	if err != nil {
		t.Fatal(err)
	}
	defer func() {
		_ = task.Stop()
	}()

	err = task.CleanExpired()
	if err != nil {
		t.Fatal(err)
	}

	defer func() {
		_ = task.Flush()
	}()

	t.Log("=== inspect ===")
	task.TestInspect(t)
}

func TestKVTask_Upload(t *testing.T) {
	var task = metrics.NewKVTask(&serverconfigs.MetricItemConfig{