mocks

package
v2.14.0-beta0 Latest Latest
Warning

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

Go to latest
Published: Jul 3, 2024 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ConnectionsManager

type ConnectionsManager struct {
	mock.Mock
}

ConnectionsManager is an autogenerated mock type for the ConnectionsManager type

func NewConnectionsManager

func NewConnectionsManager(t interface {
	mock.TestingT
	Cleanup(func())
}) *ConnectionsManager

NewConnectionsManager creates a new instance of ConnectionsManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ConnectionsManager) Close

func (_m *ConnectionsManager) Close()

Close provides a mock function with given fields:

func (*ConnectionsManager) Connect

func (_m *ConnectionsManager) Connect(opts feeds.ConnectOpts)

Connect provides a mock function with given fields: opts

func (*ConnectionsManager) Disconnect

func (_m *ConnectionsManager) Disconnect(id int64) error

Disconnect provides a mock function with given fields: id

func (*ConnectionsManager) GetClient

func (_m *ConnectionsManager) GetClient(id int64) (proto.FeedsManagerClient, error)

GetClient provides a mock function with given fields: id

func (*ConnectionsManager) IsConnected

func (_m *ConnectionsManager) IsConnected(id int64) bool

IsConnected provides a mock function with given fields: id

type FeedsManagerClient

type FeedsManagerClient struct {
	mock.Mock
}

FeedsManagerClient is an autogenerated mock type for the FeedsManagerClient type

func NewFeedsManagerClient

func NewFeedsManagerClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *FeedsManagerClient

NewFeedsManagerClient creates a new instance of FeedsManagerClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*FeedsManagerClient) ApprovedJob

ApprovedJob provides a mock function with given fields: ctx, in

func (*FeedsManagerClient) CancelledJob

CancelledJob provides a mock function with given fields: ctx, in

func (*FeedsManagerClient) Healthcheck

Healthcheck provides a mock function with given fields: ctx, in

func (*FeedsManagerClient) RejectedJob

RejectedJob provides a mock function with given fields: ctx, in

func (*FeedsManagerClient) UpdateNode

UpdateNode provides a mock function with given fields: ctx, in

type ORM

type ORM struct {
	mock.Mock
}

ORM is an autogenerated mock type for the ORM type

func NewORM

func NewORM(t interface {
	mock.TestingT
	Cleanup(func())
}) *ORM

NewORM creates a new instance of ORM. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ORM) ApproveSpec

func (_m *ORM) ApproveSpec(ctx context.Context, id int64, externalJobID uuid.UUID) error

ApproveSpec provides a mock function with given fields: ctx, id, externalJobID

func (*ORM) CancelSpec

func (_m *ORM) CancelSpec(ctx context.Context, id int64) error

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

func (*ORM) CountJobProposals

func (_m *ORM) CountJobProposals(ctx context.Context) (int64, error)

CountJobProposals provides a mock function with given fields: ctx

func (*ORM) CountJobProposalsByStatus

func (_m *ORM) CountJobProposalsByStatus(ctx context.Context) (*feeds.JobProposalCounts, error)

CountJobProposalsByStatus provides a mock function with given fields: ctx

func (*ORM) CountManagers

func (_m *ORM) CountManagers(ctx context.Context) (int64, error)

CountManagers provides a mock function with given fields: ctx

func (*ORM) CreateBatchChainConfig

func (_m *ORM) CreateBatchChainConfig(ctx context.Context, cfgs []feeds.ChainConfig) ([]int64, error)

CreateBatchChainConfig provides a mock function with given fields: ctx, cfgs

func (*ORM) CreateChainConfig

func (_m *ORM) CreateChainConfig(ctx context.Context, cfg feeds.ChainConfig) (int64, error)

CreateChainConfig provides a mock function with given fields: ctx, cfg

func (*ORM) CreateJobProposal

func (_m *ORM) CreateJobProposal(ctx context.Context, jp *feeds.JobProposal) (int64, error)

CreateJobProposal provides a mock function with given fields: ctx, jp

func (*ORM) CreateManager

func (_m *ORM) CreateManager(ctx context.Context, ms *feeds.FeedsManager) (int64, error)

CreateManager provides a mock function with given fields: ctx, ms

func (*ORM) CreateSpec

func (_m *ORM) CreateSpec(ctx context.Context, spec feeds.JobProposalSpec) (int64, error)

CreateSpec provides a mock function with given fields: ctx, spec

func (*ORM) DeleteChainConfig

func (_m *ORM) DeleteChainConfig(ctx context.Context, id int64) (int64, error)

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

func (*ORM) DeleteProposal

func (_m *ORM) DeleteProposal(ctx context.Context, id int64) error

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

func (*ORM) EXPECT

func (_m *ORM) EXPECT() *ORM_Expecter

func (*ORM) ExistsSpecByJobProposalIDAndVersion

func (_m *ORM) ExistsSpecByJobProposalIDAndVersion(ctx context.Context, jpID int64, version int32) (bool, error)

