mocks

Aug 22, 2024

Changes in this version

type AssetRepository

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

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

+ type AssetRepository_DeleteByQueryExpr_Call struct

+ func (_c *AssetRepository_DeleteByQueryExpr_Call) Return(_a0 []string, _a1 error) *AssetRepository_DeleteByQueryExpr_Call

+ func (_c *AssetRepository_DeleteByQueryExpr_Call) Run(run func(ctx context.Context, queryExpr queryexpr.ExprStr)) *AssetRepository_DeleteByQueryExpr_Call

+ func (_c *AssetRepository_DeleteByQueryExpr_Call) RunAndReturn(run func(context.Context, queryexpr.ExprStr) ([]string, error)) *AssetRepository_DeleteByQueryExpr_Call

type AssetRepository_Expecter

+ func (_e *AssetRepository_Expecter) DeleteByQueryExpr(ctx interface{}, queryExpr interface{}) *AssetRepository_DeleteByQueryExpr_Call

+ func (_e *AssetRepository_Expecter) GetCountByQueryExpr(ctx interface{}, queryExpr interface{}) *AssetRepository_GetCountByQueryExpr_Call

+ type AssetRepository_GetCountByQueryExpr_Call struct

+ func (_c *AssetRepository_GetCountByQueryExpr_Call) Return(_a0 int, _a1 error) *AssetRepository_GetCountByQueryExpr_Call

+ func (_c *AssetRepository_GetCountByQueryExpr_Call) Run(run func(ctx context.Context, queryExpr queryexpr.ExprStr)) *AssetRepository_GetCountByQueryExpr_Call

+ func (_c *AssetRepository_GetCountByQueryExpr_Call) RunAndReturn(run func(context.Context, queryexpr.ExprStr) (int, error)) *AssetRepository_GetCountByQueryExpr_Call

type DiscoveryRepository

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

+ type DiscoveryRepository_DeleteByQueryExpr_Call struct

+ func (_c *DiscoveryRepository_DeleteByQueryExpr_Call) Return(_a0 error) *DiscoveryRepository_DeleteByQueryExpr_Call

+ func (_c *DiscoveryRepository_DeleteByQueryExpr_Call) Run(run func(ctx context.Context, queryExpr queryexpr.ExprStr)) *DiscoveryRepository_DeleteByQueryExpr_Call

+ func (_c *DiscoveryRepository_DeleteByQueryExpr_Call) RunAndReturn(run func(context.Context, queryexpr.ExprStr) error) *DiscoveryRepository_DeleteByQueryExpr_Call

type DiscoveryRepository_Expecter

+ func (_e *DiscoveryRepository_Expecter) DeleteByQueryExpr(ctx interface{}, queryExpr interface{}) *DiscoveryRepository_DeleteByQueryExpr_Call

type LineageRepository

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

+ type LineageRepository_DeleteByURNs_Call struct

+ func (_c *LineageRepository_DeleteByURNs_Call) Return(_a0 error) *LineageRepository_DeleteByURNs_Call

+ func (_c *LineageRepository_DeleteByURNs_Call) Run(run func(ctx context.Context, urns []string)) *LineageRepository_DeleteByURNs_Call

+ func (_c *LineageRepository_DeleteByURNs_Call) RunAndReturn(run func(context.Context, []string) error) *LineageRepository_DeleteByURNs_Call

type LineageRepository_Expecter

+ func (_e *LineageRepository_Expecter) DeleteByURNs(ctx interface{}, urns interface{}) *LineageRepository_DeleteByURNs_Call

type Worker

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

+ type Worker_EnqueueDeleteAssetsByQueryExprJob_Call struct

+ func (_c *Worker_EnqueueDeleteAssetsByQueryExprJob_Call) Return(_a0 error) *Worker_EnqueueDeleteAssetsByQueryExprJob_Call

+ func (_c *Worker_EnqueueDeleteAssetsByQueryExprJob_Call) Run(run func(ctx context.Context, queryExpr string)) *Worker_EnqueueDeleteAssetsByQueryExprJob_Call

