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"`
	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"`
	ExternalLinks []ExternalLink         `json:"external_links,omitempty"`
	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 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"`
}

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"`
}

type ListResult struct {
	Assets  []*Asset
	Total   int
	Filters AvailableFilters
}

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

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 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)
	List(ctx context.Context, offset, limit int) (*ListResult, error)
	Search(ctx context.Context, filter SearchFilter, calculateCounts bool) ([]*Asset, int, AvailableFilters, error)
	Summary(ctx context.Context) (*AssetSummary, error)
	Update(ctx context.Context, asset *Asset) error
	Delete(ctx context.Context, id 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)
}

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"`
}

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)
	List(ctx context.Context, offset, limit int) (*ListResult, error)
	Search(ctx context.Context, filter SearchFilter, calculateCounts bool) ([]*Asset, int, AvailableFilters, error)
	Summary(ctx context.Context) (*AssetSummary, error)
	Update(ctx context.Context, id string, input UpdateInput) (*Asset, error)
	Delete(ctx context.Context, id 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)
}

type ServiceOption func(*service)

type UpdateInput struct {
	Name          *string                `json:"name"`
	Description   *string                `json:"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"`
}