ExistsSpecByJobProposalIDAndVersion provides a mock function with given fields: ctx, jpID, version

func (*ORM) GetApprovedSpec

func (_m *ORM) GetApprovedSpec(ctx context.Context, jpID int64) (*feeds.JobProposalSpec, error)

GetApprovedSpec provides a mock function with given fields: ctx, jpID

func (*ORM) GetChainConfig

func (_m *ORM) GetChainConfig(ctx context.Context, id int64) (*feeds.ChainConfig, error)

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

func (*ORM) GetJobProposal

func (_m *ORM) GetJobProposal(ctx context.Context, id int64) (*feeds.JobProposal, error)

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

func (*ORM) GetJobProposalByRemoteUUID

func (_m *ORM) GetJobProposalByRemoteUUID(ctx context.Context, _a1 uuid.UUID) (*feeds.JobProposal, error)

GetJobProposalByRemoteUUID provides a mock function with given fields: ctx, _a1

func (*ORM) GetLatestSpec

func (_m *ORM) GetLatestSpec(ctx context.Context, jpID int64) (*feeds.JobProposalSpec, error)

GetLatestSpec provides a mock function with given fields: ctx, jpID

func (*ORM) GetManager

func (_m *ORM) GetManager(ctx context.Context, id int64) (*feeds.FeedsManager, error)

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

func (*ORM) GetSpec

func (_m *ORM) GetSpec(ctx context.Context, id int64) (*feeds.JobProposalSpec, error)

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

func (*ORM) IsJobManaged

func (_m *ORM) IsJobManaged(ctx context.Context, jobID int64) (bool, error)

IsJobManaged provides a mock function with given fields: ctx, jobID

func (*ORM) ListChainConfigsByManagerIDs

func (_m *ORM) ListChainConfigsByManagerIDs(ctx context.Context, mgrIDs []int64) ([]feeds.ChainConfig, error)

ListChainConfigsByManagerIDs provides a mock function with given fields: ctx, mgrIDs

func (*ORM) ListJobProposals

func (_m *ORM) ListJobProposals(ctx context.Context) ([]feeds.JobProposal, error)

ListJobProposals provides a mock function with given fields: ctx

func (*ORM) ListJobProposalsByManagersIDs

func (_m *ORM) ListJobProposalsByManagersIDs(ctx context.Context, ids []int64) ([]feeds.JobProposal, error)

ListJobProposalsByManagersIDs provides a mock function with given fields: ctx, ids

func (*ORM) ListManagers

func (_m *ORM) ListManagers(ctx context.Context) ([]feeds.FeedsManager, error)

ListManagers provides a mock function with given fields: ctx

func (*ORM) ListManagersByIDs

func (_m *ORM) ListManagersByIDs(ctx context.Context, ids []int64) ([]feeds.FeedsManager, error)

ListManagersByIDs provides a mock function with given fields: ctx, ids

func (*ORM) ListSpecsByJobProposalIDs

func (_m *ORM) ListSpecsByJobProposalIDs(ctx context.Context, ids []int64) ([]feeds.JobProposalSpec, error)

ListSpecsByJobProposalIDs provides a mock function with given fields: ctx, ids

func (*ORM) RejectSpec

func (_m *ORM) RejectSpec(ctx context.Context, id int64) error

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

func (*ORM) RevokeSpec

func (_m *ORM) RevokeSpec(ctx context.Context, id int64) error

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

func (*ORM) Transact added in v2.12.0

func (_m *ORM) Transact(_a0 context.Context, _a1 func(feeds.ORM) error) error

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

func (*ORM) UpdateChainConfig

func (_m *ORM) UpdateChainConfig(ctx context.Context, cfg feeds.ChainConfig) (int64, error)

UpdateChainConfig provides a mock function with given fields: ctx, cfg

func (*ORM) UpdateJobProposalStatus

func (_m *ORM) UpdateJobProposalStatus(ctx context.Context, id int64, status feeds.JobProposalStatus) error

UpdateJobProposalStatus provides a mock function with given fields: ctx, id, status

func (*ORM) UpdateManager

func (_m *ORM) UpdateManager(ctx context.Context, mgr feeds.FeedsManager) error

UpdateManager provides a mock function with given fields: ctx, mgr

func (*ORM) UpdateSpecDefinition

func (_m *ORM) UpdateSpecDefinition(ctx context.Context, id int64, spec string) error

UpdateSpecDefinition provides a mock function with given fields: ctx, id, spec

func (*ORM) UpsertJobProposal

func (_m *ORM) UpsertJobProposal(ctx context.Context, jp *feeds.JobProposal) (int64, error)

UpsertJobProposal provides a mock function with given fields: ctx, jp

func (*ORM) WithDataSource added in v2.12.0

func (_m *ORM) WithDataSource(_a0 sqlutil.DataSource) feeds.ORM

WithDataSource provides a mock function with given fields: _a0

type ORM_ApproveSpec_Call