+ func (_c *Worker_EnqueueDeleteAssetsByQueryExprJob_Call) RunAndReturn(run func(context.Context, string) error) *Worker_EnqueueDeleteAssetsByQueryExprJob_Call

type Worker_Expecter

+ func (_e *Worker_Expecter) EnqueueDeleteAssetsByQueryExprJob(ctx interface{}, queryExpr interface{}) *Worker_EnqueueDeleteAssetsByQueryExprJob_Call

Dec 11, 2023

Changes in this version

type DiscoveryRepository

+ func (_m *DiscoveryRepository) SyncAssets(ctx context.Context, indexName string) (func() error, error)

type DiscoveryRepository_Expecter

+ func (_e *DiscoveryRepository_Expecter) SyncAssets(ctx interface{}, indexName interface{}) *DiscoveryRepository_SyncAssets_Call

+ type DiscoveryRepository_SyncAssets_Call struct

+ func (_c *DiscoveryRepository_SyncAssets_Call) Return(cleanup func() error, err error) *DiscoveryRepository_SyncAssets_Call

+ func (_c *DiscoveryRepository_SyncAssets_Call) Run(run func(ctx context.Context, indexName string)) *DiscoveryRepository_SyncAssets_Call

+ func (_c *DiscoveryRepository_SyncAssets_Call) RunAndReturn(run func(context.Context, string) (func() error, error)) *DiscoveryRepository_SyncAssets_Call

type Worker

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

+ type Worker_EnqueueSyncAssetJob_Call struct

+ func (_c *Worker_EnqueueSyncAssetJob_Call) Return(_a0 error) *Worker_EnqueueSyncAssetJob_Call

+ func (_c *Worker_EnqueueSyncAssetJob_Call) Run(run func(ctx context.Context, service string)) *Worker_EnqueueSyncAssetJob_Call

+ func (_c *Worker_EnqueueSyncAssetJob_Call) RunAndReturn(run func(context.Context, string) error) *Worker_EnqueueSyncAssetJob_Call

type Worker_Expecter

+ func (_e *Worker_Expecter) EnqueueSyncAssetJob(ctx interface{}, service interface{}) *Worker_EnqueueSyncAssetJob_Call

Aug 16, 2023

Changes in this version

type DiscoveryRepository_GroupAssets_Call

+ func (_c *DiscoveryRepository_GroupAssets_Call) RunAndReturn(run func(context.Context, asset.GroupConfig) ([]asset.GroupResult, error)) *DiscoveryRepository_GroupAssets_Call

+ type Worker struct

+ func NewWorker(t mockConstructorTestingTNewWorker) *Worker

+ func (_m *Worker) Close() error

+ func (_m *Worker) EXPECT() *Worker_Expecter

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

+ func (_m *Worker) EnqueueIndexAssetJob(ctx context.Context, ast asset.Asset) error

+ type Worker_Close_Call struct

+ func (_c *Worker_Close_Call) Return(_a0 error) *Worker_Close_Call

+ func (_c *Worker_Close_Call) Run(run func()) *Worker_Close_Call

+ func (_c *Worker_Close_Call) RunAndReturn(run func() error) *Worker_Close_Call

+ type Worker_EnqueueDeleteAssetJob_Call struct

+ func (_c *Worker_EnqueueDeleteAssetJob_Call) Return(_a0 error) *Worker_EnqueueDeleteAssetJob_Call

+ func (_c *Worker_EnqueueDeleteAssetJob_Call) Run(run func(ctx context.Context, urn string)) *Worker_EnqueueDeleteAssetJob_Call

+ func (_c *Worker_EnqueueDeleteAssetJob_Call) RunAndReturn(run func(context.Context, string) error) *Worker_EnqueueDeleteAssetJob_Call

+ type Worker_EnqueueIndexAssetJob_Call struct

+ func (_c *Worker_EnqueueIndexAssetJob_Call) Return(_a0 error) *Worker_EnqueueIndexAssetJob_Call

