asset

Sep 3, 2024

Changes in this version

+ type Config struct

+ AdditionalTypes []string

+ DeleteAssetsTimeout time.Duration

+ func (c *Config) Validate() error

type ServiceDeps

+ Config Config

Aug 22, 2024

Changes in this version

+ var ErrEmptyQuery = errors.New("query is empty")

type Asset

+ RefreshedAt *time.Time

+ type DeleteAssetExpr struct

+ func (d DeleteAssetExpr) ToQuery() (string, error)

+ func (d DeleteAssetExpr) Validate() error

+ type DeleteAssetsRequest struct

+ DryRun bool

+ QueryExpr string

type DiscoveryRepository

+ DeleteByQueryExpr func(ctx context.Context, queryExpr queryexpr.ExprStr) error

type LineageRepository

+ DeleteByURNs func(ctx context.Context, urns []string) error

type Repository

+ DeleteByQueryExpr func(ctx context.Context, queryExpr queryexpr.ExprStr) ([]string, error)

+ GetCountByQueryExpr func(ctx context.Context, queryExpr queryexpr.ExprStr) (int, error)

type Service

+ func (s *Service) DeleteAssets(ctx context.Context, request DeleteAssetsRequest) (affectedRows uint32, err error)

type ServiceDeps

+ Logger log.Logger

type Worker

+ EnqueueDeleteAssetsByQueryExprJob func(ctx context.Context, queryExpr string) error

Aug 22, 2024

Changes in this version

+ func RegisterSupportedTypes(types ...Type) error

type Type

+ func GetSupportedTypes() []Type

Jul 25, 2024

Changes in this version

type LineageQuery

+ WithAttributes bool

Apr 30, 2024

Changes in this version

type Type

+ const TypeMetric

Dec 11, 2023

Changes in this version

type DiscoveryRepository

+ SyncAssets func(ctx context.Context, indexName string) (cleanup func() error, err error)

type Service

+ func (s *Service) SyncAssets(ctx context.Context, services []string) error

type Worker

+ EnqueueSyncAssetJob func(ctx context.Context, service string) error

Nov 8, 2023

Changes in this version

type Type

+ const TypeQuery

Oct 9, 2023

Changes in this version

type SearchFlags

+ IsColumnSearch bool

Oct 6, 2023

Changes in this version

type SearchConfig

+ IncludeFields []string

Aug 21, 2023

Changes in this version

type Service

+ func (s *Service) GetAssetByIDWithoutProbes(ctx context.Context, id string) (Asset, error)

Aug 16, 2023

Changes in this version

type DiscoveryError

+ ESCode string

+ type ServiceDeps struct

+ AssetRepo Repository

+ DiscoveryRepo DiscoveryRepository

+ LineageRepo LineageRepository

+ Worker Worker

+ type Worker interface

+ Close func() error

+ EnqueueDeleteAssetJob func(ctx context.Context, urn string) error

+ EnqueueIndexAssetJob func(ctx context.Context, ast Asset) error

Jul 5, 2023

Changes in this version

+ var ErrProbeExists = errors.New("asset probe already exists")

May 26, 2023

Changes in this version

type SearchConfig

+ Flags SearchFlags

+ Offset int

+ type SearchFlags struct

+ DisableFuzzy bool

+ EnableHighlight bool

May 12, 2023

Changes in this version

type DiscoveryRepository

+ GroupAssets func(ctx context.Context, cfg GroupConfig) (results []GroupResult, err error)

+ type GroupConfig struct

+ Filters SearchFilter

+ GroupBy []string

+ IncludedFields []string

+ Size int

+ type GroupField struct

+ Name string

+ Value string

+ type GroupResult struct

+ Assets []Asset

+ Fields []GroupField

type Service

+ func (s *Service) GroupAssets(ctx context.Context, cfg GroupConfig) (results []GroupResult, err error)

May 2, 2023

Changes in this version

type LineageRepository

+ DeleteByURN func(ctx context.Context, urn string) error

Apr 12, 2023

Changes in this version

type DiscoveryError

+ ID string

+ Index string

+ Op string

Mar 14, 2023

Changes in this version

+ const BaseVersion

+ var AllSupportedTypes = []Type

+ var ErrEmptyID = errors.New("asset does not have ID")

+ var ErrEmptyURN = errors.New("asset does not have URN")

+ var ErrNilAsset = errors.New("nil asset")

+ var ErrUnknownType = errors.New("unknown type")

+ func IncreaseMinorVersion(v string) (string, error)

+ func NewFilterBuilder() *filterBuilder

+ func ParseVersion(v string) (*semver.Version, error)

+ type Asset struct

+ Changelog diff.Changelog

+ CreatedAt time.Time

+ Data map[string]interface{}

+ Description string

+ ID string

+ Labels map[string]string

+ Name string

+ Owners []user.User

+ Probes []Probe

+ Service string

+ Type Type

+ URL string

+ URN string

+ UpdatedAt time.Time

+ UpdatedBy user.User

+ Version string

+ func (a *Asset) Diff(otherAsset *Asset) (diff.Changelog, error)

+ func (a *Asset) Patch(patchData map[string]interface{})

+ type DiscoveryError struct

+ Err error

+ func (err DiscoveryError) Error() string

