service

type ModelStorage interface {
	ReadModel(ctx context.Context, modelID app.ServableID, version int) ([]byte, error)
	ReadAllModels(ctx context.Context, modelID app.ServableID) ([]byte, error)

	SaveModel(ctx context.Context, modelID app.ServableID, version int, archive io.Reader) (*storage.SaveModelResponse, error)
	RemoveModel(ctx context.Context, id app.ServableID, version int64) error
}

type ModelsConfig interface {
	DefaultLabel() string
	AddModel(ctx context.Context, modelID app.ModelID) error
	ConfigFileStream(ctx context.Context, team, project string) ([]byte, error)
	RemoveModel(ctx context.Context, id app.ModelID) error
	RemoveModelLabel(ctx context.Context, id app.ModelID) error
	UpdateLabel(ctx context.Context, id app.ModelID) (int64, error)
}

type ModelsMetadata interface {
	Add(ctx context.Context, model app.ModelData) (int64, error)
	ChangeLabel(ctx context.Context, model app.ModelData) error
	Delete(ctx context.Context, id int64) error
	RemoveLabel(ctx context.Context, model app.ModelData) error
	Get(ctx context.Context, parameters app.QueryParameters) (*app.ModelData, error)
	List(ctx context.Context, parameters app.QueryParameters) ([]*app.ModelData, error)
	ListUniqueTeamProject(ctx context.Context) ([]*app.ServableID, error)
	NextVersion(ctx context.Context, parameters app.QueryParameters) (int64, error)
	UpdateStatus(ctx context.Context, id int64, status string) error
	IsStatusPending(ctx context.Context, servableID app.ServableID) (bool, error)
}

type ModelsReload interface {
	ReloadConfig(ctx context.Context, team, project string, skipConfigWithoutLabels bool) ([]app.ReloadResponse, error)
}

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

type ModuleStorage interface {
	ReadModule(ctx context.Context, moduleID app.ServableID, version int) ([]byte, error)
	SaveModule(ctx context.Context, moduleID app.ServableID, version int, archive io.Reader) error
	RemoveModule(ctx context.Context, id app.ServableID, version int64) error
}

type ModulesMetadata interface {
	Add(ctx context.Context, module app.ModuleData) (int64, error)
	Delete(ctx context.Context, id int64) error
	Get(ctx context.Context, parameters app.QueryParameters) (*app.ModuleData, error)
	List(ctx context.Context, parameters app.QueryParameters) ([]*app.ModuleData, error)
	NextVersion(ctx context.Context, parameters app.QueryParameters) (int64, error)
}

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