william/th7
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

print ok msg after Write()

Browse Source
This commit is contained in:
William Clark 2023-11-24 10:57:34 +00:00
parent 627834c072
commit 0a90368c04
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
db/influxdb.go
View File

@ -117,12 +117,12 @@ func (ad *InfluxDBAdapter) Save(channels []core.Channel) error {
saveContext, cancel := context.WithTimeout(context.Background(), INFLUXDB_MAX_SAVE_DUR) saveContext, cancel := context.WithTimeout(context.Background(), INFLUXDB_MAX_SAVE_DUR)
defer cancel() defer cancel()
fmt.Printf("[InfluxDB] logged %d channels OK\n", len(channels))
err = ad.client.Write(saveContext, []byte(sb.String())) err = ad.client.Write(saveContext, []byte(sb.String()))
if err != nil { if err != nil {
return err return err
} }
fmt.Printf("[InfluxDB] logged %d channels OK\n", len(channels))
return nil return nil
} }