+ type DiscoveryRepository interface

+ DeleteByID func(ctx context.Context, assetID string) error

+ DeleteByURN func(ctx context.Context, assetURN string) error

+ Search func(ctx context.Context, cfg SearchConfig) (results []SearchResult, err error)

+ Suggest func(ctx context.Context, cfg SearchConfig) (suggestions []string, err error)

+ Upsert func(context.Context, Asset) error

+ type Filter struct

+ Data map[string][]string

+ Offset int

+ Query string

+ QueryFields []string

+ Services []string

+ Size int

+ SortBy string

+ SortDirection string

+ Types []Type

+ func (f *Filter) Validate() error

+ type InvalidError struct

+ AssetID string

+ func (err InvalidError) Error() string

+ type Lineage struct

+ Edges []LineageEdge

+ NodeAttrs map[string]NodeAttributes

+ type LineageDirection string

+ const LineageDirectionDownstream

+ const LineageDirectionUpstream

+ func (dir LineageDirection) IsValid() bool

+ type LineageEdge struct

+ Prop map[string]interface{}

+ Source string

+ Target string

+ type LineageGraph []LineageEdge

+ type LineageQuery struct

+ Direction LineageDirection

+ Level int

+ type LineageRepository interface

+ GetGraph func(ctx context.Context, urn string, query LineageQuery) (LineageGraph, error)

+ Upsert func(ctx context.Context, urn string, upstreams, downstreams []string) error

+ type NodeAttributes struct

+ Probes ProbesInfo

+ type NotFoundError struct

+ AssetID string

+ URN string

+ func (err NotFoundError) Error() string

+ type Probe struct

+ AssetURN string

+ CreatedAt time.Time

+ ID string

+ Metadata map[string]interface{}

+ Status string

+ StatusReason string

+ Timestamp time.Time

+ type ProbesFilter struct

+ AssetURNs []string

+ MaxRows int

+ NewerThan time.Time

+ OlderThan time.Time

+ type ProbesInfo struct

+ Latest Probe

+ type Repository interface

+ AddProbe func(ctx context.Context, assetURN string, probe *Probe) error

+ DeleteByID func(ctx context.Context, id string) error

+ DeleteByURN func(ctx context.Context, urn string) error

+ GetAll func(context.Context, Filter) ([]Asset, error)

+ GetByID func(ctx context.Context, id string) (Asset, error)

+ GetByURN func(ctx context.Context, urn string) (Asset, error)

+ GetByVersionWithID func(ctx context.Context, id string, version string) (Asset, error)

+ GetByVersionWithURN func(ctx context.Context, urn string, version string) (Asset, error)

+ GetCount func(context.Context, Filter) (int, error)

+ GetProbes func(ctx context.Context, assetURN string) ([]Probe, error)

+ GetProbesWithFilter func(ctx context.Context, flt ProbesFilter) (map[string][]Probe, error)

+ GetTypes func(ctx context.Context, flt Filter) (map[Type]int, error)

+ GetVersionHistory func(ctx context.Context, flt Filter, id string) ([]Asset, error)

+ Upsert func(ctx context.Context, ast *Asset) (string, error)

+ type SearchConfig struct

+ Filters SearchFilter

+ MaxResults int

+ Queries map[string]string

+ RankBy string

+ Text string

+ type SearchFilter = map[string][]string

+ type SearchResult struct

+ Data map[string]interface{}

+ Description string

+ ID string

+ Labels map[string]string

+ Service string

+ Title string

+ Type string

+ URN string

+ func (sr SearchResult) ToAsset() Asset

+ type Service struct

+ func NewService(assetRepository Repository, discoveryRepository DiscoveryRepository, ...) *Service

+ func (s *Service) AddProbe(ctx context.Context, assetURN string, probe *Probe) error

+ func (s *Service) DeleteAsset(ctx context.Context, id string) error

+ func (s *Service) GetAllAssets(ctx context.Context, flt Filter, withTotal bool) ([]Asset, uint32, error)

+ func (s *Service) GetAssetByID(ctx context.Context, id string) (ast Asset, err error)

+ func (s *Service) GetAssetByVersion(ctx context.Context, id string, version string) (Asset, error)

+ func (s *Service) GetAssetVersionHistory(ctx context.Context, flt Filter, id string) ([]Asset, error)

+ func (s *Service) GetLineage(ctx context.Context, urn string, query LineageQuery) (Lineage, error)

+ func (s *Service) GetTypes(ctx context.Context, flt Filter) (map[Type]int, error)

+ func (s *Service) SearchAssets(ctx context.Context, cfg SearchConfig) (results []SearchResult, err error)

+ func (s *Service) SuggestAssets(ctx context.Context, cfg SearchConfig) (suggestions []string, err error)

+ func (s *Service) UpsertAsset(ctx context.Context, ast *Asset, upstreams, downstreams []string) (string, error)

+ func (s *Service) UpsertAssetWithoutLineage(ctx context.Context, ast *Asset) (string, error)

+ type Type string

+ const TypeApplication

+ const TypeDashboard

+ const TypeFeatureTable

+ const TypeJob

+ const TypeModel

+ const TypeTable

+ const TypeTopic

+ func (t Type) IsValid() bool

+ func (t Type) String() string