common

Documentation

Index

• Constants
• func OpenSQLConn(driverName string, dataSourceName string, interval time.Duration, ...) (*sql.DB, error)
• type KatibDBInterface

Constants

const (
	ConnectInterval = 5 * time.Second

	DBUserEnvName     = "DB_USER"
	DBNameEnvName     = "DB_NAME"
	DBPasswordEnvName = "DB_PASSWORD"

	MySqlDBNameEnvValue = "mysql"

	MySQLDBHostEnvName = "KATIB_MYSQL_DB_HOST"
	MySQLDBPortEnvName = "KATIB_MYSQL_DB_PORT"
	MySQLDatabase      = "KATIB_MYSQL_DB_DATABASE"

	DefaultMySQLUser     = "root"
	DefaultMySQLDatabase = "katib"
	DefaultMySQLHost     = "katib-mysql"
	DefaultMySQLPort     = "3306"

	PostgresSQLDBNameEnvValue = "postgres"

	PostgreSQLDBHostEnvName = "KATIB_POSTGRESQL_DB_HOST"
	PostgreSQLDBPortEnvName = "KATIB_POSTGRESQL_DB_PORT"
	PostgreSQLDatabase      = "KATIB_POSTGRESQL_DB_DATABASE"
	PostgreSSLMode          = "KATIB_POSTGRESQL_SSL_MODE"

	DefaultPostgreSQLUser     = "katib"
	DefaultPostgreSQLDatabase = "katib"
	DefaultPostgreSQLHost     = "katib-postgres"
	DefaultPostgreSQLPort     = "5432"
	DefaultPostgreSSLMode     = "disable"

	SkipDbInitializationEnvName = "SKIP_DB_INITIALIZATION"
)

Functions

func OpenSQLConn

func OpenSQLConn(driverName string, dataSourceName string, interval time.Duration,
	timeout time.Duration) (*sql.DB, error)

Types

type KatibDBInterface

type KatibDBInterface interface {
	DBInit()
	SelectOne() error

	RegisterObservationLog(trialName string, observationLog *v1beta1.ObservationLog) error
	GetObservationLog(trialName string, metricName string, startTime string, endTime string) (*v1beta1.ObservationLog, error)
	DeleteObservationLog(trialName string) error
}