+ func (_c *Worker_EnqueueIndexAssetJob_Call) Run(run func(ctx context.Context, ast asset.Asset)) *Worker_EnqueueIndexAssetJob_Call

+ func (_c *Worker_EnqueueIndexAssetJob_Call) RunAndReturn(run func(context.Context, asset.Asset) error) *Worker_EnqueueIndexAssetJob_Call

+ type Worker_Expecter struct

+ func (_e *Worker_Expecter) Close() *Worker_Close_Call

+ func (_e *Worker_Expecter) EnqueueDeleteAssetJob(ctx interface{}, urn interface{}) *Worker_EnqueueDeleteAssetJob_Call

+ func (_e *Worker_Expecter) EnqueueIndexAssetJob(ctx interface{}, ast interface{}) *Worker_EnqueueIndexAssetJob_Call

May 12, 2023

Changes in this version

type DiscoveryRepository

+ func (_m *DiscoveryRepository) GroupAssets(ctx context.Context, cfg asset.GroupConfig) ([]asset.GroupResult, error)

type DiscoveryRepository_Expecter

+ func (_e *DiscoveryRepository_Expecter) GroupAssets(ctx interface{}, cfg interface{}) *DiscoveryRepository_GroupAssets_Call

+ type DiscoveryRepository_GroupAssets_Call struct

+ func (_c *DiscoveryRepository_GroupAssets_Call) Return(results []asset.GroupResult, err error) *DiscoveryRepository_GroupAssets_Call

+ func (_c *DiscoveryRepository_GroupAssets_Call) Run(run func(ctx context.Context, cfg asset.GroupConfig)) *DiscoveryRepository_GroupAssets_Call

May 2, 2023

Changes in this version

type AssetRepository_AddProbe_Call

+ func (_c *AssetRepository_AddProbe_Call) RunAndReturn(run func(context.Context, string, *asset.Probe) error) *AssetRepository_AddProbe_Call

type AssetRepository_DeleteByID_Call

+ func (_c *AssetRepository_DeleteByID_Call) RunAndReturn(run func(context.Context, string) error) *AssetRepository_DeleteByID_Call

type AssetRepository_DeleteByURN_Call

+ func (_c *AssetRepository_DeleteByURN_Call) RunAndReturn(run func(context.Context, string) error) *AssetRepository_DeleteByURN_Call

type AssetRepository_GetAll_Call

+ func (_c *AssetRepository_GetAll_Call) RunAndReturn(run func(context.Context, asset.Filter) ([]asset.Asset, error)) *AssetRepository_GetAll_Call

type AssetRepository_GetByID_Call

+ func (_c *AssetRepository_GetByID_Call) RunAndReturn(run func(context.Context, string) (asset.Asset, error)) *AssetRepository_GetByID_Call

type AssetRepository_GetByURN_Call

+ func (_c *AssetRepository_GetByURN_Call) RunAndReturn(run func(context.Context, string) (asset.Asset, error)) *AssetRepository_GetByURN_Call

type AssetRepository_GetByVersionWithID_Call

+ func (_c *AssetRepository_GetByVersionWithID_Call) RunAndReturn(run func(context.Context, string, string) (asset.Asset, error)) *AssetRepository_GetByVersionWithID_Call

type AssetRepository_GetByVersionWithURN_Call

+ func (_c *AssetRepository_GetByVersionWithURN_Call) RunAndReturn(run func(context.Context, string, string) (asset.Asset, error)) *AssetRepository_GetByVersionWithURN_Call

type AssetRepository_GetCount_Call

+ func (_c *AssetRepository_GetCount_Call) RunAndReturn(run func(context.Context, asset.Filter) (int, error)) *AssetRepository_GetCount_Call

type AssetRepository_GetProbesWithFilter_Call

+ func (_c *AssetRepository_GetProbesWithFilter_Call) RunAndReturn(...) *AssetRepository_GetProbesWithFilter_Call

type AssetRepository_GetProbes_Call

+ func (_c *AssetRepository_GetProbes_Call) RunAndReturn(run func(context.Context, string) ([]asset.Probe, error)) *AssetRepository_GetProbes_Call