type ORM_ApproveSpec_Call struct {
	*mock.Call
}

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

func (*ORM_ApproveSpec_Call) Return

func (*ORM_ApproveSpec_Call) Run

func (_c *ORM_ApproveSpec_Call) Run(run func(ctx context.Context, id int64, externalJobID uuid.UUID)) *ORM_ApproveSpec_Call

func (*ORM_ApproveSpec_Call) RunAndReturn

type ORM_CancelSpec_Call

type ORM_CancelSpec_Call struct {
	*mock.Call
}

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

func (*ORM_CancelSpec_Call) Return

func (*ORM_CancelSpec_Call) Run

func (_c *ORM_CancelSpec_Call) Run(run func(ctx context.Context, id int64)) *ORM_CancelSpec_Call

func (*ORM_CancelSpec_Call) RunAndReturn

func (_c *ORM_CancelSpec_Call) RunAndReturn(run func(context.Context, int64) error) *ORM_CancelSpec_Call

type ORM_CountJobProposalsByStatus_Call

type ORM_CountJobProposalsByStatus_Call struct {
	*mock.Call
}

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

func (*ORM_CountJobProposalsByStatus_Call) Return

func (*ORM_CountJobProposalsByStatus_Call) Run

func (*ORM_CountJobProposalsByStatus_Call) RunAndReturn

type ORM_CountJobProposals_Call

type ORM_CountJobProposals_Call struct {
	*mock.Call
}

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

func (*ORM_CountJobProposals_Call) Return

func (*ORM_CountJobProposals_Call) Run

func (*ORM_CountJobProposals_Call) RunAndReturn

type ORM_CountManagers_Call

type ORM_CountManagers_Call struct {
	*mock.Call
}

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

func (*ORM_CountManagers_Call) Return

func (*ORM_CountManagers_Call) Run

func (*ORM_CountManagers_Call) RunAndReturn

func (_c *ORM_CountManagers_Call) RunAndReturn(run func(context.Context) (int64, error)) *ORM_CountManagers_Call

type ORM_CreateBatchChainConfig_Call

type ORM_CreateBatchChainConfig_Call struct {
	*mock.Call
}

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

func (*ORM_CreateBatchChainConfig_Call) Return

func (*ORM_CreateBatchChainConfig_Call) Run

func (*ORM_CreateBatchChainConfig_Call) RunAndReturn

type ORM_CreateChainConfig_Call

type ORM_CreateChainConfig_Call struct {
	*mock.Call
}

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

func (*ORM_CreateChainConfig_Call) Return

func (*ORM_CreateChainConfig_Call) Run

func (*ORM_CreateChainConfig_Call) RunAndReturn

type ORM_CreateJobProposal_Call

type ORM_CreateJobProposal_Call struct {
	*mock.Call
}

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

func (*ORM_CreateJobProposal_Call) Return

func (*ORM_CreateJobProposal_Call) Run

func (*ORM_CreateJobProposal_Call) RunAndReturn

type ORM_CreateManager_Call

type ORM_CreateManager_Call struct {
	*mock.Call
}

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

func (*ORM_CreateManager_Call) Return

func (*ORM_CreateManager_Call) Run

func (*ORM_CreateManager_Call) RunAndReturn

type ORM_CreateSpec_Call

type ORM_CreateSpec_Call struct {
	*mock.Call
}

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

func (*ORM_CreateSpec_Call) Return

func (_c *ORM_CreateSpec_Call) Return(_a0 int64, _a1 error) *ORM_CreateSpec_Call

func (*ORM_CreateSpec_Call) Run

func (*ORM_CreateSpec_Call) RunAndReturn

type ORM_DeleteChainConfig_Call

type ORM_DeleteChainConfig_Call struct {
	*mock.Call
}

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

func (*ORM_DeleteChainConfig_Call) Return

func (*ORM_DeleteChainConfig_Call) Run

func (*ORM_DeleteChainConfig_Call) RunAndReturn

type ORM_DeleteProposal_Call

type ORM_DeleteProposal_Call struct {
	*mock.Call
}

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

func (*ORM_DeleteProposal_Call) Return

func (*ORM_DeleteProposal_Call) Run

func (*ORM_DeleteProposal_Call) RunAndReturn

type ORM_ExistsSpecByJobProposalIDAndVersion_Call

type ORM_ExistsSpecByJobProposalIDAndVersion_Call struct {
	*mock.Call
}

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

func (*ORM_ExistsSpecByJobProposalIDAndVersion_Call) Return

func (*ORM_ExistsSpecByJobProposalIDAndVersion_Call) Run

func (*ORM_ExistsSpecByJobProposalIDAndVersion_Call) RunAndReturn

type ORM_Expecter

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

func (*ORM_Expecter) ApproveSpec

func (_e *ORM_Expecter) ApproveSpec(ctx interface{}, id interface{}, externalJobID interface{}) *ORM_ApproveSpec_Call

