Versions in this module Expand all Collapse all v1 v1.0.0 Jan 19, 2024 Changes in this version + type Database struct + func CreateDatabase(dbHost string, dbPort int, dbUser string, dbPassword string, dbName string, ...) *Database + func PrepareTests() (*Database, error) + func PrepareTestsWithPrefix(prefix string) (*Database, error) + func (db *Database) AddHost(host *core.Host) error + func (db *Database) AddMetric(id string, metricType int, metric *core.Metric) error + func (db *Database) AddVM(host *core.VM) error + func (db *Database) Bind(vmID, hostID string) error + func (db *Database) Close() + func (db *Database) Connect() error + func (db *Database) Drop() error + func (db *Database) Export(id string, metricType int, filename string) error + func (db *Database) GetHost(hostID string) (*core.Host, error) + func (db *Database) GetHosts() ([]*core.Host, error) + func (db *Database) GetMetrics(hostID string, metricType int, since time.Time, count int) ([]*core.Metric, error) + func (db *Database) GetVM(vmID string) (*core.VM, error) + func (db *Database) GetVMs() ([]*core.VM, error) + func (db *Database) RemoveHost(hostID string) error + func (db *Database) RemoveVM(vmID string) error + func (db *Database) SetHostResources(hostID string, usageCPU float64, usageMemory int64) error + func (db *Database) SetVMResources(vmID string, usageCPU float64, usageMemory int64) error + func (db *Database) Unbind(vmID string) error + func (db Database) Initialize() error + type Postgresql interface + Begin func() (*sql.Tx, error) + BeginTx func(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error) + Close func() error + Conn func(ctx context.Context) (*sql.Conn, error) + Driver func() driver.Driver + Exec func(query string, args ...any) (sql.Result, error) + ExecContext func(ctx context.Context, query string, args ...any) (sql.Result, error) + Ping func() error + PingContext func(ctx context.Context) error + Prepare func(query string) (*sql.Stmt, error) + PrepareContext func(ctx context.Context, query string) (*sql.Stmt, error) + Query func(query string, args ...any) (*sql.Rows, error) + QueryContext func(ctx context.Context, query string, args ...any) (*sql.Rows, error) + QueryRow func(query string, args ...any) *sql.Row + QueryRowContext func(ctx context.Context, query string, args ...any) *sql.Row + SetConnMaxIdleTime func(d time.Duration) + SetConnMaxLifetime func(d time.Duration) + SetMaxIdleConns func(n int) + SetMaxOpenConns func(n int) + Stats func() sql.DBStats
Go to main page