storage

type ArchiveHeader struct {
	Header      *tar.Header
	ContentPath string
}

type Archiver interface {
	GetFileContent(ctx context.Context, source string) ([]byte, error)
	SaveArchiveFile(ctx context.Context, header *tar.Header, archive *tar.Reader, archivePath string) error
}

type ModelReader interface {
	ReadConfig(ctx context.Context, team, project string) ([]byte, error)
	ReadModel(ctx context.Context, modelID app.ServableID, version int) ([]ArchiveHeader, error)
	ReadAllModels(ctx context.Context, modelID app.ServableID) ([]ArchiveHeader, error)
	DirectoryLayout(path string) ([]string, error)
}

type ModelRemover interface {
	RemoveModel(ctx context.Context, id app.ServableID, version int) error
}

type ModelStorage interface {
	Archiver
	ModelReader
	ModelWriter
	ModelRemover
}

type ModelWriter interface {
	SaveConfig(ctx context.Context, team, project string, config []byte) error
	SaveModel(ctx context.Context, archivePath string, modelID app.ServableID, version int) error
	SaveIncomingModelArchive(modelID app.ServableID, archive io.Reader) (string, error)
}

type ModelsStorage struct {
	// contains filtered or unexported fields
}

type ModuleReader interface {
	ReadModule(ctx context.Context, moduleID app.ServableID, version int) ([]ArchiveHeader, error)
	DirectoryLayout(path string) ([]string, error)
}

type ModuleRemover interface {
	RemoveModule(ctx context.Context, id app.ServableID, version int64) error
}

type ModuleStorage interface {
	Archiver
	ModuleReader
	ModuleWriter
	ModuleRemover
}

type ModuleWriter interface {
	SaveModule(ctx context.Context, archivePath string, moduleID app.ServableID, version int) error
	SaveIncomingModuleArchive(moduleID app.ServableID, archive io.Reader) (string, error)
}

type ModulesStorage struct {
	// contains filtered or unexported fields
}

type SaveModelResponse struct {
	Config []byte
}