ApproveSpec is a helper method to define mock.On call

  • ctx context.Context
  • id int64
  • externalJobID uuid.UUID

func (*ORM_Expecter) CancelSpec

func (_e *ORM_Expecter) CancelSpec(ctx interface{}, id interface{}) *ORM_CancelSpec_Call

CancelSpec is a helper method to define mock.On call

  • ctx context.Context
  • id int64

func (*ORM_Expecter) CountJobProposals

func (_e *ORM_Expecter) CountJobProposals(ctx interface{}) *ORM_CountJobProposals_Call

CountJobProposals is a helper method to define mock.On call

  • ctx context.Context

func (*ORM_Expecter) CountJobProposalsByStatus

func (_e *ORM_Expecter) CountJobProposalsByStatus(ctx interface{}) *ORM_CountJobProposalsByStatus_Call

CountJobProposalsByStatus is a helper method to define mock.On call

  • ctx context.Context

func (*ORM_Expecter) CountManagers

func (_e *ORM_Expecter) CountManagers(ctx interface{}) *ORM_CountManagers_Call

CountManagers is a helper method to define mock.On call

  • ctx context.Context

func (*ORM_Expecter) CreateBatchChainConfig

func (_e *ORM_Expecter) CreateBatchChainConfig(ctx interface{}, cfgs interface{}) *ORM_CreateBatchChainConfig_Call

CreateBatchChainConfig is a helper method to define mock.On call

  • ctx context.Context
  • cfgs []feeds.ChainConfig

func (*ORM_Expecter) CreateChainConfig

func (_e *ORM_Expecter) CreateChainConfig(ctx interface{}, cfg interface{}) *ORM_CreateChainConfig_Call

CreateChainConfig is a helper method to define mock.On call

  • ctx context.Context
  • cfg feeds.ChainConfig

func (*ORM_Expecter) CreateJobProposal

func (_e *ORM_Expecter) CreateJobProposal(ctx interface{}, jp interface{}) *ORM_CreateJobProposal_Call

CreateJobProposal is a helper method to define mock.On call

  • ctx context.Context
  • jp *feeds.JobProposal

func (*ORM_Expecter) CreateManager

func (_e *ORM_Expecter) CreateManager(ctx interface{}, ms interface{}) *ORM_CreateManager_Call

CreateManager is a helper method to define mock.On call

  • ctx context.Context
  • ms *feeds.FeedsManager

func (*ORM_Expecter) CreateSpec

func (_e *ORM_Expecter) CreateSpec(ctx interface{}, spec interface{}) *ORM_CreateSpec_Call

CreateSpec is a helper method to define mock.On call

  • ctx context.Context
  • spec feeds.JobProposalSpec

func (*ORM_Expecter) DeleteChainConfig

func (_e *ORM_Expecter) DeleteChainConfig(ctx interface{}, id interface{}) *ORM_DeleteChainConfig_Call

DeleteChainConfig is a helper method to define mock.On call

  • ctx context.Context
  • id int64

func (*ORM_Expecter) DeleteProposal

func (_e *ORM_Expecter) DeleteProposal(ctx interface{}, id interface{}) *ORM_DeleteProposal_Call

DeleteProposal is a helper method to define mock.On call

  • ctx context.Context
  • id int64

func (*ORM_Expecter) ExistsSpecByJobProposalIDAndVersion

func (_e *ORM_Expecter) ExistsSpecByJobProposalIDAndVersion(ctx interface{}, jpID interface{}, version interface{}) *ORM_ExistsSpecByJobProposalIDAndVersion_Call

ExistsSpecByJobProposalIDAndVersion is a helper method to define mock.On call

  • ctx context.Context
  • jpID int64
  • version int32

func (*ORM_Expecter) GetApprovedSpec

func (_e *ORM_Expecter) GetApprovedSpec(ctx interface{}, jpID interface{}) *ORM_GetApprovedSpec_Call

GetApprovedSpec is a helper method to define mock.On call

  • ctx context.Context
  • jpID int64

func (*ORM_Expecter) GetChainConfig

func (_e *ORM_Expecter) GetChainConfig(ctx interface{}, id interface{}) *ORM_GetChainConfig_Call

GetChainConfig is a helper method to define mock.On call

  • ctx context.Context
  • id int64

func (*ORM_Expecter) GetJobProposal

func (_e *ORM_Expecter) GetJobProposal(ctx interface{}, id interface{}) *ORM_GetJobProposal_Call

GetJobProposal is a helper method to define mock.On call

  • ctx context.Context
  • id int64

func (*ORM_Expecter) GetJobProposalByRemoteUUID

func (_e *ORM_Expecter) GetJobProposalByRemoteUUID(ctx interface{}, _a1 interface{}) *ORM_GetJobProposalByRemoteUUID_Call

GetJobProposalByRemoteUUID is a helper method to define mock.On call

  • ctx context.Context
  • _a1 uuid.UUID

func (*ORM_Expecter) GetLatestSpec

