mocks

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 16, 2023 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AssetRepository 

type AssetRepository struct {
	mock.Mock
}

AssetRepository is an autogenerated mock type for the Repository type

func NewAssetRepository 

func NewAssetRepository(t mockConstructorTestingTNewAssetRepository) *AssetRepository

NewAssetRepository creates a new instance of AssetRepository. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*AssetRepository) AddProbe 

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

AddProbe provides a mock function with given fields: ctx, assetURN, probe

func (*AssetRepository) DeleteByID 

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

DeleteByID provides a mock function with given fields: ctx, id

func (*AssetRepository) DeleteByURN 

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

DeleteByURN provides a mock function with given fields: ctx, urn

func (*AssetRepository) EXPECT 

func (_m *AssetRepository) EXPECT() *AssetRepository_Expecter

func (*AssetRepository) GetAll 

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

GetAll provides a mock function with given fields: _a0, _a1

func (*AssetRepository) GetByID 

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

GetByID provides a mock function with given fields: ctx, id

func (*AssetRepository) GetByURN 

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

GetByURN provides a mock function with given fields: ctx, urn

func (*AssetRepository) GetByVersionWithID 

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

GetByVersionWithID provides a mock function with given fields: ctx, id, version

func (*AssetRepository) GetByVersionWithURN 

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

GetByVersionWithURN provides a mock function with given fields: ctx, urn, version

func (*AssetRepository) GetCount 

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

GetCount provides a mock function with given fields: _a0, _a1

func (*AssetRepository) GetProbes 

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

GetProbes provides a mock function with given fields: ctx, assetURN

func (*AssetRepository) GetProbesWithFilter 

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

GetProbesWithFilter provides a mock function with given fields: ctx, flt

func (*AssetRepository) GetTypes 

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

GetTypes provides a mock function with given fields: ctx, flt

func (*AssetRepository) GetVersionHistory 

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

GetVersionHistory provides a mock function with given fields: ctx, flt, id

func (*AssetRepository) Upsert 

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

Upsert provides a mock function with given fields: ctx, ast

type AssetRepository_AddProbe_Call 

type AssetRepository_AddProbe_Call struct {
	*mock.Call
}

AssetRepository_AddProbe_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AddProbe'

func (*AssetRepository_AddProbe_Call) Return 

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

func (*AssetRepository_AddProbe_Call) Run 

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

func (*AssetRepository_AddProbe_Call) RunAndReturn added in v0.5.3 

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

type AssetRepository_DeleteByID_Call 

type AssetRepository_DeleteByID_Call struct {
	*mock.Call
}

AssetRepository_DeleteByID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteByID'

func (*AssetRepository_DeleteByID_Call) Return 

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

func (*AssetRepository_DeleteByID_Call) Run 

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

func (*AssetRepository_DeleteByID_Call) RunAndReturn added in v0.5.3 

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

type AssetRepository_DeleteByURN_Call 

type AssetRepository_DeleteByURN_Call struct {
	*mock.Call
}

AssetRepository_DeleteByURN_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteByURN'

func (*AssetRepository_DeleteByURN_Call) Return 

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

func (*AssetRepository_DeleteByURN_Call) Run 

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

func (*AssetRepository_DeleteByURN_Call) RunAndReturn added in v0.5.3 

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

type AssetRepository_Expecter 

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

func (*AssetRepository_Expecter) AddProbe 

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

AddProbe is a helper method to define mock.On call

  • ctx context.Context
  • assetURN string
  • probe *asset.Probe

func (*AssetRepository_Expecter) DeleteByID 

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

DeleteByID is a helper method to define mock.On call

  • ctx context.Context
  • id string

func (*AssetRepository_Expecter) DeleteByURN 

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

DeleteByURN is a helper method to define mock.On call

  • ctx context.Context
  • urn string

func (*AssetRepository_Expecter) GetAll 

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

GetAll is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 asset.Filter

func (*AssetRepository_Expecter) GetByID 

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

GetByID is a helper method to define mock.On call

  • ctx context.Context
  • id string

func (*AssetRepository_Expecter) GetByURN 

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

GetByURN is a helper method to define mock.On call

  • ctx context.Context
  • urn string

func (*AssetRepository_Expecter) GetByVersionWithID 

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

GetByVersionWithID is a helper method to define mock.On call

  • ctx context.Context
  • id string
  • version string

func (*AssetRepository_Expecter) GetByVersionWithURN 

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

