Documentation
¶
Index ¶
- Constants
- Variables
- func NewUUID() string
- type AlembicVersion
- type App
- type AppState
- type Base
- type DBInstance
- type DBProvider
- type Dashboard
- type Experiment
- type ExperimentTag
- type Importer
- type LatestMetric
- type LifecycleStage
- type Metric
- type Param
- type PostgresDBInstance
- type RowNum
- type Run
- type SchemaVersion
- type SqliteDBInstance
- type Status
- type Tag
Constants ¶
View Source
const (
SQLiteCustomDriverName = "sqlite3_custom_driver"
)
Variables ¶
View Source
var DB *gorm.DB
DB is a global gorm.DB reference
Functions ¶
Types ¶
type AlembicVersion ¶
type AlembicVersion struct {
Version string `gorm:"column:version_num;type:varchar(32);not null;primaryKey"`
}
func (AlembicVersion) TableName ¶
func (AlembicVersion) TableName() string
type AppState ¶
func (AppState) GormDataType ¶
type Base ¶
type DBInstance ¶ added in v0.3.0
DBInstance is the base concrete type for DbProvider.
func (*DBInstance) Close ¶ added in v0.3.0
func (db *DBInstance) Close() error
Close will invoke the closers.
func (*DBInstance) Dsn ¶ added in v0.3.0
func (db *DBInstance) Dsn() string
Dsn will return the dsn string.
func (*DBInstance) GormDB ¶ added in v0.3.0
func (db *DBInstance) GormDB() *gorm.DB
Db will return the gorm DB.
type DBProvider ¶ added in v0.3.0
DBProvider is the interface to access the DB.
type Dashboard ¶
type Dashboard struct {
Base
Name string `json:"name"`
Description string `json:"description"`
AppID *uuid.UUID `gorm:"type:uuid" json:"app_id"`
App App `json:"-"`
}
func (Dashboard) MarshalJSON ¶
type Experiment ¶
type Experiment struct {
ID *int32 `gorm:"column:experiment_id;not null;primaryKey"`
Name string `gorm:"type:varchar(256);not null;unique"`
ArtifactLocation string `gorm:"type:varchar(256)"`
LifecycleStage LifecycleStage `gorm:"type:varchar(32);check:lifecycle_stage IN ('active', 'deleted')"`
CreationTime sql.NullInt64 `gorm:"type:bigint"`
LastUpdateTime sql.NullInt64 `gorm:"type:bigint"`
Tags []ExperimentTag `gorm:"constraint:OnDelete:CASCADE"`
Runs []Run `gorm:"constraint:OnDelete:CASCADE"`
}
type ExperimentTag ¶
type Importer ¶ added in v0.3.0
type Importer struct {
// contains filtered or unexported fields
}
Importer will handle transport of data from source to destination db.
func NewImporter ¶ added in v0.3.0
func NewImporter(input, output DBProvider) *Importer
NewImporter initializes an Importer.
type LatestMetric ¶
type LifecycleStage ¶
type LifecycleStage string
const ( LifecycleStageActive LifecycleStage = "active" LifecycleStageDeleted LifecycleStage = "deleted" )
type Metric ¶
type Metric struct {
Key string `gorm:"type:varchar(250);not null;primaryKey"`
Value float64 `gorm:"type:double precision;not null;primaryKey"`
Timestamp int64 `gorm:"not null;primaryKey"`
RunID string `gorm:"column:run_uuid;not null;primaryKey;index"`
Step int64 `gorm:"default:0;not null;primaryKey"`
IsNan bool `gorm:"default:false;not null;primaryKey"`
Iter int64 `gorm:"index"`
}
type PostgresDBInstance ¶ added in v0.3.0
type PostgresDBInstance struct {
DBInstance
}
PostgresDBInstance is the Postgres-specific DbInstance variant.
func NewPostgresDBInstance ¶ added in v0.3.0
func NewPostgresDBInstance( dsnURL url.URL, slowThreshold time.Duration, poolMax int, reset bool, ) (*PostgresDBInstance, error)
NewPostgresDBInstance will construct a Postgres DbInstance.
func (PostgresDBInstance) Reset ¶ added in v0.3.0
func (pgdb PostgresDBInstance) Reset() error
Reset implementation for this type.
type Run ¶
type Run struct {
ID string `gorm:"<-:create;column:run_uuid;type:varchar(32);not null;primaryKey"`
Name string `gorm:"type:varchar(250)"`
SourceType string `gorm:"<-:create;type:varchar(20);check:source_type IN ('NOTEBOOK', 'JOB', 'LOCAL', 'UNKNOWN', 'PROJECT')"`
SourceName string `gorm:"<-:create;type:varchar(500)"`
EntryPointName string `gorm:"<-:create;type:varchar(50)"`
UserID string `gorm:"<-:create;type:varchar(256)"`
Status Status `gorm:"type:varchar(9);check:status IN ('SCHEDULED', 'FAILED', 'FINISHED', 'RUNNING', 'KILLED')"`
StartTime sql.NullInt64 `gorm:"<-:create;type:bigint"`
EndTime sql.NullInt64 `gorm:"type:bigint"`
SourceVersion string `gorm:"<-:create;type:varchar(50)"`
LifecycleStage LifecycleStage `gorm:"type:varchar(20);check:lifecycle_stage IN ('active', 'deleted')"`
ArtifactURI string `gorm:"<-:create;type:varchar(200)"`
ExperimentID int32
Experiment Experiment
DeletedTime sql.NullInt64 `gorm:"type:bigint"`
RowNum RowNum `gorm:"<-:create;index"`
Params []Param `gorm:"constraint:OnDelete:CASCADE"`
Tags []Tag `gorm:"constraint:OnDelete:CASCADE"`
Metrics []Metric `gorm:"constraint:OnDelete:CASCADE"`
LatestMetrics []LatestMetric `gorm:"constraint:OnDelete:CASCADE"`
}
type SchemaVersion ¶
type SchemaVersion struct {
Version string `gorm:"not null;primaryKey"`
}
func (SchemaVersion) TableName ¶
func (SchemaVersion) TableName() string
type SqliteDBInstance ¶ added in v0.3.0
type SqliteDBInstance struct {
DBInstance
}
SqliteDBInstance is the sqlite specific variant of DbInstance.
func NewSqliteDBInstance ¶ added in v0.3.0
func NewSqliteDBInstance( dsnURL url.URL, slowThreshold time.Duration, poolMax int, reset bool, ) (*SqliteDBInstance, error)
NewSqliteDBInstance will create a Sqlite DbInstance.
func (SqliteDBInstance) Reset ¶ added in v0.3.0
func (f SqliteDBInstance) Reset() error
Reset implementation for this type.
Click to show internal directories.
Click to hide internal directories.