func (_e *ORM_Expecter) GetLatestSpec(ctx interface{}, jpID interface{}) *ORM_GetLatestSpec_Call

GetLatestSpec is a helper method to define mock.On call

  • ctx context.Context
  • jpID int64

func (*ORM_Expecter) GetManager

func (_e *ORM_Expecter) GetManager(ctx interface{}, id interface{}) *ORM_GetManager_Call

GetManager is a helper method to define mock.On call

  • ctx context.Context
  • id int64

func (*ORM_Expecter) GetSpec

func (_e *ORM_Expecter) GetSpec(ctx interface{}, id interface{}) *ORM_GetSpec_Call

GetSpec is a helper method to define mock.On call

  • ctx context.Context
  • id int64

func (*ORM_Expecter) IsJobManaged

func (_e *ORM_Expecter) IsJobManaged(ctx interface{}, jobID interface{}) *ORM_IsJobManaged_Call

IsJobManaged is a helper method to define mock.On call

  • ctx context.Context
  • jobID int64

func (*ORM_Expecter) ListChainConfigsByManagerIDs

func (_e *ORM_Expecter) ListChainConfigsByManagerIDs(ctx interface{}, mgrIDs interface{}) *ORM_ListChainConfigsByManagerIDs_Call

ListChainConfigsByManagerIDs is a helper method to define mock.On call

  • ctx context.Context
  • mgrIDs []int64

func (*ORM_Expecter) ListJobProposals

func (_e *ORM_Expecter) ListJobProposals(ctx interface{}) *ORM_ListJobProposals_Call

ListJobProposals is a helper method to define mock.On call

  • ctx context.Context

func (*ORM_Expecter) ListJobProposalsByManagersIDs

func (_e *ORM_Expecter) ListJobProposalsByManagersIDs(ctx interface{}, ids interface{}) *ORM_ListJobProposalsByManagersIDs_Call

ListJobProposalsByManagersIDs is a helper method to define mock.On call

  • ctx context.Context
  • ids []int64

func (*ORM_Expecter) ListManagers

func (_e *ORM_Expecter) ListManagers(ctx interface{}) *ORM_ListManagers_Call

ListManagers is a helper method to define mock.On call

  • ctx context.Context

func (*ORM_Expecter) ListManagersByIDs

func (_e *ORM_Expecter) ListManagersByIDs(ctx interface{}, ids interface{}) *ORM_ListManagersByIDs_Call

ListManagersByIDs is a helper method to define mock.On call

  • ctx context.Context
  • ids []int64

func (*ORM_Expecter) ListSpecsByJobProposalIDs

func (_e *ORM_Expecter) ListSpecsByJobProposalIDs(ctx interface{}, ids interface{}) *ORM_ListSpecsByJobProposalIDs_Call

ListSpecsByJobProposalIDs is a helper method to define mock.On call

  • ctx context.Context
  • ids []int64

func (*ORM_Expecter) RejectSpec

func (_e *ORM_Expecter) RejectSpec(ctx interface{}, id interface{}) *ORM_RejectSpec_Call

RejectSpec is a helper method to define mock.On call

  • ctx context.Context
  • id int64

func (*ORM_Expecter) RevokeSpec

func (_e *ORM_Expecter) RevokeSpec(ctx interface{}, id interface{}) *ORM_RevokeSpec_Call

RevokeSpec is a helper method to define mock.On call

  • ctx context.Context
  • id int64

func (*ORM_Expecter) Transact added in v2.12.0

func (_e *ORM_Expecter) Transact(_a0 interface{}, _a1 interface{}) *ORM_Transact_Call

Transact is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 func(feeds.ORM) error

func (*ORM_Expecter) UpdateChainConfig

func (_e *ORM_Expecter) UpdateChainConfig(ctx interface{}, cfg interface{}) *ORM_UpdateChainConfig_Call

UpdateChainConfig is a helper method to define mock.On call

  • ctx context.Context
  • cfg feeds.ChainConfig

func (*ORM_Expecter) UpdateJobProposalStatus

func (_e *ORM_Expecter) UpdateJobProposalStatus(ctx interface{}, id interface{}, status interface{}) *ORM_UpdateJobProposalStatus_Call

UpdateJobProposalStatus is a helper method to define mock.On call

  • ctx context.Context
  • id int64
  • status feeds.JobProposalStatus

func (*ORM_Expecter) UpdateManager

func (_e *ORM_Expecter) UpdateManager(ctx interface{}, mgr interface{}) *ORM_UpdateManager_Call

UpdateManager is a helper method to define mock.On call

  • ctx context.Context
  • mgr feeds.FeedsManager

func (*ORM_Expecter) UpdateSpecDefinition

func (_e *ORM_Expecter) UpdateSpecDefinition(ctx interface{}, id interface{}, spec interface{}) *ORM_UpdateSpecDefinition_Call

UpdateSpecDefinition is a helper method to define mock.On call

  • ctx context.Context
  • id int64
  • spec string

func (*ORM_Expecter) UpsertJobProposal

