asset

type Asset struct {
	ID              string                 `json:"id,omitempty"`
	ParentMRN       *string                `json:"parent_mrn,omitempty"`
	Name            *string                `json:"name,omitempty"`
	Description     *string                `json:"description,omitempty"`
	UserDescription *string                `json:"user_description,omitempty"`
	Type            string                 `json:"type"`
	Providers       []string               `json:"providers"`
	MRN             *string                `json:"mrn,omitempty"`
	Schema          map[string]string      `json:"schema,omitempty"`
	Metadata        map[string]interface{} `json:"metadata,omitempty"`
	Sources         []AssetSource          `json:"sources,omitempty"`
	Tags            []string               `json:"tags,omitempty"`
	Environments    map[string]Environment `json:"environments,omitempty"`
	Query           *string                `json:"query,omitempty"`
	QueryLanguage   *string                `json:"query_language,omitempty"`
	IsStub          bool                   `json:"is_stub"`
	ExternalLinks   []ExternalLink         `json:"external_links,omitempty"`
	HasRunHistory   bool                   `json:"has_run_history"`
	CreatedAt       time.Time              `json:"created_at,omitempty"`
	UpdatedAt       time.Time              `json:"updated_at,omitempty"`
	LastSyncAt      time.Time              `json:"last_sync_at,omitempty"`
	CreatedBy       string                 `json:"created_by,omitempty"`
}

type AssetSource struct {
	Name       string                 `json:"name"`
	LastSyncAt time.Time              `json:"last_sync_at"`
	Properties map[string]interface{} `json:"properties"`
	Priority   int                    `json:"priority"`
}

type AssetSummary struct {
	Types     map[string]AssetTypeSummary `json:"types"`
	Providers map[string]int              `json:"providers"`
	Tags      map[string]int              `json:"tags"`
}

type AssetTerm struct {
	TermID            string    `json:"term_id"`
	TermName          string    `json:"term_name"`
	Definition        string    `json:"definition"`
	Source            string    `json:"source"` // "user" or "plugin:name"
	CreatedAt         time.Time `json:"created_at"`
	CreatedBy         *string   `json:"created_by,omitempty"`
	CreatedByUsername *string   `json:"created_by_username,omitempty"`
}

type AssetTypeSummary struct {
	Count   int    `json:"count"`
	Service string `json:"service"`
}

type AvailableFilters struct {
	Types     map[string]int `json:"types"`
	Providers map[string]int `json:"providers"`
	Tags      map[string]int `json:"tags"`
}

type CreateInput struct {
	Name          *string                `json:"name" validate:"required"`
	MRN           *string                `json:"mrn" validate:"required"`
	Type          string                 `json:"type" validate:"required"`
	Providers     []string               `json:"providers" validate:"required"`
	Description   *string                `json:"description"`
	Metadata      map[string]interface{} `json:"metadata"`
	Schema        map[string]string      `json:"schema"`
	Tags          []string               `json:"tags"`
	CreatedBy     string                 `json:"created_by" validate:"required"`
	Sources       []AssetSource          `json:"sources"`
	Environments  map[string]Environment `json:"environments"`
	ExternalLinks []ExternalLink         `json:"external_links"`
	Query         *string                `json:"query,omitempty"`
	QueryLanguage *string                `json:"query_language,omitempty"`
	IsStub        bool                   `json:"is_stub"`
}

type Environment struct {
	Name     string                 `json:"name"`
	Path     string                 `json:"path"`
	Metadata map[string]interface{} `json:"metadata,omitempty"`
}

type ExternalLink struct {
	Name string `json:"name"`
	Icon string `json:"icon"`
	URL  string `json:"url"`
}

type Filter struct {
	Types        []string   `json:"types,omitempty"`
	Providers    []string   `json:"providers,omitempty"`
	Tags         []string   `json:"tags,omitempty"`
	ParentMRN    *string    `json:"parent_mrn,omitempty"`
	UpdatedAt    *time.Time `json:"updated_at,omitempty"`
	UpdatedAfter *time.Time `json:"updated_after,omitempty"`
	Limit        int        `json:"limit,omitempty"`
	Offset       int        `json:"offset,omitempty"`
	Environment  *string    `json:"environment,omitempty"`
	IncludeStubs bool       `json:"include_stubs,omitempty"`
	OwnerType    *string    `json:"owner_type,omitempty"`
	OwnerID      *string    `json:"owner_id,omitempty"`
}

