(t *testing.T)
| 124 | } |
| 125 | |
| 126 | func TestKVTask_InsertStat(t *testing.T) { |
| 127 | var item = &serverconfigs.MetricItemConfig{ |
| 128 | Id: 1, |
| 129 | IsOn: false, |
| 130 | Category: "", |
| 131 | Period: 1, |
| 132 | PeriodUnit: serverconfigs.MetricItemPeriodUnitDay, |
| 133 | Keys: []string{"${remoteAddr}"}, |
| 134 | Value: "${countRequest}", |
| 135 | Version: 1, |
| 136 | } |
| 137 | var task = metrics.NewKVTask(item) |
| 138 | err := task.Init() |
| 139 | if err != nil { |
| 140 | t.Fatal(err) |
| 141 | } |
| 142 | |
| 143 | defer func() { |
| 144 | err = task.Flush() |
| 145 | if err != nil { |
| 146 | t.Fatal(err) |
| 147 | } |
| 148 | }() |
| 149 | |
| 150 | err = task.Start() |
| 151 | if err != nil { |
| 152 | t.Fatal(err) |
| 153 | } |
| 154 | defer func() { |
| 155 | _ = task.Stop() |
| 156 | }() |
| 157 | |
| 158 | { |
| 159 | err = task.InsertStat(&metrics.Stat{ |
| 160 | ServerId: 1, |
| 161 | Keys: []string{"127.0.0.1"}, |
| 162 | Hash: "", |
| 163 | Value: 1, |
| 164 | Time: item.CurrentTime(), |
| 165 | }) |
| 166 | if err != nil { |
| 167 | t.Fatal(err) |
| 168 | } |
| 169 | } |
| 170 | |
| 171 | { |
| 172 | err = task.InsertStat(&metrics.Stat{ |
| 173 | ServerId: 2, |
| 174 | Keys: []string{"127.0.0.2"}, |
| 175 | Hash: "", |
| 176 | Value: 3, |
| 177 | Time: item.CurrentTime(), |
| 178 | }) |
| 179 | if err != nil { |
| 180 | t.Fatal(err) |
| 181 | } |
| 182 | } |
| 183 |
nothing calls this directly
no test coverage detected