GetByVersionWithURN is a helper method to define mock.On call

  • ctx context.Context
  • urn string
  • version string

func (*AssetRepository_Expecter) GetCount 

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

GetCount is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 asset.Filter

func (*AssetRepository_Expecter) GetProbes 

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

GetProbes is a helper method to define mock.On call

  • ctx context.Context
  • assetURN string

func (*AssetRepository_Expecter) GetProbesWithFilter 

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

GetProbesWithFilter is a helper method to define mock.On call

  • ctx context.Context
  • flt asset.ProbesFilter

func (*AssetRepository_Expecter) GetTypes 

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

GetTypes is a helper method to define mock.On call

  • ctx context.Context
  • flt asset.Filter

func (*AssetRepository_Expecter) GetVersionHistory 

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

GetVersionHistory is a helper method to define mock.On call

  • ctx context.Context
  • flt asset.Filter
  • id string

func (*AssetRepository_Expecter) Upsert 

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

Upsert is a helper method to define mock.On call

  • ctx context.Context
  • ast *asset.Asset

type AssetRepository_GetAll_Call 

type AssetRepository_GetAll_Call struct {
	*mock.Call
}

AssetRepository_GetAll_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetAll'

func (*AssetRepository_GetAll_Call) Return 

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

func (*AssetRepository_GetAll_Call) Run 

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

func (*AssetRepository_GetAll_Call) RunAndReturn added in v0.5.3 

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

type AssetRepository_GetByID_Call 

type AssetRepository_GetByID_Call struct {
	*mock.Call
}

AssetRepository_GetByID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetByID'

func (*AssetRepository_GetByID_Call) Return 

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

func (*AssetRepository_GetByID_Call) Run 

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

func (*AssetRepository_GetByID_Call) RunAndReturn added in v0.5.3 

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

type AssetRepository_GetByURN_Call 

type AssetRepository_GetByURN_Call struct {
	*mock.Call
}

AssetRepository_GetByURN_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetByURN'

func (*AssetRepository_GetByURN_Call) Return 

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

func (*AssetRepository_GetByURN_Call) Run 

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

func (*AssetRepository_GetByURN_Call) RunAndReturn added in v0.5.3 

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

type AssetRepository_GetByVersionWithID_Call 

type AssetRepository_GetByVersionWithID_Call struct {
	*mock.Call
}

AssetRepository_GetByVersionWithID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetByVersionWithID'

func (*AssetRepository_GetByVersionWithID_Call) Return 

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

func (*AssetRepository_GetByVersionWithID_Call) Run 

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

func (*AssetRepository_GetByVersionWithID_Call) RunAndReturn added in v0.5.3 

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

type AssetRepository_GetByVersionWithURN_Call 

type AssetRepository_GetByVersionWithURN_Call struct {
	*mock.Call
}

AssetRepository_GetByVersionWithURN_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetByVersionWithURN'

func (*AssetRepository_GetByVersionWithURN_Call) Return 

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

func (*AssetRepository_GetByVersionWithURN_Call) Run 

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

func (*AssetRepository_GetByVersionWithURN_Call) RunAndReturn added in v0.5.3 

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

type AssetRepository_GetCount_Call 

type AssetRepository_GetCount_Call struct {
	*mock.Call
}

AssetRepository_GetCount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetCount'

func (*AssetRepository_GetCount_Call) Return 

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

func (*AssetRepository_GetCount_Call) Run 

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

func (*AssetRepository_GetCount_Call) RunAndReturn added in v0.5.3 

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

type AssetRepository_GetProbesWithFilter_Call 

type AssetRepository_GetProbesWithFilter_Call struct {
	*mock.Call
}

AssetRepository_GetProbesWithFilter_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetProbesWithFilter'

func (*AssetRepository_GetProbesWithFilter_Call) Return 

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

func (*AssetRepository_GetProbesWithFilter_Call) Run 

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

func (*AssetRepository_GetProbesWithFilter_Call) RunAndReturn added in v0.5.3 

func (_c *AssetRepository_GetProbesWithFilter_Call) RunAndReturn(run func(context.Context, asset.ProbesFilter) (map[string][]asset.Probe, error)) *AssetRepository_GetProbesWithFilter_Call

type AssetRepository_GetProbes_Call 

type AssetRepository_GetProbes_Call struct {
	*mock.Call
}

AssetRepository_GetProbes_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetProbes'