type HistogramBucket struct {
	Date     string `json:"date"`
	Total    int    `json:"total"`
	Complete int    `json:"complete"`
	Fail     int    `json:"fail"`
	Running  int    `json:"running"`
	Abort    int    `json:"abort"`
	Other    int    `json:"other"`
}

type Logger interface {
	Info(msg string, fields ...interface{})
	Error(msg string, err error, fields ...interface{})
}

type MembershipObserver interface {
	OnAssetCreated(ctx context.Context, asset *Asset)
	OnAssetDeleted(ctx context.Context, assetID string) error
}

type MetadataContext struct {
	Query   string            `json:"query"`
	Filters map[string]string `json:"filters"`
}

type MetadataFieldSuggestion struct {
	Field     string      `json:"field"`
	Type      string      `json:"type"`
	Count     int         `json:"count"`
	Example   interface{} `json:"example"`
	PathParts []string    `json:"path_parts"`
	Types     []string    `json:"types"`
}

type MetadataValueSuggestion struct {
	Value   string `json:"value"`
	Count   int    `json:"count"`
	Example *Asset `json:"example,omitempty"`
}

type MetricsClient interface {
	Count(name string, value int64, tags ...string)
	Timing(name string, value time.Duration, tags ...string)
}

type NotificationObserver interface {
	OnAssetUpdated(ctx context.Context, asset *Asset, changeType string)
}

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

type Repository interface {
	Create(ctx context.Context, asset *Asset) error
	Get(ctx context.Context, id string) (*Asset, error)
	GetByMRN(ctx context.Context, qualifiedName string) (*Asset, error)
	Search(ctx context.Context, filter SearchFilter, calculateCounts bool) ([]*Asset, int, AvailableFilters, error)
	GetMyAssets(ctx context.Context, userID string, teamIDs []string, limit, offset int) ([]*Asset, int, error)
	Summary(ctx context.Context) (*AssetSummary, error)
	Update(ctx context.Context, asset *Asset) error
	Delete(ctx context.Context, id string) error
	DeleteByMRN(ctx context.Context, mrn string) error
	ListByPattern(ctx context.Context, pattern string, assetType string) ([]*Asset, error)
	GetByMRNs(ctx context.Context, mrns []string) ([]*Asset, error)
	GetByTypeAndName(ctx context.Context, assetType, name string) (*Asset, error)
	GetMetadataFieldsWithContext(ctx context.Context, queryContext *MetadataContext) ([]MetadataFieldSuggestion, error)
	GetMetadataValuesWithContext(ctx context.Context, field string, prefix string, limit int, queryContext *MetadataContext) ([]MetadataValueSuggestion, error)
	GetMetadataFields(ctx context.Context) ([]MetadataFieldSuggestion, error)
	GetMetadataValues(ctx context.Context, field string, prefix string, limit int) ([]MetadataValueSuggestion, error)
	GetTagSuggestions(ctx context.Context, prefix string, limit int) ([]string, error)
	GetRunHistory(ctx context.Context, assetID string, limit, offset int) ([]*RunHistory, int, error)
	GetRunHistoryHistogram(ctx context.Context, assetID string, days int) ([]HistogramBucket, error)

	AddTerms(ctx context.Context, assetID string, termIDs []string, source string, createdBy string) error
	RemoveTerm(ctx context.Context, assetID string, termID string) error
	GetTerms(ctx context.Context, assetID string) ([]AssetTerm, error)
	GetAssetsByTerm(ctx context.Context, termID string, limit, offset int) ([]*Asset, int, error)
}