type AssetRepository_GetTypes_Call

+ func (_c *AssetRepository_GetTypes_Call) RunAndReturn(run func(context.Context, asset.Filter) (map[asset.Type]int, error)) *AssetRepository_GetTypes_Call

type AssetRepository_GetVersionHistory_Call

+ func (_c *AssetRepository_GetVersionHistory_Call) RunAndReturn(run func(context.Context, asset.Filter, string) ([]asset.Asset, error)) *AssetRepository_GetVersionHistory_Call

type AssetRepository_Upsert_Call

+ func (_c *AssetRepository_Upsert_Call) RunAndReturn(run func(context.Context, *asset.Asset) (string, error)) *AssetRepository_Upsert_Call

type DiscoveryRepository_DeleteByID_Call

+ func (_c *DiscoveryRepository_DeleteByID_Call) RunAndReturn(run func(context.Context, string) error) *DiscoveryRepository_DeleteByID_Call

type DiscoveryRepository_DeleteByURN_Call

+ func (_c *DiscoveryRepository_DeleteByURN_Call) RunAndReturn(run func(context.Context, string) error) *DiscoveryRepository_DeleteByURN_Call

type DiscoveryRepository_Search_Call

+ func (_c *DiscoveryRepository_Search_Call) RunAndReturn(run func(context.Context, asset.SearchConfig) ([]asset.SearchResult, error)) *DiscoveryRepository_Search_Call

type DiscoveryRepository_Suggest_Call

+ func (_c *DiscoveryRepository_Suggest_Call) RunAndReturn(run func(context.Context, asset.SearchConfig) ([]string, error)) *DiscoveryRepository_Suggest_Call

type DiscoveryRepository_Upsert_Call

+ func (_c *DiscoveryRepository_Upsert_Call) RunAndReturn(run func(context.Context, asset.Asset) error) *DiscoveryRepository_Upsert_Call

type LineageRepository

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

+ type LineageRepository_DeleteByURN_Call struct

+ func (_c *LineageRepository_DeleteByURN_Call) Return(_a0 error) *LineageRepository_DeleteByURN_Call

+ func (_c *LineageRepository_DeleteByURN_Call) Run(run func(ctx context.Context, urn string)) *LineageRepository_DeleteByURN_Call

+ func (_c *LineageRepository_DeleteByURN_Call) RunAndReturn(run func(context.Context, string) error) *LineageRepository_DeleteByURN_Call

type LineageRepository_Expecter

+ func (_e *LineageRepository_Expecter) DeleteByURN(ctx interface{}, urn interface{}) *LineageRepository_DeleteByURN_Call

type LineageRepository_GetGraph_Call

+ func (_c *LineageRepository_GetGraph_Call) RunAndReturn(...) *LineageRepository_GetGraph_Call

type LineageRepository_Upsert_Call

+ func (_c *LineageRepository_Upsert_Call) RunAndReturn(run func(context.Context, string, []string, []string) error) *LineageRepository_Upsert_Call

Mar 14, 2023

Changes in this version

+ type AssetRepository struct

+ func NewAssetRepository(t mockConstructorTestingTNewAssetRepository) *AssetRepository

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

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

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

+ func (_m *AssetRepository) EXPECT() *AssetRepository_Expecter

+ func (_m *AssetRepository) GetAll(_a0 context.Context, _a1 asset.Filter) ([]asset.Asset, error)

+ func (_m *AssetRepository) GetByID(ctx context.Context, id string) (asset.Asset, error)

+ func (_m *AssetRepository) GetByURN(ctx context.Context, urn string) (asset.Asset, error)

+ func (_m *AssetRepository) GetByVersionWithID(ctx context.Context, id string, version string) (asset.Asset, error)

+ func (_m *AssetRepository) GetByVersionWithURN(ctx context.Context, urn string, version string) (asset.Asset, error)

+ func (_m *AssetRepository) GetCount(_a0 context.Context, _a1 asset.Filter) (int, error)

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

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

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

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

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

