mocks

package
v2.12.0-beta2 Latest Latest
Warning

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

 Go to latest Published: May 20, 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 

func (_m *FeedsManagerClient) ApprovedJob(ctx context.Context, in *proto.ApprovedJobRequest) (*proto.ApprovedJobResponse, error)

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

func (*FeedsManagerClient) CancelledJob 

func (_m *FeedsManagerClient) CancelledJob(ctx context.Context, in *proto.CancelledJobRequest) (*proto.CancelledJobResponse, error)

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

func (*FeedsManagerClient) Healthcheck 

func (_m *FeedsManagerClient) Healthcheck(ctx context.Context, in *proto.HealthcheckRequest) (*proto.HealthcheckResponse, error)

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

func (*FeedsManagerClient) RejectedJob 

func (_m *FeedsManagerClient) RejectedJob(ctx context.Context, in *proto.RejectedJobRequest) (*proto.RejectedJobResponse, error)

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

func (*FeedsManagerClient) UpdateNode 

func (_m *FeedsManagerClient) UpdateNode(ctx context.Context, in *proto.UpdateNodeRequest) (*proto.UpdateNodeResponse, error)

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 (_c *ORM_ApproveSpec_Call) Return(_a0 error) *ORM_ApproveSpec_Call

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 

func (_c *ORM_ApproveSpec_Call) RunAndReturn(run func(context.Context, int64, uuid.UUID) error) *ORM_ApproveSpec_Call

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 (_c *ORM_CancelSpec_Call) Return(_a0 error) *ORM_CancelSpec_Call

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 (_c *ORM_CountJobProposalsByStatus_Call) Return(counts *feeds.JobProposalCounts, err error) *ORM_CountJobProposalsByStatus_Call

func (*ORM_CountJobProposalsByStatus_Call) Run 

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

func (*ORM_CountJobProposalsByStatus_Call) RunAndReturn 

func (_c *ORM_CountJobProposalsByStatus_Call) RunAndReturn(run func(context.Context) (*feeds.JobProposalCounts, error)) *ORM_CountJobProposalsByStatus_Call

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 (_c *ORM_CountJobProposals_Call) Return(_a0 int64, _a1 error) *ORM_CountJobProposals_Call

func (*ORM_CountJobProposals_Call) Run 

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

func (*ORM_CountJobProposals_Call) RunAndReturn 

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

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 (_c *ORM_CountManagers_Call) Return(_a0 int64, _a1 error) *ORM_CountManagers_Call

func (*ORM_CountManagers_Call) Run 

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

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 (_c *ORM_CreateBatchChainConfig_Call) Return(_a0 []int64, _a1 error) *ORM_CreateBatchChainConfig_Call

func (*ORM_CreateBatchChainConfig_Call) Run 

func (_c *ORM_CreateBatchChainConfig_Call) Run(run func(ctx context.Context, cfgs []feeds.ChainConfig)) *ORM_CreateBatchChainConfig_Call

func (*ORM_CreateBatchChainConfig_Call) RunAndReturn 

func (_c *ORM_CreateBatchChainConfig_Call) RunAndReturn(run func(context.Context, []feeds.ChainConfig) ([]int64, error)) *ORM_CreateBatchChainConfig_Call

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 (_c *ORM_CreateChainConfig_Call) Return(_a0 int64, _a1 error) *ORM_CreateChainConfig_Call

func (*ORM_CreateChainConfig_Call) Run 

func (_c *ORM_CreateChainConfig_Call) Run(run func(ctx context.Context, cfg feeds.ChainConfig)) *ORM_CreateChainConfig_Call

func (*ORM_CreateChainConfig_Call) RunAndReturn 

func (_c *ORM_CreateChainConfig_Call) RunAndReturn(run func(context.Context, feeds.ChainConfig) (int64, error)) *ORM_CreateChainConfig_Call

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 (_c *ORM_CreateJobProposal_Call) Return(_a0 int64, _a1 error) *ORM_CreateJobProposal_Call

func (*ORM_CreateJobProposal_Call) Run 

func (_c *ORM_CreateJobProposal_Call) Run(run func(ctx context.Context, jp *feeds.JobProposal)) *ORM_CreateJobProposal_Call

func (*ORM_CreateJobProposal_Call) RunAndReturn 

func (_c *ORM_CreateJobProposal_Call) RunAndReturn(run func(context.Context, *feeds.JobProposal) (int64, error)) *ORM_CreateJobProposal_Call

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 (_c *ORM_CreateManager_Call) Return(_a0 int64, _a1 error) *ORM_CreateManager_Call

func (*ORM_CreateManager_Call) Run 

func (_c *ORM_CreateManager_Call) Run(run func(ctx context.Context, ms *feeds.FeedsManager)) *ORM_CreateManager_Call

func (*ORM_CreateManager_Call) RunAndReturn 

func (_c *ORM_CreateManager_Call) RunAndReturn(run func(context.Context, *feeds.FeedsManager) (int64, error)) *ORM_CreateManager_Call

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 (_c *ORM_CreateSpec_Call) Run(run func(ctx context.Context, spec feeds.JobProposalSpec)) *ORM_CreateSpec_Call

func (*ORM_CreateSpec_Call) RunAndReturn 

func (_c *ORM_CreateSpec_Call) RunAndReturn(run func(context.Context, feeds.JobProposalSpec) (int64, error)) *ORM_CreateSpec_Call

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 (_c *ORM_DeleteChainConfig_Call) Return(_a0 int64, _a1 error) *ORM_DeleteChainConfig_Call

func (*ORM_DeleteChainConfig_Call) Run 

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

func (*ORM_DeleteChainConfig_Call) RunAndReturn 

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

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 (_c *ORM_DeleteProposal_Call) Return(_a0 error) *ORM_DeleteProposal_Call

func (*ORM_DeleteProposal_Call) Run 

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

func (*ORM_DeleteProposal_Call) RunAndReturn 

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

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 (_c *ORM_ExistsSpecByJobProposalIDAndVersion_Call) Return(exists bool, err error) *ORM_ExistsSpecByJobProposalIDAndVersion_Call

func (*ORM_ExistsSpecByJobProposalIDAndVersion_Call) Run 

func (_c *ORM_ExistsSpecByJobProposalIDAndVersion_Call) Run(run func(ctx context.Context, jpID int64, version int32)) *ORM_ExistsSpecByJobProposalIDAndVersion_Call

func (*ORM_ExistsSpecByJobProposalIDAndVersion_Call) RunAndReturn 

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

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 (_c *ORM_GetApprovedSpec_Call) Return(_a0 *feeds.JobProposalSpec, _a1 error) *ORM_GetApprovedSpec_Call

func (*ORM_GetApprovedSpec_Call) Run 

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

func (*ORM_GetApprovedSpec_Call) RunAndReturn 

func (_c *ORM_GetApprovedSpec_Call) RunAndReturn(run func(context.Context, int64) (*feeds.JobProposalSpec, error)) *ORM_GetApprovedSpec_Call

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 (_c *ORM_GetChainConfig_Call) Return(_a0 *feeds.ChainConfig, _a1 error) *ORM_GetChainConfig_Call

func (*ORM_GetChainConfig_Call) Run 

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

func (*ORM_GetChainConfig_Call) RunAndReturn 

func (_c *ORM_GetChainConfig_Call) RunAndReturn(run func(context.Context, int64) (*feeds.ChainConfig, error)) *ORM_GetChainConfig_Call

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 (_c *ORM_GetJobProposalByRemoteUUID_Call) Return(_a0 *feeds.JobProposal, _a1 error) *ORM_GetJobProposalByRemoteUUID_Call

func (*ORM_GetJobProposalByRemoteUUID_Call) Run 

func (_c *ORM_GetJobProposalByRemoteUUID_Call) Run(run func(ctx context.Context, _a1 uuid.UUID)) *ORM_GetJobProposalByRemoteUUID_Call

func (*ORM_GetJobProposalByRemoteUUID_Call) RunAndReturn 

func (_c *ORM_GetJobProposalByRemoteUUID_Call) RunAndReturn(run func(context.Context, uuid.UUID) (*feeds.JobProposal, error)) *ORM_GetJobProposalByRemoteUUID_Call

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 (_c *ORM_GetJobProposal_Call) Return(_a0 *feeds.JobProposal, _a1 error) *ORM_GetJobProposal_Call

func (*ORM_GetJobProposal_Call) Run 

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

func (*ORM_GetJobProposal_Call) RunAndReturn 

