Versions in this module Expand all Collapse all v0 v0.0.2 Oct 3, 2023 v0.0.1 Oct 1, 2023 Changes in this version + const BearerTokenEnvName + const ExperimentIDEnvName + const GitCommitTagKey + const HostTagKey + const LifecycleStageActive + const LifecycleStageDeleted + const ParentRunIDTagKey + const RunIDEnvName + const SourceNameTagKey + const SourceTypeJob + const SourceTypeLocal + const SourceTypeTagKey + const TrackingURIEnvName + const UserTagKey + var ErrUnsupported = errors.New("this operation not supported by this tracking client") + func LogStructAsParams(run Run, obj interface{}) error + func ToURI(path string) string + type ArtifactRepo interface + LogArtifact func(localPath, artifactPath string) error + LogArtifacts func(localDir, artifactPath string) error + func NewDBFSArtifactRepo(restStore *RESTStore, uri string) (ArtifactRepo, error) + func NewFileArtifactRepo(rootDir string) (ArtifactRepo, error) + type DBFSArtifactRepo struct + func (repo *DBFSArtifactRepo) LogArtifact(localPath, artifactPath string) error + func (repo *DBFSArtifactRepo) LogArtifacts(localPath, artifactPath string) error + type Experiment interface + CreateRun func(name string) (Run, error) + GetRun func(runId string) (Run, error) + ID func() string + type FileArtifactRepo struct + func (repo *FileArtifactRepo) LogArtifact(localPath, artifactPath string) error + func (repo *FileArtifactRepo) LogArtifacts(localPath, artifactPath string) error + type FileStore struct + func NewFileStore(rootDir string) (*FileStore, error) + func (f *FileStore) ExperimentsByName() (map[string]Experiment, error) + func (fs *FileStore) CreateExperiment(name string) (Experiment, error) + func (fs *FileStore) GetExperiment(id string) (Experiment, error) + func (fs *FileStore) GetOrCreateExperimentWithName(name string) (Experiment, error) + func (fs *FileStore) SearchRuns(experimentIDs []string, filter string, orderBy []string, pageToken string) ([]Run, string, error) + func (fs *FileStore) UIURL() string + func (s *FileStore) URI() string + type Metric struct + Key string + Val float64 + type Param struct + Key string + Val string + type RESTStore struct + func (rs *RESTStore) CreateExperiment(name string) (Experiment, error) + func (rs *RESTStore) ExperimentsByName() (map[string]Experiment, error) + func (rs *RESTStore) GetExperiment(id string) (Experiment, error) + func (rs *RESTStore) GetOrCreateExperimentWithName(name string) (Experiment, error) + func (rs *RESTStore) SearchRuns(experimentIDs []string, filter string, orderBy []string, pageToken string) ([]Run, string, error) + func (rs *RESTStore) UIURL() string + func (rs *RESTStore) URI() string + type Run interface + End func() error + ExperimentID func() string + Fail func() error + GetParam func(key string) (string, error) + GetTag func(key string) (string, error) + ID func() string + LogArtifact func(localPath, artifactPath string) error + LogMetric func(key string, val float64, step int64) error + LogMetrics func(metrics []Metric, step int64) error + LogParam func(key, value string) error + LogParams func(params []Param) error + Name func() string + SetName func(name string) error + SetTag func(key, value string) error + SetTags func(tags []Tag) error + UIURL func() string + func ActiveRunFromConfig(experimentName string, l *log.Logger, config interface{}) (Run, error) + func ActiveRunFromEnv(experimentName string, l *log.Logger) (Run, error) + type Tag struct + Key string + Val string + type Tracking interface + CreateExperiment func(name string) (Experiment, error) + ExperimentsByName func() (map[string]Experiment, error) + GetExperiment func(id string) (Experiment, error) + GetOrCreateExperimentWithName func(name string) (Experiment, error) + SearchRuns func(experimentIDs []string, filter string, orderBy []string, pageToken string) ([]Run, string, error) + UIURL func() string + URI func() string + func NewRESTStore(baseURL, bearerToken string) (Tracking, error) + func NewTracking(uri, bearerToken string, l *log.Logger) (Tracking, error)