models

type ArtifactMapperFunc func(artifact schema.Artifact, properties []schema.ArtifactProperty) interface{}

type CatalogArtifact struct {
	CatalogModelArtifact   CatalogModelArtifact
	CatalogMetricsArtifact CatalogMetricsArtifact
}

type CatalogArtifactEntity interface {
	GetID() *int32
	SetID(int32)
	GetProperties() *[]models.Properties
	GetCustomProperties() *[]models.Properties
}

type CatalogArtifactListOptions struct {
	models.Pagination
	Name                *string
	ExternalID          *string
	ParentResourceID    *int32
	ArtifactType        *string
	ArtifactTypesFilter []string
}

type CatalogArtifactRepository interface {
	GetByID(id int32) (CatalogArtifact, error)
	List(listOptions CatalogArtifactListOptions) (*models.ListWrapper[CatalogArtifact], error)
	DeleteByParentID(artifactType string, parentResourceID int32) error
}

type CatalogMetricsArtifact CatalogArtifactEntity

type CatalogModelArtifact CatalogArtifactEntity

type CatalogRestEntityType string

type CatalogSource interface {
	models.Entity[CatalogSourceAttributes]
}

type CatalogSourceAttributes struct {
	// Name is the source ID (used as the context name)
	Name *string
	// CreateTimeSinceEpoch is when the record was created
	CreateTimeSinceEpoch *int64
	// LastUpdateTimeSinceEpoch is when the record was last updated
	LastUpdateTimeSinceEpoch *int64
}

type CatalogSourceImpl = models.BaseEntity[CatalogSourceAttributes]

type CatalogSourceRepository interface {
	// GetBySourceID retrieves a catalog source by its source ID.
	GetBySourceID(sourceID string) (CatalogSource, error)

	// Save creates or updates a catalog source.
	// The source ID is used as the unique identifier (context name).
	Save(source CatalogSource) (CatalogSource, error)

	// Delete removes a catalog source by its source ID.
	Delete(sourceID string) error

	// GetAll retrieves all catalog sources.
	GetAll() ([]CatalogSource, error)

	// GetAllStatuses returns a map of source ID to status/error for all sources.
	GetAllStatuses() (map[string]SourceStatus, error)
}

type PropertyOption struct {
	TypeID           int32    `json:"type_id"`
	Name             string   `json:"name"`
	IsCustomProperty bool     `json:"is_custom_property"`
	StringValue      []string `json:"string_value"`
	ArrayValue       []string `json:"array_value"`
	MinDoubleValue   *float64 `json:"min_double_value"`
	MaxDoubleValue   *float64 `json:"max_double_value"`
	MinIntValue      *int64   `json:"min_int_value"`
	MaxIntValue      *int64   `json:"max_int_value"`
}

type PropertyOptionType int

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

type PropertyOptionsRepository interface {
	// Refresh rebuilds the materialized view.
	Refresh(t PropertyOptionType) error
	// List returns all the options for a type. If typeID is 0, all types are returned.
	List(t PropertyOptionType, typeID int32) ([]PropertyOption, error)
}

type SourceStatus struct {
	Status string
	Error  string
}