func (*AssetRepository_GetProbes_Call) Return 

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

func (*AssetRepository_GetProbes_Call) Run 

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

func (*AssetRepository_GetProbes_Call) RunAndReturn added in v0.5.3 

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

type AssetRepository_GetTypes_Call 

type AssetRepository_GetTypes_Call struct {
	*mock.Call
}

AssetRepository_GetTypes_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTypes'

func (*AssetRepository_GetTypes_Call) Return 

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

func (*AssetRepository_GetTypes_Call) Run 

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

func (*AssetRepository_GetTypes_Call) RunAndReturn added in v0.5.3 

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

type AssetRepository_GetVersionHistory_Call 

type AssetRepository_GetVersionHistory_Call struct {
	*mock.Call
}

AssetRepository_GetVersionHistory_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetVersionHistory'

func (*AssetRepository_GetVersionHistory_Call) Return 

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

func (*AssetRepository_GetVersionHistory_Call) Run 

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

func (*AssetRepository_GetVersionHistory_Call) RunAndReturn added in v0.5.3 

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

type AssetRepository_Upsert_Call 

type AssetRepository_Upsert_Call struct {
	*mock.Call
}

AssetRepository_Upsert_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Upsert'

func (*AssetRepository_Upsert_Call) Return 

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

func (*AssetRepository_Upsert_Call) Run 

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

func (*AssetRepository_Upsert_Call) RunAndReturn added in v0.5.3 

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

type DiscoveryRepository 

type DiscoveryRepository struct {
	mock.Mock
}

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 added in v0.5.4 

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

func (*DiscoveryRepository) Upsert 

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

Upsert provides a mock function with given fields: _a0, _a1

type DiscoveryRepository_DeleteByID_Call 

