v_0011

Documentation

Index

• Constants
• func Migrate(db *gorm.DB) error
• type AlembicVersion
  • func (AlembicVersion) TableName() string
• type App
• type AppState
  • func (s AppState) GormDataType() string
  • func (s *AppState) Scan(v interface{}) error
  • func (s AppState) Value() (driver.Value, error)
• type Base
  • func (b *Base) BeforeCreate(tx *gorm.DB) error
• type Context
• type Dashboard
  • func (d Dashboard) MarshalJSON() ([]byte, error)
• type Experiment
• type ExperimentTag
• type JSONB
  • func (JSONB) GormDBDataType(db *gorm.DB, field *schema.Field) string
  • func (JSONB) GormDataType() string
  • func (js JSONB) GormValue(ctx context.Context, db *gorm.DB) clause.Expr
  • func (j JSONB) MarshalJSON() ([]byte, error)
  • func (j *JSONB) Scan(value interface{}) error
  • func (j JSONB) String() string
  • func (j *JSONB) UnmarshalJSON(b []byte) error
  • func (j JSONB) Value() (driver.Value, error)
• type LatestMetric
• type LifecycleStage
• type Metric
• type Namespace
• type Param
• type RowNum
  • func (rn RowNum) GormDataType() string
  • func (rn RowNum) GormValue(ctx context.Context, db *gorm.DB) clause.Expr
  • func (rn *RowNum) Scan(v interface{}) error
• type Run
• type SchemaVersion
  • func (SchemaVersion) TableName() string
• type Status
• type Tag

Constants

const Version = "8x230yiog1gv"

Functions

func Migrate

func Migrate(db *gorm.DB) error

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 App

type App struct {
	Base
	Type        string    `gorm:"not null" json:"type"`
	State       AppState  `json:"state"`
	Namespace   Namespace `json:"-"`
	NamespaceID uint      `gorm:"not null" json:"-"`
}

type AppState

type AppState map[string]any

func (AppState) GormDataType

func (s AppState) GormDataType() string

func (*AppState) Scan

func (s *AppState) Scan(v interface{}) error

func (AppState) Value

func (s AppState) Value() (driver.Value, error)

type Base

type Base struct {
	ID         uuid.UUID `gorm:"type:uuid;primaryKey" json:"id"`
	CreatedAt  time.Time `json:"created_at"`
	UpdatedAt  time.Time `json:"updated_at"`
	IsArchived bool      `json:"-"`
}

func (*Base) BeforeCreate

func (b *Base) BeforeCreate(tx *gorm.DB) error

type Context

type Context struct {
	ID   uint  `gorm:"primaryKey;autoIncrement"`
	Json JSONB `gorm:"not null;unique;index"`
}

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

func (d Dashboard) MarshalJSON() ([]byte, error)

type Experiment

type Experiment struct {
	ID               *int32         `gorm:"column:experiment_id;not null;primaryKey"`
	Name             string         `gorm:"type:varchar(256);not null;index:,unique,composite:name"`
	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"`
	NamespaceID      uint           `gorm:"not null;index:,unique,composite:name"`
	Namespace        Namespace
	Tags             []ExperimentTag `gorm:"constraint:OnDelete:CASCADE"`
	Runs             []Run           `gorm:"constraint:OnDelete:CASCADE"`
}

type ExperimentTag

type ExperimentTag struct {
	Key          string `gorm:"type:varchar(250);not null;primaryKey"`
	Value        string `gorm:"type:varchar(5000)"`
	ExperimentID int32  `gorm:"not null;primaryKey"`
}

type JSONB

type JSONB json.RawMessage

JSONB defined JSONB data type, need to implements driver.Valuer, sql.Scanner interface

func (JSONB) GormDBDataType

func (JSONB) GormDBDataType(db *gorm.DB, field *schema.Field) string

GormDBDataType gorm db data type

func (JSONB) GormDataType

func (JSONB) GormDataType() string

GormDataType gorm common data type

func (JSONB) GormValue

func (js JSONB) GormValue(ctx context.Context, db *gorm.DB) clause.Expr

GormValue gorm db actual value nolint

func (JSONB) MarshalJSON

func (j JSONB) MarshalJSON() ([]byte, error)

MarshalJSON to output non base64 encoded []byte

func (*JSONB) Scan

func (j *JSONB) Scan(value interface{}) error

Scan scan value into Jsonb, implements sql.Scanner interface

func (JSONB) String

func (j JSONB) String() string

func (*JSONB) UnmarshalJSON

func (j *JSONB) UnmarshalJSON(b []byte) error

UnmarshalJSON to deserialize []byte

func (JSONB) Value

func (j JSONB) Value() (driver.Value, error)

Value return json value, implement driver.Valuer interface

type LatestMetric

type LatestMetric struct {
	Key       string  `gorm:"type:varchar(250);not null;primaryKey"`
	Value     float64 `gorm:"type:double precision;not null"`
	Timestamp int64
	Step      int64  `gorm:"not null"`
	IsNan     bool   `gorm:"not null"`
	RunID     string `gorm:"column:run_uuid;not null;primaryKey;index"`
	LastIter  int64
	ContextID uint `gorm:"not null;primaryKey"`
	Context   Context
}

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"`
	ContextID uint    `gorm:"not null;primaryKey"`
	Context   Context
}

type Namespace

type Namespace struct {
	ID                  uint           `gorm:"primaryKey;autoIncrement" json:"id"`
	Apps                []App          `gorm:"constraint:OnDelete:CASCADE" json:"apps"`
	Code                string         `gorm:"unique;index;not null" json:"code"`
	Description         string         `json:"description"`
	CreatedAt           time.Time      `json:"created_at"`
	UpdatedAt           time.Time      `json:"updated_at"`
	DeletedAt           gorm.DeletedAt `gorm:"index" json:"deleted_at"`
	DefaultExperimentID *int32         `gorm:"not null" json:"default_experiment_id"`
	Experiments         []Experiment   `gorm:"constraint:OnDelete:CASCADE" json:"experiments"`
}

type Param

type Param struct {
	Key   string `gorm:"type:varchar(250);not null;primaryKey"`
	Value string `gorm:"type:varchar(8000);not null"`
	RunID string `gorm:"column:run_uuid;not null;primaryKey;index"`
}

type RowNum

type RowNum int64

func (RowNum) GormDataType

func (rn RowNum) GormDataType() string

func (RowNum) GormValue

func (rn RowNum) GormValue(ctx context.Context, db *gorm.DB) clause.Expr

func (*RowNum) Scan

func (rn *RowNum) Scan(v interface{}) error

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 Status

type Status string

const (
	StatusRunning   Status = "RUNNING"
	StatusScheduled Status = "SCHEDULED"
	StatusFinished  Status = "FINISHED"
	StatusFailed    Status = "FAILED"
	StatusKilled    Status = "KILLED"
)

type Tag

type Tag struct {
	Key   string `gorm:"type:varchar(250);not null;primaryKey"`
	Value string `gorm:"type:varchar(5000)"`
	RunID string `gorm:"column:run_uuid;not null;primaryKey;index"`
}