Merge pull request #364 from denderello/configurable-tablenames

[WIP] Make storage table names configurable
This commit is contained in:
Victor Marmol 2014-12-17 01:58:29 +08:00
commit 43c1712be6

View File

@ -32,6 +32,7 @@ var argDbUsername = flag.String("storage_driver_user", "root", "database usernam
var argDbPassword = flag.String("storage_driver_password", "root", "database password") var argDbPassword = flag.String("storage_driver_password", "root", "database password")
var argDbHost = flag.String("storage_driver_host", "localhost:8086", "database host:port") var argDbHost = flag.String("storage_driver_host", "localhost:8086", "database host:port")
var argDbName = flag.String("storage_driver_db", "cadvisor", "database name") var argDbName = flag.String("storage_driver_db", "cadvisor", "database name")
var argDbTable = flag.String("storage_driver_table", "stats", "table name")
var argDbIsSecure = flag.Bool("storage_driver_secure", false, "use secure connection with database") var argDbIsSecure = flag.Bool("storage_driver_secure", false, "use secure connection with database")
var argDbBufferDuration = flag.Duration("storage_driver_buffer_duration", 60*time.Second, "Writes in the storage driver will be buffered for this duration, and committed to the non memory backends as a single transaction") var argDbBufferDuration = flag.Duration("storage_driver_buffer_duration", 60*time.Second, "Writes in the storage driver will be buffered for this duration, and committed to the non memory backends as a single transaction")
@ -59,7 +60,7 @@ func NewStorageDriver(driverName string) (*memory.InMemoryStorage, error) {
backendStorage, err = influxdb.New( backendStorage, err = influxdb.New(
hostname, hostname,
"stats", *argDbTable,
*argDbName, *argDbName,
*argDbUsername, *argDbUsername,
*argDbPassword, *argDbPassword,
@ -75,7 +76,7 @@ func NewStorageDriver(driverName string) (*memory.InMemoryStorage, error) {
} }
backendStorage, err = bigquery.New( backendStorage, err = bigquery.New(
hostname, hostname,
"cadvisor", *argDbTable,
*argDbName, *argDbName,
) )