Documentation ¶
Index ¶
- type AssetService
- func (_m *AssetService) AddProbe(ctx context.Context, assetURN string, probe *asset.Probe) error
- func (_m *AssetService) DeleteAsset(ctx context.Context, id string) error
- func (_m *AssetService) EXPECT() *AssetService_Expecter
- func (_m *AssetService) GetAllAssets(ctx context.Context, flt asset.Filter, withTotal bool) ([]asset.Asset, uint32, error)
- func (_m *AssetService) GetAssetByID(ctx context.Context, id string) (asset.Asset, error)
- func (_m *AssetService) GetAssetByVersion(ctx context.Context, id string, version string) (asset.Asset, error)
- func (_m *AssetService) GetAssetVersionHistory(ctx context.Context, flt asset.Filter, id string) ([]asset.Asset, error)
- func (_m *AssetService) GetLineage(ctx context.Context, urn string, query asset.LineageQuery) (asset.Lineage, error)
- func (_m *AssetService) GetTypes(ctx context.Context, flt asset.Filter) (map[asset.Type]int, error)
- func (_m *AssetService) GroupAssets(ctx context.Context, cfg asset.GroupConfig) ([]asset.GroupResult, error)
- func (_m *AssetService) SearchAssets(ctx context.Context, cfg asset.SearchConfig) ([]asset.SearchResult, error)
- func (_m *AssetService) SuggestAssets(ctx context.Context, cfg asset.SearchConfig) ([]string, error)
- func (_m *AssetService) UpsertAsset(ctx context.Context, ast *asset.Asset, upstreams []string, ...) (string, error)
- func (_m *AssetService) UpsertAssetWithoutLineage(ctx context.Context, ast *asset.Asset) (string, error)
- type AssetService_AddProbe_Call
- func (_c *AssetService_AddProbe_Call) Return(_a0 error) *AssetService_AddProbe_Call
- func (_c *AssetService_AddProbe_Call) Run(run func(ctx context.Context, assetURN string, probe *asset.Probe)) *AssetService_AddProbe_Call
- func (_c *AssetService_AddProbe_Call) RunAndReturn(run func(context.Context, string, *asset.Probe) error) *AssetService_AddProbe_Call
- type AssetService_DeleteAsset_Call
- func (_c *AssetService_DeleteAsset_Call) Return(_a0 error) *AssetService_DeleteAsset_Call
- func (_c *AssetService_DeleteAsset_Call) Run(run func(ctx context.Context, id string)) *AssetService_DeleteAsset_Call
- func (_c *AssetService_DeleteAsset_Call) RunAndReturn(run func(context.Context, string) error) *AssetService_DeleteAsset_Call
- type AssetService_Expecter
- func (_e *AssetService_Expecter) AddProbe(ctx interface{}, assetURN interface{}, probe interface{}) *AssetService_AddProbe_Call
- func (_e *AssetService_Expecter) DeleteAsset(ctx interface{}, id interface{}) *AssetService_DeleteAsset_Call
- func (_e *AssetService_Expecter) GetAllAssets(ctx interface{}, flt interface{}, withTotal interface{}) *AssetService_GetAllAssets_Call
- func (_e *AssetService_Expecter) GetAssetByID(ctx interface{}, id interface{}) *AssetService_GetAssetByID_Call
- func (_e *AssetService_Expecter) GetAssetByVersion(ctx interface{}, id interface{}, version interface{}) *AssetService_GetAssetByVersion_Call
- func (_e *AssetService_Expecter) GetAssetVersionHistory(ctx interface{}, flt interface{}, id interface{}) *AssetService_GetAssetVersionHistory_Call
- func (_e *AssetService_Expecter) GetLineage(ctx interface{}, urn interface{}, query interface{}) *AssetService_GetLineage_Call
- func (_e *AssetService_Expecter) GetTypes(ctx interface{}, flt interface{}) *AssetService_GetTypes_Call
- func (_e *AssetService_Expecter) GroupAssets(ctx interface{}, cfg interface{}) *AssetService_GroupAssets_Call
- func (_e *AssetService_Expecter) SearchAssets(ctx interface{}, cfg interface{}) *AssetService_SearchAssets_Call
- func (_e *AssetService_Expecter) SuggestAssets(ctx interface{}, cfg interface{}) *AssetService_SuggestAssets_Call
- func (_e *AssetService_Expecter) UpsertAsset(ctx interface{}, ast interface{}, upstreams interface{}, ...) *AssetService_UpsertAsset_Call
- func (_e *AssetService_Expecter) UpsertAssetWithoutLineage(ctx interface{}, ast interface{}) *AssetService_UpsertAssetWithoutLineage_Call
- type AssetService_GetAllAssets_Call
- func (_c *AssetService_GetAllAssets_Call) Return(_a0 []asset.Asset, _a1 uint32, _a2 error) *AssetService_GetAllAssets_Call
- func (_c *AssetService_GetAllAssets_Call) Run(run func(ctx context.Context, flt asset.Filter, withTotal bool)) *AssetService_GetAllAssets_Call
- func (_c *AssetService_GetAllAssets_Call) RunAndReturn(run func(context.Context, asset.Filter, bool) ([]asset.Asset, uint32, error)) *AssetService_GetAllAssets_Call
- type AssetService_GetAssetByID_Call
- func (_c *AssetService_GetAssetByID_Call) Return(_a0 asset.Asset, _a1 error) *AssetService_GetAssetByID_Call
- func (_c *AssetService_GetAssetByID_Call) Run(run func(ctx context.Context, id string)) *AssetService_GetAssetByID_Call
- func (_c *AssetService_GetAssetByID_Call) RunAndReturn(run func(context.Context, string) (asset.Asset, error)) *AssetService_GetAssetByID_Call
- type AssetService_GetAssetByVersion_Call
- func (_c *AssetService_GetAssetByVersion_Call) Return(_a0 asset.Asset, _a1 error) *AssetService_GetAssetByVersion_Call
- func (_c *AssetService_GetAssetByVersion_Call) Run(run func(ctx context.Context, id string, version string)) *AssetService_GetAssetByVersion_Call
- func (_c *AssetService_GetAssetByVersion_Call) RunAndReturn(run func(context.Context, string, string) (asset.Asset, error)) *AssetService_GetAssetByVersion_Call
- type AssetService_GetAssetVersionHistory_Call
- func (_c *AssetService_GetAssetVersionHistory_Call) Return(_a0 []asset.Asset, _a1 error) *AssetService_GetAssetVersionHistory_Call
- func (_c *AssetService_GetAssetVersionHistory_Call) Run(run func(ctx context.Context, flt asset.Filter, id string)) *AssetService_GetAssetVersionHistory_Call
- func (_c *AssetService_GetAssetVersionHistory_Call) RunAndReturn(run func(context.Context, asset.Filter, string) ([]asset.Asset, error)) *AssetService_GetAssetVersionHistory_Call
- type AssetService_GetLineage_Call
- func (_c *AssetService_GetLineage_Call) Return(_a0 asset.Lineage, _a1 error) *AssetService_GetLineage_Call
- func (_c *AssetService_GetLineage_Call) Run(run func(ctx context.Context, urn string, query asset.LineageQuery)) *AssetService_GetLineage_Call
- func (_c *AssetService_GetLineage_Call) RunAndReturn(run func(context.Context, string, asset.LineageQuery) (asset.Lineage, error)) *AssetService_GetLineage_Call
- type AssetService_GetTypes_Call
- func (_c *AssetService_GetTypes_Call) Return(_a0 map[asset.Type]int, _a1 error) *AssetService_GetTypes_Call
- func (_c *AssetService_GetTypes_Call) Run(run func(ctx context.Context, flt asset.Filter)) *AssetService_GetTypes_Call
- func (_c *AssetService_GetTypes_Call) RunAndReturn(run func(context.Context, asset.Filter) (map[asset.Type]int, error)) *AssetService_GetTypes_Call
- type AssetService_GroupAssets_Call
- func (_c *AssetService_GroupAssets_Call) Return(results []asset.GroupResult, err error) *AssetService_GroupAssets_Call
- func (_c *AssetService_GroupAssets_Call) Run(run func(ctx context.Context, cfg asset.GroupConfig)) *AssetService_GroupAssets_Call
- func (_c *AssetService_GroupAssets_Call) RunAndReturn(run func(context.Context, asset.GroupConfig) ([]asset.GroupResult, error)) *AssetService_GroupAssets_Call
- type AssetService_SearchAssets_Call
- func (_c *AssetService_SearchAssets_Call) Return(results []asset.SearchResult, err error) *AssetService_SearchAssets_Call
- func (_c *AssetService_SearchAssets_Call) Run(run func(ctx context.Context, cfg asset.SearchConfig)) *AssetService_SearchAssets_Call
- func (_c *AssetService_SearchAssets_Call) RunAndReturn(run func(context.Context, asset.SearchConfig) ([]asset.SearchResult, error)) *AssetService_SearchAssets_Call
- type AssetService_SuggestAssets_Call
- func (_c *AssetService_SuggestAssets_Call) Return(suggestions []string, err error) *AssetService_SuggestAssets_Call
- func (_c *AssetService_SuggestAssets_Call) Run(run func(ctx context.Context, cfg asset.SearchConfig)) *AssetService_SuggestAssets_Call
- func (_c *AssetService_SuggestAssets_Call) RunAndReturn(run func(context.Context, asset.SearchConfig) ([]string, error)) *AssetService_SuggestAssets_Call
- type AssetService_UpsertAssetWithoutLineage_Call
- func (_c *AssetService_UpsertAssetWithoutLineage_Call) Return(_a0 string, _a1 error) *AssetService_UpsertAssetWithoutLineage_Call
- func (_c *AssetService_UpsertAssetWithoutLineage_Call) Run(run func(ctx context.Context, ast *asset.Asset)) *AssetService_UpsertAssetWithoutLineage_Call
- func (_c *AssetService_UpsertAssetWithoutLineage_Call) RunAndReturn(run func(context.Context, *asset.Asset) (string, error)) *AssetService_UpsertAssetWithoutLineage_Call
- type AssetService_UpsertAsset_Call
- func (_c *AssetService_UpsertAsset_Call) Return(_a0 string, _a1 error) *AssetService_UpsertAsset_Call
- func (_c *AssetService_UpsertAsset_Call) Run(run func(ctx context.Context, ast *asset.Asset, upstreams []string, ...)) *AssetService_UpsertAsset_Call
- func (_c *AssetService_UpsertAsset_Call) RunAndReturn(run func(context.Context, *asset.Asset, []string, []string) (string, error)) *AssetService_UpsertAsset_Call
- type 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) GroupAssets(ctx context.Context, cfg asset.GroupConfig) ([]asset.GroupResult, error)
- 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
- 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
- func (_c *DiscoveryRepository_DeleteByID_Call) RunAndReturn(run func(context.Context, string) error) *DiscoveryRepository_DeleteByID_Call
- type DiscoveryRepository_DeleteByURN_Call
- 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
- func (_c *DiscoveryRepository_DeleteByURN_Call) RunAndReturn(run func(context.Context, string) error) *DiscoveryRepository_DeleteByURN_Call
- type DiscoveryRepository_Expecter
- 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) GroupAssets(ctx interface{}, cfg interface{}) *DiscoveryRepository_GroupAssets_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_GroupAssets_Call
- 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
- func (_c *DiscoveryRepository_GroupAssets_Call) RunAndReturn(run func(context.Context, asset.GroupConfig) ([]asset.GroupResult, error)) *DiscoveryRepository_GroupAssets_Call
- type DiscoveryRepository_Search_Call
- 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
- 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) 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
- 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) Return(_a0 error) *DiscoveryRepository_Upsert_Call
- func (_c *DiscoveryRepository_Upsert_Call) Run(run func(_a0 context.Context, _a1 asset.Asset)) *DiscoveryRepository_Upsert_Call
- func (_c *DiscoveryRepository_Upsert_Call) RunAndReturn(run func(context.Context, asset.Asset) error) *DiscoveryRepository_Upsert_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AssetService ¶
AssetService is an autogenerated mock type for the AssetService type
func NewAssetService ¶
func NewAssetService(t mockConstructorTestingTNewAssetService) *AssetService
NewAssetService creates a new instance of AssetService. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*AssetService) AddProbe ¶
AddProbe provides a mock function with given fields: ctx, assetURN, probe
func (*AssetService) DeleteAsset ¶
func (_m *AssetService) DeleteAsset(ctx context.Context, id string) error
DeleteAsset provides a mock function with given fields: ctx, id
func (*AssetService) EXPECT ¶
func (_m *AssetService) EXPECT() *AssetService_Expecter
func (*AssetService) GetAllAssets ¶
func (_m *AssetService) GetAllAssets(ctx context.Context, flt asset.Filter, withTotal bool) ([]asset.Asset, uint32, error)
GetAllAssets provides a mock function with given fields: ctx, flt, withTotal
func (*AssetService) GetAssetByID ¶
GetAssetByID provides a mock function with given fields: ctx, id
func (*AssetService) GetAssetByVersion ¶
func (_m *AssetService) GetAssetByVersion(ctx context.Context, id string, version string) (asset.Asset, error)
GetAssetByVersion provides a mock function with given fields: ctx, id, version
func (*AssetService) GetAssetVersionHistory ¶
func (_m *AssetService) GetAssetVersionHistory(ctx context.Context, flt asset.Filter, id string) ([]asset.Asset, error)
GetAssetVersionHistory provides a mock function with given fields: ctx, flt, id
func (*AssetService) GetLineage ¶
func (_m *AssetService) GetLineage(ctx context.Context, urn string, query asset.LineageQuery) (asset.Lineage, error)
GetLineage provides a mock function with given fields: ctx, urn, query
func (*AssetService) GroupAssets ¶
func (_m *AssetService) GroupAssets(ctx context.Context, cfg asset.GroupConfig) ([]asset.GroupResult, error)
GroupAssets provides a mock function with given fields: ctx, cfg
func (*AssetService) SearchAssets ¶
func (_m *AssetService) SearchAssets(ctx context.Context, cfg asset.SearchConfig) ([]asset.SearchResult, error)
SearchAssets provides a mock function with given fields: ctx, cfg
func (*AssetService) SuggestAssets ¶
func (_m *AssetService) SuggestAssets(ctx context.Context, cfg asset.SearchConfig) ([]string, error)
SuggestAssets provides a mock function with given fields: ctx, cfg
func (*AssetService) UpsertAsset ¶
func (_m *AssetService) UpsertAsset(ctx context.Context, ast *asset.Asset, upstreams []string, downstreams []string) (string, error)
UpsertAsset provides a mock function with given fields: ctx, ast, upstreams, downstreams
func (*AssetService) UpsertAssetWithoutLineage ¶
func (_m *AssetService) UpsertAssetWithoutLineage(ctx context.Context, ast *asset.Asset) (string, error)
UpsertAssetWithoutLineage provides a mock function with given fields: ctx, ast
type AssetService_AddProbe_Call ¶
AssetService_AddProbe_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AddProbe'
func (*AssetService_AddProbe_Call) Return ¶
func (_c *AssetService_AddProbe_Call) Return(_a0 error) *AssetService_AddProbe_Call
func (*AssetService_AddProbe_Call) Run ¶
func (_c *AssetService_AddProbe_Call) Run(run func(ctx context.Context, assetURN string, probe *asset.Probe)) *AssetService_AddProbe_Call
func (*AssetService_AddProbe_Call) RunAndReturn ¶
func (_c *AssetService_AddProbe_Call) RunAndReturn(run func(context.Context, string, *asset.Probe) error) *AssetService_AddProbe_Call
type AssetService_DeleteAsset_Call ¶
AssetService_DeleteAsset_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteAsset'
func (*AssetService_DeleteAsset_Call) Return ¶
func (_c *AssetService_DeleteAsset_Call) Return(_a0 error) *AssetService_DeleteAsset_Call
func (*AssetService_DeleteAsset_Call) Run ¶
func (_c *AssetService_DeleteAsset_Call) Run(run func(ctx context.Context, id string)) *AssetService_DeleteAsset_Call
func (*AssetService_DeleteAsset_Call) RunAndReturn ¶
func (_c *AssetService_DeleteAsset_Call) RunAndReturn(run func(context.Context, string) error) *AssetService_DeleteAsset_Call
type AssetService_Expecter ¶
type AssetService_Expecter struct {
// contains filtered or unexported fields
}
func (*AssetService_Expecter) AddProbe ¶
func (_e *AssetService_Expecter) AddProbe(ctx interface{}, assetURN interface{}, probe interface{}) *AssetService_AddProbe_Call
AddProbe is a helper method to define mock.On call
- ctx context.Context
- assetURN string
- probe *asset.Probe
func (*AssetService_Expecter) DeleteAsset ¶
func (_e *AssetService_Expecter) DeleteAsset(ctx interface{}, id interface{}) *AssetService_DeleteAsset_Call
DeleteAsset is a helper method to define mock.On call
- ctx context.Context
- id string
func (*AssetService_Expecter) GetAllAssets ¶
func (_e *AssetService_Expecter) GetAllAssets(ctx interface{}, flt interface{}, withTotal interface{}) *AssetService_GetAllAssets_Call
GetAllAssets is a helper method to define mock.On call
- ctx context.Context
- flt asset.Filter
- withTotal bool
func (*AssetService_Expecter) GetAssetByID ¶
func (_e *AssetService_Expecter) GetAssetByID(ctx interface{}, id interface{}) *AssetService_GetAssetByID_Call
GetAssetByID is a helper method to define mock.On call
- ctx context.Context
- id string
func (*AssetService_Expecter) GetAssetByVersion ¶
func (_e *AssetService_Expecter) GetAssetByVersion(ctx interface{}, id interface{}, version interface{}) *AssetService_GetAssetByVersion_Call
GetAssetByVersion is a helper method to define mock.On call
- ctx context.Context
- id string
- version string
func (*AssetService_Expecter) GetAssetVersionHistory ¶
func (_e *AssetService_Expecter) GetAssetVersionHistory(ctx interface{}, flt interface{}, id interface{}) *AssetService_GetAssetVersionHistory_Call
GetAssetVersionHistory is a helper method to define mock.On call
- ctx context.Context
- flt asset.Filter
- id string
func (*AssetService_Expecter) GetLineage ¶
func (_e *AssetService_Expecter) GetLineage(ctx interface{}, urn interface{}, query interface{}) *AssetService_GetLineage_Call
GetLineage is a helper method to define mock.On call
- ctx context.Context
- urn string
- query asset.LineageQuery
func (*AssetService_Expecter) GetTypes ¶
func (_e *AssetService_Expecter) GetTypes(ctx interface{}, flt interface{}) *AssetService_GetTypes_Call
GetTypes is a helper method to define mock.On call
- ctx context.Context
- flt asset.Filter
func (*AssetService_Expecter) GroupAssets ¶
func (_e *AssetService_Expecter) GroupAssets(ctx interface{}, cfg interface{}) *AssetService_GroupAssets_Call
GroupAssets is a helper method to define mock.On call
- ctx context.Context
- cfg asset.GroupConfig
func (*AssetService_Expecter) SearchAssets ¶
func (_e *AssetService_Expecter) SearchAssets(ctx interface{}, cfg interface{}) *AssetService_SearchAssets_Call
SearchAssets is a helper method to define mock.On call
- ctx context.Context
- cfg asset.SearchConfig
func (*AssetService_Expecter) SuggestAssets ¶
func (_e *AssetService_Expecter) SuggestAssets(ctx interface{}, cfg interface{}) *AssetService_SuggestAssets_Call
SuggestAssets is a helper method to define mock.On call
- ctx context.Context
- cfg asset.SearchConfig
func (*AssetService_Expecter) UpsertAsset ¶
func (_e *AssetService_Expecter) UpsertAsset(ctx interface{}, ast interface{}, upstreams interface{}, downstreams interface{}) *AssetService_UpsertAsset_Call
UpsertAsset is a helper method to define mock.On call
- ctx context.Context
- ast *asset.Asset
- upstreams []string
- downstreams []string
func (*AssetService_Expecter) UpsertAssetWithoutLineage ¶
func (_e *AssetService_Expecter) UpsertAssetWithoutLineage(ctx interface{}, ast interface{}) *AssetService_UpsertAssetWithoutLineage_Call
UpsertAssetWithoutLineage is a helper method to define mock.On call
- ctx context.Context
- ast *asset.Asset
type AssetService_GetAllAssets_Call ¶
AssetService_GetAllAssets_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetAllAssets'
func (*AssetService_GetAllAssets_Call) Return ¶
func (_c *AssetService_GetAllAssets_Call) Return(_a0 []asset.Asset, _a1 uint32, _a2 error) *AssetService_GetAllAssets_Call
func (*AssetService_GetAllAssets_Call) Run ¶
func (_c *AssetService_GetAllAssets_Call) Run(run func(ctx context.Context, flt asset.Filter, withTotal bool)) *AssetService_GetAllAssets_Call
func (*AssetService_GetAllAssets_Call) RunAndReturn ¶
type AssetService_GetAssetByID_Call ¶
AssetService_GetAssetByID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetAssetByID'
func (*AssetService_GetAssetByID_Call) Return ¶
func (_c *AssetService_GetAssetByID_Call) Return(_a0 asset.Asset, _a1 error) *AssetService_GetAssetByID_Call
func (*AssetService_GetAssetByID_Call) Run ¶
func (_c *AssetService_GetAssetByID_Call) Run(run func(ctx context.Context, id string)) *AssetService_GetAssetByID_Call
func (*AssetService_GetAssetByID_Call) RunAndReturn ¶
func (_c *AssetService_GetAssetByID_Call) RunAndReturn(run func(context.Context, string) (asset.Asset, error)) *AssetService_GetAssetByID_Call
type AssetService_GetAssetByVersion_Call ¶
AssetService_GetAssetByVersion_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetAssetByVersion'
func (*AssetService_GetAssetByVersion_Call) Return ¶
func (_c *AssetService_GetAssetByVersion_Call) Return(_a0 asset.Asset, _a1 error) *AssetService_GetAssetByVersion_Call
func (*AssetService_GetAssetByVersion_Call) Run ¶
func (_c *AssetService_GetAssetByVersion_Call) Run(run func(ctx context.Context, id string, version string)) *AssetService_GetAssetByVersion_Call
func (*AssetService_GetAssetByVersion_Call) RunAndReturn ¶
func (_c *AssetService_GetAssetByVersion_Call) RunAndReturn(run func(context.Context, string, string) (asset.Asset, error)) *AssetService_GetAssetByVersion_Call
type AssetService_GetAssetVersionHistory_Call ¶
AssetService_GetAssetVersionHistory_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetAssetVersionHistory'
func (*AssetService_GetAssetVersionHistory_Call) Return ¶
func (_c *AssetService_GetAssetVersionHistory_Call) Return(_a0 []asset.Asset, _a1 error) *AssetService_GetAssetVersionHistory_Call
func (*AssetService_GetAssetVersionHistory_Call) Run ¶
func (_c *AssetService_GetAssetVersionHistory_Call) Run(run func(ctx context.Context, flt asset.Filter, id string)) *AssetService_GetAssetVersionHistory_Call
func (*AssetService_GetAssetVersionHistory_Call) RunAndReturn ¶
func (_c *AssetService_GetAssetVersionHistory_Call) RunAndReturn(run func(context.Context, asset.Filter, string) ([]asset.Asset, error)) *AssetService_GetAssetVersionHistory_Call
type AssetService_GetLineage_Call ¶
AssetService_GetLineage_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLineage'
func (*AssetService_GetLineage_Call) Return ¶
func (_c *AssetService_GetLineage_Call) Return(_a0 asset.Lineage, _a1 error) *AssetService_GetLineage_Call
func (*AssetService_GetLineage_Call) Run ¶
func (_c *AssetService_GetLineage_Call) Run(run func(ctx context.Context, urn string, query asset.LineageQuery)) *AssetService_GetLineage_Call
func (*AssetService_GetLineage_Call) RunAndReturn ¶
func (_c *AssetService_GetLineage_Call) RunAndReturn(run func(context.Context, string, asset.LineageQuery) (asset.Lineage, error)) *AssetService_GetLineage_Call
type AssetService_GetTypes_Call ¶
AssetService_GetTypes_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTypes'
func (*AssetService_GetTypes_Call) Return ¶
func (_c *AssetService_GetTypes_Call) Return(_a0 map[asset.Type]int, _a1 error) *AssetService_GetTypes_Call
func (*AssetService_GetTypes_Call) Run ¶
func (_c *AssetService_GetTypes_Call) Run(run func(ctx context.Context, flt asset.Filter)) *AssetService_GetTypes_Call
func (*AssetService_GetTypes_Call) RunAndReturn ¶
func (_c *AssetService_GetTypes_Call) RunAndReturn(run func(context.Context, asset.Filter) (map[asset.Type]int, error)) *AssetService_GetTypes_Call
type AssetService_GroupAssets_Call ¶
AssetService_GroupAssets_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GroupAssets'
func (*AssetService_GroupAssets_Call) Return ¶
func (_c *AssetService_GroupAssets_Call) Return(results []asset.GroupResult, err error) *AssetService_GroupAssets_Call
func (*AssetService_GroupAssets_Call) Run ¶
func (_c *AssetService_GroupAssets_Call) Run(run func(ctx context.Context, cfg asset.GroupConfig)) *AssetService_GroupAssets_Call
func (*AssetService_GroupAssets_Call) RunAndReturn ¶
func (_c *AssetService_GroupAssets_Call) RunAndReturn(run func(context.Context, asset.GroupConfig) ([]asset.GroupResult, error)) *AssetService_GroupAssets_Call
type AssetService_SearchAssets_Call ¶
AssetService_SearchAssets_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SearchAssets'
func (*AssetService_SearchAssets_Call) Return ¶
func (_c *AssetService_SearchAssets_Call) Return(results []asset.SearchResult, err error) *AssetService_SearchAssets_Call
func (*AssetService_SearchAssets_Call) Run ¶
func (_c *AssetService_SearchAssets_Call) Run(run func(ctx context.Context, cfg asset.SearchConfig)) *AssetService_SearchAssets_Call
func (*AssetService_SearchAssets_Call) RunAndReturn ¶
func (_c *AssetService_SearchAssets_Call) RunAndReturn(run func(context.Context, asset.SearchConfig) ([]asset.SearchResult, error)) *AssetService_SearchAssets_Call
type AssetService_SuggestAssets_Call ¶
AssetService_SuggestAssets_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SuggestAssets'
func (*AssetService_SuggestAssets_Call) Return ¶
func (_c *AssetService_SuggestAssets_Call) Return(suggestions []string, err error) *AssetService_SuggestAssets_Call
func (*AssetService_SuggestAssets_Call) Run ¶
func (_c *AssetService_SuggestAssets_Call) Run(run func(ctx context.Context, cfg asset.SearchConfig)) *AssetService_SuggestAssets_Call
func (*AssetService_SuggestAssets_Call) RunAndReturn ¶
func (_c *AssetService_SuggestAssets_Call) RunAndReturn(run func(context.Context, asset.SearchConfig) ([]string, error)) *AssetService_SuggestAssets_Call
type AssetService_UpsertAssetWithoutLineage_Call ¶
AssetService_UpsertAssetWithoutLineage_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpsertAssetWithoutLineage'
func (*AssetService_UpsertAssetWithoutLineage_Call) Return ¶
func (_c *AssetService_UpsertAssetWithoutLineage_Call) Return(_a0 string, _a1 error) *AssetService_UpsertAssetWithoutLineage_Call
func (*AssetService_UpsertAssetWithoutLineage_Call) Run ¶
func (_c *AssetService_UpsertAssetWithoutLineage_Call) Run(run func(ctx context.Context, ast *asset.Asset)) *AssetService_UpsertAssetWithoutLineage_Call
func (*AssetService_UpsertAssetWithoutLineage_Call) RunAndReturn ¶
func (_c *AssetService_UpsertAssetWithoutLineage_Call) RunAndReturn(run func(context.Context, *asset.Asset) (string, error)) *AssetService_UpsertAssetWithoutLineage_Call
type AssetService_UpsertAsset_Call ¶
AssetService_UpsertAsset_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpsertAsset'
func (*AssetService_UpsertAsset_Call) Return ¶
func (_c *AssetService_UpsertAsset_Call) Return(_a0 string, _a1 error) *AssetService_UpsertAsset_Call
func (*AssetService_UpsertAsset_Call) Run ¶
func (_c *AssetService_UpsertAsset_Call) Run(run func(ctx context.Context, ast *asset.Asset, upstreams []string, downstreams []string)) *AssetService_UpsertAsset_Call
func (*AssetService_UpsertAsset_Call) RunAndReturn ¶
func (_c *AssetService_UpsertAsset_Call) RunAndReturn(run func(context.Context, *asset.Asset, []string, []string) (string, error)) *AssetService_UpsertAsset_Call
type DiscoveryRepository ¶
DiscoveryRepository is an autogenerated mock type for the DiscoveryRepository type
func NewDiscoveryRepository ¶
func NewDiscoveryRepository(t mockConstructorTestingTNewDiscoveryRepository) *DiscoveryRepository
NewDiscoveryRepository creates a new instance of DiscoveryRepository. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*DiscoveryRepository) DeleteByID ¶
func (_m *DiscoveryRepository) DeleteByID(ctx context.Context, assetID string) error
DeleteByID provides a mock function with given fields: ctx, assetID
func (*DiscoveryRepository) DeleteByURN ¶
func (_m *DiscoveryRepository) DeleteByURN(ctx context.Context, assetURN string) error
DeleteByURN provides a mock function with given fields: ctx, assetURN
func (*DiscoveryRepository) EXPECT ¶
func (_m *DiscoveryRepository) EXPECT() *DiscoveryRepository_Expecter
func (*DiscoveryRepository) GroupAssets ¶
func (_m *DiscoveryRepository) GroupAssets(ctx context.Context, cfg asset.GroupConfig) ([]asset.GroupResult, error)
GroupAssets provides a mock function with given fields: ctx, cfg
func (*DiscoveryRepository) Search ¶
func (_m *DiscoveryRepository) Search(ctx context.Context, cfg asset.SearchConfig) ([]asset.SearchResult, error)
Search provides a mock function with given fields: ctx, cfg
func (*DiscoveryRepository) Suggest ¶
func (_m *DiscoveryRepository) Suggest(ctx context.Context, cfg asset.SearchConfig) ([]string, error)
Suggest provides a mock function with given fields: ctx, cfg
type DiscoveryRepository_DeleteByID_Call ¶
DiscoveryRepository_DeleteByID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteByID'
func (*DiscoveryRepository_DeleteByID_Call) Return ¶
func (_c *DiscoveryRepository_DeleteByID_Call) Return(_a0 error) *DiscoveryRepository_DeleteByID_Call
func (*DiscoveryRepository_DeleteByID_Call) Run ¶
func (_c *DiscoveryRepository_DeleteByID_Call) Run(run func(ctx context.Context, assetID string)) *DiscoveryRepository_DeleteByID_Call
func (*DiscoveryRepository_DeleteByID_Call) RunAndReturn ¶
func (_c *DiscoveryRepository_DeleteByID_Call) RunAndReturn(run func(context.Context, string) error) *DiscoveryRepository_DeleteByID_Call
type DiscoveryRepository_DeleteByURN_Call ¶
DiscoveryRepository_DeleteByURN_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteByURN'
func (*DiscoveryRepository_DeleteByURN_Call) Return ¶
func (_c *DiscoveryRepository_DeleteByURN_Call) Return(_a0 error) *DiscoveryRepository_DeleteByURN_Call
func (*DiscoveryRepository_DeleteByURN_Call) Run ¶
func (_c *DiscoveryRepository_DeleteByURN_Call) Run(run func(ctx context.Context, assetURN string)) *DiscoveryRepository_DeleteByURN_Call
func (*DiscoveryRepository_DeleteByURN_Call) RunAndReturn ¶
func (_c *DiscoveryRepository_DeleteByURN_Call) RunAndReturn(run func(context.Context, string) error) *DiscoveryRepository_DeleteByURN_Call
type DiscoveryRepository_Expecter ¶
type DiscoveryRepository_Expecter struct {
// contains filtered or unexported fields
}
func (*DiscoveryRepository_Expecter) DeleteByID ¶
func (_e *DiscoveryRepository_Expecter) DeleteByID(ctx interface{}, assetID interface{}) *DiscoveryRepository_DeleteByID_Call
DeleteByID is a helper method to define mock.On call
- ctx context.Context
- assetID string
func (*DiscoveryRepository_Expecter) DeleteByURN ¶
func (_e *DiscoveryRepository_Expecter) DeleteByURN(ctx interface{}, assetURN interface{}) *DiscoveryRepository_DeleteByURN_Call
DeleteByURN is a helper method to define mock.On call
- ctx context.Context
- assetURN string
func (*DiscoveryRepository_Expecter) GroupAssets ¶
func (_e *DiscoveryRepository_Expecter) GroupAssets(ctx interface{}, cfg interface{}) *DiscoveryRepository_GroupAssets_Call
GroupAssets is a helper method to define mock.On call
- ctx context.Context
- cfg asset.GroupConfig
func (*DiscoveryRepository_Expecter) Search ¶
func (_e *DiscoveryRepository_Expecter) Search(ctx interface{}, cfg interface{}) *DiscoveryRepository_Search_Call
Search is a helper method to define mock.On call
- ctx context.Context
- cfg asset.SearchConfig
func (*DiscoveryRepository_Expecter) Suggest ¶
func (_e *DiscoveryRepository_Expecter) Suggest(ctx interface{}, cfg interface{}) *DiscoveryRepository_Suggest_Call
Suggest is a helper method to define mock.On call
- ctx context.Context
- cfg asset.SearchConfig
func (*DiscoveryRepository_Expecter) Upsert ¶
func (_e *DiscoveryRepository_Expecter) Upsert(_a0 interface{}, _a1 interface{}) *DiscoveryRepository_Upsert_Call
Upsert is a helper method to define mock.On call
- _a0 context.Context
- _a1 asset.Asset
type DiscoveryRepository_GroupAssets_Call ¶
DiscoveryRepository_GroupAssets_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GroupAssets'
func (*DiscoveryRepository_GroupAssets_Call) Return ¶
func (_c *DiscoveryRepository_GroupAssets_Call) Return(results []asset.GroupResult, err error) *DiscoveryRepository_GroupAssets_Call
func (*DiscoveryRepository_GroupAssets_Call) Run ¶
func (_c *DiscoveryRepository_GroupAssets_Call) Run(run func(ctx context.Context, cfg asset.GroupConfig)) *DiscoveryRepository_GroupAssets_Call
func (*DiscoveryRepository_GroupAssets_Call) RunAndReturn ¶
func (_c *DiscoveryRepository_GroupAssets_Call) RunAndReturn(run func(context.Context, asset.GroupConfig) ([]asset.GroupResult, error)) *DiscoveryRepository_GroupAssets_Call
type DiscoveryRepository_Search_Call ¶
DiscoveryRepository_Search_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Search'
func (*DiscoveryRepository_Search_Call) Return ¶
func (_c *DiscoveryRepository_Search_Call) Return(results []asset.SearchResult, err error) *DiscoveryRepository_Search_Call
func (*DiscoveryRepository_Search_Call) Run ¶
func (_c *DiscoveryRepository_Search_Call) Run(run func(ctx context.Context, cfg asset.SearchConfig)) *DiscoveryRepository_Search_Call
func (*DiscoveryRepository_Search_Call) RunAndReturn ¶
func (_c *DiscoveryRepository_Search_Call) RunAndReturn(run func(context.Context, asset.SearchConfig) ([]asset.SearchResult, error)) *DiscoveryRepository_Search_Call
type DiscoveryRepository_Suggest_Call ¶
DiscoveryRepository_Suggest_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Suggest'
func (*DiscoveryRepository_Suggest_Call) Return ¶
func (_c *DiscoveryRepository_Suggest_Call) Return(suggestions []string, err error) *DiscoveryRepository_Suggest_Call
func (*DiscoveryRepository_Suggest_Call) Run ¶
func (_c *DiscoveryRepository_Suggest_Call) Run(run func(ctx context.Context, cfg asset.SearchConfig)) *DiscoveryRepository_Suggest_Call
func (*DiscoveryRepository_Suggest_Call) RunAndReturn ¶
func (_c *DiscoveryRepository_Suggest_Call) RunAndReturn(run func(context.Context, asset.SearchConfig) ([]string, error)) *DiscoveryRepository_Suggest_Call
type DiscoveryRepository_Upsert_Call ¶
DiscoveryRepository_Upsert_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Upsert'
func (*DiscoveryRepository_Upsert_Call) Return ¶
func (_c *DiscoveryRepository_Upsert_Call) Return(_a0 error) *DiscoveryRepository_Upsert_Call
func (*DiscoveryRepository_Upsert_Call) Run ¶
func (_c *DiscoveryRepository_Upsert_Call) Run(run func(_a0 context.Context, _a1 asset.Asset)) *DiscoveryRepository_Upsert_Call
func (*DiscoveryRepository_Upsert_Call) RunAndReturn ¶
func (_c *DiscoveryRepository_Upsert_Call) RunAndReturn(run func(context.Context, asset.Asset) error) *DiscoveryRepository_Upsert_Call