func (_e *ORM_Expecter) UpsertJobProposal(ctx interface{}, jp interface{}) *ORM_UpsertJobProposal_Call

UpsertJobProposal is a helper method to define mock.On call

  • ctx context.Context
  • jp *feeds.JobProposal

func (*ORM_Expecter) WithDataSource added in v2.12.0

func (_e *ORM_Expecter) WithDataSource(_a0 interface{}) *ORM_WithDataSource_Call

WithDataSource is a helper method to define mock.On call

  • _a0 sqlutil.DataSource

type ORM_GetApprovedSpec_Call

type ORM_GetApprovedSpec_Call struct {
	*mock.Call
}

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

func (*ORM_GetApprovedSpec_Call) Return

func (*ORM_GetApprovedSpec_Call) Run

func (*ORM_GetApprovedSpec_Call) RunAndReturn

type ORM_GetChainConfig_Call

type ORM_GetChainConfig_Call struct {
	*mock.Call
}

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

func (*ORM_GetChainConfig_Call) Return

func (*ORM_GetChainConfig_Call) Run

func (*ORM_GetChainConfig_Call) RunAndReturn

type ORM_GetJobProposalByRemoteUUID_Call

type ORM_GetJobProposalByRemoteUUID_Call struct {
	*mock.Call
}

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

func (*ORM_GetJobProposalByRemoteUUID_Call) Return

func (*ORM_GetJobProposalByRemoteUUID_Call) Run

func (*ORM_GetJobProposalByRemoteUUID_Call) RunAndReturn

type ORM_GetJobProposal_Call

type ORM_GetJobProposal_Call struct {
	*mock.Call
}

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

func (*ORM_GetJobProposal_Call) Return

func (*ORM_GetJobProposal_Call) Run

func (*ORM_GetJobProposal_Call) RunAndReturn

type ORM_GetLatestSpec_Call

type ORM_GetLatestSpec_Call struct {
	*mock.Call
}

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

func (*ORM_GetLatestSpec_Call) Return

func (*ORM_GetLatestSpec_Call) Run

func (_c *ORM_GetLatestSpec_Call) Run(run func(ctx context.Context, jpID int64)) *ORM_GetLatestSpec_Call

func (*ORM_GetLatestSpec_Call) RunAndReturn

type ORM_GetManager_Call

type ORM_GetManager_Call struct {
	*mock.Call
}

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

func (*ORM_GetManager_Call) Return

func (*ORM_GetManager_Call) Run

func (_c *ORM_GetManager_Call) Run(run func(ctx context.Context, id int64)) *ORM_GetManager_Call

func (*ORM_GetManager_Call) RunAndReturn

type ORM_GetSpec_Call

type ORM_GetSpec_Call struct {
	*mock.Call
}

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

func (*ORM_GetSpec_Call) Return

func (*ORM_GetSpec_Call) Run

func (_c *ORM_GetSpec_Call) Run(run func(ctx context.Context, id int64)) *ORM_GetSpec_Call

func (*ORM_GetSpec_Call) RunAndReturn

type ORM_IsJobManaged_Call

type ORM_IsJobManaged_Call struct {
	*mock.Call
}

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

func (*ORM_IsJobManaged_Call) Return

func (_c *ORM_IsJobManaged_Call) Return(_a0 bool, _a1 error) *ORM_IsJobManaged_Call

func (*ORM_IsJobManaged_Call) Run

func (_c *ORM_IsJobManaged_Call) Run(run func(ctx context.Context, jobID int64)) *ORM_IsJobManaged_Call

func (*ORM_IsJobManaged_Call) RunAndReturn

func (_c *ORM_IsJobManaged_Call) RunAndReturn(run func(context.Context, int64) (bool, error)) *ORM_IsJobManaged_Call

type ORM_ListChainConfigsByManagerIDs_Call

type ORM_ListChainConfigsByManagerIDs_Call struct {
	*mock.Call
}

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

func (*ORM_ListChainConfigsByManagerIDs_Call) Return

func (*ORM_ListChainConfigsByManagerIDs_Call) Run

func (*ORM_ListChainConfigsByManagerIDs_Call) RunAndReturn

type ORM_ListJobProposalsByManagersIDs_Call

type ORM_ListJobProposalsByManagersIDs_Call struct {
	*mock.Call
}

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

func (*ORM_ListJobProposalsByManagersIDs_Call) Return

func (*ORM_ListJobProposalsByManagersIDs_Call) Run

func (*ORM_ListJobProposalsByManagersIDs_Call) RunAndReturn

type ORM_ListJobProposals_Call

type ORM_ListJobProposals_Call struct {
	*mock.Call
}

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

func (*ORM_ListJobProposals_Call) Return

func (*ORM_ListJobProposals_Call) Run

func (*ORM_ListJobProposals_Call) RunAndReturn

type ORM_ListManagersByIDs_Call

type ORM_ListManagersByIDs_Call struct {
	*mock.Call
}

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