type DiscoveryRepository_DeleteByID_Call struct {
	*mock.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 added in v0.5.3 

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

type DiscoveryRepository_DeleteByURN_Call 

type DiscoveryRepository_DeleteByURN_Call struct {
	*mock.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 added in v0.5.3 

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 added in v0.5.4 

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 added in v0.5.4 

type DiscoveryRepository_GroupAssets_Call struct {
	*mock.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 added in v0.5.4 

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

func (*DiscoveryRepository_GroupAssets_Call) Run added in v0.5.4 

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

func (*DiscoveryRepository_GroupAssets_Call) RunAndReturn added in v0.6.0 

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

type DiscoveryRepository_Search_Call 

type DiscoveryRepository_Search_Call struct {
	*mock.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 added in v0.5.3 

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

type DiscoveryRepository_Suggest_Call 

type DiscoveryRepository_Suggest_Call struct {
	*mock.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 added in v0.5.3 

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

type DiscoveryRepository_Upsert_Call 

type DiscoveryRepository_Upsert_Call struct {
	*mock.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 added in v0.5.3 

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

type LineageRepository 

type LineageRepository struct {
	mock.Mock
}

LineageRepository is an autogenerated mock type for the LineageRepository type

func NewLineageRepository 

func NewLineageRepository(t mockConstructorTestingTNewLineageRepository) *LineageRepository

NewLineageRepository creates a new instance of LineageRepository. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*LineageRepository) DeleteByURN added in v0.5.3 

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

DeleteByURN provides a mock function with given fields: ctx, urn

func (*LineageRepository) EXPECT 

func (_m *LineageRepository) EXPECT() *LineageRepository_Expecter

func (*LineageRepository) GetGraph 

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

GetGraph provides a mock function with given fields: ctx, urn, query

func (*LineageRepository) Upsert 

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

Upsert provides a mock function with given fields: ctx, urn, upstreams, downstreams

type LineageRepository_DeleteByURN_Call added in v0.5.3 

type LineageRepository_DeleteByURN_Call struct {
	*mock.Call
}

LineageRepository_DeleteByURN_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteByURN'

func (*LineageRepository_DeleteByURN_Call) Return added in v0.5.3 

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

func (*LineageRepository_DeleteByURN_Call) Run added in v0.5.3 

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

func (*LineageRepository_DeleteByURN_Call) RunAndReturn added in v0.5.3 

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

type LineageRepository_Expecter 

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

func (*LineageRepository_Expecter) DeleteByURN added in v0.5.3 

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

DeleteByURN is a helper method to define mock.On call

  • ctx context.Context
  • urn string

func (*LineageRepository_Expecter) GetGraph 

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

GetGraph is a helper method to define mock.On call

  • ctx context.Context
  • urn string
  • query asset.LineageQuery

func (*LineageRepository_Expecter) Upsert 

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

Upsert is a helper method to define mock.On call

  • ctx context.Context
  • urn string
  • upstreams []string
  • downstreams []string

type LineageRepository_GetGraph_Call 

type LineageRepository_GetGraph_Call struct {
	*mock.Call
}

LineageRepository_GetGraph_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetGraph'

func (*LineageRepository_GetGraph_Call) Return 

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

func (*LineageRepository_GetGraph_Call) Run 

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

func (*LineageRepository_GetGraph_Call) RunAndReturn added in v0.5.3 

func (_c *LineageRepository_GetGraph_Call) RunAndReturn(run func(context.Context, string, asset.LineageQuery) (asset.LineageGraph, error)) *LineageRepository_GetGraph_Call

type LineageRepository_Upsert_Call 

type LineageRepository_Upsert_Call struct {
	*mock.Call
}

LineageRepository_Upsert_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Upsert'

func (*LineageRepository_Upsert_Call) Return 

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

func (*LineageRepository_Upsert_Call) Run 

func (_c *LineageRepository_Upsert_Call) Run(run func(ctx context.Context, urn string, upstreams []string, downstreams []string)) *LineageRepository_Upsert_Call

func (*LineageRepository_Upsert_Call) RunAndReturn added in v0.5.3 

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

type Worker added in v0.6.0 

type Worker struct {
	mock.Mock
}

Worker is an autogenerated mock type for the Worker type

func NewWorker added in v0.6.0 

func NewWorker(t mockConstructorTestingTNewWorker) *Worker

NewWorker creates a new instance of Worker. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*Worker) Close added in v0.6.0 

func (_m *Worker) Close() error

Close provides a mock function with given fields:

func (*Worker) EXPECT added in v0.6.0 

func (_m *Worker) EXPECT() *Worker_Expecter

func (*Worker) EnqueueDeleteAssetJob added in v0.6.0 

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

EnqueueDeleteAssetJob provides a mock function with given fields: ctx, urn

func (*Worker) EnqueueIndexAssetJob added in v0.6.0 

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

EnqueueIndexAssetJob provides a mock function with given fields: ctx, ast

type Worker_Close_Call added in v0.6.0 

type Worker_Close_Call struct {
	*mock.Call
}

Worker_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'

func (*Worker_Close_Call) Return added in v0.6.0 

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

func (*Worker_Close_Call) Run added in v0.6.0 

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

func (*Worker_Close_Call) RunAndReturn added in v0.6.0 

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

type Worker_EnqueueDeleteAssetJob_Call added in v0.6.0 

type Worker_EnqueueDeleteAssetJob_Call struct {
	*mock.Call
}

Worker_EnqueueDeleteAssetJob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'EnqueueDeleteAssetJob'

func (*Worker_EnqueueDeleteAssetJob_Call) Return added in v0.6.0 

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

func (*Worker_EnqueueDeleteAssetJob_Call) Run added in v0.6.0 

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

func (*Worker_EnqueueDeleteAssetJob_Call) RunAndReturn added in v0.6.0 

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

type Worker_EnqueueIndexAssetJob_Call added in v0.6.0 

type Worker_EnqueueIndexAssetJob_Call struct {
	*mock.Call
}

Worker_EnqueueIndexAssetJob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'EnqueueIndexAssetJob'

func (*Worker_EnqueueIndexAssetJob_Call) Return added in v0.6.0 

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

func (*Worker_EnqueueIndexAssetJob_Call) Run added in v0.6.0 

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

func (*Worker_EnqueueIndexAssetJob_Call) RunAndReturn added in v0.6.0 

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

type Worker_Expecter added in v0.6.0 

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

func (*Worker_Expecter) Close added in v0.6.0 

func (_e *Worker_Expecter) Close() *Worker_Close_Call

Close is a helper method to define mock.On call

func (*Worker_Expecter) EnqueueDeleteAssetJob added in v0.6.0 

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

EnqueueDeleteAssetJob is a helper method to define mock.On call

  • ctx context.Context
  • urn string

func (*Worker_Expecter) EnqueueIndexAssetJob added in v0.6.0 

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

EnqueueIndexAssetJob is a helper method to define mock.On call

  • ctx context.Context
  • ast asset.Asset

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.