()
| 403 | } |
| 404 | |
| 405 | func (this *KVTask) Truncate() error { |
| 406 | var db = this.itemsTable.DB() |
| 407 | err := db.Truncate() |
| 408 | if err != nil { |
| 409 | return err |
| 410 | } |
| 411 | return db.Store().Flush() |
| 412 | } |
| 413 | |
| 414 | func (this *KVTask) uploadServerStats(rpcClient *rpc.RPCClient, serverId int64, currentTime string) (countValues int, uploadErr error) { |
| 415 | var pbStats []*pb.UploadingMetricStat |