+ type AssetRepository_AddProbe_Call struct

+ func (_c *AssetRepository_AddProbe_Call) Return(_a0 error) *AssetRepository_AddProbe_Call

+ func (_c *AssetRepository_AddProbe_Call) Run(run func(ctx context.Context, assetURN string, probe *asset.Probe)) *AssetRepository_AddProbe_Call

+ type AssetRepository_DeleteByID_Call struct

+ func (_c *AssetRepository_DeleteByID_Call) Return(_a0 error) *AssetRepository_DeleteByID_Call

+ func (_c *AssetRepository_DeleteByID_Call) Run(run func(ctx context.Context, id string)) *AssetRepository_DeleteByID_Call

+ type AssetRepository_DeleteByURN_Call struct

+ func (_c *AssetRepository_DeleteByURN_Call) Return(_a0 error) *AssetRepository_DeleteByURN_Call

+ func (_c *AssetRepository_DeleteByURN_Call) Run(run func(ctx context.Context, urn string)) *AssetRepository_DeleteByURN_Call

+ type AssetRepository_Expecter struct

+ func (_e *AssetRepository_Expecter) AddProbe(ctx interface{}, assetURN interface{}, probe interface{}) *AssetRepository_AddProbe_Call

+ func (_e *AssetRepository_Expecter) DeleteByID(ctx interface{}, id interface{}) *AssetRepository_DeleteByID_Call

+ func (_e *AssetRepository_Expecter) DeleteByURN(ctx interface{}, urn interface{}) *AssetRepository_DeleteByURN_Call

+ func (_e *AssetRepository_Expecter) GetAll(_a0 interface{}, _a1 interface{}) *AssetRepository_GetAll_Call

+ func (_e *AssetRepository_Expecter) GetByID(ctx interface{}, id interface{}) *AssetRepository_GetByID_Call

+ func (_e *AssetRepository_Expecter) GetByURN(ctx interface{}, urn interface{}) *AssetRepository_GetByURN_Call

+ func (_e *AssetRepository_Expecter) GetByVersionWithID(ctx interface{}, id interface{}, version interface{}) *AssetRepository_GetByVersionWithID_Call

+ func (_e *AssetRepository_Expecter) GetByVersionWithURN(ctx interface{}, urn interface{}, version interface{}) *AssetRepository_GetByVersionWithURN_Call

+ func (_e *AssetRepository_Expecter) GetCount(_a0 interface{}, _a1 interface{}) *AssetRepository_GetCount_Call

+ func (_e *AssetRepository_Expecter) GetProbes(ctx interface{}, assetURN interface{}) *AssetRepository_GetProbes_Call

+ func (_e *AssetRepository_Expecter) GetProbesWithFilter(ctx interface{}, flt interface{}) *AssetRepository_GetProbesWithFilter_Call

+ func (_e *AssetRepository_Expecter) GetTypes(ctx interface{}, flt interface{}) *AssetRepository_GetTypes_Call

+ func (_e *AssetRepository_Expecter) GetVersionHistory(ctx interface{}, flt interface{}, id interface{}) *AssetRepository_GetVersionHistory_Call

+ func (_e *AssetRepository_Expecter) Upsert(ctx interface{}, ast interface{}) *AssetRepository_Upsert_Call

+ type AssetRepository_GetAll_Call struct

+ func (_c *AssetRepository_GetAll_Call) Return(_a0 []asset.Asset, _a1 error) *AssetRepository_GetAll_Call

+ func (_c *AssetRepository_GetAll_Call) Run(run func(_a0 context.Context, _a1 asset.Filter)) *AssetRepository_GetAll_Call

+ type AssetRepository_GetByID_Call struct

+ func (_c *AssetRepository_GetByID_Call) Return(_a0 asset.Asset, _a1 error) *AssetRepository_GetByID_Call

+ func (_c *AssetRepository_GetByID_Call) Run(run func(ctx context.Context, id string)) *AssetRepository_GetByID_Call

+ type AssetRepository_GetByURN_Call struct

