Versions in this module Expand all Collapse all v1 v1.0.0 Sep 23, 2020 Changes in this version + var ErrConfigDoesNotExist = exterr.NewErrorWithMessage("config does not exist").WithComponent(app.ComponentStorage).WithCode(logStorageConfigDoesNotExistCode) + type ArchiveHeader struct + ContentPath string + Header *tar.Header + type Archiver interface + GetFileContent func(ctx context.Context, source string) ([]byte, error) + SaveArchiveFile func(ctx context.Context, header *tar.Header, archive *tar.Reader, ...) error + type ModelReader interface + DirectoryLayout func(path string) ([]string, error) + ReadAllModels func(ctx context.Context, modelID app.ServableID) ([]ArchiveHeader, error) + ReadConfig func(ctx context.Context, team, project string) ([]byte, error) + ReadModel func(ctx context.Context, modelID app.ServableID, version int) ([]ArchiveHeader, error) + type ModelRemover interface + RemoveModel func(ctx context.Context, id app.ServableID, version int) error + type ModelStorage interface + type ModelWriter interface + SaveConfig func(ctx context.Context, team, project string, config []byte) error + SaveIncomingModelArchive func(modelID app.ServableID, archive io.Reader) (string, error) + SaveModel func(ctx context.Context, archivePath string, modelID app.ServableID, version int) error + type ModelsStorage struct + func NewModelsStorage(storageImplementation ModelStorage) *ModelsStorage + func (m *ModelsStorage) ReadAllModels(ctx context.Context, modelID app.ServableID) ([]byte, error) + func (m *ModelsStorage) ReadConfig(ctx context.Context, team, project string) ([]byte, error) + func (m *ModelsStorage) ReadModel(ctx context.Context, modelID app.ServableID, version int) ([]byte, error) + func (m *ModelsStorage) RemoveModel(ctx context.Context, id app.ServableID, version int64) error + func (m *ModelsStorage) SaveConfig(ctx context.Context, team, project string, config []byte) error + func (m *ModelsStorage) SaveModel(ctx context.Context, modelID app.ServableID, version int, archive io.Reader) (*SaveModelResponse, error) + type ModuleReader interface + DirectoryLayout func(path string) ([]string, error) + ReadModule func(ctx context.Context, moduleID app.ServableID, version int) ([]ArchiveHeader, error) + type ModuleRemover interface + RemoveModule func(ctx context.Context, id app.ServableID, version int64) error + type ModuleStorage interface + type ModuleWriter interface + SaveIncomingModuleArchive func(moduleID app.ServableID, archive io.Reader) (string, error) + SaveModule func(ctx context.Context, archivePath string, moduleID app.ServableID, version int) error + type ModulesStorage struct + func NewModuleStorage(storageImplementation ModuleStorage) *ModulesStorage + func (m *ModulesStorage) ReadModule(ctx context.Context, moduleID app.ServableID, version int) ([]byte, error) + func (m *ModulesStorage) RemoveModule(ctx context.Context, id app.ServableID, version int64) error + func (m *ModulesStorage) SaveModule(ctx context.Context, moduleID app.ServableID, version int, archive io.Reader) error + type SaveModelResponse struct + Config []byte
Go to main page