Documentation
¶
Index ¶
- type Database
- 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) Initialize() 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
- type Postgresql
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Database ¶
type Database struct {
// contains filtered or unexported fields
}
func CreateDatabase ¶
func PrepareTests ¶
func PrepareTestsWithPrefix ¶
func (*Database) GetMetrics ¶
func (Database) Initialize ¶
func (*Database) RemoveHost ¶
func (*Database) SetHostResources ¶
func (*Database) SetVMResources ¶
type Postgresql ¶
type Postgresql interface {
Begin() (*sql.Tx, error)
BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)
Close() error
Conn(ctx context.Context) (*sql.Conn, error)
Driver() driver.Driver
Exec(query string, args ...any) (sql.Result, error)
ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
Ping() error
PingContext(ctx context.Context) error
Prepare(query string) (*sql.Stmt, error)
PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)
Query(query string, args ...any) (*sql.Rows, error)
QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
QueryRow(query string, args ...any) *sql.Row
QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row
SetConnMaxIdleTime(d time.Duration)
SetConnMaxLifetime(d time.Duration)
SetMaxIdleConns(n int)
SetMaxOpenConns(n int)
Stats() sql.DBStats
}
Source Files
Click to show internal directories.
Click to hide internal directories.