func (*ORM_ListManagersByIDs_Call) Return

func (*ORM_ListManagersByIDs_Call) Run

func (*ORM_ListManagersByIDs_Call) RunAndReturn

type ORM_ListManagers_Call

type ORM_ListManagers_Call struct {
	*mock.Call
}

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

func (*ORM_ListManagers_Call) Return

func (*ORM_ListManagers_Call) Run

func (*ORM_ListManagers_Call) RunAndReturn

type ORM_ListSpecsByJobProposalIDs_Call

type ORM_ListSpecsByJobProposalIDs_Call struct {
	*mock.Call
}

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

func (*ORM_ListSpecsByJobProposalIDs_Call) Return

func (*ORM_ListSpecsByJobProposalIDs_Call) Run

func (*ORM_ListSpecsByJobProposalIDs_Call) RunAndReturn

type ORM_RejectSpec_Call

type ORM_RejectSpec_Call struct {
	*mock.Call
}

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

func (*ORM_RejectSpec_Call) Return

func (*ORM_RejectSpec_Call) Run

func (_c *ORM_RejectSpec_Call) Run(run func(ctx context.Context, id int64)) *ORM_RejectSpec_Call

func (*ORM_RejectSpec_Call) RunAndReturn

func (_c *ORM_RejectSpec_Call) RunAndReturn(run func(context.Context, int64) error) *ORM_RejectSpec_Call

type ORM_RevokeSpec_Call

type ORM_RevokeSpec_Call struct {
	*mock.Call
}

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

func (*ORM_RevokeSpec_Call) Return

func (*ORM_RevokeSpec_Call) Run

func (_c *ORM_RevokeSpec_Call) Run(run func(ctx context.Context, id int64)) *ORM_RevokeSpec_Call

func (*ORM_RevokeSpec_Call) RunAndReturn

func (_c *ORM_RevokeSpec_Call) RunAndReturn(run func(context.Context, int64) error) *ORM_RevokeSpec_Call

type ORM_Transact_Call added in v2.12.0

type ORM_Transact_Call struct {
	*mock.Call
}

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

func (*ORM_Transact_Call) Return added in v2.12.0

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

func (*ORM_Transact_Call) Run added in v2.12.0

func (_c *ORM_Transact_Call) Run(run func(_a0 context.Context, _a1 func(feeds.ORM) error)) *ORM_Transact_Call

func (*ORM_Transact_Call) RunAndReturn added in v2.12.0

func (_c *ORM_Transact_Call) RunAndReturn(run func(context.Context, func(feeds.ORM) error) error) *ORM_Transact_Call

type ORM_UpdateChainConfig_Call

type ORM_UpdateChainConfig_Call struct {
	*mock.Call
}

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

func (*ORM_UpdateChainConfig_Call) Return

func (*ORM_UpdateChainConfig_Call) Run

func (*ORM_UpdateChainConfig_Call) RunAndReturn

type ORM_UpdateJobProposalStatus_Call

type ORM_UpdateJobProposalStatus_Call struct {
	*mock.Call
}

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

func (*ORM_UpdateJobProposalStatus_Call) Return

func (*ORM_UpdateJobProposalStatus_Call) Run

func (*ORM_UpdateJobProposalStatus_Call) RunAndReturn

type ORM_UpdateManager_Call

type ORM_UpdateManager_Call struct {
	*mock.Call
}

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

func (*ORM_UpdateManager_Call) Return

func (*ORM_UpdateManager_Call) Run

func (*ORM_UpdateManager_Call) RunAndReturn

type ORM_UpdateSpecDefinition_Call

type ORM_UpdateSpecDefinition_Call struct {
	*mock.Call
}

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

func (*ORM_UpdateSpecDefinition_Call) Return

func (*ORM_UpdateSpecDefinition_Call) Run

func (*ORM_UpdateSpecDefinition_Call) RunAndReturn

type ORM_UpsertJobProposal_Call

type ORM_UpsertJobProposal_Call struct {
	*mock.Call
}

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

func (*ORM_UpsertJobProposal_Call) Return

func (*ORM_UpsertJobProposal_Call) Run

func (*ORM_UpsertJobProposal_Call) RunAndReturn

type ORM_WithDataSource_Call added in v2.12.0

type ORM_WithDataSource_Call struct {
	*mock.Call
}

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

func (*ORM_WithDataSource_Call) Return added in v2.12.0

func (*ORM_WithDataSource_Call) Run added in v2.12.0

func (*ORM_WithDataSource_Call) RunAndReturn added in v2.12.0

type Service

type Service struct {
	mock.Mock
}

Service is an autogenerated mock type for the Service type

func NewService

func NewService(t interface {
	mock.TestingT
	Cleanup(func())
}) *Service

NewService creates a new instance of Service. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Service) ApproveSpec

func (_m *Service) ApproveSpec(ctx context.Context, id int64, force bool) error

ApproveSpec provides a mock function with given fields: ctx, id, force

func (*Service) CancelSpec

