diff --git a/pkg/util/influxdb/influxdb.go b/pkg/util/influxdb/influxdb.go index 51d40b82f6..200ff7dc84 100644 --- a/pkg/util/influxdb/influxdb.go +++ b/pkg/util/influxdb/influxdb.go @@ -23,6 +23,7 @@ import ( "path" "strconv" "strings" + "time" "yunion.io/x/jsonutils" "yunion.io/x/log" @@ -299,3 +300,7 @@ func (db *SInfluxdb) SetRetentionPolicy(rp SRetentionPolicy) error { return db.CreateRetentionPolicy(rp) } } + +func (db *SInfluxdb) SetTimeout(timeout time.Duration) { + db.client.Timeout = timeout +}