Versions in this module Expand all Collapse all v0 v0.8.100 Mar 23, 2022 Changes in this version + func StartPullerAndProcessModels(downloader *Downloader, commands <-chan ModelOp, logger *zap.SugaredLogger) + func SyncModelDir(modelDir string, logger *zap.SugaredLogger) (map[string]modelWrapper, error) + type Downloader struct + Logger *zap.SugaredLogger + ModelDir string + Providers map[storage.Protocol]storage.Provider + func (d *Downloader) DownloadModel(modelName string, modelSpec *v1alpha1.ModelSpec) error + type FileError error + var NoSuccessFile FileError = fmt.Errorf("no success file can be found") + type ModelChannel struct + type ModelOp struct + ModelName string + OnStartup bool + Op OpType + Spec *v1.ModelSpec + type OpType string + const Add + const Remove + type Puller struct + Downloader *Downloader + type WaitGroupWrapper struct + type Watcher struct + ModelEvents chan ModelOp + ModelTracker map[string]modelWrapper + func NewWatcher(configDir string, modelDir string, logger *zap.SugaredLogger) Watcher + func (w *Watcher) Start()