func (_m *Service) CancelSpec(ctx context.Context, id int64) error

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

func (*Service) Close

func (_m *Service) Close() error

Close provides a mock function with given fields:

func (*Service) CountJobProposalsByStatus

func (_m *Service) CountJobProposalsByStatus(ctx context.Context) (*feeds.JobProposalCounts, error)

CountJobProposalsByStatus provides a mock function with given fields: ctx

func (*Service) CountManagers

func (_m *Service) CountManagers(ctx context.Context) (int64, error)

CountManagers provides a mock function with given fields: ctx

func (*Service) CreateChainConfig

func (_m *Service) CreateChainConfig(ctx context.Context, cfg feeds.ChainConfig) (int64, error)

CreateChainConfig provides a mock function with given fields: ctx, cfg

func (*Service) DeleteChainConfig

func (_m *Service) DeleteChainConfig(ctx context.Context, id int64) (int64, error)

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

func (*Service) DeleteJob

func (_m *Service) DeleteJob(ctx context.Context, args *feeds.DeleteJobArgs) (int64, error)

DeleteJob provides a mock function with given fields: ctx, args

func (*Service) GetChainConfig

func (_m *Service) GetChainConfig(ctx context.Context, id int64) (*feeds.ChainConfig, error)

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

func (*Service) GetJobProposal

func (_m *Service) GetJobProposal(ctx context.Context, id int64) (*feeds.JobProposal, error)

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

func (*Service) GetManager

func (_m *Service) GetManager(ctx context.Context, id int64) (*feeds.FeedsManager, error)

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

func (*Service) GetSpec

func (_m *Service) GetSpec(ctx context.Context, id int64) (*feeds.JobProposalSpec, error)

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

func (*Service) IsJobManaged

func (_m *Service) IsJobManaged(ctx context.Context, jobID int64) (bool, error)

IsJobManaged provides a mock function with given fields: ctx, jobID

func (*Service) ListChainConfigsByManagerIDs

func (_m *Service) ListChainConfigsByManagerIDs(ctx context.Context, mgrIDs []int64) ([]feeds.ChainConfig, error)

ListChainConfigsByManagerIDs provides a mock function with given fields: ctx, mgrIDs

func (*Service) ListJobProposals

func (_m *Service) ListJobProposals(ctx context.Context) ([]feeds.JobProposal, error)

ListJobProposals provides a mock function with given fields: ctx

func (*Service) ListJobProposalsByManagersIDs

func (_m *Service) ListJobProposalsByManagersIDs(ctx context.Context, ids []int64) ([]feeds.JobProposal, error)

ListJobProposalsByManagersIDs provides a mock function with given fields: ctx, ids

func (*Service) ListManagers

func (_m *Service) ListManagers(ctx context.Context) ([]feeds.FeedsManager, error)

ListManagers provides a mock function with given fields: ctx

func (*Service) ListManagersByIDs

func (_m *Service) ListManagersByIDs(ctx context.Context, ids []int64) ([]feeds.FeedsManager, error)

ListManagersByIDs provides a mock function with given fields: ctx, ids

func (*Service) ListSpecsByJobProposalIDs

func (_m *Service) ListSpecsByJobProposalIDs(ctx context.Context, ids []int64) ([]feeds.JobProposalSpec, error)

ListSpecsByJobProposalIDs provides a mock function with given fields: ctx, ids

func (*Service) ProposeJob

func (_m *Service) ProposeJob(ctx context.Context, args *feeds.ProposeJobArgs) (int64, error)

ProposeJob provides a mock function with given fields: ctx, args

func (*Service) RegisterManager

func (_m *Service) RegisterManager(ctx context.Context, params feeds.RegisterManagerParams) (int64, error)

RegisterManager provides a mock function with given fields: ctx, params

func (*Service) RejectSpec

func (_m *Service) RejectSpec(ctx context.Context, id int64) error

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

func (*Service) RevokeJob

func (_m *Service) RevokeJob(ctx context.Context, args *feeds.RevokeJobArgs) (int64, error)

RevokeJob provides a mock function with given fields: ctx, args

func (*Service) Start

func (_m *Service) Start(ctx context.Context) error

Start provides a mock function with given fields: ctx

func (*Service) SyncNodeInfo

func (_m *Service) SyncNodeInfo(ctx context.Context, id int64) error

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

func (*Service) UpdateChainConfig

func (_m *Service) UpdateChainConfig(ctx context.Context, cfg feeds.ChainConfig) (int64, error)

UpdateChainConfig provides a mock function with given fields: ctx, cfg

func (*Service) UpdateManager

func (_m *Service) UpdateManager(ctx context.Context, mgr feeds.FeedsManager) error

UpdateManager provides a mock function with given fields: ctx, mgr

func (*Service) UpdateSpecDefinition

func (_m *Service) UpdateSpecDefinition(ctx context.Context, id int64, spec string) error

UpdateSpecDefinition provides a mock function with given fields: ctx, id, spec

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL