mocks

package
v0.7.3 Latest Latest
Warning

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

 Go to latest Published: Jan 5, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

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) 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) SyncAssets added in v0.7.0 

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

SyncAssets provides a mock function with given fields: ctx, indexName

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_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 

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) 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) SyncAssets added in v0.7.0 

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

SyncAssets is a helper method to define mock.On call

  • ctx context.Context
  • indexName string

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

type DiscoveryRepository_SyncAssets_Call struct {
	*mock.Call
}

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

func (*DiscoveryRepository_SyncAssets_Call) Return added in v0.7.0 

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

func (*DiscoveryRepository_SyncAssets_Call) Run added in v0.7.0 

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

func (*DiscoveryRepository_SyncAssets_Call) RunAndReturn added in v0.7.0 

func (_c *DiscoveryRepository_SyncAssets_Call) RunAndReturn(run func(context.Context, string) (func() error, error)) *DiscoveryRepository_SyncAssets_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 

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

type Worker 

type Worker struct {
	mock.Mock
}

Worker is an autogenerated mock type for the Worker type

func NewWorker 

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) EXPECT 

func (_m *Worker) EXPECT() *Worker_Expecter

func (*Worker) Enqueue 

func (_m *Worker) Enqueue(ctx context.Context, jobs ...worker.JobSpec) error

Enqueue provides a mock function with given fields: ctx, jobs

func (*Worker) GetSyncJobsByService added in v0.7.0 

func (_m *Worker) GetSyncJobsByService(ctx context.Context, service string) ([]worker.Job, error)

GetSyncJobsByService provides a mock function with given fields: ctx, service

func (*Worker) Register 

func (_m *Worker) Register(typ string, h worker.JobHandler) error

Register provides a mock function with given fields: typ, h

func (*Worker) Run 

func (_m *Worker) Run(ctx context.Context) error

Run provides a mock function with given fields: ctx

type Worker_Enqueue_Call 

type Worker_Enqueue_Call struct {
	*mock.Call
}

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

func (*Worker_Enqueue_Call) Return 

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

func (*Worker_Enqueue_Call) Run 

func (_c *Worker_Enqueue_Call) Run(run func(ctx context.Context, jobs ...worker.JobSpec)) *Worker_Enqueue_Call

func (*Worker_Enqueue_Call) RunAndReturn 

func (_c *Worker_Enqueue_Call) RunAndReturn(run func(context.Context, ...worker.JobSpec) error) *Worker_Enqueue_Call

type Worker_Expecter 

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

func (*Worker_Expecter) Enqueue 

func (_e *Worker_Expecter) Enqueue(ctx interface{}, jobs ...interface{}) *Worker_Enqueue_Call

Enqueue is a helper method to define mock.On call

  • ctx context.Context
  • jobs ...worker.JobSpec

func (*Worker_Expecter) GetSyncJobsByService added in v0.7.0 

func (_e *Worker_Expecter) GetSyncJobsByService(ctx interface{}, service interface{}) *Worker_GetSyncJobsByService_Call

GetSyncJobsByService is a helper method to define mock.On call

  • ctx context.Context
  • service string

func (*Worker_Expecter) Register 

func (_e *Worker_Expecter) Register(typ interface{}, h interface{}) *Worker_Register_Call

Register is a helper method to define mock.On call

  • typ string
  • h worker.JobHandler

func (*Worker_Expecter) Run 

func (_e *Worker_Expecter) Run(ctx interface{}) *Worker_Run_Call

Run is a helper method to define mock.On call

  • ctx context.Context

type Worker_GetSyncJobsByService_Call added in v0.7.0 

type Worker_GetSyncJobsByService_Call struct {
	*mock.Call
}

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

func (*Worker_GetSyncJobsByService_Call) Return added in v0.7.0 

func (_c *Worker_GetSyncJobsByService_Call) Return(_a0 []worker.Job, _a1 error) *Worker_GetSyncJobsByService_Call

func (*Worker_GetSyncJobsByService_Call) Run added in v0.7.0 

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

func (*Worker_GetSyncJobsByService_Call) RunAndReturn added in v0.7.0 

func (_c *Worker_GetSyncJobsByService_Call) RunAndReturn(run func(context.Context, string) ([]worker.Job, error)) *Worker_GetSyncJobsByService_Call

type Worker_Register_Call 

type Worker_Register_Call struct {
	*mock.Call
}

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

func (*Worker_Register_Call) Return 

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

func (*Worker_Register_Call) Run 

func (_c *Worker_Register_Call) Run(run func(typ string, h worker.JobHandler)) *Worker_Register_Call

func (*Worker_Register_Call) RunAndReturn 

func (_c *Worker_Register_Call) RunAndReturn(run func(string, worker.JobHandler) error) *Worker_Register_Call

type Worker_Run_Call 

type Worker_Run_Call struct {
	*mock.Call
}

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

func (*Worker_Run_Call) Return 

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

func (*Worker_Run_Call) Run 

func (_c *Worker_Run_Call) Run(run func(ctx context.Context)) *Worker_Run_Call

func (*Worker_Run_Call) RunAndReturn 

func (_c *Worker_Run_Call) RunAndReturn(run func(context.Context) error) *Worker_Run_Call

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.