type RunHistory struct {
	ID           string     `json:"id"`
	RunID        string     `json:"run_id"`
	JobName      string     `json:"job_name"`
	JobNamespace string     `json:"job_namespace"`
	Status       string     `json:"status"`
	StartTime    *time.Time `json:"start_time,omitempty"`
	EndTime      *time.Time `json:"end_time,omitempty"`
	DurationMs   *int64     `json:"duration_ms,omitempty"`
	Type         string     `json:"type"`
	EventTime    time.Time  `json:"event_time"`
}

type SearchFilter struct {
	Query        string   `json:"query" validate:"omitempty"`
	Types        []string `json:"types" validate:"omitempty"`
	Providers    []string `json:"providers" validate:"omitempty"`
	Tags         []string `json:"tags" validate:"omitempty"`
	Limit        int      `json:"limit" validate:"omitempty,gte=0"`
	Offset       int      `json:"offset" validate:"omitempty,gte=0"`
	IncludeStubs bool     `json:"include_stubs,omitempty"`
	OwnerType    *string  `json:"owner_type,omitempty"`
	OwnerID      *string  `json:"owner_id,omitempty"`
}

type Service interface {
	Create(ctx context.Context, input CreateInput) (*Asset, error)
	Get(ctx context.Context, id string) (*Asset, error)
	GetByMRN(ctx context.Context, qualifiedName string) (*Asset, error)
	Search(ctx context.Context, filter SearchFilter, calculateCounts bool) ([]*Asset, int, AvailableFilters, error)
	GetMyAssets(ctx context.Context, userID string, teamIDs []string, limit, offset int) ([]*Asset, int, error)
	Summary(ctx context.Context) (*AssetSummary, error)
	Update(ctx context.Context, id string, input UpdateInput) (*Asset, error)
	Delete(ctx context.Context, id string) error
	DeleteByMRN(ctx context.Context, mrn string) error
	AddTag(ctx context.Context, id string, tag string) (*Asset, error)
	RemoveTag(ctx context.Context, id string, tag string) (*Asset, error)
	ListByPattern(ctx context.Context, pattern string, assetType string) ([]*Asset, error)
	GetByMRNs(ctx context.Context, mrns []string) (map[string]*Asset, error)
	GetByTypeAndName(ctx context.Context, assetType, name string) (*Asset, error)
	GetMetadataFields(ctx context.Context, queryContext *MetadataContext) ([]MetadataFieldSuggestion, error)
	GetMetadataValues(ctx context.Context, field string, prefix string, limit int, queryContext *MetadataContext) ([]MetadataValueSuggestion, error)
	GetTagSuggestions(ctx context.Context, prefix string, limit int) ([]string, error)
	GetRunHistory(ctx context.Context, assetID string, limit, offset int) ([]*RunHistory, int, error)
	GetRunHistoryHistogram(ctx context.Context, assetID string, days int) ([]HistogramBucket, error)

	AddTerms(ctx context.Context, assetID string, termIDs []string, source string, createdBy string) error
	RemoveTerm(ctx context.Context, assetID string, termID string) error
	GetTerms(ctx context.Context, assetID string) ([]AssetTerm, error)
	GetAssetsByTerm(ctx context.Context, termID string, limit, offset int) ([]*Asset, int, error)

	// SetMembershipObserver registers an observer for asset create/delete events.
	SetMembershipObserver(observer MembershipObserver)
	// SetNotificationObserver registers an observer for asset update notifications.
	SetNotificationObserver(observer NotificationObserver)
}

type ServiceOption func(*service)

type UpdateInput struct {
	Name             *string                `json:"name"`
	Description      *string                `json:"description"`
	UserDescription  *string                `json:"user_description"`
	Metadata         map[string]interface{} `json:"metadata"`
	Type             string                 `json:"type"`
	Providers        []string               `json:"providers"`
	Schema           map[string]string      `json:"schema"`
	Tags             []string               `json:"tags"`
	Sources          []AssetSource          `json:"sources"`
	Environments     map[string]Environment `json:"environments"`
	ExternalLinks    []ExternalLink         `json:"external_links"`
	Query            *string                `json:"query,omitempty"`
	QueryLanguage    *string                `json:"query_language,omitempty"`
	SkipNotification bool                   `json:"-"`
}