+ func (_c *AssetRepository_GetByURN_Call) Return(_a0 asset.Asset, _a1 error) *AssetRepository_GetByURN_Call

+ func (_c *AssetRepository_GetByURN_Call) Run(run func(ctx context.Context, urn string)) *AssetRepository_GetByURN_Call

+ type AssetRepository_GetByVersionWithID_Call struct

+ func (_c *AssetRepository_GetByVersionWithID_Call) Return(_a0 asset.Asset, _a1 error) *AssetRepository_GetByVersionWithID_Call

+ func (_c *AssetRepository_GetByVersionWithID_Call) Run(run func(ctx context.Context, id string, version string)) *AssetRepository_GetByVersionWithID_Call

+ type AssetRepository_GetByVersionWithURN_Call struct

+ func (_c *AssetRepository_GetByVersionWithURN_Call) Return(_a0 asset.Asset, _a1 error) *AssetRepository_GetByVersionWithURN_Call

+ func (_c *AssetRepository_GetByVersionWithURN_Call) Run(run func(ctx context.Context, urn string, version string)) *AssetRepository_GetByVersionWithURN_Call

+ type AssetRepository_GetCount_Call struct

+ func (_c *AssetRepository_GetCount_Call) Return(_a0 int, _a1 error) *AssetRepository_GetCount_Call

+ func (_c *AssetRepository_GetCount_Call) Run(run func(_a0 context.Context, _a1 asset.Filter)) *AssetRepository_GetCount_Call

+ type AssetRepository_GetProbesWithFilter_Call struct

+ func (_c *AssetRepository_GetProbesWithFilter_Call) Return(_a0 map[string][]asset.Probe, _a1 error) *AssetRepository_GetProbesWithFilter_Call

+ func (_c *AssetRepository_GetProbesWithFilter_Call) Run(run func(ctx context.Context, flt asset.ProbesFilter)) *AssetRepository_GetProbesWithFilter_Call

+ type AssetRepository_GetProbes_Call struct

+ func (_c *AssetRepository_GetProbes_Call) Return(_a0 []asset.Probe, _a1 error) *AssetRepository_GetProbes_Call

+ func (_c *AssetRepository_GetProbes_Call) Run(run func(ctx context.Context, assetURN string)) *AssetRepository_GetProbes_Call

+ type AssetRepository_GetTypes_Call struct

+ func (_c *AssetRepository_GetTypes_Call) Return(_a0 map[asset.Type]int, _a1 error) *AssetRepository_GetTypes_Call

+ func (_c *AssetRepository_GetTypes_Call) Run(run func(ctx context.Context, flt asset.Filter)) *AssetRepository_GetTypes_Call

+ type AssetRepository_GetVersionHistory_Call struct

+ func (_c *AssetRepository_GetVersionHistory_Call) Return(_a0 []asset.Asset, _a1 error) *AssetRepository_GetVersionHistory_Call

+ func (_c *AssetRepository_GetVersionHistory_Call) Run(run func(ctx context.Context, flt asset.Filter, id string)) *AssetRepository_GetVersionHistory_Call

+ type AssetRepository_Upsert_Call struct

+ func (_c *AssetRepository_Upsert_Call) Return(_a0 string, _a1 error) *AssetRepository_Upsert_Call

+ func (_c *AssetRepository_Upsert_Call) Run(run func(ctx context.Context, ast *asset.Asset)) *AssetRepository_Upsert_Call

+ type DiscoveryRepository struct

+ func NewDiscoveryRepository(t testing.TB) *DiscoveryRepository

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

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

+ func (_m *DiscoveryRepository) EXPECT() *DiscoveryRepository_Expecter

+ func (_m *DiscoveryRepository) Search(ctx context.Context, cfg asset.SearchConfig) ([]asset.SearchResult, error)

+ func (_m *DiscoveryRepository) Suggest(ctx context.Context, cfg asset.SearchConfig) ([]string, error)

+ func (_m *DiscoveryRepository) Upsert(_a0 context.Context, _a1 asset.Asset) error