func (_c *ORM_GetJobProposal_Call) RunAndReturn(run func(context.Context, int64) (*feeds.JobProposal, error)) *ORM_GetJobProposal_Call

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 (_c *ORM_GetLatestSpec_Call) Return(_a0 *feeds.JobProposalSpec, _a1 error) *ORM_GetLatestSpec_Call

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 

func (_c *ORM_GetLatestSpec_Call) RunAndReturn(run func(context.Context, int64) (*feeds.JobProposalSpec, error)) *ORM_GetLatestSpec_Call

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 (_c *ORM_GetManager_Call) Return(_a0 *feeds.FeedsManager, _a1 error) *ORM_GetManager_Call

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 

func (_c *ORM_GetManager_Call) RunAndReturn(run func(context.Context, int64) (*feeds.FeedsManager, error)) *ORM_GetManager_Call

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 (_c *ORM_GetSpec_Call) Return(_a0 *feeds.JobProposalSpec, _a1 error) *ORM_GetSpec_Call

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 

func (_c *ORM_GetSpec_Call) RunAndReturn(run func(context.Context, int64) (*feeds.JobProposalSpec, error)) *ORM_GetSpec_Call

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 (_c *ORM_ListChainConfigsByManagerIDs_Call) Return(_a0 []feeds.ChainConfig, _a1 error) *ORM_ListChainConfigsByManagerIDs_Call

func (*ORM_ListChainConfigsByManagerIDs_Call) Run 

func (_c *ORM_ListChainConfigsByManagerIDs_Call) Run(run func(ctx context.Context, mgrIDs []int64)) *ORM_ListChainConfigsByManagerIDs_Call

func (*ORM_ListChainConfigsByManagerIDs_Call) RunAndReturn 

func (_c *ORM_ListChainConfigsByManagerIDs_Call) RunAndReturn(run func(context.Context, []int64) ([]feeds.ChainConfig, error)) *ORM_ListChainConfigsByManagerIDs_Call

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 (_c *ORM_ListJobProposalsByManagersIDs_Call) Return(_a0 []feeds.JobProposal, _a1 error) *ORM_ListJobProposalsByManagersIDs_Call

func (*ORM_ListJobProposalsByManagersIDs_Call) Run 

func (_c *ORM_ListJobProposalsByManagersIDs_Call) Run(run func(ctx context.Context, ids []int64)) *ORM_ListJobProposalsByManagersIDs_Call

func (*ORM_ListJobProposalsByManagersIDs_Call) RunAndReturn 

func (_c *ORM_ListJobProposalsByManagersIDs_Call) RunAndReturn(run func(context.Context, []int64) ([]feeds.JobProposal, error)) *ORM_ListJobProposalsByManagersIDs_Call

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 (_c *ORM_ListJobProposals_Call) Return(jps []feeds.JobProposal, err error) *ORM_ListJobProposals_Call

func (*ORM_ListJobProposals_Call) Run 

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

func (*ORM_ListJobProposals_Call) RunAndReturn 

func (_c *ORM_ListJobProposals_Call) RunAndReturn(run func(context.Context) ([]feeds.JobProposal, error)) *ORM_ListJobProposals_Call

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 (_c *ORM_ListManagersByIDs_Call) Return(_a0 []feeds.FeedsManager, _a1 error) *ORM_ListManagersByIDs_Call

func (*ORM_ListManagersByIDs_Call) Run 

func (_c *ORM_ListManagersByIDs_Call) Run(run func(ctx context.Context, ids []int64)) *ORM_ListManagersByIDs_Call

func (*ORM_ListManagersByIDs_Call) RunAndReturn 

func (_c *ORM_ListManagersByIDs_Call) RunAndReturn(run func(context.Context, []int64) ([]feeds.FeedsManager, error)) *ORM_ListManagersByIDs_Call

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 (_c *ORM_ListManagers_Call) Return(mgrs []feeds.FeedsManager, err error) *ORM_ListManagers_Call

func (*ORM_ListManagers_Call) Run 

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

func (*ORM_ListManagers_Call) RunAndReturn 

func (_c *ORM_ListManagers_Call) RunAndReturn(run func(context.Context) ([]feeds.FeedsManager, error)) *ORM_ListManagers_Call

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 (_c *ORM_ListSpecsByJobProposalIDs_Call) Return(_a0 []feeds.JobProposalSpec, _a1 error) *ORM_ListSpecsByJobProposalIDs_Call

