prometheus/cadvisor
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

s/db/storage_driver/

Browse Source
This commit is contained in:
Nan Deng 2014-07-08 18:15:36 -07:00
parent d18ca6fddd
commit 135ddd8f01
2 changed files with 10 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
cadvisor.go
View File

@ -30,21 +30,18 @@ import (
)
var argPort = flag.Int("port", 8080, "port to listen")
var argSampleSize = flag.Int("samples", 1024, "number of samples we want to keep")
var argHistoryDuration = flag.Int("history_duration", 60, "number of seconds of container history to keep")
var argAllowLmctfy = flag.Bool("allow_lmctfy", true, "whether to allow lmctfy as a container handler")
var argDbDriver = flag.String("db", "memory", "database driver name")
var argDbDriver = flag.String("storage_driver", "memory", "database driver name")
func main() {
flag.Parse()
storageDriver, err := NewStorage(*argDbDriver)
storageDriver, err := NewStorageDriver(*argDbDriver)
if err != nil {
log.Fatalf("Failed to connect to database: %s", err)
}
// TODO(monnand): Add stats writer for manager
containerManager, err := manager.New(storageDriver)
if err != nil {
log.Fatalf("Failed to create a Container Manager: %s", err)

14
storagedriver.go
View File

@ -25,13 +25,15 @@ import (
"github.com/google/cadvisor/storage/memory"
)
var argDbUsername = flag.String("db.user", "root", "database username")
var argDbPassword = flag.String("db.password", "root", "database password")
var argDbHost = flag.String("db.host", "localhost:8086", "database host:port")
var argDbName = flag.String("db.name", "cadvisor", "database name")
var argDbIsSecure = flag.Bool("db.secure", false, "use secure connection with database")
var argSampleSize = flag.Int("samples", 1024, "number of samples we want to keep")
var argHistoryDuration = flag.Int("history_duration", 60, "number of seconds of container history to keep")
var argDbUsername = flag.String("storage_driver.user", "root", "database username")
var argDbPassword = flag.String("storage_driver.password", "root", "database password")
var argDbHost = flag.String("storage_driver.host", "localhost:8086", "database host:port")
var argDbName = flag.String("storage_driver.name", "cadvisor", "database name")
var argDbIsSecure = flag.Bool("storage_driver.secure", false, "use secure connection with database")
func NewStorage(driverName string) (storage.StorageDriver, error) {
func NewStorageDriver(driverName string) (storage.StorageDriver, error) {
var storageDriver storage.StorageDriver
var err error
switch driverName {