+ type DiscoveryRepository_DeleteByID_Call struct

+ func (_c *DiscoveryRepository_DeleteByID_Call) Return(_a0 error) *DiscoveryRepository_DeleteByID_Call

+ func (_c *DiscoveryRepository_DeleteByID_Call) Run(run func(ctx context.Context, assetID string)) *DiscoveryRepository_DeleteByID_Call

+ type DiscoveryRepository_DeleteByURN_Call struct

+ func (_c *DiscoveryRepository_DeleteByURN_Call) Return(_a0 error) *DiscoveryRepository_DeleteByURN_Call

+ func (_c *DiscoveryRepository_DeleteByURN_Call) Run(run func(ctx context.Context, assetURN string)) *DiscoveryRepository_DeleteByURN_Call

+ type DiscoveryRepository_Expecter struct

+ func (_e *DiscoveryRepository_Expecter) DeleteByID(ctx interface{}, assetID interface{}) *DiscoveryRepository_DeleteByID_Call

+ func (_e *DiscoveryRepository_Expecter) DeleteByURN(ctx interface{}, assetURN interface{}) *DiscoveryRepository_DeleteByURN_Call

+ func (_e *DiscoveryRepository_Expecter) Search(ctx interface{}, cfg interface{}) *DiscoveryRepository_Search_Call

+ func (_e *DiscoveryRepository_Expecter) Suggest(ctx interface{}, cfg interface{}) *DiscoveryRepository_Suggest_Call

+ func (_e *DiscoveryRepository_Expecter) Upsert(_a0 interface{}, _a1 interface{}) *DiscoveryRepository_Upsert_Call

+ type DiscoveryRepository_Search_Call struct

+ func (_c *DiscoveryRepository_Search_Call) Return(results []asset.SearchResult, err error) *DiscoveryRepository_Search_Call

+ func (_c *DiscoveryRepository_Search_Call) Run(run func(ctx context.Context, cfg asset.SearchConfig)) *DiscoveryRepository_Search_Call

+ type DiscoveryRepository_Suggest_Call struct

+ func (_c *DiscoveryRepository_Suggest_Call) Return(suggestions []string, err error) *DiscoveryRepository_Suggest_Call

+ func (_c *DiscoveryRepository_Suggest_Call) Run(run func(ctx context.Context, cfg asset.SearchConfig)) *DiscoveryRepository_Suggest_Call

+ type DiscoveryRepository_Upsert_Call struct

+ func (_c *DiscoveryRepository_Upsert_Call) Return(_a0 error) *DiscoveryRepository_Upsert_Call

+ func (_c *DiscoveryRepository_Upsert_Call) Run(run func(_a0 context.Context, _a1 asset.Asset)) *DiscoveryRepository_Upsert_Call

+ type LineageRepository struct

+ func NewLineageRepository(t mockConstructorTestingTNewLineageRepository) *LineageRepository

+ func (_m *LineageRepository) EXPECT() *LineageRepository_Expecter

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

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

+ type LineageRepository_Expecter struct

+ func (_e *LineageRepository_Expecter) GetGraph(ctx interface{}, urn interface{}, query interface{}) *LineageRepository_GetGraph_Call

+ func (_e *LineageRepository_Expecter) Upsert(ctx interface{}, urn interface{}, upstreams interface{}, ...) *LineageRepository_Upsert_Call

+ type LineageRepository_GetGraph_Call struct

+ func (_c *LineageRepository_GetGraph_Call) Return(_a0 asset.LineageGraph, _a1 error) *LineageRepository_GetGraph_Call

+ func (_c *LineageRepository_GetGraph_Call) Run(run func(ctx context.Context, urn string, query asset.LineageQuery)) *LineageRepository_GetGraph_Call

+ type LineageRepository_Upsert_Call struct

+ func (_c *LineageRepository_Upsert_Call) Return(_a0 error) *LineageRepository_Upsert_Call

+ func (_c *LineageRepository_Upsert_Call) Run(...) *LineageRepository_Upsert_Call