func (*ORM_ListSpecsByJobProposalIDs_Call) Run 

func (_c *ORM_ListSpecsByJobProposalIDs_Call) Run(run func(ctx context.Context, ids []int64)) *ORM_ListSpecsByJobProposalIDs_Call

func (*ORM_ListSpecsByJobProposalIDs_Call) RunAndReturn 

func (_c *ORM_ListSpecsByJobProposalIDs_Call) RunAndReturn(run func(context.Context, []int64) ([]feeds.JobProposalSpec, error)) *ORM_ListSpecsByJobProposalIDs_Call

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 (_c *ORM_RejectSpec_Call) Return(_a0 error) *ORM_RejectSpec_Call

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 (_c *ORM_RevokeSpec_Call) Return(_a0 error) *ORM_RevokeSpec_Call

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 (_c *ORM_UpdateChainConfig_Call) Return(_a0 int64, _a1 error) *ORM_UpdateChainConfig_Call

func (*ORM_UpdateChainConfig_Call) Run 

func (_c *ORM_UpdateChainConfig_Call) Run(run func(ctx context.Context, cfg feeds.ChainConfig)) *ORM_UpdateChainConfig_Call

func (*ORM_UpdateChainConfig_Call) RunAndReturn 

func (_c *ORM_UpdateChainConfig_Call) RunAndReturn(run func(context.Context, feeds.ChainConfig) (int64, error)) *ORM_UpdateChainConfig_Call

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 (_c *ORM_UpdateJobProposalStatus_Call) Return(_a0 error) *ORM_UpdateJobProposalStatus_Call

func (*ORM_UpdateJobProposalStatus_Call) Run 

func (_c *ORM_UpdateJobProposalStatus_Call) Run(run func(ctx context.Context, id int64, status feeds.JobProposalStatus)) *ORM_UpdateJobProposalStatus_Call

func (*ORM_UpdateJobProposalStatus_Call) RunAndReturn 

func (_c *ORM_UpdateJobProposalStatus_Call) RunAndReturn(run func(context.Context, int64, feeds.JobProposalStatus) error) *ORM_UpdateJobProposalStatus_Call

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 (_c *ORM_UpdateManager_Call) Return(_a0 error) *ORM_UpdateManager_Call

func (*ORM_UpdateManager_Call) Run 

func (_c *ORM_UpdateManager_Call) Run(run func(ctx context.Context, mgr feeds.FeedsManager)) *ORM_UpdateManager_Call

func (*ORM_UpdateManager_Call) RunAndReturn 

func (_c *ORM_UpdateManager_Call) RunAndReturn(run func(context.Context, feeds.FeedsManager) error) *ORM_UpdateManager_Call

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 (_c *ORM_UpdateSpecDefinition_Call) Return(_a0 error) *ORM_UpdateSpecDefinition_Call

func (*ORM_UpdateSpecDefinition_Call) Run 

func (_c *ORM_UpdateSpecDefinition_Call) Run(run func(ctx context.Context, id int64, spec string)) *ORM_UpdateSpecDefinition_Call

func (*ORM_UpdateSpecDefinition_Call) RunAndReturn 

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

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 (_c *ORM_UpsertJobProposal_Call) Return(_a0 int64, _a1 error) *ORM_UpsertJobProposal_Call

func (*ORM_UpsertJobProposal_Call) Run 

func (_c *ORM_UpsertJobProposal_Call) Run(run func(ctx context.Context, jp *feeds.JobProposal)) *ORM_UpsertJobProposal_Call

func (*ORM_UpsertJobProposal_Call) RunAndReturn 

func (_c *ORM_UpsertJobProposal_Call) RunAndReturn(run func(context.Context, *feeds.JobProposal) (int64, error)) *ORM_UpsertJobProposal_Call

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 (_c *ORM_WithDataSource_Call) Return(_a0 feeds.ORM) *ORM_WithDataSource_Call

func (*ORM_WithDataSource_Call) Run added in v2.12.0 

func (_c *ORM_WithDataSource_Call) Run(run func(_a0 sqlutil.DataSource)) *ORM_WithDataSource_Call

func (*ORM_WithDataSource_Call) RunAndReturn added in v2.12.0 

func (_c *ORM_WithDataSource_Call) RunAndReturn(run func(sqlutil.DataSource) feeds.ORM) *ORM_WithDataSource_Call

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

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.